Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

xds

package

Go to main page

Versions in this module

v1

v1.16.4

Nov 29, 2024

v0

v0.16.4

Nov 29, 2024

Changes in this version

+ const DefaultAuthCheckFrequency

+ const LocalAgentClusterName

+ const OriginalDestinationClusterName

+ const UnnamedSubset

+ var StatsCounters = []prometheus.CounterDefinition

+ var StatsGauges = []prometheus.GaugeDefinition

+ var StatsSummaries = []prometheus.SummaryDefinition

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

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

+ type ADSDeltaStream = envoy_discovery_v3.AggregatedDiscoveryService_DeltaAggregatedResourcesServer

+ type ADSStream = envoy_discovery_v3.AggregatedDiscoveryService_StreamAggregatedResourcesServer

+ type ConfigFetcher interface

+ AdvertiseAddrLAN func() string

+ type JWTInfo struct

+ Issuer string

+ Provider *structs.IntentionJWTProvider

+ type PendingUpdate struct

+ Remove bool

+ Version string

+ 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 struct

+ AuthCheckFrequency time.Duration

+ CfgFetcher ConfigFetcher

+ CfgSrc ProxyConfigSource

+ Logger hclog.Logger

+ NodeName string

+ ResolveToken ACLResolverFunc

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

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

+ 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 struct

+ EnvoyVersion string

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

+ func (e *TestEnvoy) Close() error

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