kafka_endpoints

Documentation

Index

• func MakeConsumerEndpoint(svc pb.KafkaServiceServer) endpoint.Endpoint
• func MakeProducerEndpoint(svc pb.KafkaServiceServer) endpoint.Endpoint
• type Endpoints
  • func MakeEndpoints(svc pb.KafkaServiceServer) Endpoints
  • func (e *Endpoints) Consumer(ctx context.Context, in *pb.ConsumerRequest) (*pb.ConsumerResponse, error)
  • func (e *Endpoints) ConsumerStream(in *pb.ConsumerStreamRequest, server pb.KafkaService_ConsumerStreamServer) error
  • func (e *Endpoints) Producer(ctx context.Context, in *pb.ProducerRequest) (*pb.ProducerResponse, error)
• type StreamEndpoint
  • func MakeConsumerStreamEndpoint(svc pb.KafkaServiceServer) StreamEndpoint

Functions

func MakeConsumerEndpoint

func MakeConsumerEndpoint(svc pb.KafkaServiceServer) endpoint.Endpoint

func MakeProducerEndpoint

func MakeProducerEndpoint(svc pb.KafkaServiceServer) endpoint.Endpoint

Types

type Endpoints

type Endpoints struct {
	ConsumerEndpoint endpoint.Endpoint

	ProducerEndpoint endpoint.Endpoint

	ConsumerStreamEndpoint StreamEndpoint
}

func MakeEndpoints

func MakeEndpoints(svc pb.KafkaServiceServer) Endpoints

func (*Endpoints) Consumer

func (e *Endpoints) Consumer(ctx context.Context, in *pb.ConsumerRequest) (*pb.ConsumerResponse, error)

func (*Endpoints) ConsumerStream

func (e *Endpoints) ConsumerStream(in *pb.ConsumerStreamRequest, server pb.KafkaService_ConsumerStreamServer) error

func (*Endpoints) Producer

func (e *Endpoints) Producer(ctx context.Context, in *pb.ProducerRequest) (*pb.ProducerResponse, error)

type StreamEndpoint

type StreamEndpoint func(server interface{}, req interface{}) (err error)

func MakeConsumerStreamEndpoint

func MakeConsumerStreamEndpoint(svc pb.KafkaServiceServer) StreamEndpoint