rpc

type ClusterRefresher interface {
	RefreshCluster()
}

type GetServerer interface {
	GetServers() ([]*api.Server, error)
}

type GrpcConfig struct {
	TaskService      TaskService
	TaskDefService   TaskDefService
	GetServerer      GetServerer
	ClusterRefresher ClusterRefresher
}

type TaskDefService interface {
	SaveTask(task model.TaskDef) error
}

type TaskService interface {
	Poll(taskName string, batchSize int) (*api.Tasks, error)
	Push(*api.TaskResult) error
}