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
• func RegisterProfiling(mux *http.ServeMux)
• 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)
• type PodChecker
  • func NewPodChecker(podInformer corev1informers.PodInformer, dataAccess *db.DataAccess, ...) *PodChecker
  • func (p *PodChecker) Run(ctx context.Context)
  • func (p *PodChecker) Start(ctx context.Context)

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

func RegisterProfiling

func RegisterProfiling(mux *http.ServeMux)

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)

type PodChecker

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

func NewPodChecker

func NewPodChecker(podInformer corev1informers.PodInformer, dataAccess *db.DataAccess, checkPeriod time.Duration) *PodChecker

func (*PodChecker) Run

func (p *PodChecker) Run(ctx context.Context)

func (*PodChecker) Start

func (p *PodChecker) Start(ctx context.Context)