messaging

Documentation

Index

• Variables
• type Record
  • func (r *Record) Clone() Record
  • func (r *Record) Validate() error
• type Store

Variables

var (
	ErrDuplicateMessageID = errors.New("duplicate message id")
)

Types

type Record

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

func (*Record) Clone

func (r *Record) Clone() Record

func (*Record) Validate

func (r *Record) Validate() error

type Store

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)
}

Store stores messages.