memory

Documentation

Index

• type Driver
  • func New() *Driver
  • func (d *Driver) Ack(eid uid.ID) error
  • func (d *Driver) Close() error
  • func (d *Driver) Dequeue(queue string, eid uid.ID) (e *storage.Envelope, err error)
  • func (d *Driver) Enqueue(queue string, id uid.ID, e *storage.Envelope, opts *storage.EnqueueOptions) (*storage.EnqueueMeta, error)
  • func (d *Driver) Reset(eid uid.ID) error

Types

type Driver

type Driver struct {
	// contains filtered or unexported fields
}

func New

func New() *Driver

func (*Driver) Ack

func (d *Driver) Ack(eid uid.ID) error

func (*Driver) Close

func (d *Driver) Close() error

func (*Driver) Dequeue

func (d *Driver) Dequeue(queue string, eid uid.ID) (e *storage.Envelope, err error)

func (*Driver) Enqueue

func (d *Driver) Enqueue(queue string, id uid.ID, e *storage.Envelope, opts *storage.EnqueueOptions) (*storage.EnqueueMeta, error)

func (*Driver) Reset

func (d *Driver) Reset(eid uid.ID) error