Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Conn ¶
type Conn interface {
GetConns(ctx context.Context, serviceName string, opts ...grpc.DialOption) ([]*grpc.ClientConn, error)
GetConn(ctx context.Context, serviceName string, opts ...grpc.DialOption) (*grpc.ClientConn, error)
GetSelfConnTarget() string
AddOption(opts ...grpc.DialOption)
CloseConn(conn *grpc.ClientConn)
GetClientLocalConns() map[string][]*grpc.ClientConn //del
GetUserIdHashGatewayHost(ctx context.Context, userId string) (string, error) //del
}
type SvcDiscoveryRegistry ¶
type SvcDiscoveryRegistry interface {
Conn
Register(serviceName, host string, port int, opts ...grpc.DialOption) error
UnRegister() error //del
// CreateRpcRootNodes When an upstream node accesses a downstream RPC node,
//it is imperative to call this method, such as from an API.
//Failing to do so can cause the RPC node to be inaccessible and block until it is refreshed after 30 minutes.
// This occurs because if the RPC node starts after the upstream node, the directory node in ZooKeeper needs to be created first.
//Otherwise, when the RPC node starts, the upstream node will not receive the ZooKeeper EventNodeChildrenChanged event.
CreateRpcRootNodes(serviceNames []string) error //del
RegisterConf2Registry(key string, conf []byte) error //del
GetConfFromRegistry(key string) ([]byte, error) //del
Close()
}
Click to show internal directories.
Click to hide internal directories.