register

Documentation

Index

• Variables
• type DogRegister
• type EtcdConfig
• type EtcdRegister
  • func (e *EtcdRegister) Close()
  • func (e *EtcdRegister) GetRootNode() (root string)
  • func (e *EtcdRegister) SetHeartBeat(heartBeat time.Duration)
  • func (e *EtcdRegister) SetOffline(offline bool)
  • func (e *EtcdRegister) SetRootNode(root string) (err error)
  • func (e *EtcdRegister) Start() error
• type ZkConfig
• type ZkRegister
  • func (z *ZkRegister) Close()
  • func (z *ZkRegister) GetRootNode() (root string)
  • func (z *ZkRegister) SetHeartBeat(heartBeat time.Duration)
  • func (z *ZkRegister) SetOffline(offline bool)
  • func (z *ZkRegister) SetRootNode(root string) (err error)
  • func (z *ZkRegister) Start() error

Variables

var (
	DefaultHeartBeat  uint64 = 10
	DefaultRetryTimes        = 3
)

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 ZkConfig

type ZkConfig struct {
	Host     []string         // zk server host
	Root     string           // root path
	Group    string           // service group
	Service  string           // service name
	NodeInfo service.NodeInfo // service node info
	Environ  string           //service run environment
}

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