Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 200 for recorder (0.17 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. pkg/controller/cronjob/cronjob_controllerv2.go

    func getRef(object runtime.Object) (*corev1.ObjectReference, error) {
    	return ref.GetReference(scheme.Scheme, object)
    }
    
    func formatSchedule(cj *batchv1.CronJob, recorder record.EventRecorder) string {
    	if strings.Contains(cj.Spec.Schedule, "TZ") {
    		if recorder != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 09 03:34:25 UTC 2024
    - 29.2K bytes
    - Viewed (0)
  10. 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)
Back to top