ads

Documentation

Overview

Package ads implements Envoy's Aggregated Discovery Service (ADS).

Index

• Constants
• type Server
  • func NewADSServer(meshCatalog catalog.MeshCataloger, proxyRegistry *registry.ProxyRegistry, ...) *Server
  • func (s *Server) DeltaAggregatedResources(xds_discovery.AggregatedDiscoveryService_DeltaAggregatedResourcesServer) error
  • func (s *Server) GetID() string
  • func (s *Server) GetXDSLog() *map[certificate.CommonName]map[envoy.TypeURI][]time.Time
  • func (s *Server) Liveness() bool
  • func (s *Server) Readiness() bool
  • func (s *Server) Start(ctx context.Context, cancel context.CancelFunc, port int, ...) error
  • func (s *Server) StreamAggregatedResources(...) error

Constants

const (
	// MaxXdsLogsPerProxy keeps a higher bound of how many timestamps do we keep per proxy
	MaxXdsLogsPerProxy = 20
)

const (
	// ServerType is the type identifier for the ADS server
	ServerType = "ADS"
)

Types

type Server

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

Server implements the Envoy xDS Aggregate Discovery Services

func NewADSServer

func NewADSServer(meshCatalog catalog.MeshCataloger, proxyRegistry *registry.ProxyRegistry, enableDebug bool, osmNamespace string, cfg configurator.Configurator, certManager certificate.Manager) *Server

NewADSServer creates a new Aggregated Discovery Service server

func (*Server) DeltaAggregatedResources

func (s *Server) DeltaAggregatedResources(xds_discovery.AggregatedDiscoveryService_DeltaAggregatedResourcesServer) error

DeltaAggregatedResources implements discovery.AggregatedDiscoveryServiceServer

func (*Server) GetID

func (s *Server) GetID() string

GetID returns the ID of the probe

func (*Server) GetXDSLog

func (s *Server) GetXDSLog() *map[certificate.CommonName]map[envoy.TypeURI][]time.Time

GetXDSLog implements XDSDebugger interface and a log of the XDS responses sent to Envoy proxies.

func (*Server) Liveness

func (s *Server) Liveness() bool

Liveness is the Kubernetes liveness probe handler.

func (*Server) Readiness

func (s *Server) Readiness() bool

Readiness is the Kubernetes readiness probe handler.

func (*Server) Start

func (s *Server) Start(ctx context.Context, cancel context.CancelFunc, port int, adsCert certificate.Certificater) error

Start starts the ADS server

func (*Server) StreamAggregatedResources

func (s *Server) StreamAggregatedResources(server xds_discovery.AggregatedDiscoveryService_StreamAggregatedResourcesServer) error

StreamAggregatedResources handles streaming of the clusters to the connected Envoy proxies This is evaluated once per new Envoy proxy connecting and remains running for the duration of the gRPC socket.