release

Documentation

Index

• Constants
• type CapacityTargetSpecPatch
  • func (p *CapacityTargetSpecPatch) Alters(o interface{}) bool
  • func (p *CapacityTargetSpecPatch) IsEmpty() bool
  • func (p *CapacityTargetSpecPatch) PatchSpec() (string, schema.GroupVersionKind, []byte)
• type Controller
  • func NewController(clientset shipperclient.Interface, ...) *Controller
  • func (c *Controller) Run(threadiness int, stopCh <-chan struct{})
• type ExecutorPipeline
  • func NewExecutorPipeline() *ExecutorPipeline
  • func (p *ExecutorPipeline) Enqueue(step PipelineStep)
  • func (p *ExecutorPipeline) Process(strategyStep shipper.RolloutStrategyStep, ...) (bool, []StrategyPatch, []ReleaseStrategyStateTransition)
• type Pipeline
• type PipelineContinuation
• type PipelineStep
• type ReleaseStrategyStateTransition
• type ReleaseStrategyStatusPatch
  • func (p *ReleaseStrategyStatusPatch) Alters(o interface{}) bool
  • func (p *ReleaseStrategyStatusPatch) IsEmpty() bool
  • func (p *ReleaseStrategyStatusPatch) PatchSpec() (string, schema.GroupVersionKind, []byte)
• type Scheduler
  • func NewScheduler(clientset shipperclientset.Interface, clusterLister listers.ClusterLister, ...) *Scheduler
  • func (s *Scheduler) ChooseClusters(rel *shipper.Release) (*shipper.Release, error)
  • func (s *Scheduler) CreateOrUpdateCapacityTarget(rel *shipper.Release, totalReplicaCount int32) (*shipper.CapacityTarget, error)
  • func (s *Scheduler) CreateOrUpdateInstallationTarget(rel *shipper.Release) (*shipper.InstallationTarget, error)
  • func (s *Scheduler) CreateOrUpdateTrafficTarget(rel *shipper.Release) (*shipper.TrafficTarget, error)
  • func (s *Scheduler) ScheduleRelease(rel *shipper.Release) (*releaseInfo, error)
• type StrategyExecutor
  • func NewStrategyExecutor(strategy *shipper.RolloutStrategy, step int32, isSteppingBackwards bool) *StrategyExecutor
  • func (e *StrategyExecutor) Execute(prev, curr, succ *releaseInfo, pipeline Pipeline) (bool, []StrategyPatch, []ReleaseStrategyStateTransition)
• type StrategyPatch
• type TrafficTargetSpecPatch
  • func (p *TrafficTargetSpecPatch) Alters(o interface{}) bool
  • func (p *TrafficTargetSpecPatch) IsEmpty() bool
  • func (p *TrafficTargetSpecPatch) PatchSpec() (string, schema.GroupVersionKind, []byte)

Constants

const (
	AgentName = "release-controller"
)

const (
	ClustersNotReady = "ClustersNotReady"
)

Types

type CapacityTargetSpecPatch

type CapacityTargetSpecPatch struct {
	Name    string
	NewSpec *shipper.CapacityTargetSpec
}

func (*CapacityTargetSpecPatch) Alters

func (p *CapacityTargetSpecPatch) Alters(o interface{}) bool

func (*CapacityTargetSpecPatch) IsEmpty

func (p *CapacityTargetSpecPatch) IsEmpty() bool

func (*CapacityTargetSpecPatch) PatchSpec

func (p *CapacityTargetSpecPatch) PatchSpec() (string, schema.GroupVersionKind, []byte)

type Controller

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

Controller is a Kubernetes controller whose role is to pick up a newly created release and progress it forward by scheduling the release on a set of selected clusters, creating a set of associated objects and executing the strategy.

func NewController

func NewController(
	clientset shipperclient.Interface,
	informerFactory shipperinformers.SharedInformerFactory,
	chartFetcher shipperrepo.ChartFetcher,
	recorder record.EventRecorder,
) *Controller

func (*Controller) Run

func (c *Controller) Run(threadiness int, stopCh <-chan struct{})

Run starts Release Controller workers and waits until stopCh is closed.

type ExecutorPipeline

type ExecutorPipeline []PipelineStep

func NewExecutorPipeline

func NewExecutorPipeline() *ExecutorPipeline

func (*ExecutorPipeline) Enqueue

func (p *ExecutorPipeline) Enqueue(step PipelineStep)

