impl

Documentation

Index

• func GetExecutionCluster(scope promutils.Scope, kubeConfig, master string, ...) executioncluster_interface.ClusterInterface
• func NewInCluster(initializationErrorCounter prometheus.Counter, kubeConfig, master string) (interfaces.ClusterInterface, error)
• func NewRandomClusterSelector(initializationErrorCounter prometheus.Counter, config runtime.Configuration, ...) (interfaces.ClusterInterface, error)
• type InCluster
  • func (i InCluster) GetAllValidTargets() []executioncluster.ExecutionTarget
  • func (i InCluster) GetTarget(ctx context.Context, spec *executioncluster.ExecutionTargetSpec) (*executioncluster.ExecutionTarget, error)
• type RandomClusterSelector
  • func (s RandomClusterSelector) GetAllValidTargets() []executioncluster.ExecutionTarget
  • 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 NewInCluster

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

func NewRandomClusterSelector

func NewRandomClusterSelector(initializationErrorCounter prometheus.Counter, config runtime.Configuration, executionTargetProvider interfaces.ExecutionTargetProvider, db repositories.RepositoryInterface) (interfaces.ClusterInterface, error)

Types

type InCluster

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

func (InCluster) GetAllValidTargets

func (i InCluster) GetAllValidTargets() []executioncluster.ExecutionTarget

func (InCluster) GetTarget

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

type RandomClusterSelector

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

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

func (RandomClusterSelector) GetAllValidTargets

func (s RandomClusterSelector) GetAllValidTargets() []executioncluster.ExecutionTarget

func (RandomClusterSelector) GetTarget

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