discovery

Documentation

Index

• type Controller
  • func NewController(client dynamic.Interface, namespace string, snapshot *envoy.Snapshot, ...) *Controller
  • func (ctrl *Controller) Run(threadiness int, stopCh <-chan struct{})
• type VirtualNodeManager
  • func NewVirtualNodeManager(client dynamic.Interface, gatewayMesh string, gatewayName string, ...) *VirtualNodeManager
  • func (vnm *VirtualNodeManager) CheckAccess() error
  • func (vnm *VirtualNodeManager) Reconcile(backends []string) error
• type VirtualServiceManager
  • func NewVirtualServiceManager(client dynamic.Interface, optIn bool) *VirtualServiceManager
  • func (vsm *VirtualServiceManager) ConvertToUpstream(vs appmeshv1.VirtualService) envoy.Upstream
  • func (vsm *VirtualServiceManager) IsValid(vs appmeshv1.VirtualService) bool
  • func (vsm *VirtualServiceManager) VirtualServiceFromUnstructured(obj *unstructured.Unstructured) (*appmeshv1.VirtualService, error)

Types

type Controller

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

Controller watches Kubernetes for App Mesh virtual services and creates or deletes Envoy clusters and virtual hosts

func NewController

func NewController(client dynamic.Interface, namespace string, snapshot *envoy.Snapshot, vsManager *VirtualServiceManager, vnManager *VirtualNodeManager) *Controller

NewController reconciles the App Mesh virtual services with Envoy clusters and virtual hosts

func (*Controller) Run

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

Run starts the App Mesh discovery controller

type VirtualNodeManager

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

VirtualNodeManager reconciles the gateway virtual node backend

func NewVirtualNodeManager

func NewVirtualNodeManager(client dynamic.Interface, gatewayMesh string, gatewayName string, gatewayNamespace string) *VirtualNodeManager

NewVirtualNodeManager creates an App Mesh virtual node manager

func (*VirtualNodeManager) CheckAccess

func (vnm *VirtualNodeManager) CheckAccess() error

CheckAccess verifies if RBAC is allowing virtual nodes read operations

func (*VirtualNodeManager) Reconcile

func (vnm *VirtualNodeManager) Reconcile(backends []string) error

Reconcile creates or updates the virtual node and its backends

type VirtualServiceManager

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

VirtualServiceManager transforms virtual service to upstreams

func NewVirtualServiceManager

func NewVirtualServiceManager(client dynamic.Interface, optIn bool) *VirtualServiceManager

NewVirtualServiceManager creates an App Mesh virtual service manager

func (*VirtualServiceManager) ConvertToUpstream

func (vsm *VirtualServiceManager) ConvertToUpstream(vs appmeshv1.VirtualService) envoy.Upstream

ConvertToUpstream converts the App Mesh virtual service to an Upstream

func (*VirtualServiceManager) IsValid

func (vsm *VirtualServiceManager) IsValid(vs appmeshv1.VirtualService) bool

IsValid checks if a virtual service service is eligible

func (*VirtualServiceManager) VirtualServiceFromUnstructured

func (vsm *VirtualServiceManager) VirtualServiceFromUnstructured(obj *unstructured.Unstructured) (*appmeshv1.VirtualService, error)

VirtualServiceFromUnstructured converts an unstructured object to a virtual service