Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( DefaultRetry = types.Retry(10) DefaultTimeout = types.Duration(30 * time.Second) )
View Source
var ( ErrEmpty = errors.New("Error empty queue") ErrInvalidEphemeralID = errors.New("Error invalid ephemeral id") )
Functions ¶
Types ¶
type AccumState ¶
type AccumState int
const ( AccumDisabled AccumState = iota AccumStarted AccumAdded )
type Driver ¶
type Driver interface { Enqueue(string, uid.ID, *Envelope, *EnqueueOptions) (*EnqueueMeta, error) Dequeue(string, uid.ID) (*Envelope, error) Ack(uid.ID) error Reset(uid.ID) error Close() error }
func FromContext ¶
type EnqueueMeta ¶
type EnqueueMeta struct {
AccumState AccumState
}
type EnqueueOptions ¶
type Envelope ¶
type Envelope struct { ID uid.ID Queue string Retry types.Retry Timeout types.Duration Messages []*Message }
func NewEnvelope ¶
func NewEnvelope() *Envelope
func (*Envelope) AddMessage ¶
func (*Envelope) IsComposite ¶
type MultiDequeuer ¶
type MultiEnqueuer ¶
type MultiEnqueuer interface {
EnqueueAll([]*Envelope, []*EnqueueOptions) (map[string]*EnqueueMeta, error)
}
Click to show internal directories.
Click to hide internal directories.