- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 694 for recorder (0.26 sec)
-
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/server/stats/testing/mock_summary_provider.go
) // MockSummaryProvider is a mock of SummaryProvider interface. type MockSummaryProvider struct { ctrl *gomock.Controller recorder *MockSummaryProviderMockRecorder } // MockSummaryProviderMockRecorder is the mock recorder for MockSummaryProvider. type MockSummaryProviderMockRecorder struct { mock *MockSummaryProvider } // NewMockSummaryProvider creates a new mock instance.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 2.9K 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) -
pkg/kubelet/container/testing/mockdirentry.go
type MockDirEntry struct { ctrl *gomock.Controller recorder *MockDirEntryMockRecorder } // MockDirEntryMockRecorder is the mock recorder for MockDirEntry. type MockDirEntryMockRecorder struct { mock *MockDirEntry } // NewMockDirEntry creates a new mock instance. func NewMockDirEntry(ctrl *gomock.Controller) *MockDirEntry { mock := &MockDirEntry{ctrl: ctrl} mock.recorder = &MockDirEntryMockRecorder{mock} return mock }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/filters/warning.go
recorder := &recorder{writer: w} req = req.WithContext(warning.WithWarningRecorder(req.Context(), recorder)) handler.ServeHTTP(w, req) }) } var ( truncateAtTotalRunes = 4 * 1024 truncateItemRunes = 256 ) type recordedWarning struct { agent string text string } type recorder struct { // lock guards calls to AddWarning from multiple threads
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 01 16:14:06 UTC 2020 - 3.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/authentication/token/cache/cached_token_authenticator.go
record.annotations = ac.Event.Annotations record.warnings = recorder.extractWarnings() if !a.cacheErrs && record.err != nil { return record, nil } switch { case record.ok && a.successTTL > 0: a.cache.set(key, record, a.successTTL) case !record.ok && a.failureTTL > 0: a.cache.set(key, record, a.failureTTL) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 03 16:16:51 UTC 2023 - 9.8K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/watch/filter.go
} } } // Recorder records all events that are sent from the watch until it is closed. type Recorder struct { Interface lock sync.Mutex events []Event } var _ Interface = &Recorder{} // NewRecorder wraps an Interface and records any changes sent across it. func NewRecorder(w Interface) *Recorder { r := &Recorder{} r.Interface = Filter(w, r.record) return r }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 2.8K bytes - Viewed (0) -
pkg/kubelet/oom/oom_watcher_linux.go
// the oom streamer. func NewWatcher(recorder record.EventRecorder) (Watcher, error) { // for test purpose _, ok := recorder.(*record.FakeRecorder) if ok { return nil, nil } oomStreamer, err := oomparser.New() if err != nil { return nil, err } watcher := &realWatcher{ recorder: recorder, oomStreamer: oomStreamer, } return watcher, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Nov 08 23:17:05 UTC 2022 - 2.3K 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) -
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)