helper

type BambooFactory interface {
	CreateBambooWorkerClient(ctx context.Context, workerName string, cfg *WorkerClientConfig) (bamboo.BambooWorkerClient, error)
	CreateBambooWorker(cfg *WorkerConfig, workerFunc bamboo.WorkerFunc) (bamboo.BambooWorker, error)
}

type ConsumerConfig struct {
	Type      string                   `yaml:"type" validate:"required"`
	Kafka     *KafkaConsumerConfig     `yaml:"kafka"`
	Redis     *RedisConsumerConfig     `yaml:"redis"`
	Goroutine *GoroutineConsumerConfig `yaml:"goroutine"`
}

type GoroutineConsumerConfig struct {
	Channel string `yaml:"channel" validate:"required"`
}

type GoroutineRequestProducerConfig struct {
	Channel string `yaml:"channel" validate:"required"`
}

type JaegerConfig struct {
	Endpoint string `yaml:"endpoint" validate:"required"`
}

type KafkaConsumerConfig struct {
	Brokers  []string `yaml:"brokers" validate:"required"`
	GroupID  string   `yaml:"groupId" validate:"required"`
	Topic    string   `yaml:"topic" validate:"required"`
	MaxBytes int      `yaml:"maxBytes" validate:"required"`
}

type KafkaRequestProducerConfig struct {
	Addr  string `yaml:"addr" validate:"required"`
	Topic string `yaml:"topic" validate:"required"`
}

type LogConfig struct {
	Level string `yaml:"level"`
}

type PublisherConfig struct {
	Type  string                `yaml:"type" validate:"required"`
	Redis *RedisPublisherConfig `yaml:"redis"`
}

type RedisConsumerConfig struct {
	Addrs                  []string `yaml:"addrs" validate:"required"`
	Password               string   `yaml:"password"`
	Channel                string   `yaml:"channel" validate:"required"`
	RequestWaitTimeoutMSec int      `yaml:"requestWaitTimeoutMSec" validate:"required"`
}

type RedisPublisherConfig struct {
	Addrs    []string `yaml:"addrs" validate:"required"`
	Password string   `yaml:"password"`
}

type RedisRequestProducerConfig struct {
	Addrs    []string `yaml:"addrs" validate:"required"`
	Password string   `yaml:"password"`
	Channel  string   `yaml:"channel" validate:"required"`
}

type RedisResultSubscriberConfig struct {
	Addrs    []string `yaml:"addrs" validate:"required"`
	Password string   `yaml:"password"`
}

type RequestProducerConfig struct {
	Type      string                          `yaml:"type" validate:"required"`
	Kafka     *KafkaRequestProducerConfig     `yaml:"kafka"`
	Redis     *RedisRequestProducerConfig     `yaml:"redis"`
	Goroutine *GoroutineRequestProducerConfig `yaml:"goroutine"`
}

type ResultSubscriberConfig struct {
	Type  string                       `yaml:"type" validate:"required"`
	Redis *RedisResultSubscriberConfig `yaml:"redis"`
}

type TraceConfig struct {
	Exporter string        `yaml:"exporter" validate:"required"`
	Jaeger   *JaegerConfig `yaml:"jaeger"`
}

type WorkerClientConfig struct {
	RequestProducer  *RequestProducerConfig  `yaml:"requestProducer" validate:"required"`
	ResultSubscriber *ResultSubscriberConfig `yaml:"resultSubscriber" validate:"required"`
}

type WorkerConfig struct {
	Consumer   *ConsumerConfig  `yaml:"consumer"`
	Publisher  *PublisherConfig `yaml:"publisher"`
	NumWorkers int              `yaml:"numWorkers"`
}