impl

Documentation

Index

• func GetExecutionCluster(scope promutils.Scope, kubeConfig, master string, ...) executioncluster_interface.ClusterInterface
• func NewInCluster(scope promutils.Scope, kubeConfig, master string) (interfaces.ClusterInterface, error)
• func NewRandomClusterSelector(scope promutils.Scope, clusterConfig runtime.ClusterConfiguration, ...) (interfaces.ClusterInterface, error)
• type InCluster
  • func (i InCluster) GetAllValidTargets() []executioncluster.ExecutionTarget
  • func (i InCluster) GetTarget(spec *executioncluster.ExecutionTargetSpec) (*executioncluster.ExecutionTarget, error)
• type RandomClusterSelector
  • func (s RandomClusterSelector) GetAllValidTargets() []executioncluster.ExecutionTarget
  • func (s RandomClusterSelector) GetTarget(spec *executioncluster.ExecutionTargetSpec) (*executioncluster.ExecutionTarget, error)

Functions

func GetExecutionCluster

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

func NewInCluster

func NewInCluster(scope promutils.Scope, kubeConfig, master string) (interfaces.ClusterInterface, error)

func NewRandomClusterSelector

func NewRandomClusterSelector(scope promutils.Scope, clusterConfig runtime.ClusterConfiguration, executionTargetProvider interfaces.ExecutionTargetProvider, domainConfig *runtime.DomainsConfig) (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(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(spec *executioncluster.ExecutionTargetSpec) (*executioncluster.ExecutionTarget, error)