Documentation ¶
Index ¶
- Variables
- type Client
- type CommandClient
- func (c *CommandClient) Addr() string
- func (c *CommandClient) ReconnectCount() int64
- func (c *CommandClient) Request(message *amqp.Message) (*amqp.Message, error)
- func (c *CommandClient) RequestWithTimeout(message *amqp.Message, timeout time.Duration) (*amqp.Message, error)
- func (c *CommandClient) Start()
- func (c *CommandClient) Stop()
Constants ¶
This section is empty.
Variables ¶
View Source
var (
RequestTimeoutError error = fmt.Errorf("request timed out")
)
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client interface { Addr() string Start() Stop() ReconnectCount() int64 RequestWithTimeout(message *amqp.Message, timeout time.Duration) (*amqp.Message, error) Request(message *amqp.Message) (*amqp.Message, error) }
func NewCommandClient ¶
type CommandClient ¶
type CommandClient struct {
// contains filtered or unexported fields
}
func (*CommandClient) Addr ¶
func (c *CommandClient) Addr() string
func (*CommandClient) ReconnectCount ¶
func (c *CommandClient) ReconnectCount() int64
func (*CommandClient) RequestWithTimeout ¶
func (*CommandClient) Start ¶
func (c *CommandClient) Start()
func (*CommandClient) Stop ¶
func (c *CommandClient) Stop()
Click to show internal directories.
Click to hide internal directories.