ads

Documentation

Index

• type Server
  • func NewADSServer(ctx context.Context, meshCatalog catalog.MeshCataloger, meshSpec smi.MeshSpec, ...) *Server
  • func (s *Server) DeltaAggregatedResources(server xds_discovery.AggregatedDiscoveryService_DeltaAggregatedResourcesServer) error
  • 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) StreamAggregatedResources(...) error

Types

type Server

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

Server implements the Envoy xDS Aggregate Discovery Services

func NewADSServer

func NewADSServer(ctx context.Context, meshCatalog catalog.MeshCataloger, meshSpec smi.MeshSpec, enableDebug bool, osmNamespace string, cfg configurator.Configurator) *Server

NewADSServer creates a new Aggregated Discovery Service server

func (*Server) DeltaAggregatedResources

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

DeltaAggregatedResources implements discovery.AggregatedDiscoveryServiceServer

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

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

StreamAggregatedResources handles streaming of the clusters to the connected Envoy proxies