rcm

type InstanceAssignment struct {
	Instance string
	TotalLag int64
	TaskLags []TaskLag
}

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

type RemoteConfManager interface {
	Init(properties map[string]interface{}) error
	GetConfig() (conf *config.Config, err error)
	// PublishConfig publishs the config.
	PublishConfig(conf *config.Config) (err error)
	Register(ip string, port int) (err error)
	Deregister(ip string, port int) (err error)

	// Assignment loop
	Run()
	Stop()
}

type TaskLag struct {
	Task string
	Lag  int64
}