Documentation ¶
Index ¶
- func Exit()
- func Init(host string)
- type RdsPool
- func (r *RdsPool) AddToQM(key string, queue string) chatable.CompoundError
- func (r *RdsPool) Dequeue(queue string) (chatable.PublicEnvelope, chatable.CompoundError)
- func (r *RdsPool) Enqueue(queue string, env chatable.PublicEnvelope) chatable.CompoundError
- func (r *RdsPool) QMMembers(key string) ([]string, chatable.CompoundError)
- func (r *RdsPool) RemoveFromQM(key string, queue string) chatable.CompoundError
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type RdsPool ¶
type RdsPool struct {
// contains filtered or unexported fields
}
func (*RdsPool) AddToQM ¶
func (r *RdsPool) AddToQM(key string, queue string) chatable.CompoundError
func (*RdsPool) Dequeue ¶
func (r *RdsPool) Dequeue(queue string) (chatable.PublicEnvelope, chatable.CompoundError)
Dequeue pops the first element from the given queue. This is a blocking operation.
func (*RdsPool) Enqueue ¶
func (r *RdsPool) Enqueue(queue string, env chatable.PublicEnvelope) chatable.CompoundError
Enqueue pushes a PublicEnvelope into the tail of a given queue.
func (*RdsPool) QMMembers ¶
func (r *RdsPool) QMMembers(key string) ([]string, chatable.CompoundError)
func (*RdsPool) RemoveFromQM ¶
func (r *RdsPool) RemoveFromQM(key string, queue string) chatable.CompoundError
Click to show internal directories.
Click to hide internal directories.