Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( DefaultHeartBeat uint64 = 10 DefaultRetryTimes = 3 )
Functions ¶
This section is empty.
Types ¶
type DogRegister ¶
type DogRegister interface { Start() error Close() SetRootNode(node string) error GetRootNode() (root string) SetHeartBeat(heartBeat time.Duration) SetOffline(offline bool) }
register server
type EtcdConfig ¶
type EtcdConfig struct { Host []string // etcd server host Root string // root path Group string // service group Service string // service name NodeInfo service.NodeInfo // service node info HeartBeat uint64 // heartbeat Environ string // service run environment TlsConfig *tls.Config // service tls config }
server path : /root/group/service/environ/pool/ip:port
type EtcdRegister ¶
type EtcdRegister struct { EtcdConfig *EtcdConfig `inject:"etcdConfig" canNil:"true"` EtcdConf *ini.File `inject:"etcdConf" canNil:"true"` EtcdConfPath string `inject:"etcdConfPath" canNil:"true"` // contains filtered or unexported fields }
func (*EtcdRegister) Close ¶
func (e *EtcdRegister) Close()
func (*EtcdRegister) GetRootNode ¶
func (e *EtcdRegister) GetRootNode() (root string)
func (*EtcdRegister) SetHeartBeat ¶
func (e *EtcdRegister) SetHeartBeat(heartBeat time.Duration)
func (*EtcdRegister) SetOffline ¶
func (e *EtcdRegister) SetOffline(offline bool)
func (*EtcdRegister) SetRootNode ¶
func (e *EtcdRegister) SetRootNode(root string) (err error)
func (*EtcdRegister) Start ¶
func (e *EtcdRegister) Start() error
type ZkRegister ¶
type ZkRegister struct { ZkConfig *ZkConfig `inject:"zkConfig" canNil:"true"` ZkConf *ini.File `inject:"zkConf" canNil:"true"` ZkConfPath string `inject:"zkConfPath" canNil:"true"` // contains filtered or unexported fields }
func (*ZkRegister) Close ¶
func (z *ZkRegister) Close()
func (*ZkRegister) GetRootNode ¶
func (z *ZkRegister) GetRootNode() (root string)
func (*ZkRegister) SetHeartBeat ¶
func (z *ZkRegister) SetHeartBeat(heartBeat time.Duration)
func (*ZkRegister) SetOffline ¶
func (z *ZkRegister) SetOffline(offline bool)
func (*ZkRegister) SetRootNode ¶
func (z *ZkRegister) SetRootNode(root string) (err error)
func (*ZkRegister) Start ¶
func (z *ZkRegister) Start() error
Click to show internal directories.
Click to hide internal directories.