- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 286 for recorder (0.23 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) -
pkg/kubelet/eviction/mock_threshold_notifier_test.go
type MockManager struct { ctrl *gomock.Controller recorder *MockManagerMockRecorder } // MockManagerMockRecorder is the mock recorder for MockManager. type MockManagerMockRecorder struct { mock *MockManager } // NewMockManager creates a new mock instance. func NewMockManager(ctrl *gomock.Controller) *MockManager { mock := &MockManager{ctrl: ctrl} mock.recorder = &MockManagerMockRecorder{mock} return mock }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 13.2K bytes - Viewed (0) -
pkg/kubelet/apis/podresources/testing/provider_mock.go
) // MockDevicesProvider is a mock of DevicesProvider interface. type MockDevicesProvider struct { ctrl *gomock.Controller recorder *MockDevicesProviderMockRecorder } // MockDevicesProviderMockRecorder is the mock recorder for MockDevicesProvider. type MockDevicesProviderMockRecorder struct { mock *MockDevicesProvider } // NewMockDevicesProvider creates a new mock instance.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 10.1K 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/status/testing/mock_pod_status_provider.go
ctrl *gomock.Controller recorder *MockPodManagerMockRecorder } // MockPodManagerMockRecorder is the mock recorder for MockPodManager. type MockPodManagerMockRecorder struct { mock *MockPodManager } // NewMockPodManager creates a new mock instance. func NewMockPodManager(ctrl *gomock.Controller) *MockPodManager { mock := &MockPodManager{ctrl: ctrl} mock.recorder = &MockPodManagerMockRecorder{mock} return mock
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 15.4K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/controller/repair.go
serviceClient: serviceClient, networkByFamily: networkByFamily, allocatorByFamily: allocatorByFamily, leaksByFamily: leaksByFamily, broadcaster: eventBroadcaster, recorder: recorder, } } // RunUntil starts the controller until the provided ch is closed. func (c *Repair) RunUntil(onFirstSuccess func(), stopCh chan struct{}) { c.broadcaster.StartRecordingToSink(stopCh)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Sep 30 15:46:06 UTC 2023 - 13.8K bytes - Viewed (0) -
pkg/controller/util/node/controller_utils.go
errs = append(errs, err) } // record NodeNotReady event after updateStatus to make sure pod still exists recorder.Event(pod, v1.EventTypeWarning, "NodeNotReady", "Node is not ready") break } } return utilerrors.NewAggregate(errs) } // RecordNodeEvent records a event related to a node.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 05 23:39:52 UTC 2023 - 10.6K bytes - Viewed (0) -
pkg/kubelet/container/testing/runtime_mock.go
type MockVersion struct { ctrl *gomock.Controller recorder *MockVersionMockRecorder } // MockVersionMockRecorder is the mock recorder for MockVersion. type MockVersionMockRecorder struct { mock *MockVersion } // NewMockVersion creates a new mock instance. func NewMockVersion(ctrl *gomock.Controller) *MockVersion { mock := &MockVersion{ctrl: ctrl} mock.recorder = &MockVersionMockRecorder{mock} return mock }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 27K bytes - Viewed (0) -
pkg/kubelet/network/dns/dns.go
ResolverConfig string } // NewConfigurer returns a DNS configurer for launching pods. func NewConfigurer(recorder record.EventRecorder, nodeRef *v1.ObjectReference, nodeIPs []net.IP, clusterDNS []net.IP, clusterDomain, resolverConfig string) *Configurer { return &Configurer{ recorder: recorder, getHostDNSConfig: getHostDNSConfig, nodeRef: nodeRef, nodeIPs: nodeIPs, clusterDNS: clusterDNS,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 04 11:37:10 UTC 2023 - 16.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/responsewriters/writers_test.go
buf: tt.out, errs: tt.outErrs, } if tt.statusCode == 0 { tt.statusCode = http.StatusOK } recorder := httptest.NewRecorder() SerializeObject(tt.mediaType, encoder, recorder, tt.req, tt.statusCode, tt.object) result := recorder.Result() if result.StatusCode != tt.wantCode { t.Fatalf("unexpected code: %v", result.StatusCode) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 15.7K bytes - Viewed (0)