Versions in this module Expand all Collapse all v0 v0.0.2 Mar 14, 2020 Changes in this version + var CloseCommunication = errors.New("communication end") + func DecodeRequestFromClient(log log.Logger) func(context.Context, interface{}) (interface{}, error) + func DecodeResponseFromServer(log log.Logger) func(context.Context, interface{}) (interface{}, error) + func DisplayClientRequestHeaders(logger log.Logger) func(context.Context, *metadata.MD) context.Context + func DisplayClientResponseHeaders(logger log.Logger) func(context.Context, metadata.MD, metadata.MD) context.Context + func DisplayClientResponseTrailers(logger log.Logger) func(context.Context, metadata.MD, metadata.MD) context.Context + func EncodeRequestToServer(log log.Logger) func(context.Context, interface{}) (interface{}, error) + func EncodeResponseToClient(log log.Logger) func(context.Context, interface{}) (interface{}, error) + func ExtractConsumedCorrelationID(logger log.Logger) func(context.Context, metadata.MD, metadata.MD) context.Context + func InjectCorrelationID(logger log.Logger) func(context.Context, *metadata.MD) context.Context + func NewBinding(svc Service) *serverBinding + func SetCorrelationID(ctx context.Context, v string) context.Context + type Client struct + func NewDirectClient(log log.Logger, conn *grpc.ClientConn, enc kitGRPC.EncodeRequestFunc, ...) *Client + func (c *Client) ApplyExtraOptions(options ...ClientOption) + func (c Client) CallFullDuplex(cctx context.Context) error + func (c Client) CallHalfDuplex(extCtx context.Context, request *InternalRequest) error + func (c Client) Logger() log.Logger + type ClientOption func(*Client) + func ClientAfter(after ...kitGRPC.ClientResponseFunc) ClientOption + func ClientBefore(before ...kitGRPC.ClientRequestFunc) ClientOption + type InternalReply struct + Ctx context.Context + Msg string + type InternalRequest struct + Msg string + type RequestAndStreamHalfDuplex struct + Request *pb.Request + Stream pb.Streams_HalfDuplexServer + type Service interface + FullDuplex func(stream pb.Streams_FullDuplexServer) error + HalfDuplex func(request *pb.Request, stream pb.Streams_HalfDuplexServer) error + Logger func() log.Logger + func NewService(log log.Logger) Service
Go to main page