envoy

package
v1.8.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 5, 2022 License: Apache-2.0 Imports: 267 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AccessLogSocketName 

func AccessLogSocketName(name, mesh string) string

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

func MetricsHijackerSocketName 

func MetricsHijackerSocketName(name, mesh string) string

MetricsHijackerSocketName generates a socket path that will fit the Unix socket path limitation of 104 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) Mesh added in v1.8.1 

func (c *Cluster) Mesh() string

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

func (*Cluster) Name 

func (c *Cluster) Name() string

func (*Cluster) Service 

func (c *Cluster) Service() string

func (*Cluster) SetMesh added in v1.8.1 

func (c *Cluster) SetMesh(mesh 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 NewRouteOpt added in v1.8.1 

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

func WithCluster added in v1.8.1 

func WithCluster(cluster Cluster) NewRouteOpt

func WithMatchHeaderRegex added in v1.8.1 

func WithMatchHeaderRegex(name, regex string) NewRouteOpt

func WithRateLimit added in v1.8.1 

func WithRateLimit(rl *mesh_proto.RateLimit) NewRouteOpt

type Route 

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

func NewRoute added in v1.8.1 

func NewRoute(opts ...NewRouteOpt) Route

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) TLSReady added in v1.8.1 

func (c *Service) TLSReady() bool

func (*Service) Tags 

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

type Services 

type Services map[string]*Service

func (Services) Sorted added in v1.8.1 

func (c Services) Sorted() []string

type ServicesAccumulator added in v1.8.1 

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

func NewServicesAccumulator added in v1.8.1 

func NewServicesAccumulator(tlsReadiness map[string]bool) ServicesAccumulator

func (ServicesAccumulator) Add added in v1.8.1 

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

func (ServicesAccumulator) Services added in v1.8.1 

func (sa ServicesAccumulator) Services() Services

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"
)

Source Files

View all Source files

Directories

Path Synopsis
v3
v3
v3
v3/compatibility/v3alpha
metadata
v3
v3
secrets
v3
tls
v3

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.