looper

Documentation

Index

• type ActiveSkrCollection
  • func NewActiveSkrCollection(logger logr.Logger) ActiveSkrCollection
• type Checker
• type Installer
• type RunOption
  • func WithProvider(provider cloudcontrolv1beta1.ProviderType) RunOption
  • func WithTimeout(timeout time.Duration) RunOption
• type RunOptions
• type SkrLooper
  • func New(kcpCluster cluster.Cluster, skrScheme *runtime.Scheme, ...) SkrLooper
• type SkrRunner
  • func NewSkrRunner(reg registry.SkrRegistry, kcpCluster cluster.Cluster) SkrRunner

Types

type ActiveSkrCollection

type ActiveSkrCollection interface {
	AddKymaUnstructured(kyma *unstructured.Unstructured)
	RemoveKymaUnstructured(kyma *unstructured.Unstructured)
	Contains(kymaName string) bool
	GetKymaNames() []string
}

func NewActiveSkrCollection

func NewActiveSkrCollection(logger logr.Logger) ActiveSkrCollection

type Checker

type Checker interface {
	IsReady(ctx context.Context, skrCluster cluster.Cluster) bool
}

type Installer

type Installer interface {
	Handle(ctx context.Context, provider string, skrCluster cluster.Cluster) error
}

type RunOption

type RunOption = func(options *RunOptions)

func WithProvider

func WithProvider(provider cloudcontrolv1beta1.ProviderType) RunOption

func WithTimeout

func WithTimeout(timeout time.Duration) RunOption

type RunOptions

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

type SkrLooper

type SkrLooper interface {
	manager.Runnable
	ActiveSkrCollection
}

func New

func New(kcpCluster cluster.Cluster, skrScheme *runtime.Scheme, reg registry.SkrRegistry, logger logr.Logger) SkrLooper

type SkrRunner

type SkrRunner interface {
	Run(ctx context.Context, skrManager skrmanager.SkrManager, opts ...RunOption) error
}

func NewSkrRunner

func NewSkrRunner(reg registry.SkrRegistry, kcpCluster cluster.Cluster) SkrRunner