- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 412 for recorder (0.18 sec)
-
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) -
pkg/kubelet/kuberuntime/fake_kuberuntime_manager.go
ctx := context.Background() recorder := &record.FakeRecorder{} logManager, err := logs.NewContainerLogManager(runtimeService, osInterface, "1", 2, 10, metav1.Duration{Duration: 10 * time.Second}) if err != nil { return nil, err } kubeRuntimeManager := &kubeGenericRuntimeManager{ recorder: recorder, cpuCFSQuota: false,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Feb 16 17:55:59 UTC 2024 - 5.1K bytes - Viewed (0) -
pkg/kubelet/cadvisor/testing/cadvisor_mock.go
ctrl *gomock.Controller recorder *MockInterfaceMockRecorder } // MockInterfaceMockRecorder is the mock recorder for MockInterface. type MockInterfaceMockRecorder struct { mock *MockInterface } // NewMockInterface creates a new mock instance. func NewMockInterface(ctrl *gomock.Controller) *MockInterface { mock := &MockInterface{ctrl: ctrl} mock.recorder = &MockInterfaceMockRecorder{mock} return mock }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 8.4K 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/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) -
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/proxy/kubemark/hollow_proxy.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 05:08:41 UTC 2024 - 2.9K bytes - Viewed (0) -
pkg/controller/tainteviction/taint_eviction_test.go
}, } if diff := cmp.Diff(want, recorder.Events, cmp.FilterPath(f, cmp.Ignore())); len(diff) > 0 { t.Errorf("emitPodDeletionEvent() returned data (-want,+got):\n%s", diff) } }) t.Run("emitCancelPodDeletionEvent", func(t *testing.T) { controller := &Controller{} recorder := testutil.NewFakeRecorder() controller.recorder = recorder controller.emitCancelPodDeletionEvent(types.NamespacedName{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 14:24:16 UTC 2024 - 31.3K 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)