Documentation ¶
Index ¶
- func MakeConsumerHandler(ctx context.Context, svc pb.KafkaServiceServer, ...) *httptransport.Server
- func MakeProducerHandler(ctx context.Context, svc pb.KafkaServiceServer, ...) *httptransport.Server
- func RegisterHandlers(ctx context.Context, svc pb.KafkaServiceServer, mux *http.ServeMux, ...) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func MakeConsumerHandler ¶
func MakeConsumerHandler(ctx context.Context, svc pb.KafkaServiceServer, endpoint gokit_endpoint.Endpoint) *httptransport.Server
func MakeProducerHandler ¶
func MakeProducerHandler(ctx context.Context, svc pb.KafkaServiceServer, endpoint gokit_endpoint.Endpoint) *httptransport.Server
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.