memqclient

Documentation

Index

• type Client
  • func (c *Client) CreateQueue(queue string) error
  • func (c *Client) DeleteQueue(queue string) error
  • func (c *Client) Dequeue(queue string) (*memq.Message, error)
  • func (c *Client) DrainQueue(queue string) error
  • func (c *Client) Enqueue(queue, data string) (*memq.Message, error)
  • func (c *Client) Stats() (*memq.Stats, error)

Types

type Client

type Client struct {
	BaseServerURL string
}

func (*Client) CreateQueue

func (c *Client) CreateQueue(queue string) error

func (*Client) DeleteQueue

func (c *Client) DeleteQueue(queue string) error

func (*Client) Dequeue

func (c *Client) Dequeue(queue string) (*memq.Message, error)

Dequeue takes an item off of queue from the server. If a nil message is returned with no error then the queue is empty.

func (*Client) DrainQueue

func (c *Client) DrainQueue(queue string) error

func (*Client) Enqueue

func (c *Client) Enqueue(queue, data string) (*memq.Message, error)

func (*Client) Stats

func (c *Client) Stats() (*memq.Stats, error)