grpchelper

Documentation

Index

• func CreateMessage(mdesc *desc.MethodDescriptor, unmarshaler *jsonpb.Unmarshaler, ...) (*dynamic.Message, error)
• func GrpcDynamicQuery(ctx context.Context, reflectionClient *grpcreflect.Client, ...) (string, error)
• func GrpcInvokeQuery(ctx context.Context, methodDescriptor *desc.MethodDescriptor, ...) (string, error)
• func GrpcMakeDescriptor(reflectionClient *grpcreflect.Client, queryPath string) (*desc.MethodDescriptor, error)
• func ResolveMessage(fullMethodName string, rcli *grpcreflect.Client) (*desc.MethodDescriptor, error)
• type DynamicAnyResolver
  • func (DynamicAnyResolver) Resolve(typeURL string) (proto.Message, error)

Functions

func CreateMessage

func CreateMessage(mdesc *desc.MethodDescriptor, unmarshaler *jsonpb.Unmarshaler, inputJsonString string) (*dynamic.Message, error)

func GrpcDynamicQuery

func GrpcDynamicQuery(ctx context.Context, reflectionClient *grpcreflect.Client, stub *grpcdynamic.Stub, queryPath string, queryData string) (string, error)

func GrpcInvokeQuery

func GrpcInvokeQuery(
	ctx context.Context,
	methodDescriptor *desc.MethodDescriptor,
	stub *grpcdynamic.Stub,
	queryData string,
) (string, error)

func GrpcMakeDescriptor

func GrpcMakeDescriptor(reflectionClient *grpcreflect.Client, queryPath string) (*desc.MethodDescriptor, error)

func ResolveMessage

func ResolveMessage(fullMethodName string, rcli *grpcreflect.Client) (*desc.MethodDescriptor, error)

Types

type DynamicAnyResolver

type DynamicAnyResolver struct {
	jsonpb.AnyResolver // https://godoc.org/github.com/golang/protobuf/jsonpb#AnyResolver
}

func (DynamicAnyResolver) Resolve

func (DynamicAnyResolver) Resolve(typeURL string) (proto.Message, error)

Resolve implements jsonpb.AnyResolver.Resolve