xds

Documentation

Index

• func GatherTargetedClusters(outbounds []*mesh_proto.Dataplane_Networking_Outbound, ...) map[*envoy_cluster.Cluster]string
• func InsertHTTPFiltersBeforeRouter(manager *envoy_hcm.HttpConnectionManager, newFilters ...*envoy_hcm.HttpFilter) error
• type Cluster
  • func (c *Cluster) Hash() string
  • func (c *Cluster) IsExternalService() bool
  • func (c *Cluster) Mesh() string
  • func (c *Cluster) Name() string
  • func (c *Cluster) Service() string
  • func (c *Cluster) Tags() tags.Tags
• type ClusterBuilder
  • func NewClusterBuilder() *ClusterBuilder
  • func (b *ClusterBuilder) Build() *Cluster
  • func (b *ClusterBuilder) WithExternalService(isExternalService bool) *ClusterBuilder
  • func (b *ClusterBuilder) WithMesh(mesh string) *ClusterBuilder
  • func (b *ClusterBuilder) WithName(name string) *ClusterBuilder
  • func (b *ClusterBuilder) WithService(service string) *ClusterBuilder
  • func (b *ClusterBuilder) WithTags(tags tags.Tags) *ClusterBuilder
• type Clusters
  • func GatherClusters(rs *core_xds.ResourceSet) Clusters
• type EndpointMap
  • func GatherOutboundEndpoints(rs *xds.ResourceSet) EndpointMap
• type Listeners
  • func GatherListeners(rs *xds.ResourceSet) Listeners
• type NewClusterOpt
• type NewSplitOpt
• type Split
  • func (s *Split) ClusterName() string
  • func (s *Split) HasExternalService() bool
  • func (s *Split) LBMetadata() tags.Tags
  • func (s *Split) Weight() uint32
• type SplitBuilder
  • func NewSplitBuilder() *SplitBuilder
  • func (b *SplitBuilder) Build() *Split
  • func (b *SplitBuilder) WithClusterName(clusterName string) *SplitBuilder
  • func (b *SplitBuilder) WithExternalService(hasExternalService bool) *SplitBuilder
  • func (b *SplitBuilder) WithWeight(weight uint32) *SplitBuilder

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

type EndpointMap map[xds.ServiceName][]*endpointv3.ClusterLoadAssignment

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