kit/concurrency
Josh van Leeuwen 77af8ac182
events/loop & slices (#119)
* events/loop & slices

Adds a generic control loop implementation to `event/loop`.

Adds a new `slices` package that provides a generic slice de-duplication
func.

Makes events batcher and queue processer taker in Options.

Allows enqueuing multiple processor items in same func call.

Signed-off-by: joshvanl <me@joshvanl.dev>

* Lint

Signed-off-by: joshvanl <me@joshvanl.dev>

* lint

Signed-off-by: joshvanl <me@joshvanl.dev>

* lint

Signed-off-by: joshvanl <me@joshvanl.dev>

* Elements match

Signed-off-by: joshvanl <me@joshvanl.dev>

* Adds buffer size option to events loop

Signed-off-by: joshvanl <me@joshvanl.dev>

* nit

Signed-off-by: joshvanl <me@joshvanl.dev>

---------

Signed-off-by: joshvanl <me@joshvanl.dev>
2025-04-23 11:28:21 -03:00
..
cmap Adds generic ring (#108) 2024-11-20 13:48:57 -08:00
dir concurrency/dir & WriteIdentityToFile (#112) 2025-01-21 06:16:49 -08:00
fifo Adds FIFO concurrent lock & generic concurrent Slice (#107) 2024-10-15 06:03:26 -07:00
lock concurrency/lock: Adds context and outercancel locks (#115) 2025-02-24 11:15:07 -08:00
slice events/loop & slices (#119) 2025-04-23 11:28:21 -03:00
closer.go concurrency: Make runner closer take a logger (#116) 2025-04-10 15:34:54 -03:00
closer_test.go concurrency: Make runner closer take a logger (#116) 2025-04-10 15:34:54 -03:00
closer_unit.go Move dapr/concurrency to kit (#72) 2023-10-30 11:55:52 -07:00
runner.go Move dapr/concurrency to kit (#72) 2023-10-30 11:55:52 -07:00
runner_test.go Move dapr/concurrency to kit (#72) 2023-10-30 11:55:52 -07:00