Versions in this module Expand all Collapse all v1 v1.14.9 Nov 7, 2023 Changes in this version + type HTTP struct + func (st *HTTP) AddClient(client generic.Client, idx int) + func (st *HTTP) AvailableConnectionFromPool() (available bool, idx int) + func (st *HTTP) CloseConnection() + func (st *HTTP) ConnectToServer(ip, port string) + func (st *HTTP) GetClient(idx int) (client generic.Client) + func (st *HTTP) GetClientFromAddr(addr string) (client generic.Client) + func (st *HTTP) GetClients() (client []*generic.Client) + func (st *HTTP) ReadString() (message string) + func (st *HTTP) Receive() ([]byte, error) + func (st *HTTP) ResetClients() + func (st *HTTP) Send(msgToServer []byte) error + func (st *HTTP) StartServer(ip, port string, initialConnections int) + func (st *HTTP) StopServer() + func (st *HTTP) WaitForConnection(cliIdx int) (cl *generic.Client) + func (st *HTTP) WriteString(message string) + type HTTP2 struct + func (st *HTTP2) AddClient(client generic.Client, idx int) + func (st *HTTP2) AvailableConnectionFromPool() (available bool, idx int) + func (st *HTTP2) CloseConnection() + func (st *HTTP2) ConnectToServer(ip, port string) + func (st *HTTP2) GetClient(idx int) (client generic.Client) + func (st *HTTP2) GetClientFromAddr(addr string) (client generic.Client) + func (st *HTTP2) GetClients() (client []*generic.Client) + func (st *HTTP2) ReadString() (message string) + func (st *HTTP2) Receive() ([]byte, error) + func (st *HTTP2) ResetClients() + func (st *HTTP2) Send(msgToServer []byte) error + func (st *HTTP2) StartServer(ip, port string, initialConnections int) + func (st *HTTP2) StopServer() + func (st *HTTP2) WaitForConnection(cliIdx int) (cl *generic.Client) + func (st *HTTP2) WriteString(message string) + type HTTP2Client struct + Ip string + func (cl *HTTP2Client) AdaptId() int + func (cl *HTTP2Client) Address() string + func (cl *HTTP2Client) CloseConnection() + func (cl *HTTP2Client) Connection() interface{} + func (cl *HTTP2Client) Read(b []byte) (err error) + func (cl *HTTP2Client) ReadString() (message string) + func (cl *HTTP2Client) Receive() (msg []byte, err error) + func (cl *HTTP2Client) Send(msg []byte) error + func (cl *HTTP2Client) SetAdaptId(adaptId int) + func (cl *HTTP2Client) WriteString(message string) + type HTTP2Request struct + func (rq HTTP2Request) Request(w http.ResponseWriter, r *http.Request) + func (rq HTTP2Request) ServeHTTP(w http.ResponseWriter, r *http.Request) + type HTTPClient struct + Ip string + func (cl *HTTPClient) AdaptId() int + func (cl *HTTPClient) Address() string + func (cl *HTTPClient) CloseConnection() + func (cl *HTTPClient) Connection() interface{} + func (cl *HTTPClient) Read(b []byte) (err error) + func (cl *HTTPClient) ReadString() (message string) + func (cl *HTTPClient) Receive() (msg []byte, err error) + func (cl *HTTPClient) Send(msg []byte) error + func (cl *HTTPClient) SetAdaptId(adaptId int) + func (cl *HTTPClient) WriteString(message string) + type HTTPRequest struct + func (rq HTTPRequest) Request(w http.ResponseWriter, r *http.Request) + func (rq HTTPRequest) ServeHTTP(w http.ResponseWriter, r *http.Request) + type HTTPS struct + func (st *HTTPS) AddClient(client generic.Client, idx int) + func (st *HTTPS) AvailableConnectionFromPool() (available bool, idx int) + func (st *HTTPS) CloseConnection() + func (st *HTTPS) ConnectToServer(ip, port string) + func (st *HTTPS) GetClient(idx int) (client generic.Client) + func (st *HTTPS) GetClientFromAddr(addr string) (client generic.Client) + func (st *HTTPS) GetClients() (client []*generic.Client) + func (st *HTTPS) ReadString() (message string) + func (st *HTTPS) Receive() ([]byte, error) + func (st *HTTPS) ResetClients() + func (st *HTTPS) Send(msgToServer []byte) error + func (st *HTTPS) StartServer(ip, port string, initialConnections int) + func (st *HTTPS) StopServer() + func (st *HTTPS) WaitForConnection(cliIdx int) (cl *generic.Client) + func (st *HTTPS) WriteString(message string) + type HTTPSClient struct + Ip string + func (cl *HTTPSClient) AdaptId() int + func (cl *HTTPSClient) Address() string + func (cl *HTTPSClient) CloseConnection() + func (cl *HTTPSClient) Connection() interface{} + func (cl *HTTPSClient) Read(b []byte) (err error) + func (cl *HTTPSClient) ReadString() (message string) + func (cl *HTTPSClient) Receive() (msg []byte, err error) + func (cl *HTTPSClient) Send(msg []byte) error + func (cl *HTTPSClient) SetAdaptId(adaptId int) + func (cl *HTTPSClient) WriteString(message string) + type HTTPSRequest struct + func (rq HTTPSRequest) Request(w http.ResponseWriter, r *http.Request) + func (rq HTTPSRequest) ServeHTTP(w http.ResponseWriter, r *http.Request) + type RPC struct + func (st *RPC) AddClient(client generic.Client, idx int) + func (st *RPC) AvailableConnectionFromPool() (available bool, idx int) + func (st *RPC) Call(serviceMethod string, args any, reply any) (err error) + func (st *RPC) CloseConnection() + func (st *RPC) ConnectToServer(ip, port string) + func (st *RPC) GetClient(idx int) (client generic.Client) + func (st *RPC) GetClientFromAddr(addr string) (client generic.Client) + func (st *RPC) GetClients() (client []*generic.Client) + func (st *RPC) ReadString() (message string) + func (st *RPC) Receive() ([]byte, error) + func (st *RPC) ResetClients() + func (st *RPC) Send(msgToServer []byte) error + func (st *RPC) StartServer(ip, port string, initialConnections int) + func (st *RPC) StopServer() + func (st *RPC) WaitForConnection(cliIdx int) (cl *generic.Client) + func (st *RPC) WriteString(message string) + type RPCClient struct + Ip string + func (cl *RPCClient) AdaptId() int + func (cl *RPCClient) Address() string + func (cl *RPCClient) CloseConnection() + func (cl *RPCClient) Connection() interface{} + func (cl *RPCClient) Read(b []byte) (err error) + func (cl *RPCClient) ReadString() (message string) + func (cl *RPCClient) Receive() (msg []byte, err error) + func (cl *RPCClient) Send(msg []byte) error + func (cl *RPCClient) SetAdaptId(adaptId int) + func (cl *RPCClient) WriteString(message string) + type RPCRequest struct + func (rq RPCRequest) Request(request []byte, reply *[]byte) error + type TCP struct + func (st *TCP) AddClient(client generic.Client, idx int) + func (st *TCP) AvailableConnectionFromPool() (available bool, idx int) + func (st *TCP) CloseConnection() + func (st *TCP) ConnectToServer(ip, port string) + func (st *TCP) GetClient(idx int) (client generic.Client) + func (st *TCP) GetClientFromAddr(addr string) (client generic.Client) + func (st *TCP) GetClients() (client []*generic.Client) + func (st *TCP) ReadString() (message string) + func (st *TCP) Receive() ([]byte, error) + func (st *TCP) ResetClients() + func (st *TCP) Send(msgToServer []byte) error + func (st *TCP) StartServer(ip, port string, initialConnections int) + func (st *TCP) StopServer() + func (st *TCP) WaitForConnection(cliIdx int) (cl *generic.Client) + func (st *TCP) WriteString(message string) + type TCPClient struct + Ip string + func (cl *TCPClient) AdaptId() int + func (cl *TCPClient) Address() string + func (cl *TCPClient) CloseConnection() + func (cl *TCPClient) Connection() interface{} + func (cl *TCPClient) Read(b []byte) (err error) + func (cl *TCPClient) ReadString() (message string) + func (cl *TCPClient) Receive() (msg []byte, err error) + func (cl *TCPClient) Send(msg []byte) error + func (cl *TCPClient) SetAdaptId(adaptId int) + func (cl *TCPClient) WriteString(message string)