xds

Documentation

Index

• func CreateControllers(mgr *Manager, controllerManager ctrl.Manager) error
• func RegisterService(ctx context.Context, manager *Manager, grpcServer *grpc.Server)
• type Manager
  • func NewManager() *Manager
  • func (m *Manager) AddExport(export *v1alpha1.Export) error
  • func (m *Manager) AddImport(imp *v1alpha1.Import) error
  • func (m *Manager) AddPeer(peer *v1alpha1.Peer) error
  • func (m *Manager) DeleteExport(name types.NamespacedName) error
  • func (m *Manager) DeleteImport(name types.NamespacedName) error
  • func (m *Manager) DeletePeer(name string) error
  • func (m *Manager) SetPeerCertificates(_ *utiltls.ParsedCertData, rawCertData *utiltls.RawCertData) error

Functions

func CreateControllers

func CreateControllers(mgr *Manager, controllerManager ctrl.Manager) error

CreateControllers creates the various k8s controllers used to update the xDS manager.

func RegisterService

func RegisterService(ctx context.Context, manager *Manager, grpcServer *grpc.Server)

RegisterService registers an xDS service backed by Manager to the given gRPC server.

Types

type Manager

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

Manager manages the core routing components of the dataplane. It maps the following controlplane types to xDS types: - Peer -> Cluster (whose name starts with a designated prefix) - Export -> Cluster (whose name starts with a designated prefix) - Import -> Listener (whose name starts with a designated prefix) Note that imported service bindings are handled by the egress authz server.

func NewManager

func NewManager() *Manager

NewManager creates an uninitialized, non-registered xDS manager.

func (*Manager) AddExport

func (m *Manager) AddExport(export *v1alpha1.Export) error

AddExport defines a new route target for ingress dataplane connections.

func (*Manager) AddImport

func (m *Manager) AddImport(imp *v1alpha1.Import) error

AddImport adds a listening socket for an imported remote service.

func (*Manager) AddPeer

func (m *Manager) AddPeer(peer *v1alpha1.Peer) error

AddPeer defines a new route target for egress dataplane connections.

func (*Manager) DeleteExport

func (m *Manager) DeleteExport(name types.NamespacedName) error

DeleteExport removes the possibility for ingress dataplane connections to access a given service.

func (*Manager) DeleteImport

func (m *Manager) DeleteImport(name types.NamespacedName) error

DeleteImport removes the listening socket of a previously imported service.

func (*Manager) DeletePeer

func (m *Manager) DeletePeer(name string) error

DeletePeer removes the possibility for egress dataplane connections to be routed to a given peer.

func (*Manager) SetPeerCertificates

func (m *Manager) SetPeerCertificates(_ *utiltls.ParsedCertData, rawCertData *utiltls.RawCertData) error

SetPeerCertificates sets the TLS certificates used for peer-to-peer communication.