controlplane

Documentation

Overview

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

Index

• type Server
  • func NewServer(cfg *config.Config, metricsMgr *config.MetricsManager, ...) (*Server, error)
  • func (srv *Server) EnableAuthenticate(svc Service) error
  • func (srv *Server) EnableProxy(svc Service) error
  • func (srv *Server) OnConfigChange(ctx context.Context, cfg *config.Config) error
  • func (srv *Server) Run(ctx context.Context) error
  • func (srv *Server) StreamAccessLogs(stream envoy_service_accesslog_v3.AccessLogService_StreamAccessLogsServer) error
• type Service

Types

type Server

type Server struct {
	GRPCListener    net.Listener
	GRPCServer      *grpc.Server
	HTTPListener    net.Listener
	MetricsListener net.Listener
	MetricsRouter   *mux.Router
	DebugListener   net.Listener
	DebugRouter     *mux.Router
	Builder         *envoyconfig.Builder
	EventsMgr       *events.Manager
	// contains filtered or unexported fields
}

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

func NewServer

func NewServer(cfg *config.Config, metricsMgr *config.MetricsManager, eventsMgr *events.Manager) (*Server, error)

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

func (*Server) EnableAuthenticate

func (srv *Server) EnableAuthenticate(svc Service) error

EnableAuthenticate enables the authenticate service.

func (*Server) EnableProxy

func (srv *Server) EnableProxy(svc Service) error

EnableProxy enables the proxy service.

func (*Server) OnConfigChange

func (srv *Server) OnConfigChange(ctx context.Context, cfg *config.Config) error

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_v3.AccessLogService_StreamAccessLogsServer) error

StreamAccessLogs receives logs from envoy and prints them to stdout.

type Service

type Service interface {
	Mount(r *mux.Router)
}

A Service can be mounted on the control plane.