xds

Documentation

Index

• func RegisterServer(srv Server, registry *prometheus.Registry, opts ...grpc.ServerOption) *grpc.Server
• type Resource
• type Server
  • func NewContourServer(log logrus.FieldLogger, resources ...Resource) Server

Functions

func RegisterServer

func RegisterServer(srv Server, registry *prometheus.Registry, opts ...grpc.ServerOption) *grpc.Server

RegisterServer registers the given xDS protocol Server with the gRPC runtime. If registry is non-nil gRPC server metrics will be automatically configured and enabled.

Types

type Resource

type Resource interface {
	// Contents returns the contents of this resource.
	Contents() []proto.Message

	// Query returns an entry for each resource name supplied.
	Query(names []string) []proto.Message

	// Register registers ch to receive a value when Notify is called.
	Register(chan int, int, ...string)

	// TypeURL returns the typeURL of messages returned from Values.
	TypeURL() string
}

Resource represents a source of proto.Messages that can be registered for interest.

type Server

type Server interface {
	clusterservice.ClusterDiscoveryServiceServer
	discovery.AggregatedDiscoveryServiceServer
	discovery.SecretDiscoveryServiceServer
	endpointservice.EndpointDiscoveryServiceServer
	listenerservice.ListenerDiscoveryServiceServer
	routeservice.RouteDiscoveryServiceServer
}

Server is a collection of handlers for streaming discovery requests.

func NewContourServer

func NewContourServer(log logrus.FieldLogger, resources ...Resource) Server

NewContourServer creates an internally implemented Server that streams the provided set of Resource objects. The returned Server implements the xDS State of the World (SotW) variant.