client

Documentation

Index

• Variables
• type Client
  • func New(url, serverExchange, clientExchange string, opts ...Option) (*Client, error)
  • func (c *Client) Notify() <-chan error
  • func (c *Client) RemoteCall(handler string, request, response interface{}) error
  • func (c *Client) Shutdown() error
• type Message
• type Option
  • func ConnAttempts(attempts int) Option
  • func ConnWaitTime(timeout time.Duration) Option
  • func Timeout(timeout time.Duration) Option

Variables

var ErrConnectionClosed = errors.New("rmq_rpc client - Client - RemoteCall - Connection closed")

ErrConnectionClosed -.

Types

type Client

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

Client -.

func New

func New(url, serverExchange, clientExchange string, opts ...Option) (*Client, error)

New -.

func (*Client) Notify

func (c *Client) Notify() <-chan error

Notify -.

func (*Client) RemoteCall

func (c *Client) RemoteCall(handler string, request, response interface{}) error

RemoteCall -.

func (*Client) Shutdown

func (c *Client) Shutdown() error

Shutdown -.

type Message

type Message struct {
	Queue         string
	Priority      uint8
	ContentType   string
	Body          []byte
	ReplyTo       string
	CorrelationID string
}

Message -.

type Option

type Option func(*Client)

Option -.

func ConnAttempts

func ConnAttempts(attempts int) Option

ConnAttempts -.

func ConnWaitTime

func ConnWaitTime(timeout time.Duration) Option

ConnWaitTime -.

func Timeout

func Timeout(timeout time.Duration) Option

Timeout -.