func (*ExecutorPipeline) Process

func (p *ExecutorPipeline) Process(strategyStep shipper.RolloutStrategyStep, cond conditions.StrategyConditionsMap) (bool, []StrategyPatch, []ReleaseStrategyStateTransition)

type Pipeline

type Pipeline interface {
	Enqueue(step PipelineStep)
	Process(strategyStep shipper.RolloutStrategyStep, cond conditions.StrategyConditionsMap) (bool, []StrategyPatch, []ReleaseStrategyStateTransition)
	// contains filtered or unexported methods
}

type PipelineContinuation

type PipelineContinuation bool

const (
	PipelineBreak    PipelineContinuation = false
	PipelineContinue                      = true
)

type PipelineStep

type PipelineStep func(shipper.RolloutStrategyStep, conditions.StrategyConditionsMap) (PipelineContinuation, []StrategyPatch, []ReleaseStrategyStateTransition)

type ReleaseStrategyStateTransition

type ReleaseStrategyStateTransition struct {
	State    string
	Previous shipper.StrategyState
	New      shipper.StrategyState
}

type ReleaseStrategyStatusPatch

type ReleaseStrategyStatusPatch struct {
	Name              string
	NewStrategyStatus *shipper.ReleaseStrategyStatus
}

func (*ReleaseStrategyStatusPatch) Alters

func (p *ReleaseStrategyStatusPatch) Alters(o interface{}) bool

func (*ReleaseStrategyStatusPatch) IsEmpty

func (p *ReleaseStrategyStatusPatch) IsEmpty() bool

func (*ReleaseStrategyStatusPatch) PatchSpec

func (p *ReleaseStrategyStatusPatch) PatchSpec() (string, schema.GroupVersionKind, []byte)

type Scheduler

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

func NewScheduler

func NewScheduler(
	clientset shipperclientset.Interface,
	clusterLister listers.ClusterLister,
	installationTargerLister listers.InstallationTargetLister,
	capacityTargetLister listers.CapacityTargetLister,
	trafficTargetLister listers.TrafficTargetLister,
	rolloutBlockLister listers.RolloutBlockLister,
	chartFetcher shipperrepo.ChartFetcher,
	recorder record.EventRecorder,
) *Scheduler

func (*Scheduler) ChooseClusters

func (s *Scheduler) ChooseClusters(rel *shipper.Release) (*shipper.Release, error)

func (*Scheduler) CreateOrUpdateCapacityTarget

func (s *Scheduler) CreateOrUpdateCapacityTarget(rel *shipper.Release, totalReplicaCount int32) (*shipper.CapacityTarget, error)

func (*Scheduler) CreateOrUpdateInstallationTarget

func (s *Scheduler) CreateOrUpdateInstallationTarget(rel *shipper.Release) (*shipper.InstallationTarget, error)

func (*Scheduler) CreateOrUpdateTrafficTarget

func (s *Scheduler) CreateOrUpdateTrafficTarget(rel *shipper.Release) (*shipper.TrafficTarget, error)

func (*Scheduler) ScheduleRelease

func (s *Scheduler) ScheduleRelease(rel *shipper.Release) (*releaseInfo, error)

type StrategyExecutor

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

func NewStrategyExecutor

func NewStrategyExecutor(strategy *shipper.RolloutStrategy, step int32, isSteppingBackwards bool) *StrategyExecutor

func (*StrategyExecutor) Execute

func (e *StrategyExecutor) Execute(prev, curr, succ *releaseInfo, pipeline Pipeline) (bool, []StrategyPatch, []ReleaseStrategyStateTransition)

type StrategyPatch

type StrategyPatch interface {
	PatchSpec() (string, schema.GroupVersionKind, []byte)
	Alters(interface{}) bool
	IsEmpty() bool
}

type TrafficTargetSpecPatch

type TrafficTargetSpecPatch struct {
	Name    string
	NewSpec *shipper.TrafficTargetSpec
}

func (*TrafficTargetSpecPatch) Alters

func (p *TrafficTargetSpecPatch) Alters(o interface{}) bool

func (*TrafficTargetSpecPatch) IsEmpty

func (p *TrafficTargetSpecPatch) IsEmpty() bool

func (*TrafficTargetSpecPatch) PatchSpec

func (p *TrafficTargetSpecPatch) PatchSpec() (string, schema.GroupVersionKind, []byte)