discoverer

Documentation

Index

• type Deps
• type Discoverer
  • func New(deps Deps) Discoverer
• type RegionData
• type WorkerInstance
• type WorkerInstanceStatus
  • func (w *WorkerInstanceStatus) IsRunning() bool

Types

type Deps

type Deps struct {
	Client        *kubernetes.Clientset
	Namespace     string
	LabelSelector string
}

type Discoverer

type Discoverer interface {
	// RegionDataChan returns channel streaming data regarding updates of set of instances.
	RegionDataChan() <-chan RegionData
	// InstanceStatuses returns channel streaming data regarding updates of statuses on instances.
	// Useful for checking health of the worker.
	InstanceStatuses() <-chan WorkerInstanceStatus

	Run(ctx context.Context) error
}

func New

func New(deps Deps) Discoverer

type RegionData

type RegionData struct {
	RegionId  db.RegionId
	Instances []WorkerInstance
}

type WorkerInstance

type WorkerInstance struct {
	Ip string
}

type WorkerInstanceStatus

type WorkerInstanceStatus struct {
	Status   v1.PodPhase
	Ip       string
	RegionId int
}

func (*WorkerInstanceStatus) IsRunning

func (w *WorkerInstanceStatus) IsRunning() bool