dummyworker

package

v0.0.0-...-f3afebf Latest Latest Go to latest Published: Mar 1, 2018 License: MIT Imports: 7 Imported by: 4

Details

Package dummyworker implements a worker for testing and examples.

This section is empty.

This section is empty.

func New() blaster.Worker

New returns a new dummy worker

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

Worker is the worker type

func (w *Worker) Send(ctx context.Context, raw map[string]interface{}) (map[string]interface{}, error)

Send satisfies the blaster.Worker interface

func (w *Worker) Start(ctx context.Context, raw map[string]interface{}) error

Start satisfies the blaster.Starter interface