discovery

Documentation

Index

• type Server
  • func NewServer(l net.Listener, reg registry.Cache, ctl *config.Controller, ...) *Server
  • func (s *Server) Serve() error
  • func (s *Server) Stop()
  • func (s *Server) StreamDependencies(req *api.DependencyDiscoveryRequest, ...) (err error)
  • func (s *Server) StreamSvcConfigs(stream api.DiscoveryService_StreamSvcConfigsServer) (err error)
  • func (s *Server) StreamSvcEndpoints(stream api.DiscoveryService_StreamSvcEndpointsServer) (err error)
• type ServerOption

Types

type Server

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

Server is an implementation of api.DiscoveryServiceServer.

func NewServer

func NewServer(l net.Listener, reg registry.Cache, ctl *config.Controller, opts ...ServerOption) *Server

NewServer creates a discovery server.

func (*Server) Serve

func (s *Server) Serve() error

func (*Server) Stop

func (s *Server) Stop()

Stop stops the server.

func (*Server) StreamDependencies

func (s *Server) StreamDependencies(req *api.DependencyDiscoveryRequest, stream api.DiscoveryService_StreamDependenciesServer) (err error)

StreamDependencies returns all dependencies of the given instance.

func (*Server) StreamSvcConfigs

func (s *Server) StreamSvcConfigs(stream api.DiscoveryService_StreamSvcConfigsServer) (err error)

StreamSvcConfigs receives a stream of service subscription/unsubscription, and responds with a stream of the updated service configs.

func (*Server) StreamSvcEndpoints

func (s *Server) StreamSvcEndpoints(stream api.DiscoveryService_StreamSvcEndpointsServer) (err error)

StreamSvcEndpoints receives a stream of service subscription/unsubscription, and responds with a stream of the changed service endpoints.

type ServerOption

type ServerOption func(o *serverOptions)