queue

type Message struct {
	// Message is an unstructured, textual representation of the data.
	Message string
	// Ack is a function that may be invoked to (if applicable) signal the
	// underlying messaging system to consider the message delivered and
	// processed.
	Ack func(context.Context) error
}

type Reader interface {
	// Read reads a message from a specific queue (or similar channel) known to
	// the implementation. This function blocks until either a successful read or
	// an error occurs.
	Read(ctx context.Context) (*Message, error)
	// Close executes implementation-specific cleanup. Clients MUST invoke this
	// function when they are done with the Reader.
	Close(context.Context) error
}

type ReaderFactory interface {
	// NewReader returns an implementation of the Reader interface capable of
	// reading messages from a specific queue (or similar channel) of some
	// (presumably asynchronous) messaging system.
	NewReader(queueName string) (Reader, error)
	// Close executes implementation-specific cleanup. Clients MUST invoke this
	// function when they are done with the ReaderFactory.
	Close(context.Context) error
}