generator

Documentation

Index

• Constants
• func InferServiceProtocol(endpoints []core_xds.Endpoint) mesh_core.Protocol
• func Permutation(input []string) [][]string
• func TagPermutations(service string, tags map[string]string, keysAndValues ...string) []string
• type CompositeResourceGenerator
  • func (c CompositeResourceGenerator) Generate(ctx xds_context.Context, proxy *model.Proxy) ([]*model.Resource, error)
• type DirectAccessProxyGenerator
  • func (_ DirectAccessProxyGenerator) Generate(ctx xds_context.Context, proxy *core_xds.Proxy) ([]*core_xds.Resource, error)
• type Endpoint
• type Endpoints
  • func (a Endpoints) Len() int
  • func (a Endpoints) Less(i, j int) bool
  • func (a Endpoints) Swap(i, j int)
• type InboundProxyGenerator
  • func (g InboundProxyGenerator) Generate(ctx xds_context.Context, proxy *model.Proxy) ([]*model.Resource, error)
• type IngressGenerator
  • func (i IngressGenerator) Generate(ctx xds_context.Context, proxy *model.Proxy) ([]*model.Resource, error)
• type OutboundProxyGenerator
  • func (g OutboundProxyGenerator) Generate(ctx xds_context.Context, proxy *model.Proxy) ([]*model.Resource, error)
• type PrometheusEndpointGenerator
  • func (g PrometheusEndpointGenerator) Generate(ctx xds_context.Context, proxy *core_xds.Proxy) ([]*core_xds.Resource, error)
• type ProxyTemplateGenerator
  • func (g *ProxyTemplateGenerator) Generate(ctx xds_context.Context, proxy *model.Proxy) ([]*model.Resource, error)
• type ProxyTemplateProfileSource
  • func (s *ProxyTemplateProfileSource) Generate(ctx xds_context.Context, proxy *model.Proxy) ([]*model.Resource, error)
• type ProxyTemplateRawSource
  • func (s *ProxyTemplateRawSource) Generate(_ xds_context.Context, proxy *model.Proxy) ([]*model.Resource, error)
• type ResourceGenerator
  • func NewDefaultProxyProfile() ResourceGenerator
• type TransparentProxyGenerator
  • func (_ TransparentProxyGenerator) Generate(ctx xds_context.Context, proxy *model.Proxy) ([]*model.Resource, error)

Constants

const (
	IngressProxy = "ingress-proxy"
)

Functions

func InferServiceProtocol

func InferServiceProtocol(endpoints []core_xds.Endpoint) mesh_core.Protocol

InferServiceProtocol returns a common protocol for a given group of endpoints.

func Permutation

func Permutation(input []string) [][]string

func TagPermutations

func TagPermutations(service string, tags map[string]string, keysAndValues ...string) []string

Types

type CompositeResourceGenerator

type CompositeResourceGenerator []ResourceGenerator

func (CompositeResourceGenerator) Generate

func (c CompositeResourceGenerator) Generate(ctx xds_context.Context, proxy *model.Proxy) ([]*model.Resource, error)

type DirectAccessProxyGenerator

type DirectAccessProxyGenerator struct {
}

Transparent Proxy is based on having 1 IP for cluster (ex. ClusterIP of Service on K8S), so consuming apps by their IP is unknown destination from Envoy perspective. Therefore such request will go trough pass_trough cluster and won't be encrypted by mTLS. This generates listener for every IP and redirect traffic trough "direct_access" cluster which is configured to encrypt connections. Generating listener for every endpoint will cause XDS snapshot to be large therefore it should be used only if really needed.

Second approach to consider was to use FilterChainMatch on catch_all listener with list of all direct access endpoints instead of generating outbound listener, but it seemed to not work with Listener#UseOriginalDst

func (DirectAccessProxyGenerator) Generate

func (_ DirectAccessProxyGenerator) Generate(ctx xds_context.Context, proxy *core_xds.Proxy) ([]*core_xds.Resource, error)

type Endpoint

type Endpoint struct {
	Address string
	Port    uint32
}

type Endpoints

type Endpoints []Endpoint

func (Endpoints) Len

func (a Endpoints) Len() int

func (Endpoints) Less

func (a Endpoints) Less(i, j int) bool

func (Endpoints) Swap

func (a Endpoints) Swap(i, j int)

type InboundProxyGenerator

type InboundProxyGenerator struct {
}

func (InboundProxyGenerator) Generate

func (g InboundProxyGenerator) Generate(ctx xds_context.Context, proxy *model.Proxy) ([]*model.Resource, error)

type IngressGenerator

type IngressGenerator struct {
}

func (IngressGenerator) Generate

func (i IngressGenerator) Generate(ctx xds_context.Context, proxy *model.Proxy) ([]*model.Resource, error)

type OutboundProxyGenerator

type OutboundProxyGenerator struct {
}

func (OutboundProxyGenerator) Generate

func (g OutboundProxyGenerator) Generate(ctx xds_context.Context, proxy *model.Proxy) ([]*model.Resource, error)

type PrometheusEndpointGenerator

type PrometheusEndpointGenerator struct {
}

PrometheusEndpointGenerator generates an inbound Envoy listener that forwards HTTP requests into the `/stats/prometheus` endpoint of the Envoy Admin API.

When generating such a listener, it's important not to overshadow a port that is already in use by the application or other Envoy listeners. In the latter case we prefer not generate Prometheus endpoint at all rather than introduce undeterministic behaviour.

func (PrometheusEndpointGenerator) Generate

func (g PrometheusEndpointGenerator) Generate(ctx xds_context.Context, proxy *core_xds.Proxy) ([]*core_xds.Resource, error)

type ProxyTemplateGenerator

type ProxyTemplateGenerator struct {
	ProxyTemplate *kuma_mesh.ProxyTemplate
}

func (*ProxyTemplateGenerator) Generate

func (g *ProxyTemplateGenerator) Generate(ctx xds_context.Context, proxy *model.Proxy) ([]*model.Resource, error)

type ProxyTemplateProfileSource

type ProxyTemplateProfileSource struct {
	ProfileName string
}

func (*ProxyTemplateProfileSource) Generate

func (s *ProxyTemplateProfileSource) Generate(ctx xds_context.Context, proxy *model.Proxy) ([]*model.Resource, error)

type ProxyTemplateRawSource

type ProxyTemplateRawSource struct {
	Resources []*kuma_mesh.ProxyTemplateRawResource
}

func (*ProxyTemplateRawSource) Generate

func (s *ProxyTemplateRawSource) Generate(_ xds_context.Context, proxy *model.Proxy) ([]*model.Resource, error)

type ResourceGenerator

type ResourceGenerator interface {
	Generate(xds_context.Context, *model.Proxy) ([]*model.Resource, error)
}

func NewDefaultProxyProfile

func NewDefaultProxyProfile() ResourceGenerator

type TransparentProxyGenerator

type TransparentProxyGenerator struct {
}

func (TransparentProxyGenerator) Generate

func (_ TransparentProxyGenerator) Generate(ctx xds_context.Context, proxy *model.Proxy) ([]*model.Resource, error)