Documentation
¶
Index ¶
- Constants
- type ConnManager
- func (k *ConnManager) AddOption(opts ...grpc.DialOption)
- func (k *ConnManager) Close()
- func (k *ConnManager) DelData(ctx context.Context, key string) error
- func (k *ConnManager) GetConn(ctx context.Context, serviceName string, opts ...grpc.DialOption) (grpc.ClientConnInterface, error)
- func (k *ConnManager) GetConns(ctx context.Context, serviceName string, opts ...grpc.DialOption) ([]grpc.ClientConnInterface, error)
- func (k *ConnManager) GetKey(ctx context.Context, key string) ([]byte, error)
- func (k *ConnManager) GetKeyWithPrefix(ctx context.Context, key string) ([][]byte, error)
- func (k *ConnManager) GetSelfConnTarget() string
- func (k *ConnManager) GetUserIdHashGatewayHost(ctx context.Context, userId string) (string, error)
- func (k *ConnManager) IsSelfNode(cc grpc.ClientConnInterface) bool
- func (k *ConnManager) Register(ctx context.Context, serviceName, host string, port int, ...) error
- func (k *ConnManager) SetKey(ctx context.Context, key string, data []byte) error
- func (k *ConnManager) SetWithLease(ctx context.Context, key string, val []byte, ttl int64) error
- func (k *ConnManager) UnRegister() error
- func (k *ConnManager) WatchKey(ctx context.Context, key string, fn discovery.WatchKeyHandler) error
Constants ¶
View Source
const (
GRPCName = "grpc"
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ConnManager ¶
type ConnManager struct {
// contains filtered or unexported fields
}
func NewConnManager ¶
func NewConnManager(namespace string, watchNames []string, options ...grpc.DialOption) (*ConnManager, error)
NewConnManager creates a new connection manager that uses Kubernetes services for service discovery.
func (*ConnManager) AddOption ¶
func (k *ConnManager) AddOption(opts ...grpc.DialOption)
AddOption appends gRPC dial options to the existing options.
func (*ConnManager) Close ¶
func (k *ConnManager) Close()
Close closes all gRPC connections managed by ConnManager.
func (*ConnManager) GetConn ¶
func (k *ConnManager) GetConn(ctx context.Context, serviceName string, opts ...grpc.DialOption) (grpc.ClientConnInterface, error)
GetConn returns a single gRPC client connection for a given Kubernetes service name.
func (*ConnManager) GetConns ¶
func (k *ConnManager) GetConns(ctx context.Context, serviceName string, opts ...grpc.DialOption) ([]grpc.ClientConnInterface, error)
GetConns returns gRPC client connections for a given Kubernetes service name.
func (*ConnManager) GetKeyWithPrefix ¶
func (*ConnManager) GetSelfConnTarget ¶
func (k *ConnManager) GetSelfConnTarget() string
GetSelfConnTarget returns the connection target for the current service.
func (*ConnManager) GetUserIdHashGatewayHost ¶
func (*ConnManager) IsSelfNode ¶
func (k *ConnManager) IsSelfNode(cc grpc.ClientConnInterface) bool
func (*ConnManager) Register ¶
func (k *ConnManager) Register(ctx context.Context, serviceName, host string, port int, opts ...grpc.DialOption) error
func (*ConnManager) SetWithLease ¶
func (*ConnManager) UnRegister ¶
func (k *ConnManager) UnRegister() error
func (*ConnManager) WatchKey ¶
func (k *ConnManager) WatchKey(ctx context.Context, key string, fn discovery.WatchKeyHandler) error
Source Files
Click to show internal directories.
Click to hide internal directories.