schedwatch

Documentation

Index

• type SchedulerInfo
  • func (s SchedulerInfo) MarshalLogObject(enc zapcore.ObjectEncoder) error
• type SchedulerTracker
  • func StartSchedulerWatcher(ctx context.Context, parentLogger *zap.Logger, ...) (*SchedulerTracker, error)
  • func (s SchedulerTracker) Get() *SchedulerInfo

Types

type SchedulerInfo

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

func (SchedulerInfo) MarshalLogObject

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

MarshalLogObject implements zapcore.ObjectMarshaler

type SchedulerTracker

type SchedulerTracker struct {
	Stop func()
	// contains filtered or unexported fields
}

func StartSchedulerWatcher

func StartSchedulerWatcher(
	ctx context.Context,
	parentLogger *zap.Logger,
	kubeClient *kubernetes.Clientset,
	metrics watch.Metrics,
	schedulerName string,
) (*SchedulerTracker, error)

func (SchedulerTracker) Get

func (s SchedulerTracker) Get() *SchedulerInfo