compassconnection

Documentation

Index

• Constants
• func InitCompassConnectionController(mgr manager.Manager, supervisior Supervisor, ...) error
• type CRManager
• type Client
• type Connector
  • func NewCompassConnector(csrProvider certificates.CSRProvider, clientsProvider compass.ClientsProvider) Connector
• type DependencyConfig
  • func (config DependencyConfig) InitializeController() (Supervisor, error)
• type EstablishedConnection
• type Reconciler
  • func (r *Reconciler) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)
• type Supervisor
  • func NewSupervisor(connector Connector, crManager CRManager, credManager certificates.Manager, ...) Supervisor

Constants

const (
	ConnectorTokenHeader = "Connector-Token"
)

const (
	DefaultCompassConnectionName = "compass-connection"
)

Functions

func InitCompassConnectionController

func InitCompassConnectionController(
	mgr manager.Manager,
	supervisior Supervisor,
	minimalConfigSyncTime time.Duration,
	configProvider config.Provider) error

Types

type CRManager

type CRManager interface {
	Create(ctx context.Context, cc *v1alpha1.CompassConnection, options metav1.CreateOptions) (*v1alpha1.CompassConnection, error)
	Update(ctx context.Context, cc *v1alpha1.CompassConnection, options metav1.UpdateOptions) (*v1alpha1.CompassConnection, error)
	Delete(ctx context.Context, name string, options metav1.DeleteOptions) error
	Get(ctx context.Context, name string, options metav1.GetOptions) (*v1alpha1.CompassConnection, error)
}

type Client

type Client interface {
	Get(ctx context.Context, key client.ObjectKey, obj client.Object, opts ...client.GetOption) error
	Update(ctx context.Context, obj client.Object, opts ...client.UpdateOption) error
	Delete(ctx context.Context, obj client.Object, opts ...client.DeleteOption) error
}

type Connector

type Connector interface {
	EstablishConnection(ctx context.Context, connectorURL, token string) (EstablishedConnection, error)
	MaintainConnection(ctx context.Context, renewCert bool, credentialsExist bool) (*certificates.Credentials, v1alpha1.ManagementInfo, error)
}

func NewCompassConnector

func NewCompassConnector(
	csrProvider certificates.CSRProvider,
	clientsProvider compass.ClientsProvider,
) Connector

type DependencyConfig

type DependencyConfig struct {
	K8sConfig         *rest.Config
	ControllerManager manager.Manager

	ClientsProvider        compass.ClientsProvider
	CredentialsManager     certificates.Manager
	SynchronizationService kyma.Service
	ConfigProvider         config.Provider
	ConnectionDataCache    cache.ConnectionDataCache

	RuntimeURLsConfig            director.RuntimeURLsConfig
	CertValidityRenewalThreshold float64
	MinimalCompassSyncTime       time.Duration
}

func (DependencyConfig) InitializeController

func (config DependencyConfig) InitializeController() (Supervisor, error)

type EstablishedConnection

type EstablishedConnection struct {
	Credentials    certificates.Credentials
	ManagementInfo v1alpha1.ManagementInfo
}

type Reconciler

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

Reconciler reconciles a CompassConnection object

func (*Reconciler) Reconcile

func (r *Reconciler) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)

type Supervisor

type Supervisor interface {
	InitializeCompassConnection(ctx context.Context) (*v1alpha1.CompassConnection, error)
	SynchronizeWithCompass(ctx context.Context, connection *v1alpha1.CompassConnection) (*v1alpha1.CompassConnection, error)
	MaintainCompassConnection(ctx context.Context, connection *v1alpha1.CompassConnection) error
}

func NewSupervisor

func NewSupervisor(
	connector Connector,
	crManager CRManager,
	credManager certificates.Manager,
	clientsProvider compass.ClientsProvider,
	syncService kyma.Service,
	configProvider config.Provider,
	certValidityRenewalThreshold float64,
	minimalCompassSyncTime time.Duration,
	runtimeURLsConfig director.RuntimeURLsConfig,
	connectionDataCache cache.ConnectionDataCache,
) Supervisor