xds

Aug 14, 2023

Changes in this version

+ const OriginalDestinationClusterName

+ const UnnamedSubset

+ var StatsCounters = []prometheus.CounterDefinition

+ var StatsGauges = []prometheus.GaugeDefinition

+ var StatsSummaries = []prometheus.SummaryDefinition

+ func CustomizeClusterName(clusterName string, chain *structs.CompiledDiscoveryChain) string

+ func ToOutlierDetection(p *structs.PassiveHealthCheck, override *structs.PassiveHealthCheck, ...) *envoy_cluster_v3.OutlierDetection

+ type ADSDeltaStream = envoy_discovery_v3.AggregatedDiscoveryService_DeltaAggregatedResourcesServer

+ type ConfigFetcher interface

+ AdvertiseAddrLAN func() string

+ type GatewayConfig struct

+ BindAddresses map[string]structs.ServiceAddress

+ BindTaggedAddresses bool

+ ConnectTimeoutMs int

+ DNSDiscoveryType string

+ NoDefaultBind bool

+ TcpKeepaliveEnable bool

+ TcpKeepaliveInterval int

+ TcpKeepaliveProbes int

+ TcpKeepaliveTime int

+ func ParseGatewayConfig(m map[string]interface{}) (GatewayConfig, error)

+ type JWTInfo struct

+ Issuer string

+ Provider *structs.IntentionJWTProvider

+ type PendingUpdate struct

+ Remove bool

+ Version string

+ type ProxyConfig struct

+ BalanceInboundConnections string

+ BindAddress string

+ BindPort int

+ ListenerTracingJSON string

+ LocalClusterJSON string

+ LocalConnectTimeoutMs int

+ LocalIdleTimeoutMs *int

+ LocalRequestTimeoutMs *int

+ MaxInboundConnections int

+ Protocol string

+ PublicListenerJSON string

+ func ParseProxyConfig(m map[string]interface{}) (ProxyConfig, error)

+ type ProxyConfigSource interface

+ Watch func(id structs.ServiceID, nodeName string, token string) (<-chan *proxycfg.ConfigSnapshot, limiter.SessionTerminatedChan, ...)

+ type ResourceGenerator struct

+ CfgFetcher ConfigFetcher

+ IncrementalXDS bool

+ Logger hclog.Logger

+ ProxyFeatures xdscommon.SupportedProxyFeatures

+ func NewResourceGenerator(logger hclog.Logger, cfgFetcher ConfigFetcher, incrementalXDS bool) *ResourceGenerator

+ func (g *ResourceGenerator) AllResourcesFromSnapshot(cfgSnap *proxycfg.ConfigSnapshot) (map[string][]proto.Message, error)

type Server

+ CfgFetcher ConfigFetcher

+ CfgSrc ProxyConfigSource

+ NodeName string

+ ResourceMapMutateFn func(resourceMap *xdscommon.IndexedResources)

+ func NewServer(nodeName string, logger hclog.Logger, cfgMgr ProxyConfigSource, ...) *Server

+ func (s *Server) DeltaAggregatedResources(stream ADSDeltaStream) error

+ func (s *Server) Register(srv *grpc.Server)

+ type TestADSDeltaStream struct

+ func NewTestADSDeltaStream(t testing.T, ctx context.Context) *TestADSDeltaStream

+ func (s *TestADSDeltaStream) Context() context.Context

+ func (s *TestADSDeltaStream) Recv() (*envoy_discovery_v3.DeltaDiscoveryRequest, error)

+ func (s *TestADSDeltaStream) RecvMsg(m interface{}) error

+ func (s *TestADSDeltaStream) Send(r *envoy_discovery_v3.DeltaDiscoveryResponse) error

+ func (s *TestADSDeltaStream) SendHeader(metadata.MD) error

+ func (s *TestADSDeltaStream) SendMsg(m interface{}) error

+ func (s *TestADSDeltaStream) SetHeader(metadata.MD) error

+ func (s *TestADSDeltaStream) SetSendErr(err error)

+ func (s *TestADSDeltaStream) SetTrailer(metadata.MD)

type TestEnvoy

+ EnvoyVersion string

+ func (e *TestEnvoy) SendDeltaReq(t testing.T, typeURL string, req *envoy_discovery_v3.DeltaDiscoveryRequest)

+ func (e *TestEnvoy) SendDeltaReqACK(t testing.T, typeURL string, nonce uint64)

+ func (e *TestEnvoy) SendDeltaReqNACK(t testing.T, typeURL string, nonce uint64, errorDetail *status.Status)

+ func (e *TestEnvoy) SetSendErr(err error)

Mar 4, 2019

Changes in this version

+ const DefaultAuthCheckFrequency

type Server

+ AuthCheckFrequency time.Duration

+ func (s *Server) Initialize()

Oct 11, 2018

Changes in this version

+ const ClusterType

+ const EndpointType

+ const ListenerType

+ const LocalAgentClusterName

+ const LocalAppClusterName

+ const PublicListenerName

+ const RouteType

+ func TestCheckRequest(t testing.T, source, dest string) *envoyauth.CheckRequest

+ type ACLResolverFunc func(id string) (acl.ACL, error)

+ type ADSStream = envoydisco.AggregatedDiscoveryService_StreamAggregatedResourcesServer

+ type ConfigManager interface

+ Watch func(proxyID string) (<-chan *proxycfg.ConfigSnapshot, proxycfg.CancelFunc)

+ type ConnectAuthz interface

+ ConnectAuthorize func(token string, req *structs.ConnectAuthorizeRequest) (authz bool, reason string, m *cache.ResultMeta, err error)

+ type Server struct

+ Authz ConnectAuthz

+ CfgMgr ConfigManager

+ Logger *log.Logger

+ ResolveToken ACLResolverFunc

+ func (s *Server) Check(ctx context.Context, r *envoyauthz.CheckRequest) (*envoyauthz.CheckResponse, error)

+ func (s *Server) GRPCServer(certFile, keyFile string) (*grpc.Server, error)

+ func (s *Server) IncrementalAggregatedResources(_ envoydisco.AggregatedDiscoveryService_IncrementalAggregatedResourcesServer) error

+ func (s *Server) StreamAggregatedResources(stream ADSStream) error

+ type TestADSStream struct

+ func NewTestADSStream(t testing.T, ctx context.Context) *TestADSStream

+ func (s *TestADSStream) Context() context.Context

+ func (s *TestADSStream) Recv() (*envoy.DiscoveryRequest, error)

+ func (s *TestADSStream) RecvMsg(m interface{}) error

+ func (s *TestADSStream) Send(r *envoy.DiscoveryResponse) error

+ func (s *TestADSStream) SendHeader(metadata.MD) error

+ func (s *TestADSStream) SendMsg(m interface{}) error

+ func (s *TestADSStream) SetHeader(metadata.MD) error

+ func (s *TestADSStream) SetTrailer(metadata.MD)

+ type TestEnvoy struct

+ func NewTestEnvoy(t testing.T, proxyID, token string) *TestEnvoy

+ func (e *TestEnvoy) Close() error

+ func (e *TestEnvoy) SendReq(t testing.T, typeURL string, version, nonce uint64)