producers

Documentation

Index

• type Task
  • func NewTask(body interface{}) (*Task, error)
• type TaskProducer

Types

type Task

type Task struct {
	Body io.Reader
}

func NewTask

func NewTask(body interface{}) (*Task, error)

type TaskProducer

type TaskProducer interface {
	Produce(t *Task, options ...options.Option) (string, error)
	Close() error
}