queue_nats

queue-nats

queue-nats 是 github.com/infrago/queue 的nats 驱动。

包定位

• 类型：驱动
• 作用：把 queue 模块的统一接口落到 nats 后端实现

快速接入

import (
    _ "github.com/infrago/queue"
    _ "github.com/infrago/queue-nats"
)

[queue]
driver = "nats"

setting 专用配置项

配置位置：[queue].setting

• url / server
• token
• user / username
• pass / password
• stream（JetStream，默认 INFRAGOQ）

说明

• 普通 NATS 延迟发布是 best-effort；需要持久队列语义时使用 natsjs / nats-js / jetstream
• setting 仅对当前驱动生效，不同驱动键名可能不同
• 连接失败时优先核对 setting 中 host/port/认证/超时等参数