schedulecontroller

Documentation

Index

• Constants
• func NewNotEnoughCapableClustersInRegionError(region string, capabilities []string, required, available int) error
• type BrokenChartError
  • func NewBrokenChartError(chartName, chartVersion, chartRepo string, err error) BrokenChartError
  • func (e BrokenChartError) Error() string
• type ChartError
• type ChartFetchFailureError
  • func NewChartFetchFailureError(chartName, chartVersion, chartRepo string, err error) ChartFetchFailureError
  • func (e ChartFetchFailureError) Error() string
• type Controller
  • func NewController(shipperclientset shipperclient.Interface, ...) *Controller
  • func (c *Controller) Run(threadiness int, stopCh <-chan struct{})
• type DuplicateCapabilityRequirementError
  • func NewDuplicateCapabilityRequirementError(capability string) DuplicateCapabilityRequirementError
  • func (e DuplicateCapabilityRequirementError) Error() string
• type FailedAPICallError
  • func NewFailedAPICallError(call string, err error) FailedAPICallError
  • func (e FailedAPICallError) Error() string
• type InvalidReleaseOwnerRefsError
  • func NewInvalidReleaseOwnerRefsError(count int) InvalidReleaseOwnerRefsError
  • func (e InvalidReleaseOwnerRefsError) Error() string
• type NoRegionsSpecifiedError
  • func NewNoRegionsSpecifiedError() NoRegionsSpecifiedError
  • func (e NoRegionsSpecifiedError) Error() string
• type NotEnoughCapableClustersInRegionError
  • func (e NotEnoughCapableClustersInRegionError) Error() string
• type NotEnoughClustersInRegionError
  • func NewNotEnoughClustersInRegionError(region string, required, available int) NotEnoughClustersInRegionError
  • func (e NotEnoughClustersInRegionError) Error() string
• type Scheduler
  • func NewScheduler(release *shipper.Release, shipperclientset clientset.Interface, ...) *Scheduler
  • func (c *Scheduler) Clusters() []string
  • func (c *Scheduler) CreateCapacityTarget(totalReplicaCount int32) error
  • func (c *Scheduler) CreateInstallationTarget() error
  • func (c *Scheduler) CreateTrafficTarget() error
  • func (c *Scheduler) HasClusters() bool
  • func (c *Scheduler) SetClusters(clusters []string)
  • func (c *Scheduler) UpdateRelease() (*shipper.Release, error)
• type WrongChartDeploymentsError
  • func NewWrongChartDeploymentsError(chartName, chartVersion, chartRepo string, deploymentCount int) WrongChartDeploymentsError
  • func (e WrongChartDeploymentsError) Error() string

Constants

const (
	AgentName = "schedule-controller"
)

Functions

func NewNotEnoughCapableClustersInRegionError

func NewNotEnoughCapableClustersInRegionError(region string, capabilities []string, required, available int) error

Types

type BrokenChartError

type BrokenChartError struct {
	ChartError
	// contains filtered or unexported fields
}

func NewBrokenChartError

func NewBrokenChartError(chartName, chartVersion, chartRepo string, err error) BrokenChartError

func (BrokenChartError) Error

func (e BrokenChartError) Error() string

type ChartError

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

type ChartFetchFailureError

type ChartFetchFailureError struct {
	ChartError
	// contains filtered or unexported fields
}

func NewChartFetchFailureError

func NewChartFetchFailureError(chartName, chartVersion, chartRepo string, err error) ChartFetchFailureError

func (ChartFetchFailureError) Error

func (e ChartFetchFailureError) Error() string

type Controller

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

Controller is a Kubernetes controller that knows how to schedule Releases.

func NewController

func NewController(
	shipperclientset shipperclient.Interface,
	shipperInformerFactory shipperinformers.SharedInformerFactory,
	chartFetchFunc chart.FetchFunc,
	recorder record.EventRecorder,
) *Controller

