simple_rpc

Documentation

Index

• func Call(srv string, port int, rpcname string, args interface{}, reply interface{}) error
• func ListenRPC(port int) error
• func NewSimpleRpc(host string, port int) proto.ISimpleRpc
• func Pub(srv string, port int, rpcname string, args interface{}, reply interface{}) error
• func Regiseter(rcvrs ...interface{}) error
• func TimeoutCoder(f func(interface{}) error, e interface{}, msg string) error
• type SimpleRpc
  • func (sp *SimpleRpc) Call(rpcname string, args interface{}, reply interface{}) error
  • func (sp *SimpleRpc) ListenRPC() error
  • func (sp *SimpleRpc) Pub(rpcname string, args interface{}, reply interface{}) error
  • func (sp *SimpleRpc) RegisterRpc(rcvrs ...interface{}) error

Functions

func Call

func Call(srv string, port int, rpcname string, args interface{}, reply interface{}) error

func ListenRPC

func ListenRPC(port int) error

func NewSimpleRpc

func NewSimpleRpc(host string, port int) proto.ISimpleRpc

func Pub

func Pub(srv string, port int, rpcname string, args interface{}, reply interface{}) error

func Regiseter

func Regiseter(rcvrs ...interface{}) error

func TimeoutCoder

func TimeoutCoder(f func(interface{}) error, e interface{}, msg string) error

Types

type SimpleRpc

type SimpleRpc struct {
	Host string
	Port int
}

func (*SimpleRpc) Call

func (sp *SimpleRpc) Call(rpcname string, args interface{}, reply interface{}) error

func (*SimpleRpc) ListenRPC

func (sp *SimpleRpc) ListenRPC() error

func (*SimpleRpc) Pub

func (sp *SimpleRpc) Pub(rpcname string, args interface{}, reply interface{}) error

func (*SimpleRpc) RegisterRpc

func (sp *SimpleRpc) RegisterRpc(rcvrs ...interface{}) error