grpc_helper

package

v1.2.4 Latest Latest Go to latest Published: Aug 14, 2020 License: MIT Imports: 19 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

View Source

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

View Source

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

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

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

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 map[error]codes.Code

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

func NewErrorParser(em ErrorMapping) *ErrorParser

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

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

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

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

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

type MethodDescription struct {
	Package string
	Service string
	Method  string
}

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