dispatcher

type ConsistentHashDispatcher struct {
	sync.Mutex

	Tasks            map[string]*model.Task
	ServiceWithTasks map[string]map[string]*model.Task
	// contains filtered or unexported fields
}

type IDispatcher interface {
	AddService(serviceId string) error
	DelService(serviceId string) error

	AddTask(task *model.Task) error
	RemoveTask(taskId string) error

	GetTaskByServiceId(serviceId string) []*model.Task
	GetServiceIdByTaskId(taskId string) string
	GetTotalTaskNum() int
}