xds

package
v0.0.0-...-83c1a15 Latest Latest
Warning

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

Go to latest
Published: Apr 29, 2024 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GatherTargetedClusters

func GatherTargetedClusters(
	outbounds []*mesh_proto.Dataplane_Networking_Outbound,
	outboundSplitClusters map[string][]*envoy_cluster.Cluster,
	outboundClusters map[string]*envoy_cluster.Cluster,
) map[*envoy_cluster.Cluster]string

func InsertHTTPFiltersBeforeRouter

func InsertHTTPFiltersBeforeRouter(manager *envoy_hcm.HttpConnectionManager, newFilters ...*envoy_hcm.HttpFilter) error

Types

type Cluster

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

func (*Cluster) Hash

func (c *Cluster) Hash() string

func (*Cluster) IsExternalService

func (c *Cluster) IsExternalService() bool

func (*Cluster) Mesh

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

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

type ClusterBuilder

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

func NewClusterBuilder

func NewClusterBuilder() *ClusterBuilder

func (*ClusterBuilder) Build

func (b *ClusterBuilder) Build() *Cluster

func (*ClusterBuilder) WithExternalService

func (b *ClusterBuilder) WithExternalService(isExternalService bool) *ClusterBuilder

func (*ClusterBuilder) WithMesh

func (b *ClusterBuilder) WithMesh(mesh string) *ClusterBuilder

func (*ClusterBuilder) WithName

func (b *ClusterBuilder) WithName(name string) *ClusterBuilder

func (*ClusterBuilder) WithService

func (b *ClusterBuilder) WithService(service string) *ClusterBuilder

func (*ClusterBuilder) WithTags

func (b *ClusterBuilder) WithTags(tags tags.Tags) *ClusterBuilder

type Clusters

type Clusters struct {
	Inbound       map[string]*envoy_cluster.Cluster
	Outbound      map[string]*envoy_cluster.Cluster
	OutboundSplit map[string][]*envoy_cluster.Cluster
}

func GatherClusters

func GatherClusters(rs *core_xds.ResourceSet) Clusters

type EndpointMap

func GatherOutboundEndpoints

func GatherOutboundEndpoints(rs *xds.ResourceSet) EndpointMap

type Listeners

type Listeners struct {
	Inbound         map[core_rules.InboundListener]*envoy_listener.Listener
	Outbound        map[mesh_proto.OutboundInterface]*envoy_listener.Listener
	Ipv4Passthrough *envoy_listener.Listener
	Ipv6Passthrough *envoy_listener.Listener
}

func GatherListeners

func GatherListeners(rs *xds.ResourceSet) Listeners

type NewClusterOpt

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

type NewSplitOpt

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

type Split

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

func (*Split) ClusterName

func (s *Split) ClusterName() string

func (*Split) HasExternalService

func (s *Split) HasExternalService() bool

func (*Split) LBMetadata

func (s *Split) LBMetadata() tags.Tags

func (*Split) Weight

func (s *Split) Weight() uint32

type SplitBuilder

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

func NewSplitBuilder

func NewSplitBuilder() *SplitBuilder

func (*SplitBuilder) Build

func (b *SplitBuilder) Build() *Split

func (*SplitBuilder) WithClusterName

func (b *SplitBuilder) WithClusterName(clusterName string) *SplitBuilder

func (*SplitBuilder) WithExternalService

func (b *SplitBuilder) WithExternalService(hasExternalService bool) *SplitBuilder

func (*SplitBuilder) WithWeight

func (b *SplitBuilder) WithWeight(weight uint32) *SplitBuilder

Jump to

Keyboard shortcuts

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