workers

package
v1.3.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 11, 2019 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BaseMessageWorker

type BaseMessageWorker struct {
	Bus *bus.Bus

	MessageWorker
	// contains filtered or unexported fields
}

func NewBaseMessageWorker

func NewBaseMessageWorker(b *bus.Bus, queue string) *BaseMessageWorker

func (*BaseMessageWorker) Run

func (w *BaseMessageWorker) Run() error

func (*BaseMessageWorker) Stop

func (w *BaseMessageWorker) Stop() error

type MessageWorker

type MessageWorker interface {
	Process(*message.Message) error
	Stop() error
}

type Worker

type Worker interface {
	Run() error
	Stop() error
}

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL