envoy

Documentation

Index

• func AccessLogSocketName(name, mesh string) string
• func MetricsHijackerSocketName(name, mesh string) string
• type APIVersion
• type CLACache
• type Cluster
• type ClusterImpl
  • func NewCluster(opts ...NewClusterOpt) *ClusterImpl
  • func (c *ClusterImpl) Hash() string
  • func (c *ClusterImpl) IsExternalService() bool
  • func (c *ClusterImpl) Mesh() string
  • func (c *ClusterImpl) Name() string
  • func (c *ClusterImpl) Service() string
  • func (c *ClusterImpl) SetMesh(mesh string)
  • func (c *ClusterImpl) SetName(name string)
  • func (c *ClusterImpl) Tags() tags.Tags
  • func (c *ClusterImpl) Weight() uint32
• type NamedResource
• type NewClusterOpt
  • func WithExternalService(isExternalService bool) NewClusterOpt
  • func WithName(name string) NewClusterOpt
  • func WithService(service string) NewClusterOpt
  • func WithTags(tags tags.Tags) NewClusterOpt
  • func WithWeight(weight uint32) NewClusterOpt
• type NewRouteOpt
  • func WithCluster(cluster Cluster) NewRouteOpt
• type Route
  • func NewRoute(opts ...NewRouteOpt) Route
  • func NewRouteFromCluster(cluster Cluster) Route
• type Routes
  • func (r Routes) Clusters() []Cluster
• type Service
  • func (c *Service) Add(cluster Cluster)
  • func (c *Service) Clusters() []Cluster
  • func (c *Service) HasExternalService() bool
  • func (c *Service) TLSReady() bool
  • func (c *Service) Tags() []tags.Tags
• type Services
  • func (c Services) Sorted() []string
• type ServicesAccumulator
  • func NewServicesAccumulator(tlsReadiness map[string]bool) ServicesAccumulator
  • func (sa ServicesAccumulator) Add(clusters ...Cluster)
  • func (sa ServicesAccumulator) Services() Services
• type Split
• type StaticEndpointPath
• type TrafficDirection

Functions

func AccessLogSocketName

func AccessLogSocketName(name, mesh string) string

AccessLogSocketName generates a socket path that will fit the Unix socket path limitation of 108 chars

func MetricsHijackerSocketName

func MetricsHijackerSocketName(name, mesh string) string

MetricsHijackerSocketName generates a socket path that will fit the Unix socket path limitation of 108 chars

Types

type APIVersion

type APIVersion string

const (
	APIV3 APIVersion = "v3"
	// AnonymousResource is an empty name for the resources
	AnonymousResource = ""
)

type CLACache

type CLACache interface {
	GetCLA(ctx context.Context, meshName, meshHash string, cluster Cluster, apiVersion core_xds.APIVersion, endpointMap core_xds.EndpointMap) (proto.Message, error)
}

type Cluster

type Cluster interface {
	Service() string
	Name() string
	Mesh() string
	Tags() tags.Tags
	Hash() string
	IsExternalService() bool
}

type ClusterImpl

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

func NewCluster

func NewCluster(opts ...NewClusterOpt) *ClusterImpl

func (*ClusterImpl) Hash

func (c *ClusterImpl) Hash() string

func (*ClusterImpl) IsExternalService

func (c *ClusterImpl) IsExternalService() bool

func (*ClusterImpl) Mesh

func (c *ClusterImpl) Mesh() string

Mesh returns a non-empty string only if the cluster is in a different mesh from the context.

func (*ClusterImpl) Name

func (c *ClusterImpl) Name() string

func (*ClusterImpl) Service

func (c *ClusterImpl) Service() string

func (*ClusterImpl) SetMesh

func (c *ClusterImpl) SetMesh(mesh string)

func (*ClusterImpl) SetName

func (c *ClusterImpl) SetName(name string)

func (*ClusterImpl) Tags

func (c *ClusterImpl) Tags() tags.Tags

func (*ClusterImpl) Weight

func (c *ClusterImpl) Weight() uint32

type NamedResource

type NamedResource interface {
	envoy_types.Resource
	GetName() string
}

type NewClusterOpt

type NewClusterOpt interface {
	// contains filtered or unexported methods
}

func WithExternalService

func WithExternalService(isExternalService bool) NewClusterOpt

func WithName

func WithName(name string) NewClusterOpt

func WithService

func WithService(service string) NewClusterOpt

func WithTags

func WithTags(tags tags.Tags) NewClusterOpt

func WithWeight

func WithWeight(weight uint32) NewClusterOpt

type NewRouteOpt

type NewRouteOpt interface {
	// contains filtered or unexported methods
}

func WithCluster

func WithCluster(cluster Cluster) NewRouteOpt

type Route

type Route struct {
	Clusters []Cluster
}

func NewRoute

func NewRoute(opts ...NewRouteOpt) Route

func NewRouteFromCluster

func NewRouteFromCluster(cluster Cluster) Route

type Routes

type Routes []Route

func (Routes) Clusters

func (r Routes) Clusters() []Cluster

type Service

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

func (*Service) Add

func (c *Service) Add(cluster Cluster)

func (*Service) Clusters

func (c *Service) Clusters() []Cluster

func (*Service) HasExternalService

func (c *Service) HasExternalService() bool

func (*Service) TLSReady

func (c *Service) TLSReady() bool

func (*Service) Tags

func (c *Service) Tags() []tags.Tags

type Services

type Services map[string]*Service

func (Services) Sorted

func (c Services) Sorted() []string

type ServicesAccumulator

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

func NewServicesAccumulator

func NewServicesAccumulator(tlsReadiness map[string]bool) ServicesAccumulator

func (ServicesAccumulator) Add

func (sa ServicesAccumulator) Add(clusters ...Cluster)

func (ServicesAccumulator) Services

func (sa ServicesAccumulator) Services() Services

type Split

type Split interface {
	ClusterName() string
	Weight() uint32
	LBMetadata() tags.Tags
	HasExternalService() bool
}

type StaticEndpointPath

type StaticEndpointPath struct {
	Path             string
	ClusterName      string
	RewritePath      string
	Header           string
	HeaderExactMatch string
}

type TrafficDirection

type TrafficDirection string

const (
	TrafficDirectionOutbound    TrafficDirection = "OUTBOUND"
	TrafficDirectionInbound     TrafficDirection = "INBOUND"
	TrafficDirectionUnspecified TrafficDirection = "UNSPECIFIED"
)