Documentation ¶
Index ¶
- type TextMessageWorker
- func (w *TextMessageWorker) Command(c int)
- func (w *TextMessageWorker) ID() int
- func (w *TextMessageWorker) Label() string
- func (w *TextMessageWorker) Run(wg *sync.WaitGroup, term *chan int)
- func (w *TextMessageWorker) Subscriptions() []*worker.Subscription
- func (w *TextMessageWorker) Terminate()
- func (w *TextMessageWorker) TextMessageEvent(message []byte)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type TextMessageWorker ¶
TextMessageWorker stream worker
func NewTextMessageWorker ¶
func NewTextMessageWorker(workers *worker.Workers, id int, label string) *TextMessageWorker
NewTextMessageWorker create a new TextMessageWorker
func (*TextMessageWorker) Command ¶
func (w *TextMessageWorker) Command(c int)
Command sent to this worker
func (*TextMessageWorker) ID ¶ added in v0.2.0
func (w *TextMessageWorker) ID() int
ID return label of worker
func (*TextMessageWorker) Label ¶ added in v0.2.0
func (w *TextMessageWorker) Label() string
Label return label of worker
func (*TextMessageWorker) Run ¶
func (w *TextMessageWorker) Run(wg *sync.WaitGroup, term *chan int)
Run is main function of this worker
func (*TextMessageWorker) Subscriptions ¶ added in v0.2.0
func (w *TextMessageWorker) Subscriptions() []*worker.Subscription
Subscriptions return a copy of current scubscriptions
func (*TextMessageWorker) TextMessageEvent ¶ added in v0.2.0
func (w *TextMessageWorker) TextMessageEvent(message []byte)
TextMessageEvent -- obvious
Click to show internal directories.
Click to hide internal directories.