adss

Documentation

Index

• type DeltaDiscoveryStream
• type DiscoveryStream
• type RequestHandler
• type Server
  • func NewServer(opts *ServerOpts, pushRequests <-chan xds.PushRequest, onNewSubscriber func(), ...) *Server
  • func (s *Server) Run(ctx context.Context) error
• type ServerOpts

Types

type DeltaDiscoveryStream

type DeltaDiscoveryStream = discovery.AggregatedDiscoveryService_DeltaAggregatedResourcesServer

DeltaDiscoveryStream is a server interface for XDS. DeltaDiscoveryStream is a server interface for Delta XDS.

type DiscoveryStream

type DiscoveryStream = discovery.AggregatedDiscoveryService_StreamAggregatedResourcesServer

DeltaDiscoveryStream is a server interface for XDS. DeltaDiscoveryStream is a server interface for Delta XDS.

type RequestHandler

type RequestHandler interface {
	// GetTypeUrl returns supported XDS type.
	// An implementation can support only one XDS type.
	GetTypeUrl() string
	// GenerateResponse returns generated resources for requested XDS type.
	GenerateResponse() ([]*anypb.Any, error)
}

RequestHandler generates XDS response for requests from subscribers or push requests triggered by other events.

type Server

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

func NewServer

func NewServer(opts *ServerOpts, pushRequests <-chan xds.PushRequest, onNewSubscriber func(), handlers ...RequestHandler) *Server

func (*Server) Run

func (s *Server) Run(ctx context.Context) error

Run starts the gRPC server and the controllers.

type ServerOpts

type ServerOpts struct {
	Port     int32
	ServerID string
}