release

Documentation

Index

• Constants
• type Controller
  • func NewController(ks kubernetes.Interface, d8ClientSet versioned.Interface, ...) *Controller
  • func (c *Controller) GetModuleSources() map[string]string
  • func (c *Controller) Reconcile(ctx context.Context, releaseName string) (ctrl.Result, error)
  • func (c *Controller) Run(ctx context.Context, workers int)
  • func (c *Controller) RunPreflightCheck(ctx context.Context) error
• type ModulePullOverrideController
  • func NewModulePullOverrideController(ks kubernetes.Interface, d8ClientSet versioned.Interface, ...) *ModulePullOverrideController
  • func (c *ModulePullOverrideController) OverrideReconcile(ctx context.Context, key string) (ctrl.Result, error)
  • func (c *ModulePullOverrideController) Run(ctx context.Context, workers int)

Constants

const (
	UpdatePolicyLabel = "modules.deckhouse.io/update-policy"
)

Types

type Controller

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

Controller is the controller implementation for ModuleRelease resources

func NewController

func NewController(ks kubernetes.Interface,
	d8ClientSet versioned.Interface,
	moduleReleaseInformer d8informers.ModuleReleaseInformer,
	moduleSourceInformer d8informers.ModuleSourceInformer,
	moduleUpdatePolicyInformer d8informers.ModuleUpdatePolicyInformer,
	modulePullOverridesInformer d8informers.ModulePullOverrideInformer,
	mv moduleValidator,
	httpClient d8http.Client,
	metricStorage *metric_storage.MetricStorage,
	embeddedPolicy *v1alpha1.ModuleUpdatePolicySpec,
) *Controller

NewController returns a new sample controller

func (*Controller) GetModuleSources

func (c *Controller) GetModuleSources() map[string]string

func (*Controller) Reconcile

func (c *Controller) Reconcile(ctx context.Context, releaseName string) (ctrl.Result, error)

func (*Controller) Run

func (c *Controller) Run(ctx context.Context, workers int)

func (*Controller) RunPreflightCheck

func (c *Controller) RunPreflightCheck(ctx context.Context) error

RunPreflightCheck start a few checks and synchronize deckhouse filesystem with ModuleReleases

• Download modules, which have status=deployed on ModuleRelease but have no files on Filesystem
• Delete modules, that don't have ModuleRelease presented in the cluster

type ModulePullOverrideController

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

ModulePullOverrideController is the controller implementation for ModulePullOverride resources

func NewModulePullOverrideController

func NewModulePullOverrideController(ks kubernetes.Interface,
	d8ClientSet versioned.Interface,
	moduleSourceInformer d8informers.ModuleSourceInformer,
	modulePullOverridesInformer d8informers.ModulePullOverrideInformer,
	modulesValidator moduleValidator,
) *ModulePullOverrideController

NewModulePullOverrideController returns a new sample controller

func (*ModulePullOverrideController) OverrideReconcile

func (c *ModulePullOverrideController) OverrideReconcile(ctx context.Context, key string) (ctrl.Result, error)

func (*ModulePullOverrideController) Run

func (c *ModulePullOverrideController) Run(ctx context.Context, workers int)