messages

type AOR struct {
	Host      string `json:"host"`
	Port      string `json:"port"`
	Id        int    `json:"id"`
	ProxyName string `json:"proxy"`
}

type CRHInfo struct {
	EndPoint    EndPoint
	Protocols   map[string]generic.Protocol
	Conns       map[string]net.Conn
	QuicConns   map[string]quic.Connection
	QuicStreams map[string]quic.Stream
	RpcClient   map[string]*rpc.Client
}

type Client struct {
	Ip             string
	Connection     net.Conn
	UDPConnection  *net.UDPConn
	QUICConnection quic.Connection
	QUICStream     quic.Stream
	AdaptId        int
}

type EndPoint struct {
	Host string
	Port string
}

type FunctionalReply struct {
	Rep interface{} `json:"Rep"`
}

type FunctionalRequest struct {
	Op     string        `json:"Op"`
	Params []interface{} `json:"Params"`
}

type Invocation struct {
	Endpoint          EndPoint
	Functionalrequest FunctionalRequest
}

type ProxyInfo struct {
	In_Channel  chan SAMessage
	Out_Channel chan SAMessage
}

type ReceivedMessages struct {
	ToAddress  string
	Conn       net.Conn
	QUICStream quic.Stream
	Msg        []byte
}

type RequestorInfo struct {
	Inv               Invocation
	MarshalledMessage []byte
}

type SAMReply struct {
	Rep interface{} `json:"Rep"`
}

type SAMRequest struct {
	Op     string        `json:"Op"`
	Params []interface{} `json:"Params"`
}

type SAMessage struct {
	From    string      `json:"From"`
	To      string      `json:"To"`
	ToAddr  string      `json:"ToAddr"`
	Payload interface{} `json:"Payload"`
}

type SRHInfo struct {
	EndPoint      EndPoint              // host, port
	Protocol      generic.Protocol      // generic.Protocol (TCP, UDP, QUIC)
	Ln            net.Listener          // Listener
	QUICLn        quic.Listener         // Listener
	Conns         []net.Conn            // Set of connections
	QUICConns     []quic.Connection     // Set of connections
	CurrentConn   net.Conn              // Current connection
	UDPConnection *net.UDPConn          // UDP Connection
	RcvedMessages chan ReceivedMessages // Buffer of messages received by the server
	Clients       []*Client             // Connection Pool, possible connected
	// Counter        int
	ExecuteForever *bool
}