Tags: dapr/kit
Tags
Concurrency ctesting (#133) * Adds concurrency/ctesting Adds concurrency/ctesting package, used for concurrently running a set of runners, and collect the results via a testing assertion. Signed-off-by: joshvanl <[email protected]> * lint Signed-off-by: Fabian Martinez <[email protected]> --------- Signed-off-by: joshvanl <[email protected]> Signed-off-by: Fabian Martinez <[email protected]> Co-authored-by: joshvanl <[email protected]>
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 <[email protected]> * Lint Signed-off-by: joshvanl <[email protected]> * lint Signed-off-by: joshvanl <[email protected]> * lint Signed-off-by: joshvanl <[email protected]> * Elements match Signed-off-by: joshvanl <[email protected]> * Adds buffer size option to events loop Signed-off-by: joshvanl <[email protected]> * nit Signed-off-by: joshvanl <[email protected]> --------- Signed-off-by: joshvanl <[email protected]>
concurrency/lock: Adds context and outercancel locks (#115) * concurrency/lock: Adds context and outercancel locks Adds context lock which will cancel and return an error to Lock & RLock if the given context cancels before the lock is achieved. Adds outercancel lock which will cancel all RLocks in progress if the outer Lock is called. Signed-off-by: joshvanl <[email protected]> * lint Signed-off-by: joshvanl <[email protected]> * Lint Signed-off-by: joshvanl <[email protected]> * Fix tests Signed-off-by: joshvanl <[email protected]> * lint Signed-off-by: joshvanl <[email protected]> * lint Signed-off-by: joshvanl <[email protected]> --------- Signed-off-by: joshvanl <[email protected]>
Signals: Add cause to signal context cancel (#114) * Signals: Add cause to signal context cancel Signed-off-by: joshvanl <[email protected]> * lint Signed-off-by: joshvanl <[email protected]> --------- Signed-off-by: joshvanl <[email protected]>
Change `events/batcher` to use `events/queue` as backend. (#82) * events/batcher: use events/queue as queue backend Signed-off-by: joshvanl <[email protected]> * Make events/queue/queue key type comparable Signed-off-by: joshvanl <[email protected]> * Explicitly define NewProcessor generic type in test Signed-off-by: joshvanl <[email protected]> --------- Signed-off-by: joshvanl <[email protected]>
PreviousNext