worker

Documentation

Index

• type DeliverState
  • func (d DeliverState) Equals(other DeliverState) bool
• type Worker
  • func NewWorker(rdb *redis.Client, store *store.Store, client client.Client, ...) *Worker
  • func (w *Worker) Run()
  • func (w *Worker) StartAssociationWorker()
  • func (w *Worker) StartMessageWorker()

Types

type DeliverState

type DeliverState struct {
	Dests   []string
	Listens []string
}

func (DeliverState) Equals

func (d DeliverState) Equals(other DeliverState) bool

type Worker

type Worker struct {
	// contains filtered or unexported fields
}

func NewWorker

func NewWorker(
	rdb *redis.Client,
	store *store.Store,
	client client.Client,
	apclient *apclient.ApClient,
	bridge *bridge.Service,
	config types.ApConfig,
) *Worker

func (*Worker) Run

func (w *Worker) Run()

func (*Worker) StartAssociationWorker

func (w *Worker) StartAssociationWorker()

func (*Worker) StartMessageWorker

func (w *Worker) StartMessageWorker()