zookeeper

Documentation

Index

• func NewService(cfg config.Config, points server.EndPoints) (service.Service, error)
• func NewZookeeperClient(sn server.Node, eps server.EndPoints) (service.Client, error)
• type Base
  • func (base *Base) Get(key model.Key) ([]*model.KVData, error)
  • func (base *Base) Set(data model.KVData) error
• type ZkClient
  • func (client *ZkClient) Address() string
  • func (client *ZkClient) GetKvConfig() service.KVConfig
  • func (client *ZkClient) Resolve(sn server.Node) []builder.Address
• type ZkService
  • func (s *ZkService) GetHealthCheck() service.Health
  • func (s *ZkService) GetKvConfig() service.KVConfig
  • func (s *ZkService) Start()
  • func (s *ZkService) Stop()

Functions

func NewService

func NewService(cfg config.Config, points server.EndPoints) (service.Service, error)

注册一个服务

func NewZookeeperClient

func NewZookeeperClient(sn server.Node, eps server.EndPoints) (service.Client, error)

Types

type Base

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

func (*Base) Get

func (base *Base) Get(key model.Key) ([]*model.KVData, error)

KVBuilder interface

func (*Base) Set

func (base *Base) Set(data model.KVData) error

KVBuilder interface

type ZkClient

type ZkClient struct {
	Base
	resolver2.Builder
	// contains filtered or unexported fields
}

func (*ZkClient) Address

func (client *ZkClient) Address() string

Client interface

func (*ZkClient) GetKvConfig

func (client *ZkClient) GetKvConfig() service.KVConfig

Client interface

func (*ZkClient) Resolve

func (client *ZkClient) Resolve(sn server.Node) []builder.Address

*

• @return param2 = server config https://github.com/grpc/grpc/blob/master/doc/service_config.md

type ZkService

type ZkService struct {
	Base
	// contains filtered or unexported fields
}

func (*ZkService) GetHealthCheck

func (s *ZkService) GetHealthCheck() service.Health

func (*ZkService) GetKvConfig

func (s *ZkService) GetKvConfig() service.KVConfig

Service interface

func (*ZkService) Start

func (s *ZkService) Start()

* * Service interface * 使用 goroutine go Start

func (*ZkService) Stop

func (s *ZkService) Stop()

Service interface