control

Documentation

Index

• Constants
• func CreateControllers(mgr *Manager, controllerManager ctrl.Manager) error
• func ParseJWKSSecret(secret *v1.Secret) ([]byte, error)
• func SystemServiceName(name types.NamespacedName) string
• type Manager
  • func NewManager(cl client.Client, namespace string) *Manager
  • func (m *Manager) AddPeer(pr *v1alpha1.Peer)
  • func (m *Manager) CreateJWKSSecret(ctx context.Context) error
  • func (m *Manager) DeletePeer(name string)
  • func (m *Manager) GracefulStop() error
  • func (m *Manager) Name() string
  • func (m *Manager) SetPeerCertificates(peerTLS *tls.ParsedCertData, _ *tls.RawCertData) error
  • func (m *Manager) Start() error
  • func (m *Manager) Stop() error

Constants

const (
	AppName = "clusterlink.net"

	// service labels.
	LabelManagedBy       = "app.kubernetes.io/managed-by"
	LabelImportName      = "clusterlink.net/import-name"
	LabelImportNamespace = "clusterlink.net/import-namespace"

	// endpoint slice labels.
	LabelDPEndpointSliceName = "clusterlink.net/dataplane-endpointslice-name"

	// JWK secret.
	JWKSecretName    = "jwk"
	JWKSecretKeyName = "key"
)

Functions

func CreateControllers

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

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

func ParseJWKSSecret

func ParseJWKSSecret(secret *v1.Secret) ([]byte, error)

func SystemServiceName

func SystemServiceName(name types.NamespacedName) string

Types

type Manager

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

Manager is responsible for handling control operations, which needs to be coordinated across all dataplane/controlplane instances. This includes target port generation for imported services, as well as k8s service creation per imported service.

func NewManager

func NewManager(cl client.Client, namespace string) *Manager

NewManager returns a new control manager.

func (*Manager) AddPeer

func (m *Manager) AddPeer(pr *v1alpha1.Peer)

AddPeer defines a new route target for egress dataplane connections.

func (*Manager) CreateJWKSSecret

func (m *Manager) CreateJWKSSecret(ctx context.Context) error

CreateJWKSSecret creates the JWKS secret if it does not exist.

func (*Manager) DeletePeer

func (m *Manager) DeletePeer(name string)

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

func (*Manager) GracefulStop

func (m *Manager) GracefulStop() error

GracefulStop does a graceful stop of the peer manager.

func (*Manager) Name

func (m *Manager) Name() string

Name of the peer monitor runnable.

func (*Manager) SetPeerCertificates

func (m *Manager) SetPeerCertificates(peerTLS *tls.ParsedCertData, _ *tls.RawCertData) error

func (*Manager) Start

func (m *Manager) Start() error

Start the peer manager.

func (*Manager) Stop

func (m *Manager) Stop() error

Stop the peer manager.