recorder

Documentation

Index

• Constants
• Variables
• func ComputePodScheduleStatus(pod *corev1.Pod) (scheduleStatus gsc.PodScheduleStatus)
• func CreateRecorderParams(ctx context.Context, mode gsh.ExecutionMode, configDir string, dbDir string) ([]gsh.RecorderParams, error)
• 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 LaunchFileServer(ctx context.Context, dbDir string, reportDir string) error
• func NewDefaultRecorder(parentCtx context.Context, params gsh.RecorderParams, startTime time.Time) (gsh.Recorder, error)
• func PodInfoFromPod(p *corev1.Pod) gsc.PodInfo
• type ConnChecker
  • func NewConnChecker(shootConfig, controlConfig *rest.Config) (*ConnChecker, error)
  • func (c *ConnChecker) TestConnection(ctx context.Context) error
• type FileServer
  • func (f *FileServer) GetDatabase(w http.ResponseWriter, r *http.Request)
  • func (f *FileServer) GetReport(w http.ResponseWriter, r *http.Request)
  • func (f *FileServer) ListDatabases(w http.ResponseWriter, r *http.Request)
  • func (f *FileServer) ListReports(w http.ResponseWriter, _ *http.Request)

Constants

const CLUSTERS_CFG_FILE = "clusters.csv"

Variables

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

Functions

func ComputePodScheduleStatus

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

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

func CreateRecorderParams

func CreateRecorderParams(ctx context.Context, mode gsh.ExecutionMode, configDir string, dbDir string) ([]gsh.RecorderParams, error)

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 LaunchFileServer

func LaunchFileServer(ctx context.Context, dbDir string, reportDir string) error

func NewDefaultRecorder

func NewDefaultRecorder(parentCtx context.Context, params gsh.RecorderParams, startTime time.Time) (gsh.Recorder, error)

func PodInfoFromPod

func PodInfoFromPod(p *corev1.Pod) gsc.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

type FileServer

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

func (*FileServer) GetDatabase

func (f *FileServer) GetDatabase(w http.ResponseWriter, r *http.Request)

func (*FileServer) GetReport

func (f *FileServer) GetReport(w http.ResponseWriter, r *http.Request)

func (*FileServer) ListDatabases

func (f *FileServer) ListDatabases(w http.ResponseWriter, r *http.Request)

func (*FileServer) ListReports

func (f *FileServer) ListReports(w http.ResponseWriter, _ *http.Request)