beanstalkd

Documentation

Overview

Package beanstalkd is a higher level wrapper to utilize beanstalkd as a simple message queue. It removes some good features like reserve-delete mechanism, reserve with timeout, etc. Offical beanstalk libary should be used for such features. NOTE: This client doesn't support concurrent Get/Put operations.

Index

• type Client
  • func Dial(addr string, tubeName string) *Client
  • func (c *Client) Close()
  • func (c *Client) Get() []byte
  • func (c *Client) GetOrNull() []byte
  • func (c *Client) Len() int
  • func (c *Client) Put(d []byte) error
  • func (c *Client) PutWithPriority(d []byte, pri uint32) error
  • func (c *Client) Reconnect() error

Types

type Client

type Client struct {
	// contains filtered or unexported fields
}

func Dial

func Dial(addr string, tubeName string) *Client

func (*Client) Close

func (c *Client) Close()

func (*Client) Get

func (c *Client) Get() []byte

Get returns a job from a tube, blocking.

func (*Client) GetOrNull

func (c *Client) GetOrNull() []byte

Get returns a job from a tube. Non-blocking. When no jobs, return nil.

func (*Client) Len

func (c *Client) Len() int

func (*Client) Put

func (c *Client) Put(d []byte) error

Put the data into tube.

func (*Client) PutWithPriority

func (c *Client) PutWithPriority(d []byte, pri uint32) error

func (*Client) Reconnect

func (c *Client) Reconnect() error