queue

Documentation

Index

• type Message
• type Queuer

Types

type Message

type Message struct {
	Err  error          `json:"err"`
	Data convoy.Message `json:"data"`
}

type Queuer

type Queuer interface {
	Read() chan Message
	io.Closer
	Write(context.Context, convoy.Message) error
}