compassconnection

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 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 interface {
	EstablishConnection(ctx context.Context, connectorURL, token string) (EstablishedConnection, error)
	MaintainConnection(ctx context.Context, renewCert bool, credentialsExist bool) (*certificates.Credentials, v1alpha1.ManagementInfo, error)
}

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
}

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

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

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
}