test

package
v0.0.0-...-0e4f5d7 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 15, 2022 License: Apache-2.0 Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL