提交

这个提交包含在:
asim
2026-02-04 14:37:40 +00:00
父节点 f9ba48897a
当前提交 a38d7df106
修改 21 个文件,包含 65 行新增68 行删除
+2 -2
查看文件
@@ -15,7 +15,7 @@ type nats struct {
url string
bucket string
key string
conn *natsgo.Conn // store connection for lifecycle management
conn *natsgo.Conn // store connection for lifecycle management
kv natsgo.KeyValue
opts source.Options
}
@@ -129,7 +129,7 @@ func NewSource(opts ...source.Option) source.Source {
url: config.Url,
bucket: bucket,
key: key,
conn: nc, // store connection reference
conn: nc, // store connection reference
kv: kv,
opts: options,
}