messaging

type Callback func(ctx context.Context, m *Message) error

type Consumer interface {
	// Pull the next message, call callback and return
	// If callback returns a temporary error, the message must be rescheduled, increasing its trycount
	Pull(ctx context.Context, cb Callback) error
}

type Message struct {
	ID          string
	Data        []byte
	Attributes  map[string]string
	PublishTime time.Time
	TryCount    int
}

type Publisher interface {
	Publish(ctx context.Context, data ...[]byte) error
}