types

type Logger interface {
	// Debug logs a debug message.
	Debug(msg string, args ...interface{})

	// Info logs an informational message.
	Info(msg string, args ...interface{})

	// Warn logs a warning message.
	Warn(msg string, args ...interface{})

	// Error logs an error message.
	Error(msg string, args ...interface{})
}

type MessageHandler func(data []byte) error

type Transport interface {
	// Send transmits a message over the transport.
	// It returns an error if the message could not be sent.
	Send(data []byte) error

	// Receive blocks until a message is received or an error occurs.
	// It returns the received message as a byte slice and any error that occurred.
	Receive() ([]byte, error)

	// ReceiveWithContext is like Receive but respects the provided context.
	// It allows for cancellation and timeouts when waiting for messages.
	ReceiveWithContext(ctx context.Context) ([]byte, error)

	// Close terminates the transport connection.
	// After Close is called, the transport should not be used.
	Close() error
}

type TransportFactory interface {
	// NewTransport creates a new Transport instance.
	NewTransport() (Transport, error)

	// NewTransportWithOptions creates a new Transport instance with the specified options.
	NewTransportWithOptions(opts TransportOptions) (Transport, error)
}

type TransportOptions struct {
	// BufferSize specifies the size of the read/write buffers.
	BufferSize int

	// Logger is used for logging transport-related events.
	Logger Logger

	// Custom options can be provided as key-value pairs.
	Custom map[string]interface{}
}