Documentation
¶
Index ¶
- type MockTransport
- func (m *MockTransport) Close() error
- func (m *MockTransport) EndInput() error
- func (m *MockTransport) IsReady() bool
- func (m *MockTransport) ReadMessages(_ context.Context) (<-chan map[string]any, <-chan error)
- func (m *MockTransport) SendInbound(msg map[string]any)
- func (m *MockTransport) SendMessage(_ context.Context, data []byte) error
- func (m *MockTransport) SentMessages() []map[string]any
- func (m *MockTransport) Start(_ context.Context) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockTransport ¶
type MockTransport struct {
OnSend func(map[string]any)
InitializePayload map[string]any
// contains filtered or unexported fields
}
MockTransport is a reusable transport for tests. It can auto-respond to initialize control requests and records outbound messages for inspection.
func NewMockTransport ¶
func NewMockTransport() *MockTransport
func (*MockTransport) Close ¶
func (m *MockTransport) Close() error
func (*MockTransport) EndInput ¶
func (m *MockTransport) EndInput() error
func (*MockTransport) IsReady ¶
func (m *MockTransport) IsReady() bool
func (*MockTransport) ReadMessages ¶
func (*MockTransport) SendInbound ¶
func (m *MockTransport) SendInbound(msg map[string]any)
func (*MockTransport) SendMessage ¶
func (m *MockTransport) SendMessage(_ context.Context, data []byte) error
func (*MockTransport) SentMessages ¶
func (m *MockTransport) SentMessages() []map[string]any
Source Files
Click to show internal directories.
Click to hide internal directories.