kubernetes

package

v0.0.49-alpha.55.7 Latest Latest Go to latest Published: Aug 25, 2025 License: Apache-2.0 Imports: 19 Imported by: 0

Details

View Source

const (
	GRPCName = "grpc"
)

This section is empty.

func NewConnManager(namespace string, watchNames []string, options ...grpc.DialOption) (discovery.SvcDiscoveryRegistry, error)

NewConnManager creates a new connection manager that uses Kubernetes services for service discovery.

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

func (k *ConnManager) AddOption(opts ...grpc.DialOption)

AddOption appends gRPC dial options to the existing options.

func (k *ConnManager) Close()

Close closes all gRPC connections managed by ConnManager.

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

GetConn returns a single gRPC client connection for a given Kubernetes service name.

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

GetConns returns gRPC client connections for a given Kubernetes service name.

func (k *ConnManager) GetSelfConnTarget() string

GetSelfConnTarget returns the connection target for the current service.

func (k *ConnManager) GetUserIdHashGatewayHost(ctx context.Context, userId string) (string, error)

func (k *ConnManager) IsSelfNode(cc grpc.ClientConnInterface) bool

func (k *ConnManager) Register(serviceName, host string, port int, opts ...grpc.DialOption) error

func (k *ConnManager) UnRegister() error