- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 188 for recorder (0.14 sec)
-
pkg/controller/statefulset/stateful_pod_control_test.go
} events := collectEvents(recorder.Events) if eventCount := len(events); eventCount != 0 { t.Errorf("Pod and PVC exist: got %d events, but want 0", eventCount) for i := range events { t.Log(events[i]) } } } func TestStatefulPodControlCreatePodPvcCreateFailure(t *testing.T) { recorder := record.NewFakeRecorder(10) set := newStatefulSet(3)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 35.5K bytes - Viewed (0) -
staging/src/k8s.io/cli-runtime/pkg/genericclioptions/record_flags.go
func NewRecordFlags() *RecordFlags { record := false return &RecordFlags{ Record: &record, } } // Recorder is used to record why a runtime.Object was changed in an annotation. type Recorder interface { // Record records why a runtime.Object was changed in an annotation. Record(runtime.Object) error MakeRecordMergePatch(runtime.Object) ([]byte, error) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 28 08:48:22 UTC 2024 - 5.5K bytes - Viewed (0) -
platforms/core-configuration/kotlin-dsl/src/integTest/kotlin/org/gradle/kotlin/dsl/resolver/KotlinScriptDependenciesResolverTest.kt
} recorder.apply { assertLastEventIsInstanceOf(ResolvedDependenciesWithErrors::class) assertSingleLineWarningReport("Configuration with name 'doNotExists' not found.", 1) } } private val recorder = ResolverTestRecorder() private val resolver = KotlinBuildScriptDependenciesResolver(recorder) private
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 05:12:50 UTC 2024 - 14.3K bytes - Viewed (0) -
pkg/kubelet/cm/node_container_manager_linux.go
for { err := cm.cgroupManager.Update(cgroupConfig) if err == nil { cm.recorder.Event(nodeRef, v1.EventTypeNormal, events.SuccessfulNodeAllocatableEnforcement, "Updated Node Allocatable limit across pods") return } message := fmt.Sprintf("Failed to update Node Allocatable Limits %q: %v", cm.cgroupRoot, err) cm.recorder.Event(nodeRef, v1.EventTypeWarning, events.FailedNodeAllocatableEnforcement, message)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 10:18:16 UTC 2024 - 10.5K bytes - Viewed (0) -
pkg/kubelet/container/helpers.go
} // FilterEventRecorder creates an event recorder to record object's event except implicitly required container's, like infra container. func FilterEventRecorder(recorder record.EventRecorder) record.EventRecorder { return &innerEventRecorder{ recorder: recorder, } } type innerEventRecorder struct { recorder record.EventRecorder }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 14.3K bytes - Viewed (0) -
pkg/kubelet/network/dns/dns_test.go
// testHostNameserver and testHostDomain are also being used in dns_windows_test.go. testHostNameserver = "8.8.8.8" testHostDomain = "host.domain" fetchEvent = func(recorder *record.FakeRecorder) string { select { case event := <-recorder.Events: return event default: return "" } } ) func TestParseResolvConf(t *testing.T) { testCases := []struct { data string nameservers []string
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 25.6K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_pod_control.go
} // NewStatefulPodControlFromManager creates a StatefulPodControl using the given StatefulPodControlObjectManager and recorder. func NewStatefulPodControlFromManager(om StatefulPodControlObjectManager, recorder record.EventRecorder) *StatefulPodControl { return &StatefulPodControl{om, recorder} }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 14.9K bytes - Viewed (0) -
pkg/volume/util/operationexecutor/operation_generator.go
func NewOperationGenerator(kubeClient clientset.Interface, volumePluginMgr *volume.VolumePluginMgr, recorder record.EventRecorder, blkUtil volumepathhandler.BlockVolumePathHandler) OperationGenerator { return &operationGenerator{ kubeClient: kubeClient, volumePluginMgr: volumePluginMgr, recorder: recorder, blkUtil: blkUtil, translator: csitrans.New(), } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 101.4K bytes - Viewed (0) -
pkg/kubelet/config/config.go
func newPodStorage(updates chan<- kubetypes.PodUpdate, mode PodConfigNotificationMode, recorder record.EventRecorder, startupSLIObserver podStartupSLIObserver) *podStorage { return &podStorage{ pods: make(map[string]map[types.UID]*v1.Pod), mode: mode, updates: updates, sourcesSeen: sets.Set[string]{}, recorder: recorder, startupSLIObserver: startupSLIObserver, } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 16.7K bytes - Viewed (0) -
pkg/proxy/util/utils.go
func LogAndEmitIncorrectIPVersionEvent(recorder events.EventRecorder, fieldName, fieldValue, svcNamespace, svcName string, svcUID types.UID) { errMsg := fmt.Sprintf("%s in %s has incorrect IP version", fieldValue, fieldName) klog.ErrorS(nil, "Incorrect IP version", "service", klog.KRef(svcNamespace, svcName), "field", fieldName, "value", fieldValue) if recorder != nil { recorder.Eventf( &v1.ObjectReference{ Kind: "Service",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 20 11:57:43 UTC 2024 - 7.4K bytes - Viewed (0)