rpc

README

rpc(grpc)

*客户端 https://github.com/joshqu1985/protos/blob/master/sdk/conn.go

*服务端 https://github.com/joshqu1985/service-uauth/blob/master/cmd/main.go

Documentation

Index

• func ConvertGrpcHttpError(err error) int
• func GrpcClientInterceptor(tracer opentracing.Tracer) grpc.UnaryClientInterceptor
• func GrpcServerInterceptor(tracer opentracing.Tracer) grpc.UnaryServerInterceptor
• func HTTPStatusFromCode(code codes.Code) int
• func NewUnaryClient(service string, resolver naming.Resolver) (*grpc.ClientConn, error)
• func NewUnaryServer() *grpc.Server
• func UnWrapStatusError(err error) error
• func WrapStatusError(err error) error
• type ClientConn
• type HealthImpl
  • func (h *HealthImpl) Check(ctx context.Context, args *grpc_health_v1.HealthCheckRequest) (*grpc_health_v1.HealthCheckResponse, error)
  • func (h *HealthImpl) Watch(*grpc_health_v1.HealthCheckRequest, grpc_health_v1.Health_WatchServer) error
• type MetadataIO
  • func (w MetadataIO) ForeachKey(handler func(key, val string) error) error
  • func (w MetadataIO) Set(key, val string)

Functions

func ConvertGrpcHttpError

func ConvertGrpcHttpError(err error) int

func GrpcClientInterceptor

func GrpcClientInterceptor(tracer opentracing.Tracer) grpc.UnaryClientInterceptor

func GrpcServerInterceptor

func GrpcServerInterceptor(tracer opentracing.Tracer) grpc.UnaryServerInterceptor

func HTTPStatusFromCode

func HTTPStatusFromCode(code codes.Code) int

func NewUnaryClient

func NewUnaryClient(service string, resolver naming.Resolver) (*grpc.ClientConn, error)

func NewUnaryServer

func NewUnaryServer() *grpc.Server

func UnWrapStatusError

func UnWrapStatusError(err error) error

func WrapStatusError

func WrapStatusError(err error) error

Types

type ClientConn

type ClientConn = grpc.ClientConn

type HealthImpl

type HealthImpl struct{}

func (*HealthImpl) Check

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

func (*HealthImpl) Watch

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

type MetadataIO

type MetadataIO struct {
	metadata.MD
}

func (MetadataIO) ForeachKey

func (w MetadataIO) ForeachKey(handler func(key, val string) error) error

func (MetadataIO) Set

func (w MetadataIO) Set(key, val string)