impl

Documentation

Index

• func GetExecutionCluster(scope promutils.Scope, kubeConfig, master string, ...) executioncluster_interface.ClusterInterface
• func NewExecutionTargetProvider() interfaces.ExecutionTargetProvider
• func NewInCluster(initializationErrorCounter prometheus.Counter, kubeConfig, master string) (interfaces.ClusterInterface, error)
• func NewListTargets(initializationErrorCounter prometheus.Counter, ...) (interfaces.ListTargetsInterface, error)
• func NewRandomClusterSelector(listTargets interfaces.ListTargetsInterface, config runtime.Configuration, ...) (interfaces.ClusterInterface, error)
• type InCluster
  • func (i InCluster) GetAllTargets() map[string]*executioncluster.ExecutionTarget
  • func (i InCluster) GetTarget(ctx context.Context, spec *executioncluster.ExecutionTargetSpec) (*executioncluster.ExecutionTarget, error)
  • func (i InCluster) GetValidTargets() map[string]*executioncluster.ExecutionTarget
• type RandomClusterSelector
  • func (s RandomClusterSelector) GetTarget(ctx context.Context, spec *executioncluster.ExecutionTargetSpec) (*executioncluster.ExecutionTarget, error)

Functions

func GetExecutionCluster

func GetExecutionCluster(scope promutils.Scope, kubeConfig, master string, config interfaces.Configuration, db repositories.RepositoryInterface) executioncluster_interface.ClusterInterface

func NewExecutionTargetProvider

func NewExecutionTargetProvider() interfaces.ExecutionTargetProvider

func NewInCluster

func NewInCluster(initializationErrorCounter prometheus.Counter, kubeConfig, master string) (interfaces.ClusterInterface, error)

func NewListTargets

func NewListTargets(initializationErrorCounter prometheus.Counter, executionTargetProvider interfaces.ExecutionTargetProvider,
	clusterConfig runtime.ClusterConfiguration) (interfaces.ListTargetsInterface, error)

func NewRandomClusterSelector

func NewRandomClusterSelector(listTargets interfaces.ListTargetsInterface, config runtime.Configuration,
	db repositories.RepositoryInterface) (interfaces.ClusterInterface, error)

Types

type InCluster

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

func (InCluster) GetAllTargets

func (i InCluster) GetAllTargets() map[string]*executioncluster.ExecutionTarget

func (InCluster) GetTarget

func (i InCluster) GetTarget(ctx context.Context, spec *executioncluster.ExecutionTargetSpec) (*executioncluster.ExecutionTarget, error)

func (InCluster) GetValidTargets

func (i InCluster) GetValidTargets() map[string]*executioncluster.ExecutionTarget

type RandomClusterSelector

type RandomClusterSelector struct {
	interfaces.ListTargetsInterface
	// contains filtered or unexported fields
}

Implementation of Random cluster selector Selects cluster based on weights and domains.

func (RandomClusterSelector) GetTarget

func (s RandomClusterSelector) GetTarget(ctx context.Context, spec *executioncluster.ExecutionTargetSpec) (*executioncluster.ExecutionTarget, error)