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.