helper

type BambooPrameter interface {
	ToBytes() ([]byte, error)
}

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

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"`
}

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"`
}

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"`
}

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

type StandardClient struct {
	Clients map[string]WorkerClient
}

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

type WorkerClient interface {
	Produce(ctx context.Context, resultChannel string, heartbeatIntervalSec int, jobTimeoutSec int, headers map[string]string, data []byte) error
	Subscribe(ctx context.Context, resultChannel string, heartbeatIntervalSec int, jobTimeoutSec int) ([]byte, error)
	Ping(ctx context.Context) error
	Close(ctx context.Context)
}

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"`
}