v3

Documentation

Index

• Variables
• func NewRequestLoggingCallbacks(log logrus.FieldLogger) envoy_server_v3.Callbacks
• func RegisterServer(srv Server, g *grpc.Server)
• type Server
  • func NewSesameServer(log logrus.FieldLogger, resources ...xds.Resource) Server
• type SesameServer
  • func (s *SesameServer) StreamClusters(srv envoy_service_cluster_v3.ClusterDiscoveryService_StreamClustersServer) error
  • func (s *SesameServer) StreamEndpoints(srv envoy_service_endpoint_v3.EndpointDiscoveryService_StreamEndpointsServer) error
  • func (s *SesameServer) StreamListeners(srv envoy_service_listener_v3.ListenerDiscoveryService_StreamListenersServer) error
  • func (s *SesameServer) StreamRoutes(srv envoy_service_route_v3.RouteDiscoveryService_StreamRoutesServer) error
  • func (s *SesameServer) StreamSecrets(srv envoy_service_secret_v3.SecretDiscoveryService_StreamSecretsServer) error
• type Snapshotter
  • func NewSnapshotCache(ads bool, logger envoy_log.Logger) Snapshotter

Variables

var Hash = xds.ConstantHashV3{}

Functions

func NewRequestLoggingCallbacks

func NewRequestLoggingCallbacks(log logrus.FieldLogger) envoy_server_v3.Callbacks

NewRequestLoggingCallbacks returns an implementation of the Envoy xDS server callbacks for use when Sesame is run in Envoy xDS server mode to provide request detail logging. Currently only the xDS State of the World callback OnStreamRequest is implemented.

func RegisterServer

func RegisterServer(srv Server, g *grpc.Server)

RegisterServer registers the given xDS protocol Server with the gRPC runtime.

Types

type Server

type Server interface {
	envoy_service_cluster_v3.ClusterDiscoveryServiceServer
	envoy_service_endpoint_v3.EndpointDiscoveryServiceServer
	envoy_service_listener_v3.ListenerDiscoveryServiceServer
	envoy_service_route_v3.RouteDiscoveryServiceServer
	envoy_service_discovery_v3.AggregatedDiscoveryServiceServer
	envoy_service_secret_v3.SecretDiscoveryServiceServer
}

Server is a collection of handlers for streaming discovery requests.

func NewSesameServer

func NewSesameServer(log logrus.FieldLogger, resources ...xds.Resource) Server

NewSesameServer 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.

type SesameServer

type SesameServer struct {
	// Since we only implement the streaming state of the world
	// protocol, embed the default null implementations to handle
	// the unimplemented gRPC endpoints.
	envoy_service_discovery_v3.UnimplementedAggregatedDiscoveryServiceServer
	envoy_service_secret_v3.UnimplementedSecretDiscoveryServiceServer
	envoy_service_route_v3.UnimplementedRouteDiscoveryServiceServer
	envoy_service_endpoint_v3.UnimplementedEndpointDiscoveryServiceServer
	envoy_service_cluster_v3.UnimplementedClusterDiscoveryServiceServer
	envoy_service_listener_v3.UnimplementedListenerDiscoveryServiceServer

	logrus.FieldLogger
	// contains filtered or unexported fields
}

func (*SesameServer) StreamClusters

func (s *SesameServer) StreamClusters(srv envoy_service_cluster_v3.ClusterDiscoveryService_StreamClustersServer) error

func (*SesameServer) StreamEndpoints

func (s *SesameServer) StreamEndpoints(srv envoy_service_endpoint_v3.EndpointDiscoveryService_StreamEndpointsServer) error

func (*SesameServer) StreamListeners

func (s *SesameServer) StreamListeners(srv envoy_service_listener_v3.ListenerDiscoveryService_StreamListenersServer) error

func (*SesameServer) StreamRoutes

func (s *SesameServer) StreamRoutes(srv envoy_service_route_v3.RouteDiscoveryService_StreamRoutesServer) error

func (*SesameServer) StreamSecrets

func (s *SesameServer) StreamSecrets(srv envoy_service_secret_v3.SecretDiscoveryService_StreamSecretsServer) error

type Snapshotter

type Snapshotter interface {
	xdscache.Snapshotter
	envoy_cache_v3.SnapshotCache
}

Snapshotter is a v3 Snapshot cache that implements the xds.Snapshotter interface.

func NewSnapshotCache

func NewSnapshotCache(ads bool, logger envoy_log.Logger) Snapshotter