orchestration

type GardenerRuntimeResolver ¶

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

GardenerRuntimeResolver is the default resolver which implements the RuntimeResolver interface. This resolver uses the Shoot resources on the Gardener cluster to resolve the runtime targets.

Naive implementation, listing all the shoots and perfom filtering on the result. The logic could be optimized with k8s client cache using shoot lister / indexer. The implementation is thread safe, i.e. it is safe to call Resolve() from multiple threads concurrently.

func NewGardenerRuntimeResolver(gardenerClient gardenerclient.CoreV1beta1Interface, gardenerNamespace string, lister InstanceLister, logger logrus.FieldLogger) *GardenerRuntimeResolver

func (resolver *GardenerRuntimeResolver) Resolve(targets orchestration.TargetSpec) ([]internal.Runtime, error)

type InstanceLister ¶

type InstanceLister interface {
	FindAllJoinedWithOperations(prct ...predicate.Predicate) ([]internal.InstanceWithOperation, error)
}

InstanceLister is the interface to get InstanceWithOperation objects from KEB storage

type ParallelOrchestrationStrategy ¶

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

func (p *ParallelOrchestrationStrategy) Execute(operations []internal.RuntimeOperation, strategySpec orchestration.StrategySpec) (time.Duration, error)

type RuntimeResolver ¶

type RuntimeResolver interface {
	Resolve(targets orchestration.TargetSpec) ([]internal.Runtime, error)
}

RuntimeResolver given an input slice of target specs to include and exclude, resolves and returns a list of unique Runtime objects.

type Strategy ¶

type Strategy interface {
	// Execute invokes operation managers' Execute(operationID string) method for each operation according to the encapsulated strategy.
	Execute(operations []internal.RuntimeOperation, strategySpec orchestration.StrategySpec) (time.Duration, error)
}

Strategy interface encapsulates the strategy how the orchestration is performed.

func NewParallelOrchestrationStrategy(executor process.Executor, log logrus.FieldLogger) Strategy