envoy

Documentation

Index

• Constants
• func GetSAN(ns string, identity 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 (
	// Service accounts for Mixer and Pilot, these are hardcoded values at setup time
	PilotSvcAccName string = "istio-pilot-service-account"

	MixerSvcAccName string = "istio-mixer-service-account"
)

Functions

func GetSAN

func GetSAN(ns string, identity 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