Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type TaskChannel ¶
type TaskChannel chan queueEvent
func NewTaskChannel ¶
func NewTaskChannel() TaskChannel
func (TaskChannel) SendFailure ¶
func (t TaskChannel) SendFailure(moduleName string, errMsg string)
func (TaskChannel) SendSuccess ¶
func (t TaskChannel) SendSuccess(moduleName string)
type TaskChannels ¶
type TaskChannels struct {
// contains filtered or unexported fields
}
func NewTaskChannels ¶
func NewTaskChannels() *TaskChannels
func (*TaskChannels) Channels ¶
func (pq *TaskChannels) Channels() []string
func (*TaskChannels) Delete ¶
func (pq *TaskChannels) Delete(id string)
func (*TaskChannels) Get ¶
func (pq *TaskChannels) Get(id string) (TaskChannel, bool)
func (*TaskChannels) Set ¶
func (pq *TaskChannels) Set(id string, c TaskChannel)
Source Files
Click to show internal directories.
Click to hide internal directories.