recorder

Documentation

Index

• Variables
• func ComputePodScheduleStatus(pod *corev1.Pod) (scheduleStatus scalehist.PodScheduleStatus)
• func GetInnerMap(parentMap map[string]any, keys ...string) (map[string]any, error)
• func GetInnerMapValue(parentMap map[string]any, keys ...string) (any, error)
• func InvokeOrScheduleFunc[T any](label string, duration time.Duration, entity T, fn func(T) error)
• func IsOwnedBy(pod *corev1.Pod, gvks []schema.GroupVersionKind) bool
• func NewDefaultRecorder(params scalehist.RecorderParams, startTime time.Time) (scalehist.Recorder, error)
• type ConnChecker
  • func NewConnChecker(shootConfig, controlConfig *rest.Config) (*ConnChecker, error)
  • func (c *ConnChecker) TestConnection(ctx context.Context) error

Variables

var ErrKeyNotFound = errors.New("key not found")

Functions

func ComputePodScheduleStatus

func ComputePodScheduleStatus(pod *corev1.Pod) (scheduleStatus scalehist.PodScheduleStatus)

ComputePodScheduleStatus -1 => NotDetermined, 0 => Scheduled, 1 => Unscheduled

func GetInnerMap

func GetInnerMap(parentMap map[string]any, keys ...string) (map[string]any, error)

func GetInnerMapValue

func GetInnerMapValue(parentMap map[string]any, keys ...string) (any, error)

func InvokeOrScheduleFunc

func InvokeOrScheduleFunc[T any](label string, duration time.Duration, entity T, fn func(T) error)

func IsOwnedBy

func IsOwnedBy(pod *corev1.Pod, gvks []schema.GroupVersionKind) bool

func NewDefaultRecorder

func NewDefaultRecorder(params scalehist.RecorderParams, startTime time.Time) (scalehist.Recorder, error)

Types

type ConnChecker

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

func NewConnChecker

func NewConnChecker(shootConfig, controlConfig *rest.Config) (*ConnChecker, error)

func (*ConnChecker) TestConnection

func (c *ConnChecker) TestConnection(ctx context.Context) error