- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 694 for recorder (0.32 sec)
-
pkg/proxy/endpointslicecache.go
hostname: hostname, ipFamily: ipFamily, makeEndpointInfo: makeEndpointInfo, recorder: recorder, } } // newEndpointSliceTracker initializes an endpointSliceTracker. func newEndpointSliceTracker() *endpointSliceTracker { return &endpointSliceTracker{ applied: endpointSliceDataByName{}, pending: endpointSliceDataByName{}, } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 21:07:21 UTC 2024 - 11.7K bytes - Viewed (1) -
pkg/kubelet/images/image_gc_manager.go
// The image garbage collection policy in use. policy ImageGCPolicy // statsProvider provides stats used during image garbage collection. statsProvider StatsProvider // Recorder for Kubernetes events. recorder record.EventRecorder // Reference to this node. nodeRef *v1.ObjectReference // imageCache is the cache of latest image list. imageCache imageCache // tracer for recording spans
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 19.4K bytes - Viewed (0) -
pkg/kubelet/pod/testing/mock_manager.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 - 8.8K bytes - Viewed (0) -
pkg/kubelet/cm/container_manager_unsupported.go
return fmt.Errorf("Container Manager is unsupported in this build") } func NewContainerManager(_ mount.Interface, _ cadvisor.Interface, _ NodeConfig, failSwapOn bool, recorder record.EventRecorder, kubeClient clientset.Interface) (ContainerManager, error) { return &unsupportedContainerManager{}, nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 11 20:58:03 UTC 2022 - 1.5K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/reconciler/reconciler.go
attacherDetacher: attacherDetacher, nodeStatusUpdater: nodeStatusUpdater, nodeLister: nodeLister, timeOfLastSync: time.Now(), recorder: recorder, } } type reconciler struct { loopPeriod time.Duration maxWaitForUnmountDuration time.Duration syncDuration time.Duration
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Feb 22 21:02:38 UTC 2024 - 21.1K bytes - Viewed (0) -
src/cmd/trace/jsontrace_test.go
} func recordJSONTraceHandlerResponse(t *testing.T, parsed *parsedTrace) format.Data { h := JSONTraceHandler(parsed) recorder := httptest.NewRecorder() r := httptest.NewRequest("GET", "/jsontrace", nil) h.ServeHTTP(recorder, r) var data format.Data if err := json.Unmarshal(recorder.Body.Bytes(), &data); err != nil { t.Fatal(err) } return data }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 7.8K bytes - Viewed (0) -
cmd/kube-proxy/app/server_linux.go
config.IPTables.MasqueradeAll, *config.IPTables.LocalhostNodePorts, int(*config.IPTables.MasqueradeBit), localDetectors, s.Hostname, s.NodeIPs, s.Recorder, s.HealthzServer, config.NodePortAddresses, initOnly, ) } else { // Create a single-stack proxier if and only if the node does not support dual-stack (i.e, no iptables support).
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 08 13:48:54 UTC 2024 - 18.1K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/controller/repairip_test.go
} // override for testing r.servicesSynced = func() bool { return true } r.ipAddressSynced = func() bool { return true } r.serviceCIDRSynced = func() bool { return true } recorder := events.NewFakeRecorder(100) r.recorder = recorder for _, svc := range test.svcs { err := r.serviceStore.Add(svc) if err != nil { t.Errorf("Unexpected error trying to add Service %v object: %v", svc, err) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 31 21:05:06 UTC 2023 - 20.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/filters/warning_test.go
args: []args{{agent: "myagent", text: "my\ntext"}}, expect: nil, }, } for _, tt := range tests { t.Run(tt.name, func(t *testing.T) { responseRecorder := httptest.NewRecorder() warningRecorder := &recorder{writer: responseRecorder} for _, arg := range tt.args { warningRecorder.AddWarning(arg.agent, arg.text) } if !reflect.DeepEqual(tt.expect, responseRecorder.Header()["Warning"]) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 01 16:14:06 UTC 2020 - 4K bytes - Viewed (0) -
cmd/kube-proxy/app/server_windows.go
s.Hostname, s.NodeIPs, s.Recorder, s.HealthzServer, config.HealthzBindAddress, config.Winkernel, ) } else { proxier, err = winkernel.NewProxier( s.PrimaryIPFamily, config.IPTables.SyncPeriod.Duration, config.IPTables.MinSyncPeriod.Duration, s.Hostname, s.NodeIPs[s.PrimaryIPFamily], s.Recorder, s.HealthzServer, config.HealthzBindAddress,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 26 13:27:41 UTC 2024 - 3.9K bytes - Viewed (0)