ads

Documentation

Index

• Constants
• type Server
  • func NewADSServer(meshCatalog catalog.MeshCataloger, enableDebug bool, osmNamespace string, ...) *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 ServerType = "ADS"

ServerType is the type identifier for the ADS server

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, enableDebug bool, osmNamespace string, cfg configurator.Configurator) *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