canary

Documentation

Index

• func Add(mgr manager.Manager) error
• func GetContainerRunningState(job *corev1.Pod, containerName string) *corev1.ContainerStateRunning
• func GetContainerTerminalState(job *corev1.Pod, containerName string) *corev1.ContainerStateTerminated
• func GetJudgeJobName(c *v1.Canary) string
• func GetTestJobname(c *v1.Canary) string
• func MakeDestinationRuleName(canary *v1.Canary) string
• type DestinationRuleType
• type ReconcileCanary
  • func (r *ReconcileCanary) CreateJudgeJob(canary *v1.Canary, policy *v1.CanaryPolicy) (*corev1.Pod, error)
  • func (r *ReconcileCanary) CreateTestJob(canary *v1.Canary, policy *v1.CanaryPolicy) (*corev1.Pod, error)
  • func (r *ReconcileCanary) FindMatchingHttpAndRoute(svc string, vs *v1alpha3.VirtualService) (int, int)
  • func (r *ReconcileCanary) FindMatchingRouteInHttpRoute(svc string, http *v1alpha3.HTTPRoute) int
  • func (r *ReconcileCanary) GetCanaryPolicy(ctx context.Context, c *v1.Canary) (*v1.CanaryPolicy, error)
  • func (r *ReconcileCanary) Reconcile(request reconcile.Request) (reconcile.Result, error)
  • func (r *ReconcileCanary) ReconcilePhaseStatus(ctx context.Context, cfg *v1.Canary) error

Functions

func Add

func Add(mgr manager.Manager) error

Add creates a new Canary Controller and adds it to the Manager. The Manager will set fields on the Controller and Start it when the Manager is Started.

func GetContainerRunningState

func GetContainerRunningState(job *corev1.Pod, containerName string) *corev1.ContainerStateRunning

GetContainerRunningState returns a running state if the container has that

func GetContainerTerminalState

func GetContainerTerminalState(job *corev1.Pod, containerName string) *corev1.ContainerStateTerminated

IsPodDone returns true if the pod has all containers completed

func GetJudgeJobName

func GetJudgeJobName(c *v1.Canary) string

func GetTestJobname

func GetTestJobname(c *v1.Canary) string

func MakeDestinationRuleName

func MakeDestinationRuleName(canary *v1.Canary) string

Types

type DestinationRuleType

type DestinationRuleType string

type ReconcileCanary

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

ReconcileCanary reconciles a Canary object

func (*ReconcileCanary) CreateJudgeJob

func (r *ReconcileCanary) CreateJudgeJob(canary *v1.Canary, policy *v1.CanaryPolicy) (*corev1.Pod, error)

func (*ReconcileCanary) CreateTestJob

func (r *ReconcileCanary) CreateTestJob(canary *v1.Canary, policy *v1.CanaryPolicy) (*corev1.Pod, error)

func (*ReconcileCanary) FindMatchingHttpAndRoute

func (r *ReconcileCanary) FindMatchingHttpAndRoute(svc string, vs *v1alpha3.VirtualService) (int, int)

func (*ReconcileCanary) FindMatchingRouteInHttpRoute

func (r *ReconcileCanary) FindMatchingRouteInHttpRoute(svc string, http *v1alpha3.HTTPRoute) int

func (*ReconcileCanary) GetCanaryPolicy

func (r *ReconcileCanary) GetCanaryPolicy(ctx context.Context, c *v1.Canary) (*v1.CanaryPolicy, error)

func (*ReconcileCanary) Reconcile

func (r *ReconcileCanary) Reconcile(request reconcile.Request) (reconcile.Result, error)

Reconcile reads that state of the cluster for a Canary object and makes changes based on the state read and what is in the Canary.Spec The Controller will requeue the Request to be processed again if the returned error is non-nil or Result.Requeue is true, otherwise upon completion it will remove the work from the queue.

func (*ReconcileCanary) ReconcilePhaseStatus

func (r *ReconcileCanary) ReconcilePhaseStatus(ctx context.Context, cfg *v1.Canary) error

ReconcilePhaseStatus updates the phases of the canary