remote

Documentation

Overview

Package remote contains the remote connector for the FSM multi-cluster

Index

• type Background
  • func NewBackground(cluster *mcsv1alpha1.Cluster, kubeconfig *rest.Config, ...) (*Background, error)
  • func (b *Background) Run() error
• type Connector
  • func NewConnector(ctx context.Context, controlPlaneBroker *messaging.Broker) (*Connector, error)
  • func (c *Connector) Run(stopCh <-chan struct{}) error
  • func (c *Connector) ServiceImportExists(svcExp *mcsv1alpha1.ServiceExport) bool
  • func (c *Connector) ValidateServiceExport(svcExp *mcsv1alpha1.ServiceExport, service *corev1.Service) error

Types

type Background

type Background struct {
	Context   *cctx.ConnectorContext
	Connector *Connector
}

Background is the background struct for the remote connector

func NewBackground

func NewBackground(cluster *mcsv1alpha1.Cluster, kubeconfig *rest.Config, mc configurator.Configurator, broker *messaging.Broker) (*Background, error)

NewBackground creates a new background process for a cluster

func (*Background) Run

func (b *Background) Run() error

Run starts the background process

type Connector

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

Connector is the main struct for the remote connector

func NewConnector

func NewConnector(ctx context.Context, controlPlaneBroker *messaging.Broker) (*Connector, error)

NewConnector creates a new remote connector

func (*Connector) Run

func (c *Connector) Run(stopCh <-chan struct{}) error

Run starts the connector

func (*Connector) ServiceImportExists

func (c *Connector) ServiceImportExists(svcExp *mcsv1alpha1.ServiceExport) bool

ServiceImportExists checks if the ServiceImport exists

func (*Connector) ValidateServiceExport

func (c *Connector) ValidateServiceExport(svcExp *mcsv1alpha1.ServiceExport, service *corev1.Service) error

ValidateServiceExport validates the ServiceExport and returns error if there's any conflict