- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 94 for RECORD (0.13 sec)
-
cluster/gce/windows/k8s-node-setup.psm1
# instead of jsonPayload after extracting 'time', 'severity' and # 'stream' from the record. message ${record['log']} # If 'severity' is not set, assume stderr is ERROR and stdout is INFO. severity ${record['severity'] || if record['stream'] == 'stderr' then 'ERROR' else 'INFO' end} </record> tag ${if record['stream'] == 'stderr' then 'raw.stderr' else 'raw.stdout' end} remove_keys stream,log </match>
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 21:13:22 UTC 2024 - 88.3K bytes - Viewed (0) -
src/runtime/mheap.go
return !exists // already exists } // Removes the Special record of the given kind for the object p. // Returns the record if the record existed, nil otherwise. // The caller must FixAlloc_Free the result. func removespecial(p unsafe.Pointer, kind uint8) *special { span := spanOfHeap(uintptr(p)) if span == nil { throw("removespecial on invalid pointer") } // Ensure that the span is swept.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 22:31:00 UTC 2024 - 78K bytes - Viewed (0) -
pkg/kubelet/volumemanager/populator/desired_state_of_world_populator_test.go
if !dswp.podPreviouslyProcessed(podName) { t.Fatalf("Failed to record that the volumes for the specified pod: %s have been processed by the populator", podName) } pluginPVOmittingClient(dswp) dswp.ReprocessPod(podName) dswp.findAndAddNewPods() if !dswp.podPreviouslyProcessed(podName) { t.Fatalf("Failed to record that the volumes for the specified pod: %s have been processed by the populator", podName) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 51.4K bytes - Viewed (0) -
pkg/controller/daemon/daemon_controller.go
// in the system with actual running pods. type DaemonSetsController struct { kubeClient clientset.Interface eventBroadcaster record.EventBroadcaster eventRecorder record.EventRecorder podControl controller.PodControlInterface crControl controller.ControllerRevisionControlInterface // An dsc is temporarily suspended after creating/deleting these many replicas.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 51.3K bytes - Viewed (0) -
pkg/controller/nodelifecycle/node_lifecycle_controller.go
nodeLister corelisters.NodeLister nodeInformerSynced cache.InformerSynced getPodsAssignedToNode func(nodeName string) ([]*v1.Pod, error) broadcaster record.EventBroadcaster recorder record.EventRecorder // Value controlling Controller monitoring period, i.e. how often does Controller // check node health signal posted from kubelet. This value should be lower than
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 51.6K bytes - Viewed (0) -
src/index/suffixarray/sais2.go
// Because j-1 is type L, inserting it into sa now will sort it correctly. // But we want to distinguish a j-1 with j-2 of type L from type S. // We can process the former but want to leave the latter for the caller. // We record the difference by negating j-1 if it is preceded by type S. // Either way, the insertion (into the text[j-1] bucket) is guaranteed to // happen at sa[i´] for some i´ > i, that is, in the portion of sa we have
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 18 23:57:18 UTC 2024 - 52.3K bytes - Viewed (0) -
pkg/controller/podautoscaler/horizontal.go
downscaleStabilisationWindow time.Duration, tolerance float64, cpuInitializationPeriod, delayOfInitialReadinessStatus time.Duration, ) *HorizontalController { broadcaster := record.NewBroadcaster(record.WithContext(ctx)) broadcaster.StartStructuredLogging(3) broadcaster.StartRecordingToSink(&v1core.EventSinkImpl{Interface: evtNamespacer.Events("")})
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 63.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/validating/admission_test.go
}, }, } }) require.NoError(t, testContext.UpdateAndWait(fakeParams, denyPolicy, denyBinding)) record := attributeRecord(nil, fakeParams, admission.Create) require.ErrorContains(t, testContext.Plugin.Dispatch( testContext, record, &admission.RuntimeObjectInterfaces{}, ), `Denied`) require.NoError(t, testContext.DeleteAndWait(denyPolicy))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 25 01:39:01 UTC 2024 - 63.8K bytes - Viewed (0) -
src/go/types/expr.go
may also be untyped, but not constant. Untyped expressions may eventually become fully typed (i.e., not untyped), typically when the value is assigned to a variable, or is used otherwise. The updateExprType method is used to record this final type and update the recorded types: the type-checked expression tree is again traversed down, and the new type is propagated as needed. Untyped constant expression values
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 02:09:54 UTC 2024 - 49.7K bytes - Viewed (0) -
src/runtime/mgcmark.go
// See issue 30453. scanblock(uintptr(unsafe.Pointer(&d.fn)), goarch.PtrSize, &oneptrmask[0], gcw, &state) } if d.link != nil { // The link field of a stack-allocated defer record might point // to a heap-allocated defer record. Keep that heap record live. scanblock(uintptr(unsafe.Pointer(&d.link)), goarch.PtrSize, &oneptrmask[0], gcw, &state) } // Retain defers records themselves.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 18 21:25:11 UTC 2024 - 52.5K bytes - Viewed (0)