Versions in this module Expand all Collapse all v1 v1.0.1 Feb 21, 2024 v1.0.0 Feb 21, 2024 Changes in this version + const KindKey + type EventInfo struct + CreatedAt time.Time + Note string + Reason string + RecordedAt time.Time + type EventWatcher interface + List func(objectNsName types.NamespacedName, createdAfter time.Time) []*EventInfo + func NewEventWatcher(ctx context.Context, gvk schema.GroupVersionKind, ...) (EventWatcher, error) + type PluginManager struct + func NewPluginManager(ctx context.Context, iCtx pluginsCore.SetupContext, entry k8s.PluginEntry, ...) (*PluginManager, error) + func NewPluginManagerWithBackOff(ctx context.Context, iCtx pluginsCore.SetupContext, entry k8s.PluginEntry, ...) (*PluginManager, error) + func (e *PluginManager) Finalize(ctx context.Context, tCtx pluginsCore.TaskExecutionContext) (err error) + func (e *PluginManager) GetID() string + func (e *PluginManager) GetProperties() pluginsCore.PluginProperties + func (e PluginManager) Abort(ctx context.Context, tCtx pluginsCore.TaskExecutionContext) error + func (e PluginManager) Handle(ctx context.Context, tCtx pluginsCore.TaskExecutionContext) (pluginsCore.Transition, error) + type PluginMetrics struct + GetAPILatency labeled.StopWatch + GetCacheHit labeled.StopWatch + GetCacheMiss labeled.StopWatch + ResourceDeleted labeled.Counter + Scope promutils.Scope + type PluginPhase uint8 + const PluginPhaseAllocationTokenAcquired + const PluginPhaseNotStarted + const PluginPhaseStarted + type PluginState struct + K8sPluginState k8s.PluginState + LastEventUpdate time.Time + Phase PluginPhase + type ResourceLevelMonitor struct + CollectorTimer *labeled.StopWatch + Levels *labeled.Gauge + Scope promutils.Scope + func (r *ResourceLevelMonitor) RunCollector(ctx context.Context) + func (r *ResourceLevelMonitor) RunCollectorOnce(ctx context.Context) + type ResourceMonitorIndex struct + func NewResourceMonitorIndex() *ResourceMonitorIndex + func (r *ResourceMonitorIndex) GetOrCreateResourceLevelMonitor(ctx context.Context, scope promutils.Scope, si cache.SharedIndexInformer, ...) *ResourceLevelMonitor + type TaskExecutionContext struct + func (t TaskExecutionContext) TaskExecutionMetadata() pluginsCore.TaskExecutionMetadata + type TaskExecutionMetadata struct + func (t TaskExecutionMetadata) GetAnnotations() map[string]string + func (t TaskExecutionMetadata) GetLabels() map[string]string
Go to main page