stream

Documentation

Index

• Constants
• type ScheduleKafkaConsumer
  • func NewScheduleKafkaClient(loggerSugar *zap.SugaredLogger, scheduleService input.IScheduleService, ...) ScheduleKafkaConsumer
  • func (schedule *ScheduleKafkaConsumer) ConsumerMessages()
• type ScheduleMessageKafka

Constants

const (
	ScheduleKafkaConsumerErrorToReadMessage        = "error to read message from schedule kafka consumer"
	ScheduleKafkaConsumerErrorTimeoutToReadMessage = "timeout error to read message from schedule kafka consumer"
	ScheduleKafkaConsumerSuccessToConsumer         = "success to consumer"
	ScheduleKafkaErrorToStartConsumer              = "error to start consumer from kafka"
)

Types

type ScheduleKafkaConsumer

type ScheduleKafkaConsumer struct {
	LoggerSugar     *zap.SugaredLogger
	ScheduleService input.IScheduleService
	KafkaClient     *kgo.Client
}

func NewScheduleKafkaClient

func NewScheduleKafkaClient(loggerSugar *zap.SugaredLogger,
	scheduleService input.IScheduleService,
	bootstrapServer string,
	groupID string,
	autoOffsetReset string,
	topic string) ScheduleKafkaConsumer

func (*ScheduleKafkaConsumer) ConsumerMessages

func (schedule *ScheduleKafkaConsumer) ConsumerMessages()

type ScheduleMessageKafka

type ScheduleMessageKafka struct {
	Booking                    string `json:"booking"`
	PetId                      int    `json:"pet_id"`
	ServiceEmployeeAttentionId int    `json:"service_employee_attention_id"`
}