test

Documentation

Index

• type FakeClient
  • func NewFakeClient() *FakeClient
  • func (c *FakeClient) Addr() string
  • func (c *FakeClient) AwaitRunning()
  • func (c *FakeClient) Connected() bool
  • func (c *FakeClient) ReconnectCount() int64
  • func (c *FakeClient) Request(message *amqp.Message) (*amqp.Message, error)
  • func (c *FakeClient) RequestWithTimeout(message *amqp.Message, timeout time.Duration) (*amqp.Message, error)
  • func (c *FakeClient) Start()
  • func (c *FakeClient) Stop()
• type RequestHandler

Types

type FakeClient

type FakeClient struct {
	Handler RequestHandler
}

func NewFakeClient

func NewFakeClient() *FakeClient

func (*FakeClient) Addr

func (c *FakeClient) Addr() string

func (*FakeClient) AwaitRunning

func (c *FakeClient) AwaitRunning()

func (*FakeClient) Connected

func (c *FakeClient) Connected() bool

func (*FakeClient) ReconnectCount

func (c *FakeClient) ReconnectCount() int64

func (*FakeClient) Request

func (c *FakeClient) Request(message *amqp.Message) (*amqp.Message, error)

func (*FakeClient) RequestWithTimeout

func (c *FakeClient) RequestWithTimeout(message *amqp.Message, timeout time.Duration) (*amqp.Message, error)

func (*FakeClient) Start

func (c *FakeClient) Start()

func (*FakeClient) Stop

func (c *FakeClient) Stop()

type RequestHandler

type RequestHandler = func(m *amqp.Message) (*amqp.Message, error)