Versions in this module Expand all Collapse all v1 v1.0.1 Aug 31, 2023 Changes in this version + var ErrConnIsNil = errors.New("conn is nil") + var ErrConnIsNilButLocalNotNil = errors.New("conn is nil, but local is not nil") + type Logger interface + Printf func(string, ...interface{}) + type Resolver struct + func (r *Resolver) ResolveNow(o resolver.ResolveNowOptions) + func (r *Resolver) ResolveNowZK(o resolver.ResolveNowOptions) + func (s *Resolver) Close() + type ZkClient struct + 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) CloseConn(conn grpc.ClientConnInterface) + func (s *ZkClient) CloseZK() + 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.ClientConnInterface + func (s *ZkClient) GetConfFromRegistry(key string) ([]byte, error) + func (s *ZkClient) GetConn(ctx context.Context, serviceName string, opts ...grpc.DialOption) (grpc.ClientConnInterface, error) + func (s *ZkClient) GetConns(ctx context.Context, serviceName string, opts ...grpc.DialOption) ([]grpc.ClientConnInterface, 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) GetZkConn() *zk.Conn + 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(*ZkClient) + func WithFreq(freq time.Duration) ZkOption + func WithLogger(logger Logger) ZkOption + func WithOptions(opts ...grpc.DialOption) ZkOption + func WithRoundRobin() ZkOption + func WithTimeout(timeout int) ZkOption + func WithUserNameAndPassword(userName, password string) ZkOption