Documentation
¶
Index ¶
- func DecodeConsumerResponse(_ context.Context, grpcResponse interface{}) (interface{}, error)
- func DecodeProducerResponse(_ context.Context, grpcResponse interface{}) (interface{}, error)
- func EncodeConsumerRequest(_ context.Context, request interface{}) (interface{}, error)
- func EncodeProducerRequest(_ context.Context, request interface{}) (interface{}, error)
- func New(conn *grpc.ClientConn, logger log.Logger) pb.KafkaServiceServer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DecodeConsumerResponse ¶
func DecodeProducerResponse ¶
func EncodeConsumerRequest ¶
func EncodeProducerRequest ¶
func New ¶
func New(conn *grpc.ClientConn, logger log.Logger) pb.KafkaServiceServer
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.