zookeeper

Documentation

Index

• Variables
• type Resolver
  • func (r *Resolver) Close()
  • func (r *Resolver) ResolveNow(o resolver.ResolveNowOptions)
  • func (r *Resolver) ResolveNowZK(o resolver.ResolveNowOptions)
• type ZkClient
  • func NewClient(zkServers []string, zkRoot string, options ...ZkOption) (*ZkClient, error)
  • func (s *ZkClient) AddOption(opts ...grpc.DialOption)
  • func (s *ZkClient) Build(target resolver.Target, cc resolver.ClientConn, opts resolver.BuildOptions) (resolver.Resolver, error)
  • func (s *ZkClient) Close()
  • func (s *ZkClient) CloseConn(conn *grpc.ClientConn)
  • func (s *ZkClient) CreateRpcRootNodes(serviceNames []string) error
  • func (s *ZkClient) CreateTempNode(rpcRegisterName, addr string) (node string, err error)
  • func (s *ZkClient) GetClientLocalConns() map[string][]*grpc.ClientConn
  • func (s *ZkClient) GetConfFromRegistry(key string) ([]byte, error)
  • func (s *ZkClient) GetConn(ctx context.Context, serviceName string, opts ...grpc.DialOption) (*grpc.ClientConn, error)
  • func (s *ZkClient) GetConns(ctx context.Context, serviceName string, opts ...grpc.DialOption) ([]*grpc.ClientConn, error)
  • func (s *ZkClient) GetConnsRemote(serviceName string) (conns []resolver.Address, err error)
  • func (s *ZkClient) GetNode() string
  • func (s *ZkClient) GetRootPath() string
  • func (s *ZkClient) GetSelfConnTarget() string
  • func (s *ZkClient) GetUserIdHashGatewayHost(ctx context.Context, userId string) (string, error)
  • func (s *ZkClient) GetZkConn() *zk.Conn
  • func (s *ZkClient) Printf(format string, a ...any)
  • func (s *ZkClient) Register(rpcRegisterName, host string, port int, opts ...grpc.DialOption) error
  • func (s *ZkClient) RegisterConf2Registry(key string, conf []byte) error
  • func (s *ZkClient) Scheme() string
  • func (s *ZkClient) UnRegister() error
• type ZkOption
  • func WithFreq(freq time.Duration) ZkOption
  • func WithLogger(logger log.Logger) ZkOption
  • func WithOptions(opts ...grpc.DialOption) ZkOption
  • func WithRoundRobin() ZkOption
  • func WithTimeout(timeout int) ZkOption
  • func WithUserNameAndPassword(userName, password string) ZkOption

Variables

var (
	ErrConnIsNil               = errors.New("conn is nil")
	ErrConnIsNilButLocalNotNil = errors.New("conn is nil, but local is not nil")
)

Types

type Resolver

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

func (*Resolver) Close

func (r *Resolver) Close()

func (*Resolver) ResolveNow

func (r *Resolver) ResolveNow(o resolver.ResolveNowOptions)

func (*Resolver) ResolveNowZK

func (r *Resolver) ResolveNowZK(o resolver.ResolveNowOptions)

type ZkClient

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

func NewClient

func NewClient(zkServers []string, zkRoot string, options ...ZkOption) (*ZkClient, error)

func (*ZkClient) AddOption

func (s *ZkClient) AddOption(opts ...grpc.DialOption)

func (*ZkClient) Build

func (s *ZkClient) Build(target resolver.Target, cc resolver.ClientConn, opts resolver.BuildOptions) (resolver.Resolver, error)

func (*ZkClient) Close

func (s *ZkClient) Close()

func (*ZkClient) CloseConn

func (s *ZkClient) CloseConn(conn *grpc.ClientConn)

func (*ZkClient) CreateRpcRootNodes

func (s *ZkClient) CreateRpcRootNodes(serviceNames []string) error

func (*ZkClient) CreateTempNode

func (s *ZkClient) CreateTempNode(rpcRegisterName, addr string) (node string, err error)

func (*ZkClient) GetClientLocalConns

func (s *ZkClient) GetClientLocalConns() map[string][]*grpc.ClientConn

func (*ZkClient) GetConfFromRegistry

func (s *ZkClient) GetConfFromRegistry(key string) ([]byte, error)

func (*ZkClient) GetConn

func (s *ZkClient) GetConn(ctx context.Context, serviceName string, opts ...grpc.DialOption) (*grpc.ClientConn, error)

func (*ZkClient) GetConns

func (s *ZkClient) GetConns(ctx context.Context, serviceName string, opts ...grpc.DialOption) ([]*grpc.ClientConn, error)

func (*ZkClient) GetConnsRemote

func (s *ZkClient) GetConnsRemote(serviceName string) (conns []resolver.Address, err error)

func (*ZkClient) GetNode

func (s *ZkClient) GetNode() string

func (*ZkClient) GetRootPath

func (s *ZkClient) GetRootPath() string

func (*ZkClient) GetSelfConnTarget

func (s *ZkClient) GetSelfConnTarget() string

func (*ZkClient) GetUserIdHashGatewayHost

func (s *ZkClient) GetUserIdHashGatewayHost(ctx context.Context, userId string) (string, error)

func (*ZkClient) GetZkConn

func (s *ZkClient) GetZkConn() *zk.Conn

func (*ZkClient) Printf

func (s *ZkClient) Printf(format string, a ...any)

func (*ZkClient) Register

func (s *ZkClient) Register(rpcRegisterName, host string, port int, opts ...grpc.DialOption) error

func (*ZkClient) RegisterConf2Registry

func (s *ZkClient) RegisterConf2Registry(key string, conf []byte) error

func (*ZkClient) Scheme

func (s *ZkClient) Scheme() string

func (*ZkClient) UnRegister

func (s *ZkClient) UnRegister() error

type ZkOption

type ZkOption func(*ZkClient)

func WithFreq

func WithFreq(freq time.Duration) ZkOption

func WithLogger

func WithLogger(logger log.Logger) ZkOption

func WithOptions

func WithOptions(opts ...grpc.DialOption) ZkOption

func WithRoundRobin

func WithRoundRobin() ZkOption

func WithTimeout

func WithTimeout(timeout int) ZkOption

func WithUserNameAndPassword

func WithUserNameAndPassword(userName, password string) ZkOption