consul

Documentation

Index

• Variables
• func BalanceInit()
• func ConsulManagerInit()
• func GetBalanceAddr(name string) string
• func GetConsulSrv(name string) map[string]*ConsulManager
• func RegisterBalance(name string)
• type Balance
  • func (b *Balance) Add(v interface{})
  • func (b *Balance) Make(size int)
  • func (b *Balance) Roll() interface{}
• type ConsulManager
  • func GetConsulManager() *ConsulManager
  • func (c *ConsulManager) DeRegisterSrv(SrvId string) error
  • func (c *ConsulManager) FindAllSrvs() error
  • func (c *ConsulManager) RegisterApiSrv() error

Variables

var ConsulServices = make(map[string]*ConsulManager)

Functions

func BalanceInit

func BalanceInit()

func ConsulManagerInit

func ConsulManagerInit()

func GetBalanceAddr

func GetBalanceAddr(name string) string

func GetConsulSrv

func GetConsulSrv(name string) map[string]*ConsulManager

func RegisterBalance

func RegisterBalance(name string)

Types

type Balance

type Balance struct {
	// contains filtered or unexported fields
}

var (
	BalanceSysParam *Balance = nil
	BalanceUser     *Balance = nil
	BalanceNobility *Balance = nil
	BalanceGift     *Balance = nil
	BalanceShop     *Balance = nil
	BalanceLive     *Balance = nil
)

func (*Balance) Add

func (b *Balance) Add(v interface{})

添加节点数据

func (*Balance) Make

func (b *Balance) Make(size int)

func (*Balance) Roll

func (b *Balance) Roll() interface{}

轮询

type ConsulManager

type ConsulManager struct {
	Addr    string
	Port    int
	Name    string
	Id      string
	SrvAddr string
}

func GetConsulManager

func GetConsulManager() *ConsulManager

func (*ConsulManager) DeRegisterSrv

func (c *ConsulManager) DeRegisterSrv(SrvId string) error

取消consul注册的服务

func (*ConsulManager) FindAllSrvs

func (c *ConsulManager) FindAllSrvs() error

func (*ConsulManager) RegisterApiSrv

func (c *ConsulManager) RegisterApiSrv() error