Documentation
¶
Index ¶
- type Service
- func (s *Service) AddNodeTask(list []*service.NodeTask) error
- func (s *Service) DeleteNodeSource(list []int64) error
- func (s *Service) GetNodeInfo() (map[string][]string, []string, error)
- func (s *Service) GetNodeTaskCountByNodeId(nodeId string) int64
- func (s *Service) GetNodeTaskCountWithIng(codes []string, nodeMp map[string][]string, log *logrus.Entry) ([]string, map[string][]string)
- func (s *Service) GetNodeTaskCountWithMap() map[string]int64
- func (s *Service) GetTaskForExec(codes []string) ([]*service.NodeSource, error)
- func (s *Service) RebuildWeight(nodeId string, weight int64) int64
- func (s *Service) Start()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Service ¶
type Service struct {
// contains filtered or unexported fields
}
func NewService ¶
func (*Service) DeleteNodeSource ¶
func (*Service) GetNodeInfo ¶
func (*Service) GetNodeTaskCountByNodeId ¶
func (*Service) GetNodeTaskCountWithIng ¶
func (*Service) GetNodeTaskCountWithMap ¶
func (*Service) GetTaskForExec ¶
func (s *Service) GetTaskForExec(codes []string) ([]*service.NodeSource, error)
func (*Service) RebuildWeight ¶
RebuildWeight 根据积压的任务，动态的调整 最终权重
Source Files
Click to show internal directories.
Click to hide internal directories.