endpoints

Documentation

Index

• Variables
• func ExtractEnvoyEndpoints(locEps []*LocalityEndpoints) []*endpoint.LocalityLbEndpoints
• type EndpointBuilder
  • func NewCDSEndpointBuilder(proxy *model.Proxy, push *model.PushContext, clusterName string, ...) *EndpointBuilder
  • func NewEndpointBuilder(clusterName string, proxy *model.Proxy, push *model.PushContext) EndpointBuilder
  • func (b *EndpointBuilder) BuildClusterLoadAssignment(endpointIndex *model.EndpointIndex) *endpoint.ClusterLoadAssignment
  • func (b *EndpointBuilder) Cacheable() bool
  • func (b *EndpointBuilder) DependentConfigs() []model.ConfigHash
  • func (b *EndpointBuilder) DestinationRule() *v1alpha3.DestinationRule
  • func (b *EndpointBuilder) EndpointsByNetworkFilter(endpoints []*LocalityEndpoints) []*LocalityEndpoints
  • func (b *EndpointBuilder) EndpointsWithMTLSFilter(endpoints []*LocalityEndpoints) []*LocalityEndpoints
  • func (b *EndpointBuilder) FromServiceEndpoints() []*endpoint.LocalityLbEndpoints
  • func (b *EndpointBuilder) IsDNSCluster() bool
  • func (b *EndpointBuilder) Key() any
  • func (b *EndpointBuilder) ServiceFound() bool
  • func (b *EndpointBuilder) Type() string
  • func (b *EndpointBuilder) WithSubset(subset string) *EndpointBuilder
  • func (b *EndpointBuilder) WriteHash(h hash.Hash)
• type LocalityEndpoints
  • func (e *LocalityEndpoints) AssertInvarianceInTest()

Variables

var (
	Separator = []byte{'~'}
	Slash     = []byte{'/'}
)

Functions

func ExtractEnvoyEndpoints

func ExtractEnvoyEndpoints(locEps []*LocalityEndpoints) []*endpoint.LocalityLbEndpoints

Types

type EndpointBuilder

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

func NewCDSEndpointBuilder

func NewCDSEndpointBuilder(
	proxy *model.Proxy, push *model.PushContext, clusterName string,
	dir model.TrafficDirection, subsetName string, hostname host.Name, port int,
	service *model.Service, dr *model.ConsolidatedDestRule,
) *EndpointBuilder

NewCDSEndpointBuilder allows setting some fields directly when we already have the Service and DestinationRule.

func NewEndpointBuilder

func NewEndpointBuilder(clusterName string, proxy *model.Proxy, push *model.PushContext) EndpointBuilder

func (*EndpointBuilder) BuildClusterLoadAssignment

func (b *EndpointBuilder) BuildClusterLoadAssignment(endpointIndex *model.EndpointIndex) *endpoint.ClusterLoadAssignment

BuildClusterLoadAssignment converts the shards for this EndpointBuilder's Service into a ClusterLoadAssignment. Used for EDS.

func (*EndpointBuilder) Cacheable

func (b *EndpointBuilder) Cacheable() bool

func (*EndpointBuilder) DependentConfigs

func (b *EndpointBuilder) DependentConfigs() []model.ConfigHash

func (*EndpointBuilder) DestinationRule

func (b *EndpointBuilder) DestinationRule() *v1alpha3.DestinationRule

func (*EndpointBuilder) EndpointsByNetworkFilter

func (b *EndpointBuilder) EndpointsByNetworkFilter(endpoints []*LocalityEndpoints) []*LocalityEndpoints

EndpointsByNetworkFilter is a network filter function to support Split Horizon EDS - filter the endpoints based on the network of the connected sidecar. The filter will filter out all endpoints which are not present within the sidecar network and add a gateway endpoint to remote networks that have endpoints (if gateway exists and its IP is an IP and not a dns name). Information for the mesh networks is provided as a MeshNetwork config map.

func (*EndpointBuilder) EndpointsWithMTLSFilter

func (b *EndpointBuilder) EndpointsWithMTLSFilter(endpoints []*LocalityEndpoints) []*LocalityEndpoints

EndpointsWithMTLSFilter removes all endpoints that do not handle mTLS. This is determined by looking at auto-mTLS, DestinationRule, and PeerAuthentication to determine if we would send mTLS to these endpoints. Note there is no guarantee these destinations *actually* handle mTLS; just that we are configured to send mTLS to them.

func (*EndpointBuilder) FromServiceEndpoints

func (b *EndpointBuilder) FromServiceEndpoints() []*endpoint.LocalityLbEndpoints

FromServiceEndpoints builds LocalityLbEndpoints from the PushContext's snapshotted ServiceIndex. Used for CDS (ClusterLoadAssignment constructed elsewhere).

func (*EndpointBuilder) IsDNSCluster

func (b *EndpointBuilder) IsDNSCluster() bool

func (*EndpointBuilder) Key

func (b *EndpointBuilder) Key() any

Key provides the eds cache key and should include any information that could change the way endpoints are generated.

func (*EndpointBuilder) ServiceFound

func (b *EndpointBuilder) ServiceFound() bool

func (*EndpointBuilder) Type

func (b *EndpointBuilder) Type() string

func (*EndpointBuilder) WithSubset

func (b *EndpointBuilder) WithSubset(subset string) *EndpointBuilder

func (*EndpointBuilder) WriteHash

func (b *EndpointBuilder) WriteHash(h hash.Hash)

type LocalityEndpoints

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

func (*LocalityEndpoints) AssertInvarianceInTest

func (e *LocalityEndpoints) AssertInvarianceInTest()