kubernetes

Documentation

Index

• type KubernetesConnManager
  • func NewKubernetesConnManager(namespace string, options ...grpc.DialOption) (*KubernetesConnManager, error)
  • func (k *KubernetesConnManager) AddOption(opts ...grpc.DialOption)
  • func (k *KubernetesConnManager) Close()
  • func (k *KubernetesConnManager) DelData(ctx context.Context, key string) error
  • func (k *KubernetesConnManager) GetConn(ctx context.Context, serviceName string, opts ...grpc.DialOption) (grpc.ClientConnInterface, error)
  • func (k *KubernetesConnManager) GetConns(ctx context.Context, serviceName string, opts ...grpc.DialOption) ([]grpc.ClientConnInterface, error)
  • func (k *KubernetesConnManager) GetKey(ctx context.Context, key string) ([]byte, error)
  • func (k *KubernetesConnManager) GetSelfConnTarget() string
  • func (k *KubernetesConnManager) GetUserIdHashGatewayHost(ctx context.Context, userId string) (string, error)
  • func (k *KubernetesConnManager) IsSelfNode(cc grpc.ClientConnInterface) bool
  • func (k *KubernetesConnManager) Register(ctx context.Context, serviceName, host string, port int, ...) error
  • func (k *KubernetesConnManager) SetKey(ctx context.Context, key string, data []byte) error
  • func (k *KubernetesConnManager) UnRegister() error
  • func (k *KubernetesConnManager) WatchKey(ctx context.Context, key string, fn discovery.WatchKeyHandler) error

Types

type KubernetesConnManager

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

func NewKubernetesConnManager

func NewKubernetesConnManager(namespace string, options ...grpc.DialOption) (*KubernetesConnManager, error)

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

func (*KubernetesConnManager) AddOption

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

AddOption appends gRPC dial options to the existing options.

func (*KubernetesConnManager) Close

func (k *KubernetesConnManager) Close()

Close closes all gRPC connections managed by KubernetesConnManager.

func (*KubernetesConnManager) DelData

func (k *KubernetesConnManager) DelData(ctx context.Context, key string) error

func (*KubernetesConnManager) GetConn

func (k *KubernetesConnManager) 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 (*KubernetesConnManager) GetConns

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

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

func (*KubernetesConnManager) GetKey

func (k *KubernetesConnManager) GetKey(ctx context.Context, key string) ([]byte, error)

func (*KubernetesConnManager) GetSelfConnTarget

func (k *KubernetesConnManager) GetSelfConnTarget() string

GetSelfConnTarget returns the connection target for the current service.

func (*KubernetesConnManager) GetUserIdHashGatewayHost

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

func (*KubernetesConnManager) IsSelfNode

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

func (*KubernetesConnManager) Register

func (k *KubernetesConnManager) Register(ctx context.Context, serviceName, host string, port int, opts ...grpc.DialOption) error

func (*KubernetesConnManager) SetKey

func (k *KubernetesConnManager) SetKey(ctx context.Context, key string, data []byte) error

func (*KubernetesConnManager) UnRegister

func (k *KubernetesConnManager) UnRegister() error

func (*KubernetesConnManager) WatchKey

func (k *KubernetesConnManager) WatchKey(ctx context.Context, key string, fn discovery.WatchKeyHandler) error