schedwatch

Documentation

Index

• func StartSchedulerWatcher(ctx context.Context, parentLogger *zap.Logger, ...) (*watch.Store[corev1.Pod], error)
• func WatchSchedulerUpdates(ctx context.Context, logger *zap.Logger, ...) (SchedulerWatch, *SchedulerInfo, error)
• type SchedulerInfo
  • func (info SchedulerInfo) Format(state fmt.State, verb rune)
  • func (s SchedulerInfo) MarshalLogObject(enc zapcore.ObjectEncoder) error
• type SchedulerWatch
  • func (w SchedulerWatch) ExpectingDeleted()
  • func (w SchedulerWatch) ExpectingReady()
  • func (w SchedulerWatch) Stop()
  • func (w SchedulerWatch) Using(sched SchedulerInfo)
• type WatchEvent
  • func (ev WatchEvent) Format(state fmt.State, verb rune)
  • func (ev WatchEvent) MarshalLogObject(enc zapcore.ObjectEncoder) error

Functions

func StartSchedulerWatcher

func StartSchedulerWatcher(
	ctx context.Context,
	parentLogger *zap.Logger,
	kubeClient *kubernetes.Clientset,
	metrics watch.Metrics,
	eventBroker *pubsub.Broker[WatchEvent],
	schedulerName string,
) (*watch.Store[corev1.Pod], error)

func WatchSchedulerUpdates

func WatchSchedulerUpdates(
	ctx context.Context,
	logger *zap.Logger,
	eventBroker *pubsub.Broker[WatchEvent],
	store *watch.Store[corev1.Pod],
) (SchedulerWatch, *SchedulerInfo, error)

Types

type SchedulerInfo

type SchedulerInfo struct {
	PodName util.NamespacedName
	UID     types.UID
	IP      string
}

func (SchedulerInfo) Format

func (info SchedulerInfo) Format(state fmt.State, verb rune)

func (SchedulerInfo) MarshalLogObject

func (s SchedulerInfo) MarshalLogObject(enc zapcore.ObjectEncoder) error

MarshalLogObject implements zapcore.ObjectMarshaler

type SchedulerWatch

type SchedulerWatch struct {
	ReadyQueue <-chan SchedulerInfo
	Deleted    <-chan SchedulerInfo
	// contains filtered or unexported fields
}

SchedulerWatch is the interface returned by WatchSchedulerUpdates

func (SchedulerWatch) ExpectingDeleted

func (w SchedulerWatch) ExpectingDeleted()

func (SchedulerWatch) ExpectingReady

func (w SchedulerWatch) ExpectingReady()

func (SchedulerWatch) Stop

func (w SchedulerWatch) Stop()

func (SchedulerWatch) Using

func (w SchedulerWatch) Using(sched SchedulerInfo)

type WatchEvent

type WatchEvent struct {
	// contains filtered or unexported fields
}

func (WatchEvent) Format

func (ev WatchEvent) Format(state fmt.State, verb rune)

func (WatchEvent) MarshalLogObject

func (ev WatchEvent) MarshalLogObject(enc zapcore.ObjectEncoder) error

MarshalLogObject implements zapcore.ObjectMarshaler