NewController returns a new Schedule controller.

func (*Controller) Run

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

type DuplicateCapabilityRequirementError

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

func NewDuplicateCapabilityRequirementError

func NewDuplicateCapabilityRequirementError(capability string) DuplicateCapabilityRequirementError

func (DuplicateCapabilityRequirementError) Error

func (e DuplicateCapabilityRequirementError) Error() string

type FailedAPICallError

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

func NewFailedAPICallError

func NewFailedAPICallError(call string, err error) FailedAPICallError

func (FailedAPICallError) Error

func (e FailedAPICallError) Error() string

type InvalidReleaseOwnerRefsError

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

func NewInvalidReleaseOwnerRefsError

func NewInvalidReleaseOwnerRefsError(count int) InvalidReleaseOwnerRefsError

func (InvalidReleaseOwnerRefsError) Error

func (e InvalidReleaseOwnerRefsError) Error() string

type NoRegionsSpecifiedError

type NoRegionsSpecifiedError struct{}

func NewNoRegionsSpecifiedError

func NewNoRegionsSpecifiedError() NoRegionsSpecifiedError

func (NoRegionsSpecifiedError) Error

func (e NoRegionsSpecifiedError) Error() string

type NotEnoughCapableClustersInRegionError

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

func (NotEnoughCapableClustersInRegionError) Error

func (e NotEnoughCapableClustersInRegionError) Error() string

type NotEnoughClustersInRegionError

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

func NewNotEnoughClustersInRegionError

func NewNotEnoughClustersInRegionError(region string, required, available int) NotEnoughClustersInRegionError

func (NotEnoughClustersInRegionError) Error

func (e NotEnoughClustersInRegionError) Error() string

type Scheduler

type Scheduler struct {
	Release *shipper.Release
	// contains filtered or unexported fields
}

Scheduler is an object that knows how to schedule releases.

func NewScheduler

func NewScheduler(
	release *shipper.Release,
	shipperclientset clientset.Interface,
	clusterLister listers.ClusterLister,
	installationTargetLister listers.InstallationTargetLister,
	capacityTargetLister listers.CapacityTargetLister,
	trafficTargetLister listers.TrafficTargetLister,
	chartFetchFunc shipperchart.FetchFunc,
	recorder record.EventRecorder,
) *Scheduler

NewScheduler returns a new Scheduler instance that knows how to schedule a particular Release.

func (*Scheduler) Clusters

func (c *Scheduler) Clusters() []string

func (*Scheduler) CreateCapacityTarget

func (c *Scheduler) CreateCapacityTarget(totalReplicaCount int32) error

CreateCapacityTarget creates a new CapacityTarget object for Scheduler's Release property. Returns an error if the object couldn't be created.

func (*Scheduler) CreateInstallationTarget

func (c *Scheduler) CreateInstallationTarget() error

CreateInstallationTarget creates a new InstallationTarget object for Scheduler's Release property. Returns an error if the object couldn't be created.

func (*Scheduler) CreateTrafficTarget

func (c *Scheduler) CreateTrafficTarget() error

CreateTrafficTarget creates a new TrafficTarget object for Scheduler's Release property. Returns an error if the object couldn't be created.

func (*Scheduler) HasClusters

func (c *Scheduler) HasClusters() bool

func (*Scheduler) SetClusters

func (c *Scheduler) SetClusters(clusters []string)

func (*Scheduler) UpdateRelease

func (c *Scheduler) UpdateRelease() (*shipper.Release, error)

type WrongChartDeploymentsError

type WrongChartDeploymentsError struct {
	ChartError
	// contains filtered or unexported fields
}

func NewWrongChartDeploymentsError

func NewWrongChartDeploymentsError(chartName, chartVersion, chartRepo string, deploymentCount int) WrongChartDeploymentsError

func (WrongChartDeploymentsError) Error

func (e WrongChartDeploymentsError) Error() string