Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 697 for addLog (0.16 sec)

  1. pkg/kubelet/prober/prober_manager_test.go

    	m := newTestManager()
    	defer cleanup(t, m)
    	if err := expectProbes(m, nil); err != nil {
    		t.Error(err)
    	}
    
    	// Adding a pod with no probes should be a no-op.
    	m.AddPod(&noProbePod)
    	if err := expectProbes(m, nil); err != nil {
    		t.Error(err)
    	}
    
    	// Adding a pod with probes.
    	m.AddPod(&probePod)
    	probePaths := []probeKey{
    		{"probe_pod", "readiness", readiness},
    		{"probe_pod", "liveness", liveness},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 18.8K bytes
    - Viewed (0)
  2. cluster/addons/addon-manager/kube-addons.sh

    # This label is deprecated (only for Addon Manager). In future release
    # addon-manager may not respect it anymore. Addons with
    # CLUSTER_SERVICE_LABEL=true and without ADDON_MANAGER_LABEL=EnsureExists
    # will be reconciled for now.
    CLUSTER_SERVICE_LABEL="kubernetes.io/cluster-service"
    
    # Whether only one addon manager should be running in a multi-master setup.
    # Disabling this flag will force all addon managers to assume they are the
    # leaders.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Oct 15 05:40:38 UTC 2023
    - 10.4K bytes
    - Viewed (0)
  3. src/reflect/abi.go

    	} else {
    		e = a.valueStart[i+1]
    	}
    	return a.steps[s:e]
    }
    
    // addArg extends the abiSeq with a new Go value of type t.
    //
    // If the value was stack-assigned, returns the single
    // abiStep describing that translation, and nil otherwise.
    func (a *abiSeq) addArg(t *abi.Type) *abiStep {
    	// We'll always be adding a new value, so do that first.
    	pStart := len(a.steps)
    	a.valueStart = append(a.valueStart, pStart)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue May 07 17:08:32 UTC 2024
    - 15K bytes
    - Viewed (0)
  4. plugin/pkg/auth/authorizer/node/graph.go

    	})
    	g.destinationEdgeIndex[n.ID()] = index
    }
    
    // AddPod should only be called once spec.NodeName is populated.
    // It sets up edges for the following relationships (which are immutable for a pod once bound to a node):
    //
    //	pod       -> node
    //	secret    -> pod
    //	configmap -> pod
    //	pvc       -> pod
    //	svcacct   -> pod
    func (g *Graph) AddPod(pod *corev1.Pod) {
    	start := time.Now()
    	defer func() {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 21:22:55 UTC 2024
    - 17.5K bytes
    - Viewed (0)
  5. src/cmd/compile/internal/ssa/rewriteARM64latelower.go

    	for {
    		x := v_0
    		if x.Op != OpARM64MOVBUload {
    			break
    		}
    		v.reset(OpARM64MOVDreg)
    		v.AddArg(x)
    		return true
    	}
    	// match: (MOVBUreg x:(MOVBUloadidx _ _ _))
    	// result: (MOVDreg x)
    	for {
    		x := v_0
    		if x.Op != OpARM64MOVBUloadidx {
    			break
    		}
    		v.reset(OpARM64MOVDreg)
    		v.AddArg(x)
    		return true
    	}
    	// match: (MOVBUreg x:(MOVBUreg _))
    	// result: (MOVDreg x)
    	for {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Mar 12 19:38:41 UTC 2024
    - 19.3K bytes
    - Viewed (0)
  6. pkg/controller/volume/attachdetach/cache/desired_state_of_world_test.go

    	dsw.AddNode(nodeName)
    	generatedVolumeName1, pod1AddErr := dsw.AddPod(types.UniquePodName(pod1Name), controllervolumetesting.NewPod(pod1Name, pod1Name), volumeSpec, nodeName)
    	if pod1AddErr != nil {
    		t.Fatalf(
    			"AddPod failed for pod %q. Expected: <no error> Actual: <%v>",
    			pod1Name,
    			pod1AddErr)
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 10:42:15 UTC 2024
    - 35.9K bytes
    - Viewed (0)
  7. src/cmd/compile/internal/ssa/rewritePPC64latelower.go

    		v.AddArg(convertPPC64OpToOpCC(z))
    		return true
    	}
    	// match: (CMPconst [0] z:(RLDICL x))
    	// cond: v.Block == z.Block
    	// result: (CMPconst [0] convertPPC64OpToOpCC(z))
    	for {
    		if auxIntToInt64(v.AuxInt) != 0 {
    			break
    		}
    		z := v_0
    		if z.Op != OpPPC64RLDICL {
    			break
    		}
    		if !(v.Block == z.Block) {
    			break
    		}
    		v.reset(OpPPC64CMPconst)
    		v.AuxInt = int64ToAuxInt(0)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 22 19:59:38 UTC 2024
    - 16.5K bytes
    - Viewed (0)
  8. platforms/core-configuration/declarative-dsl-core/src/test/kotlin/org/gradle/internal/declarativedsl/dom/operations/overlay/DocumentOverlayTest.kt

            )
        }
    
    
        @Test
        fun `underlay adding blocks appear before overlay ones`() {
            val underlay = resolvedDocument(
                """
                adding(1) {
                    a = 1
                }
                """.trimIndent()
            )
    
            val overlay = resolvedDocument(
                """
                adding(1) {
                    b = 2
                }
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri May 31 13:47:10 UTC 2024
    - 17.6K bytes
    - Viewed (0)
  9. pilot/pkg/xds/ads.go

    	// a better choice, it introduces a race condition; If we complete initialization of a new push
    	// context between initializeProxy and addCon, we would not get any pushes triggered for the new
    	// push context, leading the proxy to have a stale state until the next full push.
    	s.addCon(con.ID(), con)
    	// Register that initialization is complete. This triggers to calls that it is safe to access the
    	// proxy
    	defer con.MarkInitialized()
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jun 03 08:29:05 UTC 2024
    - 23.4K bytes
    - Viewed (0)
  10. src/cmd/compile/internal/ssa/decompose.go

    	cap := v.Block.NewValue0(v.Pos, OpPhi, lenType)
    	for _, a := range v.Args {
    		ptr.AddArg(a.Block.NewValue1(v.Pos, OpSlicePtr, ptrType, a))
    		len.AddArg(a.Block.NewValue1(v.Pos, OpSliceLen, lenType, a))
    		cap.AddArg(a.Block.NewValue1(v.Pos, OpSliceCap, lenType, a))
    	}
    	v.reset(OpSliceMake)
    	v.AddArg(ptr)
    	v.AddArg(len)
    	v.AddArg(cap)
    }
    
    func decomposeInt64Phi(v *Value) {
    	cfgtypes := &v.Block.Func.Config.Types
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Aug 23 21:22:15 UTC 2022
    - 13.4K bytes
    - Viewed (0)
Back to top