envoy

Documentation

Index

• Constants
• func GetMixerSAN(ns string) string
• func GetPilotSAN(ns string) string
• func NewProxy(config meshconfig.ProxyConfig, node string, logLevel string, pilotSAN []string, ...) proxy.Proxy
• type DiscoveryService
  • func NewDiscoveryService(environment *model.Environment, o DiscoveryServiceOptions) (*DiscoveryService, error)
  • func (ds *DiscoveryService) ListAllEndpoints(_ *restful.Request, response *restful.Response)
  • func (ds *DiscoveryService) Register(container *restful.Container)
• type DiscoveryServiceOptions
• type Watcher
  • func NewWatcher(certs []string, updates chan<- interface{}) Watcher

Constants

const (
	// EpochFileTemplate is a template for the root config JSON
	EpochFileTemplate = "envoy-rev%d.json"
)

Functions

func GetMixerSAN

func GetMixerSAN(ns string) string

GetMixerSAN returns the SAN used for mixer mTLS

func GetPilotSAN

func GetPilotSAN(ns string) string

GetPilotSAN returns the SAN used for pilot mTLS

func NewProxy

func NewProxy(config meshconfig.ProxyConfig, node string, logLevel string, pilotSAN []string, nodeIPs []string) proxy.Proxy

NewProxy creates an instance of the proxy control commands

Types

type DiscoveryService

type DiscoveryService struct {
	*model.Environment
	RestContainer *restful.Container
}

DiscoveryService publishes services, clusters, and routes for all proxies

func NewDiscoveryService

func NewDiscoveryService(environment *model.Environment, o DiscoveryServiceOptions) (*DiscoveryService, error)

NewDiscoveryService creates an Envoy discovery service on a given port

func (*DiscoveryService) ListAllEndpoints

func (ds *DiscoveryService) ListAllEndpoints(_ *restful.Request, response *restful.Response)

ListAllEndpoints responds with all Services and is not restricted to a single service-key Deprecated - may be used by debug tools, mapped to /v1/registration

func (*DiscoveryService) Register

func (ds *DiscoveryService) Register(container *restful.Container)

Register adds routes a web service container. This is visible for testing purposes only.

type DiscoveryServiceOptions

type DiscoveryServiceOptions struct {
	// The listening address for HTTP. If the port in the address is empty or "0" (as in "127.0.0.1:" or "[::1]:0")
	// a port number is automatically chosen.
	HTTPAddr string

	// The listening address for GRPC. If the port in the address is empty or "0" (as in "127.0.0.1:" or "[::1]:0")
	// a port number is automatically chosen.
	GrpcAddr string

	// The listening address for secure GRPC. If the port in the address is empty or "0" (as in "127.0.0.1:" or "[::1]:0")
	// a port number is automatically chosen.
	// "" means disabling secure GRPC, used in test.
	SecureGrpcAddr string

	// The listening address for the monitoring port. If the port in the address is empty or "0" (as in "127.0.0.1:" or "[::1]:0")
	// a port number is automatically chosen.
	MonitoringAddr string

	EnableProfiling bool
	EnableCaching   bool
}

DiscoveryServiceOptions contains options for create a new discovery service instance.

type Watcher

type Watcher interface {
	// Run the watcher loop (blocking call)
	Run(context.Context)
}

Watcher triggers reloads on changes to the proxy config

func NewWatcher

func NewWatcher(
	certs []string,
	updates chan<- interface{}) Watcher

NewWatcher creates a new watcher instance from a proxy agent and a set of monitored certificate file paths