kafka_handlers

Documentation

Index

• type KafkaConsumerService
  • func NewKafkaConsumerService(eventEmitter *infrastructure.EventEmitter, kr *kafka.Reader, db *gorm.DB, ...) *KafkaConsumerService
  • func (k *KafkaConsumerService) CloseConsumer() error
  • func (svc *KafkaConsumerService) ConsumeEchoIncomingText(message string) error
  • func (svc *KafkaConsumerService) InitAndRegisterConsumer(ctx context.Context, consumeFn func(m *kafka.Message) error)
  • func (svc *KafkaConsumerService) InitEventHandlers()

Types

type KafkaConsumerService

type KafkaConsumerService struct {
	// contains filtered or unexported fields
}

func NewKafkaConsumerService

func NewKafkaConsumerService(
	eventEmitter *infrastructure.EventEmitter,
	kr *kafka.Reader,
	db *gorm.DB,
	rdb *redis.Client,
	s3Client *s3.S3,
	natsClient *nats.Conn,
) *KafkaConsumerService

func (*KafkaConsumerService) CloseConsumer

func (k *KafkaConsumerService) CloseConsumer() error

func (*KafkaConsumerService) ConsumeEchoIncomingText

func (svc *KafkaConsumerService) ConsumeEchoIncomingText(message string) error

func (*KafkaConsumerService) InitAndRegisterConsumer

func (svc *KafkaConsumerService) InitAndRegisterConsumer(ctx context.Context, consumeFn func(m *kafka.Message) error)

func (*KafkaConsumerService) InitEventHandlers

func (svc *KafkaConsumerService) InitEventHandlers()