grpc_helper

Documentation

Index

• Variables
• func AuthFromMD(ctx context.Context, expectedScheme string, headerAuthorize ...string) (string, error)
• func ErrorWrapper(err error) error
• func ExpectCodes(err error, cds ...codes.Code) error
• func ExpectCodesWithoutOK(err error, cds ...codes.Code) error
• func GetSessionFromContext(ctx context.Context) int64
• func GetSubjectTokenFromContext(ctx context.Context) (string, error)
• func GetTokenFromContext(ctx context.Context) (string, error)
• func HandleGRPCError(logger log.FieldLogger, err error, format string, args ...interface{}) error
• func HttpStatusCode2GrpcStatusCode(code int) codes.Code
• func NewDialOptionWithTransportCredentials(tcs credentials.TransportCredentials) []grpc.DialOption
• func StreamServerInterceptor(logger log.FieldLogger) grpc.StreamServerInterceptor
• func UnaryServerInterceptor(logger log.FieldLogger) grpc.UnaryServerInterceptor
• type ErrorMapping
• type ErrorParser
  • func NewErrorParser(em ErrorMapping) *ErrorParser
  • func (ep *ErrorParser) ParseError(err error) error
• type HijackStream
  • func NewHijackStream(stm deviced_pb.DevicedService_ConnectClient, ...) *HijackStream
  • func (self *HijackStream) Recv() (*deviced_pb.ConnectRequest, error)
  • func (self *HijackStream) RecvChan() chan *deviced_pb.ConnectRequest
• type MethodDescription
  • func ParseMethodDescription(fullMethodName string) (*MethodDescription, error)

Variables

var (
	JSONPBMarshaler   = new(jsonpb.Marshaler)
	JSONPBUnmarshaler = new(jsonpb.Unmarshaler)
)

var (
	ErrFailedToRecvMessage = errors.New("failed to recv message")
)

var (
	InvalidFullMethodName = errors.New("invalid full method name")
)

Functions

func AuthFromMD

func AuthFromMD(ctx context.Context, expectedScheme string, headerAuthorize ...string) (string, error)

github.com/grpc-ecosystem/go-grpc-middleware/auth/metadata.go:AuthFromMD

func ErrorWrapper

func ErrorWrapper(err error) error

func ExpectCodes

func ExpectCodes(err error, cds ...codes.Code) error

func ExpectCodesWithoutOK

func ExpectCodesWithoutOK(err error, cds ...codes.Code) error

func GetSessionFromContext

func GetSessionFromContext(ctx context.Context) int64

func GetSubjectTokenFromContext

func GetSubjectTokenFromContext(ctx context.Context) (string, error)

func GetTokenFromContext

func GetTokenFromContext(ctx context.Context) (string, error)

func HandleGRPCError

func HandleGRPCError(logger log.FieldLogger, err error, format string, args ...interface{}) error

func HttpStatusCode2GrpcStatusCode

func HttpStatusCode2GrpcStatusCode(code int) codes.Code

func NewDialOptionWithTransportCredentials

func NewDialOptionWithTransportCredentials(tcs credentials.TransportCredentials) []grpc.DialOption

func StreamServerInterceptor

func StreamServerInterceptor(logger log.FieldLogger) grpc.StreamServerInterceptor

func UnaryServerInterceptor

func UnaryServerInterceptor(logger log.FieldLogger) grpc.UnaryServerInterceptor

Types

type ErrorMapping

type ErrorMapping map[error]codes.Code

type ErrorParser

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

func NewErrorParser

func NewErrorParser(em ErrorMapping) *ErrorParser

func (*ErrorParser) ParseError

func (ep *ErrorParser) ParseError(err error) error

type HijackStream

type HijackStream struct {
	deviced_pb.DevicedService_ConnectClient
	// contains filtered or unexported fields
}

func NewHijackStream

func NewHijackStream(stm deviced_pb.DevicedService_ConnectClient, on_recv func(*HijackStream, *deviced_pb.ConnectRequest) error) *HijackStream

func (*HijackStream) Recv

func (self *HijackStream) Recv() (*deviced_pb.ConnectRequest, error)

func (*HijackStream) RecvChan

func (self *HijackStream) RecvChan() chan *deviced_pb.ConnectRequest

type MethodDescription

type MethodDescription struct {
	Package string
	Service string
	Method  string
}

func ParseMethodDescription

func ParseMethodDescription(fullMethodName string) (*MethodDescription, error)