grpc

Documentation

Overview

Package grpc provides a gRPC client for the LogService service.

Index

• func DecodeGRPCPingResponse(_ context.Context, grpcReply interface{}) (interface{}, error)
• func DecodeGRPCSubmitMultipleResponse(_ context.Context, grpcReply interface{}) (interface{}, error)
• func DecodeGRPCSubmitSingleResponse(_ context.Context, grpcReply interface{}) (interface{}, error)
• func EncodeGRPCPingRequest(_ context.Context, request interface{}) (interface{}, error)
• func EncodeGRPCSubmitMultipleRequest(_ context.Context, request interface{}) (interface{}, error)
• func EncodeGRPCSubmitSingleRequest(_ context.Context, request interface{}) (interface{}, error)
• func New(conn *grpc.ClientConn, options ...ClientOption) (pb.LogServiceServer, error)
• type ClientOption
  • func CtxValuesToSend(keys ...string) ClientOption

Functions

func DecodeGRPCPingResponse

func DecodeGRPCPingResponse(_ context.Context, grpcReply interface{}) (interface{}, error)

DecodeGRPCPingResponse is a transport/grpc.DecodeResponseFunc that converts a gRPC ping reply to a user-domain ping response. Primarily useful in a client.

func DecodeGRPCSubmitMultipleResponse

func DecodeGRPCSubmitMultipleResponse(_ context.Context, grpcReply interface{}) (interface{}, error)

DecodeGRPCSubmitMultipleResponse is a transport/grpc.DecodeResponseFunc that converts a gRPC submitmultiple reply to a user-domain submitmultiple response. Primarily useful in a client.

func DecodeGRPCSubmitSingleResponse

func DecodeGRPCSubmitSingleResponse(_ context.Context, grpcReply interface{}) (interface{}, error)

DecodeGRPCSubmitSingleResponse is a transport/grpc.DecodeResponseFunc that converts a gRPC submitsingle reply to a user-domain submitsingle response. Primarily useful in a client.

func EncodeGRPCPingRequest

func EncodeGRPCPingRequest(_ context.Context, request interface{}) (interface{}, error)

EncodeGRPCPingRequest is a transport/grpc.EncodeRequestFunc that converts a user-domain ping request to a gRPC ping request. Primarily useful in a client.

func EncodeGRPCSubmitMultipleRequest

func EncodeGRPCSubmitMultipleRequest(_ context.Context, request interface{}) (interface{}, error)

EncodeGRPCSubmitMultipleRequest is a transport/grpc.EncodeRequestFunc that converts a user-domain submitmultiple request to a gRPC submitmultiple request. Primarily useful in a client.

func EncodeGRPCSubmitSingleRequest

func EncodeGRPCSubmitSingleRequest(_ context.Context, request interface{}) (interface{}, error)

EncodeGRPCSubmitSingleRequest is a transport/grpc.EncodeRequestFunc that converts a user-domain submitsingle request to a gRPC submitsingle request. Primarily useful in a client.

func New

func New(conn *grpc.ClientConn, options ...ClientOption) (pb.LogServiceServer, error)

New returns an service backed by a gRPC client connection. It is the responsibility of the caller to dial, and later close, the connection.

Types

type ClientOption

type ClientOption func(*clientConfig) error

ClientOption is a function that modifies the client config

func CtxValuesToSend

func CtxValuesToSend(keys ...string) ClientOption