Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type SendQueue ¶
type SendQueue struct {
// contains filtered or unexported fields
}
SendQueue queues messages, and sends them in the background.
func NewSendQueue ¶
type ServiceGroup ¶
func (*ServiceGroup) Go ¶
func (sg *ServiceGroup) Go(fn func(context.Context) error)
Go runs fn in another go routine. When the ServiceGroup is stopped the context passed to fn will be cancelled. If fn ever returns an error other than ctx.Err(), it will be logged. The service will be restarted, unless the group has been stopped.
func (*ServiceGroup) Stop ¶
func (sg *ServiceGroup) Stop() error
type TellHub ¶
func NewTellHub ¶
func NewTellHub() *TellHub
type WorkerPool ¶
func (*WorkerPool) SetCount ¶
func (wp *WorkerPool) SetCount(count int)
func (*WorkerPool) Stop ¶
func (wp *WorkerPool) Stop()
Click to show internal directories.
Click to hide internal directories.