service

type BytesWriter interface {
	WriteBytes(data []byte) error
}

type ErrorWriter interface {
	WriteError(err error) error
}

type ProtoWriter interface {
	WriteProto(message proto.Message) error
}

type Request interface {
	StatusWriter
	ResultWriter
	ErrorWriter
	Task() *broker.Task
	Ack() error
	Nack() error
}

type RequestReader interface {
	Read(constraints broker.Constraints, jobs int) (<-chan Request, error)
	Close() error
}

type ResultWriter interface {
	WriteResult(result broker.Result) error
}

type StatusWriter interface {
	WriteStatus(status broker.Status) error
}