discoverer

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

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
}

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

type WorkerInstance struct {
	Ip string
}

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