Documentation ¶
Index ¶
- Variables
- type Driver
- func (d *Driver) Ack(eid uid.ID) (err 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
- type Message
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrBucketNotFound = errors.New("Error bucket not found") ErrMessageNotFound = errors.New("Error message not found") )
Functions ¶
This section is empty.
Types ¶
type Driver ¶
type Driver struct {
// contains filtered or unexported fields
}
type Message ¶
type Message struct { Body []byte `msg:"body"` ContentType string `msg:"ct"` Meta map[string]interface{} `msg:"meta"` }
func (*Message) MarshalMsg ¶
MarshalMsg implements msgp.Marshaler
Click to show internal directories.
Click to hide internal directories.