controllercontext

Documentation

Index

• Variables
• type ActiveJobStore
• type Clientsets
  • func SetUpClientsets(cfg *rest.Config) (Clientsets, error)
• type Configs
  • func SetUpConfigManager(cfg *configv1alpha1.BootstrapConfigSpec, client kubernetes.Interface) Configs
• type ConfigsMap
• type Context
  • func NewForConfig(cfg *rest.Config, ctrlConfig *configv1alpha1.BootstrapConfigSpec) (Context, error)
• type ContextConfigs
  • func NewContextConfigs(mgr *configloader.ConfigManager) *ContextConfigs
  • func (c *ContextConfigs) AllConfigs() (map[configv1alpha1.ConfigName]runtime.Object, error)
  • func (c *ContextConfigs) Cron() (*configv1alpha1.CronExecutionConfig, error)
  • func (c *ContextConfigs) JobConfigs() (*configv1alpha1.JobConfigExecutionConfig, error)
  • func (c *ContextConfigs) Jobs() (*configv1alpha1.JobExecutionConfig, error)
• type ContextStores
  • func NewContextStores() *ContextStores
  • func (c *ContextStores) ActiveJobStore() (ActiveJobStore, error)
  • func (c *ContextStores) Register(store Store)
• type Informers
  • func SetUpInformers(clientsets Clientsets, cfg *configv1alpha1.BootstrapConfigSpec) Informers
• type Store
• type Stores

Variables

var (
	ErrStoreNotRegistered = errors.New("store not registered")
)

Types

type ActiveJobStore

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

type Clientsets

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

func SetUpClientsets

func SetUpClientsets(cfg *rest.Config) (Clientsets, error)

type Configs

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)
}

func SetUpConfigManager

func SetUpConfigManager(cfg *configv1alpha1.BootstrapConfigSpec, client kubernetes.Interface) Configs

SetUpConfigManager sets up the ConfigManager and returns a composed Configs interface.

type ConfigsMap

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

ConfigsMap is a map of ConfigName to Config object.

type Context

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

Context is a shared controller context that can be safely shared between controllers.

func NewForConfig

func NewForConfig(cfg *rest.Config, ctrlConfig *configv1alpha1.BootstrapConfigSpec) (Context, error)

NewForConfig prepares a new Context from a kubeconfig and controller manager config spec.

type ContextConfigs

type ContextConfigs struct {
	*configloader.ConfigManager
}

func NewContextConfigs

func NewContextConfigs(mgr *configloader.ConfigManager) *ContextConfigs

func (*ContextConfigs) AllConfigs

func (c *ContextConfigs) AllConfigs() (map[configv1alpha1.ConfigName]runtime.Object, error)

AllConfigs returns a map of all configs.

func (*ContextConfigs) Cron

func (c *ContextConfigs) Cron() (*configv1alpha1.CronExecutionConfig, error)

Cron returns the cron dynamic configuration.

func (*ContextConfigs) JobConfigs

func (c *ContextConfigs) JobConfigs() (*configv1alpha1.JobConfigExecutionConfig, error)

JobConfigs returns the job config dynamic configuration.

func (*ContextConfigs) Jobs

func (c *ContextConfigs) Jobs() (*configv1alpha1.JobExecutionConfig, error)

Jobs returns the job dynamic configuration.

type ContextStores

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

func NewContextStores

func NewContextStores() *ContextStores

func (*ContextStores) ActiveJobStore

func (c *ContextStores) ActiveJobStore() (ActiveJobStore, error)

ActiveJobStore returns the active job store.

func (*ContextStores) Register

func (c *ContextStores) Register(store Store)

Register a new Store.

type Informers

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

func SetUpInformers

func SetUpInformers(clientsets Clientsets, cfg *configv1alpha1.BootstrapConfigSpec) Informers

type Store

type Store interface {
	Name() string
}

type Stores

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