grpc_helper

Documentation

Index

• Variables
• func AuthFromMD(ctx context.Context, expectedScheme string, headerAuthorize ...string) (string, 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 StreamServerInterceptor() grpc.StreamServerInterceptor
• func UnaryServerInterceptor() grpc.UnaryServerInterceptor
• 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 (
	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 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 StreamServerInterceptor

func StreamServerInterceptor() grpc.StreamServerInterceptor

func UnaryServerInterceptor

func UnaryServerInterceptor() grpc.UnaryServerInterceptor

Types

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)