tinymq:TinyMQ是建立在bbolt之上的小型轻量级持久队列

时间:2021-03-10 19:43:14
【文件属性】:
文件名称:tinymq:TinyMQ是建立在bbolt之上的小型轻量级持久队列
文件大小:8KB
文件格式:ZIP
更新时间:2021-03-10 19:43:14
Go TinyMQ TinyMQ是建立在bbolt之上的小型轻量级持久队列。 安装 go get github.com/superiss/tinymq 例子 文件 经纪人 // Broker type Broker struct { mu * sync. Mutex db * bbolt. DB queues map [ string ] * Queue notify chan * notification errs chan error } broker.NewQueue() 创建一个新队列。 以名称字符串,autoStart bool作为参数 broker.GetQueue() 查找并返回队列(如果不存在则返回错误)。 broker.Errors() 经纪人错误的渠道。 broker.Close() 关闭TinyMQ,必须在程序结束时调用它。 队列 /
【文件预览】:
tinymq-main
----utils.go(307B)
----go.mod(140B)
----go.sum(678B)
----lane.go(767B)
----message.go(1KB)
----queue.go(7KB)
----broker.go(3KB)
----_example()
--------main.go(833B)
--------demo.go(2KB)
----README.md(2KB)

网友评论