Documentation ¶
Index ¶
- type Message
- type Queue
- type Redis
- func (r *Redis) ChangeMessageVisibility(queueName, id string, visibility int) error
- func (r *Redis) CreateQueue(queueName string, vt, delay uint, maxsize int) error
- func (r *Redis) DeleteMessage(queueName, id string) error
- func (r *Redis) DeleteQueue(queueName string) error
- func (r *Redis) GetQueueAttributes(queueName string) (*Queue, error)
- func (r *Redis) GetQueueMessageCount(queueName string) (int, error)
- func (r *Redis) ListQueues() ([]string, error)
- func (r *Redis) ReceiveMessage(queueName string) (*Message, error)
- func (r *Redis) SendMessage(queueName, message string) (string, error)
- func (r *Redis) SetQueueAttributes(queueName string, vt, delay, maxsize int) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Message ¶
type Message struct { ID string Message string Receipt string Visible bool Received int // Number of times the message has been received Sent time.Time // Time when the message was sent FirstSeen time.Time }
Message struct
type Queue ¶
type Queue struct { Name string Vt int Delay int Maxsize int Created time.Time Modified time.Time TotalSent int TotalReceived int Msgs int // Number of messages in the queue Hiddenmsgs int // Number of hidden messages in the queue }
Queue struct
type Redis ¶
type Redis struct {
// contains filtered or unexported fields
}
Redis is the client of rsmq to execute queue and message operations
func (*Redis) ChangeMessageVisibility ¶
ChangeMessageVisibility changes the visibility of a message
func (*Redis) CreateQueue ¶
CreateQueue creates a new queue with the given name
func (*Redis) DeleteMessage ¶
DeleteMessage deletes a message from the specified queue
func (*Redis) DeleteQueue ¶
DeleteQueue deletes the specified queue
func (*Redis) GetQueueAttributes ¶
GetQueueAttributes returns the attributes of the specified queue
func (*Redis) GetQueueMessageCount ¶
GetQueueMessageCount returns the number of messages in the specified queue
func (*Redis) ListQueues ¶
ListQueues returns a list of all queues
func (*Redis) ReceiveMessage ¶
ReceiveMessage receives a message from the specified queue
func (*Redis) SendMessage ¶
SendMessage sends a new message to the specified queue
Click to show internal directories.
Click to hide internal directories.