grpc

Documentation

Index

• func CallStreaming(ctx context.Context, addr string, method protoreflect.MethodDescriptor, ...) error
• func CallUnary(ctx context.Context, addr string, method protoreflect.MethodDescriptor, ...) ([]byte, error)
• func ConvertToProtoReflectDesc(fds *descriptorpb.FileDescriptorSet) ([]protoreflect.FileDescriptor, error)
• func ParseMessage(inputJSON []byte, messageDesc protoreflect.MessageDescriptor) (*emptypb.Empty, error)
• func Receive(outputJSON chan []byte, method protoreflect.MethodDescriptor, ...) error
• func Reflect(ctx context.Context, baseurl string) (*descriptorpb.FileDescriptorSet, error)
• func ReflectV1(ctx context.Context, baseurl string) (*descriptorpb.FileDescriptorSet, error)
• func ReflectV1alpha1(ctx context.Context, baseurl string) (*descriptorpb.FileDescriptorSet, error)
• func Send(inputJSON chan []byte, messageDescriptor protoreflect.MessageDescriptor, ...) error

Functions

func CallStreaming

func CallStreaming(ctx context.Context, addr string, method protoreflect.MethodDescriptor, protocol string, http1 bool, inputJSON, outputJSON chan []byte) error

func CallUnary

func CallUnary(ctx context.Context, addr string, method protoreflect.MethodDescriptor, inputData []byte, protocol string, http1 bool) ([]byte, error)

func ConvertToProtoReflectDesc

func ConvertToProtoReflectDesc(fds *descriptorpb.FileDescriptorSet) ([]protoreflect.FileDescriptor, error)

func ParseMessage

func ParseMessage(inputJSON []byte, messageDesc protoreflect.MessageDescriptor) (*emptypb.Empty, error)

func Receive

func Receive(outputJSON chan []byte, method protoreflect.MethodDescriptor, f func() (*emptypb.Empty, error)) error

func Reflect

func Reflect(ctx context.Context, baseurl string) (*descriptorpb.FileDescriptorSet, error)

func ReflectV1

func ReflectV1(ctx context.Context, baseurl string) (*descriptorpb.FileDescriptorSet, error)

nolint: dupl

func ReflectV1alpha1

func ReflectV1alpha1(ctx context.Context, baseurl string) (*descriptorpb.FileDescriptorSet, error)

nolint: dupl

func Send

func Send(inputJSON chan []byte, messageDescriptor protoreflect.MessageDescriptor, f func(*emptypb.Empty) error) error