control_plane

Documentation

Index

• Constants
• Variables
• func GenerateSnapshot() *cache.Snapshot
• func NewControlPlane(logger chassis.Logger) *controlPlane
• type ControlPlane
• type Rpc
  • func NewRPC(logger chassis.Logger, cp *controlPlane) Rpc
• type XDSRpc
  • func NewXDSRpc(logger chassis.Logger, cp *controlPlane) XDSRpc

Constants

const (
	// default listener values if key is not set in the `config.yaml` file when the service is run
	LISTENER_DEFAULT_NAME    = "listener_0"
	LISTENER_DEFAULT_ADDRESS = "0.0.0.0"
	LISTENER_DEFAULT_PORT    = 80
	// config keys
	LISTENER_ADDRESS_CONFIG_KEY = "fuse.listener.address"
	LISTENER_PORT_CONFIG_KEY    = "fuse.listener.port"

	DEFAULT_ROUTE_CONFIG_NAME = "route_config"
)

Variables

var (
	ErrFailedRouteMarshal = errors.New("failed to marshal route")
	ErrUnableToSaveRoute  = errors.New("unable to save route in the key/value store")
)

var (
	AddingRoute = "Add route request received"
	// Errors
	ErrNotImplemented           = errors.New("not implemented")
	ErrInvalidRequest           = errors.New("invalid request")
	ErrInvalidRoute             = errors.New("invalid route")
	ErrInvalidRoutePrefix       = errors.New("invalid route prefix")
	ErrInvalidRouteName         = errors.New("invalid route name")
	ErrUnableToUpdateProxyCache = errors.New("unable to update proxy cache")
)

Functions

func GenerateSnapshot

func GenerateSnapshot() *cache.Snapshot

`GenerateSnapshot` creates a snapshot with a cluster. This is only used to start the control plane.

func NewControlPlane

func NewControlPlane(logger chassis.Logger) *controlPlane

Types

type ControlPlane

type ControlPlane interface {
	cache.SnapshotCache

	LoadCache()
	UpdateCacheWithNewRoute(route *ntv1.Route) error
	Increment() string
}

type Rpc

type Rpc interface {
	chassis.RPCRegistrar

	ntConnect.NetworkingServiceHandler
}

func NewRPC

func NewRPC(logger chassis.Logger, cp *controlPlane) Rpc

rpc interface to `fuse` `control_plane`

type XDSRpc

type XDSRpc interface {
	chassis.RPCRegistrar
}

func NewXDSRpc

func NewXDSRpc(logger chassis.Logger, cp *controlPlane) XDSRpc

rpc interface to envoy xDS server