queue

Documentation

Index

• type Client
  • func NewClient(options ...func(*Client)) *Client
  • func (c *Client) Pull(ctx context.Context, fn func(context.Context, []byte) error) error
  • func (c *Client) Push(_ context.Context, content []byte) error

Types

type Client

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

Client implements the queue interface.

func NewClient

func NewClient(options ...func(*Client)) *Client

NewClient return a configured client.

func (*Client) Pull

func (c *Client) Pull(ctx context.Context, fn func(context.Context, []byte) error) error

Pull fetch a message from queue.

func (*Client) Push

func (c *Client) Push(_ context.Context, content []byte) error

Push the message to queue.