envoyfilter

Documentation

Index

• func GenerateInsertBeforeNetworkFilter(service *model.ServiceEntryWrapper, outboundProxy proto.Message, ...) []*model.EnvoyFilterWrapper
• func GenerateReplaceNetworkFilter(service *model.ServiceEntryWrapper, port *networking.ServicePort, ...) []*model.EnvoyFilterWrapper
• type Controller
  • func NewController(istioClientset *istioclient.Clientset, store istiomodel.ConfigStore, ...) *Controller
  • func (c *Controller) ConfigUpdated(event istiomodel.Event)
  • func (c *Controller) InitMeshConfig(meshConfig mesh.Holder)
  • func (c *Controller) Run(stop <-chan struct{})
• type Generator

Functions

func GenerateInsertBeforeNetworkFilter

func GenerateInsertBeforeNetworkFilter(service *model.ServiceEntryWrapper, outboundProxy proto.Message,
	inboundProxy proto.Message, filterName string, filterType string) []*model.EnvoyFilterWrapper

GenerateInsertBeforeNetworkFilter generates an EnvoyFilter that inserts a protocol specified filter before the tcp proxy

func GenerateReplaceNetworkFilter

func GenerateReplaceNetworkFilter(service *model.ServiceEntryWrapper, port *networking.ServicePort,
	outboundProxy proto.Message,
	inboundProxy proto.Message, filterName string, filterType string) []*model.EnvoyFilterWrapper

GenerateReplaceNetworkFilter generates an EnvoyFilter that replaces the default tcp proxy with a protocol specified proxy

Types

type Controller

type Controller struct {
	MetaRouterControllerClient client.Client
	// contains filtered or unexported fields
}

Controller contains the runtime configuration for the envoyFilter controller.

func NewController

func NewController(istioClientset *istioclient.Clientset, store istiomodel.ConfigStore,
	generators map[protocol.Instance]Generator, namespaceScoped bool, namespace string) *Controller

NewController creates a new controller instance based on the provided arguments.

func (*Controller) ConfigUpdated

func (c *Controller) ConfigUpdated(event istiomodel.Event)

ConfigUpdated sends a config change event to the pushChannel to trigger the generation of envoyfilters

func (*Controller) InitMeshConfig

func (c *Controller) InitMeshConfig(meshConfig mesh.Holder)

InitMeshConfig global mesh configuration

func (*Controller) Run

func (c *Controller) Run(stop <-chan struct{})

Run until a signal is received, this function won't block

type Generator

type Generator interface {
	Generate(context *model.EnvoyFilterContext) ([]*model.EnvoyFilterWrapper, error)
}

Generator generates protocol specified envoyfilters