server

Documentation

Index

• func InitServerDeps()
• func IsValidSubscriber(req *v2.DiscoveryRequest) bool
• type Server
  • func (s *Server) BiDiStreamFor(xdsType string, stream service.XDSStreamServer) error
  • func (s *Server) FetchClusters(ctx context.Context, in *v2.DiscoveryRequest) (*v2.DiscoveryResponse, error)
  • func (s *Server) FetchEndpoints(ctx context.Context, in *v2.DiscoveryRequest) (*v2.DiscoveryResponse, error)
  • func (s *Server) FetchListeners(context.Context, *v2.DiscoveryRequest) (*v2.DiscoveryResponse, error)
  • func (s *Server) FetchRoutes(context.Context, *v2.DiscoveryRequest) (*v2.DiscoveryResponse, error)
  • func (s *Server) IncrementalAggregatedResources(_ discovery.AggregatedDiscoveryService_IncrementalAggregatedResourcesServer) error
  • func (s *Server) IncrementalClusters(_ v2.ClusterDiscoveryService_IncrementalClustersServer) error
  • func (s *Server) IncrementalRoutes(v2.RouteDiscoveryService_IncrementalRoutesServer) error
  • func (s *Server) StreamAggregatedResources(stream discovery.AggregatedDiscoveryService_StreamAggregatedResourcesServer) error
  • func (s *Server) StreamClusters(stream v2.ClusterDiscoveryService_StreamClustersServer) error
  • func (s *Server) StreamEndpoints(stream v2.EndpointDiscoveryService_StreamEndpointsServer) error
  • func (s *Server) StreamListeners(stream v2.ListenerDiscoveryService_StreamListenersServer) error
  • func (s *Server) StreamRoutes(stream v2.RouteDiscoveryService_StreamRoutesServer) error

Functions

func InitServerDeps

func InitServerDeps()

func IsValidSubscriber

func IsValidSubscriber(req *v2.DiscoveryRequest) bool

Types

type Server

type Server struct{}

Server struct will impl CDS, LDS, RDS & ADS

func (*Server) BiDiStreamFor

func (s *Server) BiDiStreamFor(xdsType string, stream service.XDSStreamServer) error

BiDiStreamFor common bi-directional stream impl for cds,lds,rds

func (*Server) FetchClusters

func (s *Server) FetchClusters(ctx context.Context, in *v2.DiscoveryRequest) (*v2.DiscoveryResponse, error)

func (*Server) FetchEndpoints

func (s *Server) FetchEndpoints(ctx context.Context, in *v2.DiscoveryRequest) (*v2.DiscoveryResponse, error)

func (*Server) FetchListeners

func (s *Server) FetchListeners(context.Context, *v2.DiscoveryRequest) (*v2.DiscoveryResponse, error)

func (*Server) FetchRoutes

func (s *Server) FetchRoutes(context.Context, *v2.DiscoveryRequest) (*v2.DiscoveryResponse, error)

func (*Server) IncrementalAggregatedResources

func (s *Server) IncrementalAggregatedResources(_ discovery.AggregatedDiscoveryService_IncrementalAggregatedResourcesServer) error

IncrementalAggregatedResources - Not implemented

func (*Server) IncrementalClusters

func (s *Server) IncrementalClusters(_ v2.ClusterDiscoveryService_IncrementalClustersServer) error

func (*Server) IncrementalRoutes

func (s *Server) IncrementalRoutes(v2.RouteDiscoveryService_IncrementalRoutesServer) error

func (*Server) StreamAggregatedResources

func (s *Server) StreamAggregatedResources(stream discovery.AggregatedDiscoveryService_StreamAggregatedResourcesServer) error

StreamAggregatedResources - ADS server impl

func (*Server) StreamClusters

func (s *Server) StreamClusters(stream v2.ClusterDiscoveryService_StreamClustersServer) error

StreamClusters bi directional stream to update cluster config

func (*Server) StreamEndpoints

func (s *Server) StreamEndpoints(stream v2.EndpointDiscoveryService_StreamEndpointsServer) error

StreamClusters bi directional stream to update endpoints config

func (*Server) StreamListeners

func (s *Server) StreamListeners(stream v2.ListenerDiscoveryService_StreamListenersServer) error

func (*Server) StreamRoutes

func (s *Server) StreamRoutes(stream v2.RouteDiscoveryService_StreamRoutesServer) error