rpc

func (*Client) Call ¶

func (client *Client) Call(serviceMethod string, args any, reply any) error

Invoke RPC method

func (*Client) Connect ¶

func (client *Client) Connect() error

Connect to RPC server. Blocking

Idempotent. Returns nil if already connected. Each call to this function must be followed by a corresponding disconnect

func (*Client) Disconnect ¶

func (client *Client) Disconnect() error

Disconnect from RPC server.

Idempotent. Returns nil if already disconnected

func (*Server) Down ¶

func (server *Server) Down() error

Shutdown RPC server. Blocks until all connections to the server are terminated. Successful call indicates that server can be started again

Idempotent. Returns nil if already stopped

func (*Server) Register ¶

func (server *Server) Register(rcvr any) error

Register rcvr object as RPC receiver. Having multiple receivers of different types is allowed

func (*Server) Up ¶

func (server *Server) Up() error

Begin to accept incoming RPS requests. Non-blocking

Idempotent. Returns nil if already running i.e. has not been stopped since the last startup. Each call to this function must be followed by a corresponding shutdown