Directories
¶
| Path | Synopsis |
|---|---|
|
Package batcher provides a generic coalescing buffer: items are appended via Add and handed to a deliver closure in batches — flushed eagerly when an item-count or weight cap is reached, on an optional background ticker, or on an explicit Flush / Close.
|
Package batcher provides a generic coalescing buffer: items are appended via Add and handed to a deliver closure in batches — flushed eagerly when an item-count or weight cap is reached, on an optional background ticker, or on an explicit Flush / Close. |
|
Package buffer provides a pooled *[]byte for zero-alloc formatting in hot paths.
|
Package buffer provides a pooled *[]byte for zero-alloc formatting in hot paths. |
|
Package commit provides Group, a group commit: concurrent callers each contribute an item, one goroutine runs a flush over all of them, and every caller receives that flush's verdict.
|
Package commit provides Group, a group commit: concurrent callers each contribute an item, one goroutine runs a flush over all of them, and every caller receives that flush's verdict. |
|
Package group — the typed fan-out built on the Group.
|
Package group — the typed fan-out built on the Group. |
|
Package pool provides Pool, a bounded worker pool: a fixed set of long-lived workers consuming a bounded queue of tasks, with a refusal when there is no room, a drain, and a task's panic isolated on its worker.
|
Package pool provides Pool, a bounded worker pool: a fixed set of long-lived workers consuming a bounded queue of tasks, with a refusal when there is no room, a drain, and a task's panic isolated on its worker. |
|
Package recycler — CappedPool[T] layers a reset-on-Put + cap-discard policy on top of the plain Pool[T] declared in recycler.go.
|
Package recycler — CappedPool[T] layers a reset-on-Put + cap-discard policy on top of the plain Pool[T] declared in recycler.go. |
|
Package sema provides Weighted, a weighted semaphore: a capacity of units, Acquire takes n of them, Release gives them back.
|
Package sema provides Weighted, a weighted semaphore: a capacity of units, Acquire takes n of them, Release gives them back. |
|
Package singleflight — the in-flight call record shared by every caller of one key.
|
Package singleflight — the in-flight call record shared by every caller of one key. |
|
Package snapshot provides Value[T any], a copy-on-write container for read-mostly shared state.
|
Package snapshot provides Value[T any], a copy-on-write container for read-mostly shared state. |
|
Package worker — Every layers a ticker loop on top of the LoopDaemon lifecycle.
|
Package worker — Every layers a ticker loop on top of the LoopDaemon lifecycle. |
Click to show internal directories.
Click to hide internal directories.