- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 614 for recorder (0.14 sec)
-
pkg/registry/core/service/ipallocator/controller/repairip.go
workqueue.TypedRateLimitingQueueConfig[string]{Name: "ipaddresses"}, ), tree: iptree.New[string](), workerLoopPeriod: time.Second, broadcaster: eventBroadcaster, recorder: recorder, clock: clock.RealClock{}, } _, _ = serviceInformer.Informer().AddEventHandlerWithResyncPeriod(cache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 24.7K bytes - Viewed (0) -
logger/logger.go
SlowThreshold: 200 * time.Millisecond, LogLevel: Warn, IgnoreRecordNotFoundError: false, Colorful: true, }) // Recorder logger records running SQL into a recorder instance Recorder = traceRecorder{Interface: Default, BeginAt: time.Now()} ) // New initialize logger func New(writer Writer, config Config) Interface { var ( infoStr = "%s\n[info] "
Registered: Wed Jun 12 16:27:09 UTC 2024 - Last Modified: Tue Nov 07 02:19:41 UTC 2023 - 5.8K bytes - Viewed (0) -
pkg/controller/volume/expand/expand_controller.go
pvcsSynced cache.InformerSynced // volumePluginMgr used to initialize and fetch volume plugins volumePluginMgr volume.VolumePluginMgr // recorder is used to record events in the API server recorder record.EventRecorder operationGenerator operationexecutor.OperationGenerator queue workqueue.TypedRateLimitingInterface[string] translator CSINameTranslator
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 16.2K bytes - Viewed (0) -
pkg/kubelet/runonce_test.go
fakeRuntime, kb.mounter, kb.hostutil, kb.getPodsDir(), kb.recorder, volumetest.NewBlockVolumePathHandler()) // TODO: Factor out "stats.Provider" from Kubelet so we don't have a cyclic dependency volumeStatsAggPeriod := time.Second * 10 kb.resourceAnalyzer = stats.NewResourceAnalyzer(kb, volumeStatsAggPeriod, kb.recorder) nodeRef := &v1.ObjectReference{ Kind: "Node",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 06:59:54 UTC 2024 - 6.5K bytes - Viewed (0) -
pkg/kubelet/config/config.go
func newPodStorage(updates chan<- kubetypes.PodUpdate, mode PodConfigNotificationMode, recorder record.EventRecorder, startupSLIObserver podStartupSLIObserver) *podStorage { return &podStorage{ pods: make(map[string]map[types.UID]*v1.Pod), mode: mode, updates: updates, sourcesSeen: sets.Set[string]{}, recorder: recorder, startupSLIObserver: startupSLIObserver, } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 16.7K bytes - Viewed (0) -
pkg/kubelet/prober/prober.go
http httpprobe.Prober tcp tcpprobe.Prober grpc grpcprobe.Prober runner kubecontainer.CommandRunner recorder record.EventRecorder } // NewProber creates a Prober, it takes a command runner and // several container info managers. func newProber( runner kubecontainer.CommandRunner, recorder record.EventRecorder) *prober { const followNonLocalRedirects = false return &prober{ exec: execprobe.New(),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Feb 16 10:50:13 UTC 2024 - 8.7K bytes - Viewed (0) -
pkg/kubelet/active_deadline_test.go
pods := newTestPods(1) podStatusProvider := &mockPodStatusProvider{pods: pods} fakeRecorder := &record.FakeRecorder{} fakeClock := testingclock.NewFakeClock(time.Now()) testCases := []struct { podStatusProvider status.PodStatusProvider recorder record.EventRecorder clock clock.Clock }{ {podStatusProvider, fakeRecorder, fakeClock},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Oct 08 09:06:42 UTC 2022 - 4.5K bytes - Viewed (0) -
pkg/controller/replication/replication_controller.go
// NewReplicationManager configures a replication manager with the specified event recorder func NewReplicationManager(ctx context.Context, podInformer coreinformers.PodInformer, rcInformer coreinformers.ReplicationControllerInformer, kubeClient clientset.Interface, burstReplicas int) *ReplicationManager { logger := klog.FromContext(ctx) eventBroadcaster := record.NewBroadcaster(record.WithContext(ctx)) return &ReplicationManager{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 06:51:56 UTC 2024 - 2.4K bytes - Viewed (0) -
pkg/controller/cronjob/utils_test.go
sched, err := cron.ParseStandard(schedule) if err != nil { t.Errorf("Error parsing schedule: %#v", err) return nil } return sched } recorder := record.NewFakeRecorder(50) // T1 is a scheduled start time of that schedule T1 := *topOfTheHour() // T2 is a scheduled start time of that schedule after T1 T2 := *deltaTimeAfterTopOfTheHour(1 * time.Hour)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 03:34:25 UTC 2024 - 22.8K bytes - Viewed (0) -
pkg/proxy/util/utils.go
func LogAndEmitIncorrectIPVersionEvent(recorder events.EventRecorder, fieldName, fieldValue, svcNamespace, svcName string, svcUID types.UID) { errMsg := fmt.Sprintf("%s in %s has incorrect IP version", fieldValue, fieldName) klog.ErrorS(nil, "Incorrect IP version", "service", klog.KRef(svcNamespace, svcName), "field", fieldName, "value", fieldValue) if recorder != nil { recorder.Eventf( &v1.ObjectReference{ Kind: "Service",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 20 11:57:43 UTC 2024 - 7.4K bytes - Viewed (0)