messages

Documentation

Index

• type AOR
• type CRHInfo
• type Client
  • func Remove(slice []*Client, idx int) []*Client
  • func (c Client) Initialize()
• type EndPoint
• type FunctionalReply
• type FunctionalRequest
• type Invocation
• type ProxyInfo
• type ReceivedMessages
• type RequestorInfo
• type SAMReply
• type SAMRequest
• type SAMessage
• type SRHInfo
  • func (i SRHInfo) GetClientFromAdaptId(adaptId int, clients []*Client) *Client
  • func (i SRHInfo) GetClientFromAddr(addr string, clients []*Client) *Client

Types

type AOR

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

type CRHInfo

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

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

func Remove

func Remove(slice []*Client, idx int) []*Client

func (Client) Initialize

func (c Client) Initialize()

type EndPoint

type EndPoint struct {
	Host string
	Port string
}

type FunctionalReply

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

type FunctionalRequest

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

type Invocation

type Invocation struct {
	Endpoint          EndPoint
	Functionalrequest FunctionalRequest
}

type ProxyInfo

type ProxyInfo struct {
	In_Channel  chan SAMessage
	Out_Channel chan SAMessage
}

type ReceivedMessages

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

type RequestorInfo

type RequestorInfo struct {
	Inv               Invocation
	MarshalledMessage []byte
}

type SAMReply

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

type SAMRequest

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

type SAMessage

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

Software architecture message

type SRHInfo

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
}

func (SRHInfo) GetClientFromAdaptId

func (i SRHInfo) GetClientFromAdaptId(adaptId int, clients []*Client) *Client

func (SRHInfo) GetClientFromAddr

func (i SRHInfo) GetClientFromAddr(addr string, clients []*Client) *Client