queue

type MessageOptions struct {
	// Durable indicates whether or not the message should be durable/persisted
	// (true) or not durable/persisted (false, default)
	Durable bool
}

type Writer interface {
	// Write writes the provided message to a specific queue (or similar channel)
	// known to the implementation.
	Write(ctx context.Context, message string, opts *MessageOptions) error
	// Close executes implementation-specific cleanup. Clients MUST invoke this
	// function when they are done with the Writer.
	Close(context.Context) error
}

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