queue

type Mqtt struct {
	Endpoint             string `mapstructure:"endpoint" yaml:"endpoint" json:"endpoint"        validate:"required,url"`                           // Mqtt 代理服务器端点地址
	ClientID             string `mapstructure:"client-id" yaml:"client-id" json:"clientId"`                                                        // 客户端标识符
	ProtocolVersion      uint   `mapstructure:"protocol-version" yaml:"protocol-version" json:"protocolVersion" validate:"required"`               // Mqtt 协议版本号，4 是 3.1.1，3 是 3.1
	KeepAlive            int    `mapstructure:"keep-alive" yaml:"keep-alive" json:"keepAlive"      validate:"required,min=1"`                      // 保活时间间隔，最小值为 1 秒
	MaxReconnectInterval int    `mapstructure:"max-reconnect-interval" yaml:"max-reconnect-interval" json:"maxReconnectInterval" validate:"min=1"` // 最大连接间隔时间，单位：秒，最小值为 1 秒
	PingTimeout          int    `mapstructure:"ping-timeout" yaml:"ping-timeout" json:"pingTimeout"      validate:"min=1"`                         // ping 超时时间，单位：秒，最小值为 1 秒
	WriteTimeout         int    `mapstructure:"write-timeout" yaml:"write-timeout" json:"writeTimeout"     validate:"min=1"`                       // 写超时时间，单位：秒，最小值为 1 秒
	ConnectTimeout       int    `mapstructure:"connect-timeout" yaml:"connect-timeout" json:"connectTimeout"   validate:"min=1"`                   // 连接超时时间，单位：秒，最小值为 1 秒
	Username             string `mapstructure:"username" yaml:"username" json:"username"`                                                          // 连接到代理服务器的用户名
	Password             string `mapstructure:"password" yaml:"password" json:"password"`                                                          // 密码
	CleanSession         bool   `mapstructure:"clean-session" yaml:"clean-session" json:"cleanSession"`                                            // 设置客户端掉线服务端是否清除 session
	AutoReconnect        bool   `mapstructure:"auto-reconnect" yaml:"auto-reconnect" json:"autoReconnect"`                                         // 断开后是否重新连接
	WillTopic            string `mapstructure:"will-topic" yaml:"will-topic" json:"willTopic"`                                                     // 遗言发送的 topic
	ModuleName           string `mapstructure:"module-name" yaml:"module-name" json:"moduleName"`                                                  // 模块名称
}

type Nats struct {
	Enabled  bool   `mapstructure:"enabled" yaml:"enabled" json:"enabled"`         // 是否启用
	URL      string `mapstructure:"url" yaml:"url" json:"url" validate:"required"` // NATS 服务器地址，如 nats://127.0.0.1:4222
	Name     string `mapstructure:"name" yaml:"name" json:"name"`                  // 客户端名称，用于服务端识别
	Username string `mapstructure:"username" yaml:"username" json:"username"`      // 用户名（可选）
	Password string `mapstructure:"password" yaml:"password" json:"password"`      // 密码（可选）
	Token    string `mapstructure:"token" yaml:"token" json:"token"`               // Token 鉴权（可选）

	// === 连接级（对齐官方 nats.Options，0 值走官方库默认） ===
	ConnectTimeout   int   `mapstructure:"connect-timeout" yaml:"connect-timeout" json:"connectTimeout" validate:"min=1"` // 连接超时（秒），官方默认 2s
	ReconnectWait    int   `mapstructure:"reconnect-wait" yaml:"reconnect-wait" json:"reconnectWait" validate:"min=1"`    // 重连等待时间（秒），官方默认 2s
	ReconnectJitter  int   `mapstructure:"reconnect-jitter" yaml:"reconnect-jitter" json:"reconnectJitter"`               // 重连抖动上限（秒，0=官方默认 100ms）
	ReconnectBufSize int64 `mapstructure:"reconnect-buf-size" yaml:"reconnect-buf-size" json:"reconnectBufSize"`          // 重连期间发布缓冲区上限（字节，0=官方默认 8MB）
	MaxReconnects    int   `mapstructure:"max-reconnects" yaml:"max-reconnects" json:"maxReconnects"`                     // 最大重连次数，-1 表示无限
	PingInterval     int   `mapstructure:"ping-interval" yaml:"ping-interval" json:"pingInterval"`                        // 心跳 ping 间隔（秒，0=官方默认 120s）
	MaxPingsOut      int   `mapstructure:"max-pings-out" yaml:"max-pings-out" json:"maxPingsOut"`                         // 未回应 ping 上限（0=官方默认 2）
	FlushTimeout     int   `mapstructure:"flush-timeout" yaml:"flush-timeout" json:"flushTimeout"`                        // Flush 等待超时（秒，0=官方默认 10s）
	DrainTimeout     int   `mapstructure:"drain-timeout" yaml:"drain-timeout" json:"drainTimeout"`                        // Drain 排空超时（秒，0=官方默认 30s）

	// === JetStream 流级运维参数（对齐官方 nats.StreamConfig；流名由业务建流时决策） ===
	JetStream        bool   `mapstructure:"jet-stream" yaml:"jet-stream" json:"jetStream"`                      // 是否启用 JetStream 持久化
	Replicas         int    `mapstructure:"replicas" yaml:"replicas" json:"replicas"`                           // 副本数（0=单副本；超出集群规模时建流报错）
	Storage          string `mapstructure:"storage" yaml:"storage" json:"storage"`                              // 存储后端：file|memory（空=file）
	Retention        string `mapstructure:"retention" yaml:"retention" json:"retention"`                        // 保留策略：limits|interest|workqueue（空=limits）
	MaxAge           int64  `mapstructure:"max-age" yaml:"max-age" json:"maxAge"`                               // 消息最大保留时长（秒，0=不限）
	MaxBytes         int64  `mapstructure:"max-bytes" yaml:"max-bytes" json:"maxBytes"`                         // 流最大体积（字节，0=不限）
	DuplicatesWindow int64  `mapstructure:"duplicates-window" yaml:"duplicates-window" json:"duplicatesWindow"` // Publish 去重窗口（秒，0=官方默认 120s）

	ModuleName      string `mapstructure:"module-name" yaml:"module-name" json:"moduleName"`                  // 模块名称
	WorkerPoolSize  int    `mapstructure:"worker-pool-size" yaml:"worker-pool-size" json:"workerPoolSize"`    // 全局消费者 WorkerPool 大小（0 表示不初始化）
	WorkerQueueSize int    `mapstructure:"worker-queue-size" yaml:"worker-queue-size" json:"workerQueueSize"` // 全局消费者 WorkerPool 任务队列大小（0 表示不初始化）
}