zookeeper

Documentation

Index

• func NewClientZk(eps *config.EndPoints, serviceNode config.Node, timeout int) (*zk.Conn, error)
• func NewService(cfg config.Config, points config.EndPoints, registry registry.Registry) (service.Service, error)
• func NewServiceWith(cli *zk.Conn, cfg config.Config) (service.Service, error)
• func NewZkClient(conf config.Config, eps config.EndPoints, resol resolver.Resolver) (service.Client, error)
• func NewZkClientWith(cli *zk.Conn, conf *config.Config) (service.Client, error)
• type Base
  • func (base *Base) Get(key service.Key) ([]*service.Data, error)
  • func (base *Base) Set(data service.Data) error

Functions

func NewClientZk

func NewClientZk(eps *config.EndPoints, serviceNode config.Node, timeout int) (*zk.Conn, error)

func NewService

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

NewService 注册一个服务

func NewServiceWith

func NewServiceWith(cli *zk.Conn, cfg config.Config) (service.Service, error)

func NewZkClient

func NewZkClient(conf config.Config, eps config.EndPoints, resol resolver.Resolver) (service.Client, error)

func NewZkClientWith

func NewZkClientWith(cli *zk.Conn, conf *config.Config) (service.Client, error)

Types

type Base

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

func (*Base) Get

func (base *Base) Get(key service.Key) ([]*service.Data, error)

Get interface

func (*Base) Set

func (base *Base) Set(data service.Data) error

Set interface