router

Documentation

Index

• type AppMeshRouter
  • func (ar *AppMeshRouter) GetRoutes(canary *flaggerv1.Canary) (primaryWeight int, canaryWeight int, err error)
  • func (ar *AppMeshRouter) SetRoutes(canary *flaggerv1.Canary, primaryWeight int, canaryWeight int) error
  • func (ar *AppMeshRouter) Sync(canary *flaggerv1.Canary) error
• type Factory
  • func NewFactory(kubeClient kubernetes.Interface, flaggerClient clientset.Interface, ...) *Factory
  • func (factory *Factory) KubernetesRouter() *KubernetesRouter
  • func (factory *Factory) MeshRouter(provider string) Interface
• type Interface
• type IstioRouter
  • func (ir *IstioRouter) GetRoutes(canary *flaggerv1.Canary) (primaryWeight int, canaryWeight int, err error)
  • func (ir *IstioRouter) SetRoutes(canary *flaggerv1.Canary, primaryWeight int, canaryWeight int) error
  • func (ir *IstioRouter) Sync(canary *flaggerv1.Canary) error
• type KubernetesRouter
  • func (c *KubernetesRouter) GetRoutes(canary *flaggerv1.Canary) (primaryRoute int, canaryRoute int, err error)
  • func (c *KubernetesRouter) SetRoutes(canary *flaggerv1.Canary, primaryRoute int, canaryRoute int) error
  • func (c *KubernetesRouter) Sync(cd *flaggerv1.Canary) error

Types

type AppMeshRouter

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

AppMeshRouter is managing AppMesh virtual services

func (*AppMeshRouter) GetRoutes

func (ar *AppMeshRouter) GetRoutes(canary *flaggerv1.Canary) (
	primaryWeight int,
	canaryWeight int,
	err error,
)

GetRoutes returns the destinations weight for primary and canary

func (*AppMeshRouter) SetRoutes

func (ar *AppMeshRouter) SetRoutes(
	canary *flaggerv1.Canary,
	primaryWeight int,
	canaryWeight int,
) error

SetRoutes updates the destinations weight for primary and canary

func (*AppMeshRouter) Sync

func (ar *AppMeshRouter) Sync(canary *flaggerv1.Canary) error

Sync creates or updates App Mesh virtual nodes and virtual services

type Factory

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

func NewFactory

func NewFactory(kubeClient kubernetes.Interface,
	flaggerClient clientset.Interface,
	logger *zap.SugaredLogger,
	meshClient clientset.Interface) *Factory

func (*Factory) KubernetesRouter

func (factory *Factory) KubernetesRouter() *KubernetesRouter

KubernetesRouter returns a ClusterIP service router

func (*Factory) MeshRouter

func (factory *Factory) MeshRouter(provider string) Interface

MeshRouter returns a service mesh router (Istio or AppMesh)

type Interface

type Interface interface {
	Sync(canary *flaggerv1.Canary) error
	SetRoutes(canary *flaggerv1.Canary, primaryWeight int, canaryWeight int) error
	GetRoutes(canary *flaggerv1.Canary) (primaryWeight int, canaryWeight int, err error)
}

type IstioRouter

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

IstioRouter is managing Istio virtual services

func (*IstioRouter) GetRoutes

func (ir *IstioRouter) GetRoutes(canary *flaggerv1.Canary) (
	primaryWeight int,
	canaryWeight int,
	err error,
)

GetRoutes returns the destinations weight for primary and canary

func (*IstioRouter) SetRoutes

func (ir *IstioRouter) SetRoutes(
	canary *flaggerv1.Canary,
	primaryWeight int,
	canaryWeight int,
) error

SetRoutes updates the destinations weight for primary and canary

func (*IstioRouter) Sync

func (ir *IstioRouter) Sync(canary *flaggerv1.Canary) error

Sync creates or updates the Istio virtual service

type KubernetesRouter

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

KubernetesRouter is managing ClusterIP services

func (*KubernetesRouter) GetRoutes

func (c *KubernetesRouter) GetRoutes(canary *flaggerv1.Canary) (primaryRoute int, canaryRoute int, err error)

func (*KubernetesRouter) SetRoutes

func (c *KubernetesRouter) SetRoutes(canary *flaggerv1.Canary, primaryRoute int, canaryRoute int) error

func (*KubernetesRouter) Sync

func (c *KubernetesRouter) Sync(cd *flaggerv1.Canary) error

Sync creates or updates the primary and canary services