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
	Conns    map[string]net.Conn
}

type Client

type Client struct {
	Ip            string
	Connection    net.Conn
	UDPConnection *net.UDPConn
	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
	Chn       net.Conn
	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
	Ln             net.Listener          // Listener
	Conns          []net.Conn            // 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