consumer

type Consumer interface {
	ConsumeMessages() error
}

type EcflowClientConsumer struct {
	Source      RabbitMQSource
	Target      ElasticSearchTarget
	WorkerCount int
	BulkSize    int
	Debug       bool
}

type ElasticSearchTarget struct {
	Server string
}

type KafkaPrinterConsumer struct {
	Source       KafkaSource
	WorkerCount  int
	ConsumerName string
	Debug        bool
}

type KafkaSource struct {
	Brokers []string
	Topic   string
	Offset  int64

	Reader *kafka.Reader
}

type PredictConsumer struct {
	Source      RabbitMQSource
	Target      ElasticSearchTarget
	WorkerCount int
	BulkSize    int
	Debug       bool
}

type PrinterConsumer struct {
	Source       RabbitMQSource
	WorkerCount  int
	ConsumerName string
	Debug        bool
}

type ProductionConsumer struct {
	Source      RabbitMQSource
	Target      ElasticSearchTarget
	WorkerCount int
	BulkSize    int
	Debug       bool
}

type RabbitMQSource struct {
	Server       string
	Exchange     string
	Topics       []string
	Queue        string
	WriteTimeout time.Duration
	// contains filtered or unexported fields
}