controller

Documentation

Overview

Package controller provides a piped component that handles all of the not completed deployments by managing a pool of planners and schedulers. Whenever a new PENDING deployment is detected, controller spawns a new planner for deciding the deployment pipeline and update the deployment status to PLANNED. Whenever a new PLANNED deployment is detected, controller spawns a new scheduler for scheduling and running its pipeline executors.

Package controller provides a piped component that handles all of the not completed deployments by managing a pool of planners and schedulers. Whenever a new PENDING deployment is detected, controller spawns a new planner for deciding the deployment pipeline and update the deployment status to PLANNED. Whenever a new PLANNED deployment is detected, controller spawns a new scheduler for scheduling and running its pipeline executors.

Index

• type DeploymentController
  • func NewController(apiClient apiClient, gitClient gitClient, deploymentLister deploymentLister, ...) DeploymentController
• type PluginRegistry
  • func DefaultPluginRegistry() PluginRegistry

Types

type DeploymentController

type DeploymentController interface {
	Run(ctx context.Context) error
}

func NewController

func NewController(
	apiClient apiClient,
	gitClient gitClient,
	deploymentLister deploymentLister,
	commandLister commandLister,
	applicationLister applicationLister,
	liveResourceLister liveResourceLister,
	analysisResultStore analysisResultStore,
	notifier notifier,
	sd secretDecrypter,
	pipedCfg *config.PipedSpec,
	pipedConfig []byte,
	appManifestsCache cache.Cache,
	gracePeriod time.Duration,
	logger *zap.Logger,
) DeploymentController

NewController creates a new instance for DeploymentController.

type PluginRegistry

type PluginRegistry interface {
	Plugin(k model.ApplicationKind) (platform.PlatformPluginClient, bool)
}

func DefaultPluginRegistry

func DefaultPluginRegistry() PluginRegistry