envoy

Documentation

Index

• func AccessLogSocketName(name, mesh string) string
• func MetricsHijackerSocketName(name, mesh string) string
• type APIVersion
• type Cluster
  • func NewCluster(opts ...NewClusterOpt) Cluster
  • func (c *Cluster) Hash() string
  • func (c *Cluster) IsExternalService() bool
  • func (c *Cluster) LB() *mesh_proto.TrafficRoute_LoadBalancer
  • func (c *Cluster) Name() string
  • func (c *Cluster) Service() string
  • func (c *Cluster) SetName(name string)
  • func (c *Cluster) Tags() Tags
  • func (c *Cluster) Timeout() *mesh_proto.Timeout_Conf
  • func (c *Cluster) Weight() uint32
• type NamedResource
• type NewClusterOpt
  • func WithExternalService(isExternalService bool) NewClusterOpt
  • func WithLB(lb *mesh_proto.TrafficRoute_LoadBalancer) NewClusterOpt
  • func WithName(name string) NewClusterOpt
  • func WithService(service string) NewClusterOpt
  • func WithTags(tags Tags) NewClusterOpt
  • func WithTimeout(timeout *mesh_proto.Timeout_Conf) NewClusterOpt
  • func WithWeight(weight uint32) NewClusterOpt
• type Route
  • func NewRouteFromCluster(cluster Cluster) Route
• type Routes
  • func (r Routes) Clusters() (clusters []Cluster)
• type Service
  • func (c *Service) Add(cluster Cluster)
  • func (c *Service) Clusters() []Cluster
  • func (c *Service) HasExternalService() bool
  • func (c *Service) Tags() []Tags
• type Services
  • func (c Services) Add(clusters ...Cluster)
  • func (c Services) Names() []string
• type StaticEndpointPath
• type TagKeyTransformer
  • func With(tags ...string) TagKeyTransformer
  • func Without(tags ...string) TagKeyTransformer
• type TagKeyTransformerFunc
  • func (f TagKeyTransformerFunc) Apply(slice TagKeys) TagKeys
• type TagKeys
  • func (t TagKeys) Transform(transformers ...TagKeyTransformer) TagKeys
• type TagKeysSlice
  • func TagKeySlice(tags []Tags) TagKeysSlice
  • func (t TagKeysSlice) Transform(transformers ...TagKeyTransformer) TagKeysSlice
• type Tags
  • func DistinctTags(tags []Tags) []Tags
  • func TagsFromString(tagsString string) (Tags, error)
  • func (t Tags) Keys() TagKeys
  • func (t Tags) String() string
  • func (t Tags) WithTags(keysAndValues ...string) Tags
  • func (t Tags) WithoutTags(tags ...string) Tags
• type TagsSlice
  • func (t TagsSlice) ToTagKeysSlice() TagKeysSlice
• 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"
)

type Cluster

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

func NewCluster

func NewCluster(opts ...NewClusterOpt) Cluster

func (*Cluster) Hash

func (c *Cluster) Hash() string

func (*Cluster) IsExternalService

func (c *Cluster) IsExternalService() bool

func (*Cluster) LB

func (c *Cluster) LB() *mesh_proto.TrafficRoute_LoadBalancer

func (*Cluster) Name

func (c *Cluster) Name() string

func (*Cluster) Service

func (c *Cluster) Service() string

func (*Cluster) SetName

func (c *Cluster) SetName(name string)

func (*Cluster) Tags

func (c *Cluster) Tags() Tags

func (*Cluster) Timeout

func (c *Cluster) Timeout() *mesh_proto.Timeout_Conf

func (*Cluster) Weight

func (c *Cluster) 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 WithLB

func WithLB(lb *mesh_proto.TrafficRoute_LoadBalancer) NewClusterOpt

func WithName

func WithName(name string) NewClusterOpt

func WithService

func WithService(service string) NewClusterOpt

func WithTags

func WithTags(tags Tags) NewClusterOpt

func WithTimeout

func WithTimeout(timeout *mesh_proto.Timeout_Conf) NewClusterOpt

func WithWeight

func WithWeight(weight uint32) NewClusterOpt

type Route

type Route struct {
	Match     *mesh_proto.TrafficRoute_Http_Match
	Modify    *mesh_proto.TrafficRoute_Http_Modify
	RateLimit *mesh_proto.RateLimit
	Clusters  []Cluster
}

func NewRouteFromCluster

func NewRouteFromCluster(cluster Cluster) Route

type Routes

type Routes []Route

func (Routes) Clusters

func (r Routes) Clusters() (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) Tags

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

type Services

type Services map[string]*Service

func (Services) Add

func (c Services) Add(clusters ...Cluster)

func (Services) Names

func (c Services) Names() []string

type StaticEndpointPath

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

type TagKeyTransformer

type TagKeyTransformer interface {
	Apply(slice TagKeys) TagKeys
}

func With

func With(tags ...string) TagKeyTransformer

func Without

func Without(tags ...string) TagKeyTransformer

type TagKeyTransformerFunc

type TagKeyTransformerFunc func(slice TagKeys) TagKeys

func (TagKeyTransformerFunc) Apply

func (f TagKeyTransformerFunc) Apply(slice TagKeys) TagKeys

type TagKeys

type TagKeys []string

func (TagKeys) Transform

func (t TagKeys) Transform(transformers ...TagKeyTransformer) TagKeys

Transform applies a list of transformers on the tag keys and return a new set of keys (always return sorted, unique sets).

type TagKeysSlice

type TagKeysSlice []TagKeys

func TagKeySlice

func TagKeySlice(tags []Tags) TagKeysSlice

func (TagKeysSlice) Transform

func (t TagKeysSlice) Transform(transformers ...TagKeyTransformer) TagKeysSlice

Transform applies each transformer to each TagKeys and returns a sorted unique TagKeysSlice.

type Tags

type Tags map[string]string

func DistinctTags

func DistinctTags(tags []Tags) []Tags

func TagsFromString

func TagsFromString(tagsString string) (Tags, error)

func (Tags) Keys

func (t Tags) Keys() TagKeys

func (Tags) String

func (t Tags) String() string

func (Tags) WithTags

func (t Tags) WithTags(keysAndValues ...string) Tags

func (Tags) WithoutTags

func (t Tags) WithoutTags(tags ...string) Tags

type TagsSlice

type TagsSlice []Tags

func (TagsSlice) ToTagKeysSlice

func (t TagsSlice) ToTagKeysSlice() TagKeysSlice

type TrafficDirection

type TrafficDirection string

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