messaging

type Record struct {
	Account   string
	MessageID uuid.UUID
	Message   []byte
}

type Store interface {
	// Insert inserts a message into a specified bin.
	//
	// ErrDuplicateMessageID is returned if the message's ID already exists in the bin.
	Insert(ctx context.Context, record *Record) error

	// Delete deletes a message in the specified bin.
	//
	// Delete is idempotent.
	Delete(ctx context.Context, account string, messageID uuid.UUID) error

	// Get returns the messages in a bin.
	Get(ctx context.Context, account string) ([]*Record, error)
}