transport

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

type DebugHandler func(message string)

type MessageHandler func(message []byte) ([]byte, error)

type Transport interface {
	// Initialize initializes the transport
	Initialize() error

	// Start starts the transport
	Start() error

	// Stop stops the transport
	Stop() error

	// Send sends a message over the transport.
	Send(message []byte) error

	// Receive receives a message from the transport.
	Receive() ([]byte, error)

	// SetMessageHandler sets the message handler
	SetMessageHandler(handler MessageHandler)

	// SetDebugHandler sets a handler for debug messages
	SetDebugHandler(handler DebugHandler)
}