forward

type BidirectionalMuxForwarder interface {
	ForwardBidirectionalMux(
		ctx context.Context,
		localConn net.Conn,
		muxConn io.ReadWriter,
		connID string,
		encoder MuxEncoder,
		decoder MuxDecoder,
	) error
}

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

type DataMessage struct {
	ConnID string // Connection ID
	Data   []byte // Data
}

type DefaultMuxDecoder struct {
	Delimiter byte
}

type DefaultMuxEncoder struct {
	Delimiter byte
	// contains filtered or unexported fields
}

type Forwarder interface {
	// Forward copies data from src to dst.
	Forward(src, dst net.Conn) error
}

type HTTPMuxForwarder interface {
	ForwardHTTP(ctx context.Context, reqData []byte, muxConn io.ReadWriter, reqID string, encoder MuxEncoder, decoder MuxDecoder, timeout time.Duration) ([]byte, error)
}

type Message struct {
	Type    MessageType // Message type
	ID      string      // Connection ID or Request ID
	Payload []byte      // Data payload
}

type MessageType int

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

type MuxConnStats struct {
	ActiveConnections int64
	TotalConnections  int64
	BytesIn           int64
	BytesOut          int64
}

type MuxDecoder interface {
	// Decode decodes a message.
	// Returns the message type, ID (conn_id or req_id), payload, and error.
	Decode(data []byte) (msgType MessageType, id string, payload []byte, err error)
}

type MuxEncoder interface {
	// EncodeData encodes a data message.
	EncodeData(connID string, data []byte) ([]byte, error)

	// EncodeClose encodes a close message.
	EncodeClose(connID string) ([]byte, error)

	// EncodeRequest encodes an HTTP request message.
	EncodeRequest(reqID string, data []byte) ([]byte, error)

	// EncodeResponse encodes an HTTP response message.
	EncodeResponse(reqID string, data []byte) ([]byte, error)

	// EncodeNewConn encodes a new connection notification.
	EncodeNewConn(connID, remoteAddr string) ([]byte, error)

	// Release releases the encoded buffer back to pool (optional).
	Release(buf []byte)
}

type MuxForwarder interface {
	// ForwardMux forwards data from localConn to muxConn with protocol encapsulation.
	ForwardMux(ctx context.Context, localConn net.Conn, muxConn io.Writer, connID string, encoder MuxEncoder) error
}

type NewConnMessage struct {
	ConnID     string // Connection ID
	RemoteAddr string // Remote address
}

type NewConnNotification struct {
	ConnID     string
	RemoteAddr string
}