- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 697 for addLog (0.16 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)