grpc

Documentation

Index

• func GetConn(serviceAddr string) (*grpc.ClientConn, error)
• func RegisterGrpc(serviceRegisterAddr string, server *grpc.Server, port int, ip string, ...) error
• type HealthImpl
  • func (h *HealthImpl) Check(ctx context.Context, req *grpc_health_v1.HealthCheckRequest) (*grpc_health_v1.HealthCheckResponse, error)
  • func (h *HealthImpl) OffLine(reason string)
  • func (h *HealthImpl) OnLine(reason string)
  • func (h *HealthImpl) Watch(*grpc_health_v1.HealthCheckRequest, grpc_health_v1.Health_WatchServer) error

Functions

func GetConn

func GetConn(serviceAddr string) (*grpc.ClientConn, error)

获取grpc连接对象

func RegisterGrpc

func RegisterGrpc(serviceRegisterAddr string, server *grpc.Server, port int, ip string, serviceName string) error

Types

type HealthImpl

type HealthImpl struct {
	Status grpc_health_v1.HealthCheckResponse_ServingStatus
	Reason string
}

func (*HealthImpl) Check

func (h *HealthImpl) Check(ctx context.Context, req *grpc_health_v1.HealthCheckRequest) (*grpc_health_v1.HealthCheckResponse, error)

func (*HealthImpl) OffLine

func (h *HealthImpl) OffLine(reason string)

func (*HealthImpl) OnLine

func (h *HealthImpl) OnLine(reason string)

func (*HealthImpl) Watch

func (h *HealthImpl) Watch(*grpc_health_v1.HealthCheckRequest, grpc_health_v1.Health_WatchServer) error