envoy

package
v0.0.0-...-ad79e7e Latest Latest
Warning

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

Go to latest
Published: Apr 21, 2024 License: Apache-2.0 Imports: 376 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 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 deprecated

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

Deprecated: for new policies use pkg/plugins/policies/xds/cluster.go

func NewCluster deprecated

func NewCluster(opts ...NewClusterOpt) *ClusterImpl

Deprecated: for new policies use pkg/plugins/policies/xds/cluster.go

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

Directories

Path Synopsis
v3
v3
v3
metadata
v3
v3

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL