mq

type ConsumerConfig struct {
	Name   string   `toml:"name"`   // 消费者名称（用于日志）
	Group  string   `toml:"group"`  // 消费组
	Topics []string `toml:"topics"` // 订阅的 topics
}

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

type KafkaConfig struct {
	Brokers   []string         `toml:"brokers"`
	Consumers []ConsumerConfig `toml:"consumers"`
	Enabled   bool             `toml:"enabled"`
}

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

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

type MessageHandler func(ctx context.Context, topic string, message []byte) error

type MessageQueue interface {
	Publish(topic string, message []byte) error
	Subscribe(topic string, handler func(message []byte) error) error
	Close() error
}