testingutils

Documentation

Index

• type MockTransport
  • func NewMockTransport() *MockTransport
  • func (t *MockTransport) Close() error
  • func (t *MockTransport) GetMessages() []*transport.BaseJsonRpcMessage
  • func (t *MockTransport) IsClosed() bool
  • func (t *MockTransport) IsStarted() bool
  • func (t *MockTransport) Send(ctx context.Context, message *transport.BaseJsonRpcMessage) error
  • func (t *MockTransport) SetCloseHandler(handler func())
  • func (t *MockTransport) SetErrorHandler(handler func(error))
  • func (t *MockTransport) SetMessageHandler(handler func(ctx context.Context, message *transport.BaseJsonRpcMessage))
  • func (t *MockTransport) SimulateError(err error)
  • func (t *MockTransport) SimulateMessage(msg *transport.BaseJsonRpcMessage)
  • func (t *MockTransport) Start(ctx context.Context) error

Types

type MockTransport

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

MockTransport implements Transport interface for testing

func NewMockTransport

func NewMockTransport() *MockTransport

func (*MockTransport) Close

func (t *MockTransport) Close() error

func (*MockTransport) GetMessages

func (t *MockTransport) GetMessages() []*transport.BaseJsonRpcMessage

func (*MockTransport) IsClosed

func (t *MockTransport) IsClosed() bool

func (*MockTransport) IsStarted

func (t *MockTransport) IsStarted() bool

func (*MockTransport) Send

func (t *MockTransport) Send(ctx context.Context, message *transport.BaseJsonRpcMessage) error

func (*MockTransport) SetCloseHandler

func (t *MockTransport) SetCloseHandler(handler func())

func (*MockTransport) SetErrorHandler

func (t *MockTransport) SetErrorHandler(handler func(error))

func (*MockTransport) SetMessageHandler

func (t *MockTransport) SetMessageHandler(handler func(ctx context.Context, message *transport.BaseJsonRpcMessage))

func (*MockTransport) SimulateError

func (t *MockTransport) SimulateError(err error)

func (*MockTransport) SimulateMessage

func (t *MockTransport) SimulateMessage(msg *transport.BaseJsonRpcMessage)

func (*MockTransport) Start

func (t *MockTransport) Start(ctx context.Context) error