Documentation ¶
Index ¶
- Constants
- func CreateControllers(mgr *Manager, controllerManager ctrl.Manager) error
- func SystemServiceName(name types.NamespacedName) string
- type Manager
- func (m *Manager) AddImport(ctx context.Context, imp *v1alpha1.Import) (err error)
- func (m *Manager) AddPeer(pr *v1alpha1.Peer)
- func (m *Manager) DeleteImport(ctx context.Context, name types.NamespacedName) error
- func (m *Manager) DeletePeer(name string)
- func (m *Manager) GracefulStop() error
- func (m *Manager) Name() string
- func (m *Manager) SetStatusCallback(callback func(*v1alpha1.Peer))
- func (m *Manager) Start() error
- func (m *Manager) Stop() error
Constants ¶
View Source
const ( AppName = "clusterlink.net" LabelManagedBy = "app.kubernetes.io/managed-by" LabelImportName = "clusterlink.net/import-name" LabelImportNamespace = "clusterlink.net/import-namespace" )
Variables ¶
This section is empty.
Functions ¶
func CreateControllers ¶
CreateControllers creates the various k8s controllers used to update the control manager.
func SystemServiceName ¶ added in v0.1.0
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, peerTLS *tls.ParsedCertData, namespace string, crdMode bool) *Manager
NewManager returns a new control manager.
func (*Manager) DeleteImport ¶
DeleteImport removes the listening socket of a previously imported service.
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) SetStatusCallback ¶
Click to show internal directories.
Click to hide internal directories.