recorder

Documentation

Index

• Constants
• Variables
• func ComputePodScheduleStatus(pod *corev1.Pod) (scheduleStatus gst.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 gsh.RecorderParams, startTime time.Time) (gsh.Recorder, error)
• func PodInfoFromPod(p *corev1.Pod) gst.PodInfo
• type ConnChecker
  • func NewConnChecker(shootConfig, controlConfig *rest.Config) (*ConnChecker, error)
  • func (c *ConnChecker) TestConnection(ctx context.Context) error

Constants

const PoolLabel = "worker.gardener.cloud/pool"

Variables

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

var ZoneLabels = []string{"topology.gke.io/zone", "topology.ebs.csi.aws.com/zone"}

Functions

func ComputePodScheduleStatus

func ComputePodScheduleStatus(pod *corev1.Pod) (scheduleStatus gst.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 gsh.RecorderParams, startTime time.Time) (gsh.Recorder, error)

func PodInfoFromPod

func PodInfoFromPod(p *corev1.Pod) gst.PodInfo

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