controller

Documentation

Index

• Constants
• func CallEventWebhook(r *flaggerv1.Canary, w flaggerv1.CanaryWebhook, message, eventtype string) error
• func CallWebhook(canary flaggerv1.Canary, phase flaggerv1.CanaryPhase, ...) error
• type CanaryJob
  • func (j CanaryJob) GetCanaryAnalysisInterval() time.Duration
  • func (j CanaryJob) Start()
  • func (j CanaryJob) Stop()
• type Controller
  • func NewController(kubeClient kubernetes.Interface, flaggerClient clientset.Interface, ...) *Controller
  • func (c *Controller) Run(threadiness int, stopCh <-chan struct{}) error
• type Informers

Constants

const (
	MetricsProviderServiceSuffix = ":service"
)

Functions

func CallEventWebhook

func CallEventWebhook(r *flaggerv1.Canary, w flaggerv1.CanaryWebhook, message, eventtype string) error

func CallWebhook

func CallWebhook(canary flaggerv1.Canary, phase flaggerv1.CanaryPhase, w flaggerv1.CanaryWebhook) error

CallWebhook does a HTTP POST to an external service and returns an error if the response status code is non-2xx

Types

type CanaryJob

type CanaryJob struct {
	Name      string
	Namespace string
	// contains filtered or unexported fields
}

CanaryJob holds the reference to a canary deployment schedule

func (CanaryJob) GetCanaryAnalysisInterval

func (j CanaryJob) GetCanaryAnalysisInterval() time.Duration

func (CanaryJob) Start

func (j CanaryJob) Start()

Start runs the canary analysis on a schedule

func (CanaryJob) Stop

func (j CanaryJob) Stop()

Stop closes the job channel and stops the ticker

type Controller

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

Controller is managing the canary objects and schedules canary deployments

func NewController

func NewController(
	kubeClient kubernetes.Interface,
	flaggerClient clientset.Interface,
	flaggerInformers Informers,
	flaggerWindow time.Duration,
	logger *zap.SugaredLogger,
	notifier notifier.Interface,
	canaryFactory *canary.Factory,
	routerFactory *router.Factory,
	observerFactory *observers.Factory,
	meshProvider string,
	version string,
	eventWebhook string,
	clusterName string,
	noCrossNamespaceRefs bool,
) *Controller

func (*Controller) Run

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

Run starts the K8s workers and the canary scheduler

type Informers

type Informers struct {
	CanaryInformer flaggerinformers.CanaryInformer
	MetricInformer flaggerinformers.MetricTemplateInformer
	AlertInformer  flaggerinformers.AlertProviderInformer
}