btpmgrcreds

Documentation

Index

• Constants
• Variables
• func CallWithRetry[T any](closure func() (T, error), maxAttempts int, retryDelay time.Duration) (T, error)
• func CreateOrUpdateSecret(k8sClient client.Client, futureSecret *apicorev1.Secret, ...) error
• func PrepareSecret(credentials *internal.ServiceManagerOperatorCredentials, clusterID string) (*apicorev1.Secret, error)
• type Job
  • func NewJob(manager *Manager, logs *logrus.Logger) *Job
  • func (s *Job) Start(autoReconcileInterval int, jobReconciliationDelay time.Duration)
• type Manager
  • func NewManager(ctx context.Context, kcpK8sClient client.Client, instanceDb storage.Instances, ...) *Manager
  • func (s *Manager) GetReconcileCandidates() ([]internal.Instance, error)
  • func (s *Manager) MatchInstance(kymaName string) (*internal.Instance, error)
  • func (s *Manager) ReconcileAll(jobReconciliationDelay time.Duration) (int, int, int, int, error)
  • func (s *Manager) ReconcileSecretForInstance(instance *internal.Instance) (bool, error)
• type Watcher
  • func NewWatcher(ctx context.Context, listenerAddr, componentName string, ...) *Watcher
  • func (s *Watcher) ReactOnSkrEvent()

Constants

const (
	BtpManagerSecretName      = "sap-btp-manager"
	BtpManagerSecretNamespace = "kyma-system"
)

Variables

var (
	BtpManagerLabels      = map[string]string{"app.kubernetes.io/managed-by": keb, "app.kubernetes.io/watched-by": keb}
	BtpManagerAnnotations = map[string]string{"Warning": "This secret is generated. Do not edit!"}
	KymaGvk               = schema.GroupVersionKind{Group: "operator.kyma-project.io", Version: "v1beta2", Kind: "Kyma"}
)

Functions

func CallWithRetry

func CallWithRetry[T any](closure func() (T, error), maxAttempts int, retryDelay time.Duration) (T, error)

func CreateOrUpdateSecret

func CreateOrUpdateSecret(k8sClient client.Client, futureSecret *apicorev1.Secret, log logrus.FieldLogger) error

func PrepareSecret

func PrepareSecret(credentials *internal.ServiceManagerOperatorCredentials, clusterID string) (*apicorev1.Secret, error)

Types

type Job

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

func NewJob

func NewJob(manager *Manager, logs *logrus.Logger) *Job

func (*Job) Start

func (s *Job) Start(autoReconcileInterval int, jobReconciliationDelay time.Duration)

type Manager

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

func NewManager

func NewManager(ctx context.Context, kcpK8sClient client.Client, instanceDb storage.Instances, logs *logrus.Logger, dryRun bool, provisioner provisioner.Client) *Manager

func (*Manager) GetReconcileCandidates

func (s *Manager) GetReconcileCandidates() ([]internal.Instance, error)

func (*Manager) MatchInstance

func (s *Manager) MatchInstance(kymaName string) (*internal.Instance, error)

func (*Manager) ReconcileAll

func (s *Manager) ReconcileAll(jobReconciliationDelay time.Duration) (int, int, int, int, error)

func (*Manager) ReconcileSecretForInstance

func (s *Manager) ReconcileSecretForInstance(instance *internal.Instance) (bool, error)

type Watcher

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

func NewWatcher

func NewWatcher(ctx context.Context, listenerAddr, componentName string, btpOperatorManager *Manager, logs *logrus.Logger) *Watcher

func (*Watcher) ReactOnSkrEvent

func (s *Watcher) ReactOnSkrEvent()