controlplane

Documentation

Overview

Package controlplane contains the HTTP and gRPC base servers and the xDS gRPC implementation for envoy.

Index

• type Server
  • func NewServer(name string) (*Server, error)
  • func (srv *Server) DeltaAggregatedResources(...) error
  • func (srv *Server) OnConfigChange(cfg *config.Config)
  • func (srv *Server) Run(ctx context.Context) error
  • func (srv *Server) StreamAccessLogs(stream envoy_service_accesslog_v2.AccessLogService_StreamAccessLogsServer) error
  • func (srv *Server) StreamAggregatedResources(...) error

Types

type Server

type Server struct {
	GRPCListener net.Listener
	GRPCServer   *grpc.Server
	HTTPListener net.Listener
	HTTPRouter   *mux.Router
	// contains filtered or unexported fields
}

A Server is the control-plane gRPC and HTTP servers.

func NewServer

func NewServer(name string) (*Server, error)

NewServer creates a new Server. Listener ports are chosen by the OS.

func (*Server) DeltaAggregatedResources

func (srv *Server) DeltaAggregatedResources(in envoy_service_discovery_v3.AggregatedDiscoveryService_DeltaAggregatedResourcesServer) error

DeltaAggregatedResources is not implemented.

func (*Server) OnConfigChange

func (srv *Server) OnConfigChange(cfg *config.Config)

OnConfigChange updates the pomerium config options.

func (*Server) Run

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

Run runs the control-plane gRPC and HTTP servers.

func (*Server) StreamAccessLogs

func (srv *Server) StreamAccessLogs(stream envoy_service_accesslog_v2.AccessLogService_StreamAccessLogsServer) error

StreamAccessLogs receives logs from envoy and prints them to stdout.

func (*Server) StreamAggregatedResources

func (srv *Server) StreamAggregatedResources(stream envoy_service_discovery_v3.AggregatedDiscoveryService_StreamAggregatedResourcesServer) error

StreamAggregatedResources streams xDS resources based on incoming discovery requests.

This is setup as 3 concurrent goroutines:

• The first retrieves the requests from the client.
• The third sends responses back to the client.
• The second waits for either the client to request a new resource type or for the config to have been updated
• in either case, we loop over all of the current client versions and if any of them are different from the current version, we send the updated resource