producer

Documentation

Index

• type ProduceService
  • func ProducerServiceHAndler() *ProduceService
  • func (svc *ProduceService) SendMessages(payload *httpEntity.ProducerRequest) (*httpEntity.ProducerResponse, error)
• type ProducerServiceInterface

Types

type ProduceService

type ProduceService struct {
	Kafka kafka.KafkaInterface
}

ProduceService ...

func ProducerServiceHAndler

func ProducerServiceHAndler() *ProduceService

ProducerServiceHAndler ...

func (*ProduceService) SendMessages

func (svc *ProduceService) SendMessages(payload *httpEntity.ProducerRequest) (*httpEntity.ProducerResponse, error)

SendMessages ... @data: string topic: string return int64, error

type ProducerServiceInterface

type ProducerServiceInterface interface {
	SendMessages(payload *httpEntity.ProducerRequest) (*httpEntity.ProducerResponse, error)
}

ProducerServiceInterface ...