Versions in this module Expand all Collapse all v0 v0.1.49 Jul 20, 2024 Changes in this version + func Check(ctx context.Context, etcdServers []string, etcdRoot string, ...) error + type SvcDiscoveryRegistryImpl struct + func NewSvcDiscoveryRegistry(rootDirectory string, endpoints []string, options ...ZkOption) (*SvcDiscoveryRegistryImpl, error) + func (r *SvcDiscoveryRegistryImpl) AddOption(opts ...grpc.DialOption) + func (r *SvcDiscoveryRegistryImpl) Close() + func (r *SvcDiscoveryRegistryImpl) CloseConn(conn *grpc.ClientConn) + func (r *SvcDiscoveryRegistryImpl) GetConn(ctx context.Context, serviceName string, opts ...grpc.DialOption) (*grpc.ClientConn, error) + func (r *SvcDiscoveryRegistryImpl) GetConns(ctx context.Context, serviceName string, opts ...grpc.DialOption) ([]*grpc.ClientConn, error) + func (r *SvcDiscoveryRegistryImpl) GetSelfConnTarget() string + func (r *SvcDiscoveryRegistryImpl) GetUserIdHashGatewayHost(ctx context.Context, userId string) (string, error) + func (r *SvcDiscoveryRegistryImpl) Register(serviceName, host string, port int, opts ...grpc.DialOption) error + func (r *SvcDiscoveryRegistryImpl) UnRegister() error + type ZkOption func(*clientv3.Config) + func WithDialTimeout(timeout time.Duration) ZkOption + func WithMaxCallSendMsgSize(size int) ZkOption + func WithUsernameAndPassword(username, password string) ZkOption
Go to main page