没有合适的资源?快使用搜索试试~ 我知道了~
caravan:Caravan是Go应用程序的进程内事件流库
共70个文件
go:55个
md:9个
yml:2个
需积分: 9 0 下载量 185 浏览量
2021-03-20
00:09:13
上传
评论
收藏 46KB ZIP 举报
温馨提示
大篷车 Caravan是应用程序的进程内事件流库。考虑 ,但要考虑软件的内部工作原理。 这是一项正在进行的工作。有基本知识,但尚未准备好用于生产。 例子 创建一个生产者和两个消费者,每个消费者独立地从生产者那里消费。 package main import ( "fmt" "github.com/kode4food/caravan" "github.com/kode4food/caravan/topic/config" ) func main () { // Create a new topic with permanent retention top := caravan . NewTopic ( config . Permanent ) // Start sending stuff to the topic p := to
资源推荐
资源详情
资源评论
收起资源包目录
caravan-main.zip (70个子文件)
caravan-main
.travis.yml 515B
docs
producers.md 502B
streams.md 1KB
consumers.md 2KB
debugging.md 1KB
channels.md 1KB
index.md 1KB
topics.md 1KB
internal
debug
debug.go 3KB
sync
channel
timeout.go 378B
timeout_test.go 383B
ready.go 980B
ready_test.go 356B
mutex
mutex.go 1KB
mutex_test.go 1KB
stream
stream.go 2KB
stream_test.go 1KB
topic
topic_test.go 2KB
log.go 4KB
cursor.go 2KB
consumer_test.go 4KB
producer_test.go 2KB
topic.go 4KB
producer.go 2KB
consumer.go 2KB
debug_test.go 848B
.github
dependabot.yml 145B
debug
debug.go 683B
LICENSE.md 1KB
.gitignore 348B
Makefile 199B
go.sum 1KB
README.md 2KB
id
id.go 283B
id_test.go 319B
caravan.go 650B
stream
node
topic_test.go 554B
map_test.go 711B
node_test.go 350B
subprocess.go 642B
filter_test.go 821B
map.go 364B
subprocess_test.go 749B
topic.go 972B
filter.go 377B
node.go 293B
stream.go 1KB
topic
topic_test.go 691B
backoff
backoff_test.go 1KB
backoff.go 1KB
config
backoff_test.go 824B
defaults_test.go 451B
retention.go 1KB
defaults.go 896B
backoff.go 1KB
retention_test.go 1010B
config.go 481B
topic.go 2KB
retention
composed_test.go 2KB
permanent.go 555B
consumed_test.go 834B
timed_test.go 882B
retention.go 957B
composed.go 3KB
counted.go 753B
consumed.go 742B
permanent_test.go 738B
timed.go 759B
counted_test.go 720B
go.mod 125B
共 70 条
- 1
资源评论
盗心魔幻
- 粉丝: 15
- 资源: 4478
上传资源 快速赚钱
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功