controllercontext

type ActiveJobStore interface {
	CountActiveJobsForConfig(rjc *execution.JobConfig) int64
	CheckAndAdd(rjc *execution.JobConfig, oldCount int64) (success bool)
	Delete(rjc *execution.JobConfig)
}

type Clientsets interface {
	Kubernetes() kubernetes.Interface
	Furiko() furiko.Interface
}

type Configs interface {
	Start(ctx context.Context) error
	AllConfigs() (map[configv1alpha1.ConfigName]runtime.Object, error)
	Jobs() (*configv1alpha1.JobExecutionConfig, error)
	JobConfigs() (*configv1alpha1.JobConfigExecutionConfig, error)
	Cron() (*configv1alpha1.CronExecutionConfig, error)
}

type ConfigsMap = map[configv1alpha1.ConfigName]runtime.Object

type Context interface {
	Start(ctx context.Context) error
	Clientsets() Clientsets
	Configs() Configs
	Stores() Stores
	Informers() Informers
}

type ContextConfigs struct {
	*configloader.ConfigManager
}

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

type Informers interface {
	Start(ctx context.Context) error
	Kubernetes() kubernetes.SharedInformerFactory
	Furiko() furiko.SharedInformerFactory
}

type Store interface {
	Name() string
}

type Stores interface {
	Register(store Store)
	ActiveJobStore() (ActiveJobStore, error)
}