labelmanager

Documentation

Index

• Variables
• type Cluster
• type LabelManager
  • func NewLabelManager() LabelManager
• type LabelManagerImpl
  • func (s *LabelManagerImpl) List() map[string]bool
  • func (s *LabelManagerImpl) SetNodeLabel(cluster Cluster, hosts []string, tags map[string]string) error

Variables

var (
	NotFoundExecutor = errors.New("Not found Executor")
)

Types

type Cluster

type Cluster struct {
	// e.g. terminus-y
	ClusterName string
	// One of the following options:
	// ServiceKindMarathon
	// ServiceKindK8S
	// JobKindMetronome
	// JobKindK8S
	ClusterType string
	// This can be ignored for k8s cluster
	SoldierURL string
}

type LabelManager

type LabelManager interface {
	// List available labels.
	// map key: label name
	// map value: Is this label a prefix?
	//
	// Although different types of
	// clusters (dcos&k8s) have different names on the compute
	// nodes, the exposed labels are uniform names.
	List() map[string]bool

	// Not yet implemented
	SetNodeLabel(cluster Cluster, hosts []string, tags map[string]string) error
}

LabelManager interface of LabelManagerImpl

func NewLabelManager

func NewLabelManager() LabelManager

NewLabelManager create LabelManager

type LabelManagerImpl

type LabelManagerImpl struct{}

LabelManagerImpl implementation of LabelManager

func (*LabelManagerImpl) List

func (s *LabelManagerImpl) List() map[string]bool

func (*LabelManagerImpl) SetNodeLabel

func (s *LabelManagerImpl) SetNodeLabel(cluster Cluster, hosts []string, tags map[string]string) error