mirror of
https://github.com/hanzoai/traces.git
synced 2026-10-30 18:20:41 +00:00
Lukasz GutandGitHub
69c804be2c
* Refactor queueManager into generic queue.Queue * Update CHANGELOG.md * Create shared processFun method and a helper function for queue creation * Remove returning error from ProcessFunc and update chan *request[T] to chan T. * Fix unit tests * Replace go.uber.org/atomic with sync/atomic * Remove redundant accessor * Fix processFunc definition * Add breaking change to CHANGELOG.md * Define metrics on the package level to overcome Prometheus DefaultRegistry limitations * Fix tests in queue_test.go * Deprecate generatorForwarder metrics in favor of queue.Queue metrics
9 lines
112 B
Go
9 lines
112 B
Go
package queue
|
|
|
|
type Config struct {
|
|
Name string
|
|
TenantID string
|
|
Size int
|
|
WorkerCount int
|
|
}
|