Documentation ¶
Index ¶
- func DefaultServer() (r *rpcx_server.Server)
- func NewRpcxServer(cfg *Cfg) (r *srv, err error)
- func SafeServer(name string) (r *srv, err error)
- func Server(name string) (r *srv)
- func StartDefaultServer(rcvr interface{}) (err error)
- func StartServer(name string, rcvr interface{}) (err error)
- func StopDefaultServer() (err error)
- func StopServer(name string) (err error)
- type Cfg
- type ServiceImpl
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DefaultServer ¶
func DefaultServer() (r *rpcx_server.Server)
func NewRpcxServer ¶
func SafeServer ¶
func StartDefaultServer ¶
func StartDefaultServer(rcvr interface{}) (err error)
func StartServer ¶
func StopDefaultServer ¶
func StopDefaultServer() (err error)
func StopServer ¶
Types ¶
type Cfg ¶
type Cfg struct { // dial DialAddr string `toml:"addr"` DialReadTimeout time.Duration `toml:"read_timeout"` DialWriteTimeout time.Duration `toml:"write_timeout"` // register, only support zookeeper RegisterServers []string `toml:"register_servers"` RegisterBasePath string `toml:"register_base_path"` RegisterUpdateInterval time.Duration `toml:"register_update_interval"` }
Click to show internal directories.
Click to hide internal directories.