文件名称：rocksq:基于RocksDB的嵌入式持久队列
文件大小：9KB
文件格式：ZIP
更新时间：2024-05-30 15:56:05
Go
Rocksq 基于RocksDB的嵌入式持久队列 例子 store, err := rocksq.NewStore(rocksq.StoreOptions{ Directory: "/opt/rocksq", MemorySize: 5 * 1024 * 1024, }) defer store.Close() q, err := store.NewQueue("queue_name") msg := "Hello World" if _, err := q.Enqueue([]byte(msg)); err != nil { // .... } id, data, err := q.Dequeue() // .... id, anotherData, err := q.Dequeue(id) // boosting the seek i
【文件预览】：
rocksq-master
----queue.go(5KB)
----rocksq_test.go(3KB)
----bench_test.go(784B)
----LICENSE(1KB)
----.gitignore(266B)
----README.md(1KB)
----utils.go(187B)
----fixtures()
--------routines.go(2KB)
----merge.go(909B)
----store.go(5KB)