Repository navigation

kq

Public

About

experimental kafka share group based job queue

0 stars

0 watching

Report repository

Name		Name	Last commit message	Last commit date
.github/workflows		.github/workflows
bench		bench
docs		docs
internal/proto/kq		internal/proto/kq
test/integration		test/integration
.gitignore		.gitignore
.slignore		.slignore
README.md		README.md
buf.gen.yaml		buf.gen.yaml
buf.yaml		buf.yaml
client.go		client.go
client_test.go		client_test.go
config.go		config.go
config_test.go		config_test.go
doc.go		doc.go
go.mod		go.mod
go.sum		go.sum
producer.go		producer.go
retry_consumer.go		retry_consumer.go
retry_grid.go		retry_grid.go
retry_grid_test.go		retry_grid_test.go
retry_mover.go		retry_mover.go
retry_mover_test.go		retry_mover_test.go
retry_policy.go		retry_policy.go
retry_policy_test.go		retry_policy_test.go
share_consumer.go		share_consumer.go
share_consumer_test.go		share_consumer_test.go
task.go		task.go
task_test.go		task_test.go
worker.go		worker.go
worker_test.go		worker_test.go

Repository files navigation

kq

kq is a kafka share-group-based job queue for go

About

experimental kafka share group based job queue

0 stars

0 watching

Report repository

Releases

Packages

Contributors

Languages