discoveryservice

Documentation

Index

• type DualXdsServer
  • func NewDualXdsServer(ctx context.Context, xDSPort uint, tlsConfig *tls.Config, logger logr.Logger) *DualXdsServer
  • func (xdss *DualXdsServer) GetCache(version envoy.APIVersion) xdss.Cache
  • func (xdss *DualXdsServer) GetDiscoveryStats(version envoy.APIVersion) *stats.Stats
  • func (xdss *DualXdsServer) Start(stopCh <-chan struct{}) error
• type Manager
  • func (dsm *Manager) Start(ctx context.Context)
• type XdsServer

Types

type DualXdsServer

type DualXdsServer struct {
	// contains filtered or unexported fields
}

DualXdsServer is a type that holds configuration and runtime objects for the envoy xds server

func NewDualXdsServer

func NewDualXdsServer(ctx context.Context, xDSPort uint, tlsConfig *tls.Config, logger logr.Logger) *DualXdsServer

NewDualXdsServer creates a new DualXdsServer object fron the given params

func (*DualXdsServer) GetCache

func (xdss *DualXdsServer) GetCache(version envoy.APIVersion) xdss.Cache

GetCache returns the Cache

func (*DualXdsServer) GetDiscoveryStats

func (xdss *DualXdsServer) GetDiscoveryStats(version envoy.APIVersion) *stats.Stats

GetCache returns the discovery stats

func (*DualXdsServer) Start

func (xdss *DualXdsServer) Start(stopCh <-chan struct{}) error

Start starts an xDS server at the given port.

type Manager

type Manager struct {
	// The namespace to watch for EnvoyConfig resources
	Namespace string
	// The xDS server port
	XdsServerPort int
	// The mutating webhook server port
	MetricsAddr string
	// The directory where server certificate and key are located
	ServerCertificatePath string
	// The directory where the CA used to authenticate clients with the xDS server is
	CACertificatePath string
	// Cfg is the config to connect to the k8s API server
	Cfg *rest.Config
}

Manager holds configuration to run a marin3r discovery service

func (*Manager) Start

func (dsm *Manager) Start(ctx context.Context)

Start runs the DiscoveryServiceManager, which runs the EnvoyConfig and EnvoyConfigRevision controller, the xDS server and the mutating webhook server

type XdsServer

type XdsServer interface {
	Start(<-chan struct{}) error
	GetCache(envoy.APIVersion) xdss.Cache
}

XdsServer in an interface that any xDS server should implement