Versions in this module Expand all Collapse all v0 v0.0.1 Apr 6, 2022 Changes in this version + type ConcurrentJobBlocker struct + func NewCJLock() *ConcurrentJobBlocker + func (hth *ConcurrentJobBlocker) Initilize(s *taskmanager.Task) + func (hth *ConcurrentJobBlocker) PostHandler(s *taskmanager.Task, err error) taskmanager.MWResult + func (hth *ConcurrentJobBlocker) PreHandler(s *taskmanager.Task) (taskmanager.MWResult, error) + func (hth *ConcurrentJobBlocker) Reset(s *taskmanager.Task) + type HasTagHandler struct + func NewTagHandler() *HasTagHandler + func (hth *HasTagHandler) DelHaveTags(tag string) + func (hth *HasTagHandler) DelRequiredTags(tag string) + func (hth *HasTagHandler) Initilize(s *taskmanager.Task) + func (hth *HasTagHandler) IsHaveTag(tag string) bool + func (hth *HasTagHandler) IsRequiredTag(tag string) bool + func (hth *HasTagHandler) PostHandler(s *taskmanager.Task, err error) taskmanager.MWResult + func (hth *HasTagHandler) PreHandler(s *taskmanager.Task) (taskmanager.MWResult, error) + func (hth *HasTagHandler) Reset(s *taskmanager.Task) + func (hth *HasTagHandler) SetHaveTags(tag string) + func (hth *HasTagHandler) SetRequiredTags(tag string)