Promote CCC to top-level Sourced namespace - #51

Open

ismasan wants to merge 151 commits into

mainfrom

Commits on Feb 24, 2026

Basic CCC store and message
ismasan
committed
ef30b5d
Read and append with consistency guard
ismasan
committed
6758e11
Add consumer group support with partition-based offset tracking

ismasan
and
claude
committed
8737661
Return ConsistencyGuard from claim_next for optimistic concurrency

ismasan
and
claude
committed
8772eb6
Use Message.to_conditions for type-aware guard conditions

ismasan
and
claude
committed
ac0b674
Cache payload_attribute_names at define time

ismasan
and
claude
committed
a77102b
Update partition plan with implemented semantics

ismasan
and
claude
committed
6581cbc
Add YARD comments to CCC::Store methods

ismasan
and
claude
committed
0342f2c
Add YARD comments to CCC::Message, QueryCondition, ConsistencyGuard

ismasan
and
claude
committed
bd3be9f
Add causation_id, correlation_id, and #correlate to CCC::Message

ismasan
and
claude
committed
0444e2a
Add replaying flag to claim_next based on highest acked position

ismasan
and
claude
committed
ff63b2a
Return ClaimResult Data struct from Store#claim_next

ismasan
and
claude
committed
732fd2c
Add CCC reactor abstraction layer (Decider, Projector, Router)

ismasan
and
claude
committed
8c17f0f
Fix causation chain: reactions correlate with event, not command

ismasan
and
claude
committed
50ac8c9
Support simple Consumer-only reactors without Decider/Projector

ismasan
and
claude
committed
9ddceba
Add CCC.load for synchronous reactor state loading with AND-filtered partition reads

ismasan
and
claude
committed
58a3b80
Add CCC background dispatch infrastructure (Worker, Dispatcher, notifier)

ismasan
and
claude
committed
11d0614
Add CCC stale claim reaper with worker heartbeats

ismasan
and
claude
committed
28c63b7
Add CCC::Supervisor as top-level process entry point

ismasan
and
claude
committed
0cce1b5
Add CCC::Configuration and module-level API (config, configure, register, store, router, reset!)

ismasan
and
claude
committed
0f5e311
Add StoreInterface to guard CCC::Configuration#store= assignment

ismasan
and
claude
committed
2fbf355
StateStored and EventSourced projectors for CCC
ismasan
committed
ee383e3
Add CCC error handling parity with SequelBackend

ismasan
and
claude
committed
d48dc4e
Error logging
ismasan
committed
9b9bc46
CCC::Command and CCC::Event subclasses with their own registries
ismasan
committed
381cbf7
Add CCC.handle! for synchronous command handling in web controllers

ismasan
and
claude
committed
9253938

Commits on Feb 28, 2026

Add CCC module README with API docs and usage examples

ismasan
and
claude
committed
432caeb
Accept #group_id objects in CCC Store consumer group methods

ismasan
and
claude
committed
926fd12

Commits on Mar 11, 2026

Syntax
ismasan
committed
ce82396
Design refs not in repo
ismasan
committed
0e1901c
Fix missing vars
ismasan
committed
7e579ae
Add #dispatch helper to CCC::Decider, allow resolving message classes by symbol name
ismasan
committed
84ea18f
Add CCC scheduled message support
ismasan
committed
68df28d
Document CCC retries and backoff
ismasan
committed
7251e03

Commits on Mar 12, 2026

New 'failed' consumer group status, and ErrorStrategy#on_fail
ismasan
committed
dc5058c
fail status for CCC consumer groups
ismasan
committed
189b81a
Add CCC::Store#stats for monitoring and debugging

ismasan
and
claude
committed
c6c5be2
Include error_context in CCC::Store#stats and document stats API

ismasan
and
claude
committed
d523210
Add CCC::Store#read_correlation_batch for tracing causal chains

ismasan
and
claude
committed
949bb51
Add YARD examples to CCC::Store#read_partition

ismasan
and
claude
committed
5c21da5
Add CCC::Store#read_all for paginating the global event log

ismasan
and
claude
committed
d6dc34e
CCC::Topology
ismasan
committed
52450ef
Falcon integration for Sourced::CCC with deferred configuration (to run after fork)
ismasan
committed
039db1f
Add CCC::Falcon::Environment and Service with post-fork setup, update docs

ismasan
and
claude
committed
59c3ceb
Revert "Add CCC::Falcon::Environment and Service with post-fork setup, update docs"
ismasan
committed
822d932
Falcon support
ismasan
committed
55be5e0
Remove CCC::Configuration#register
ismasan
committed
0f499d1
Support Sequel migrations, install store tables from migration
ismasan
committed
b0fd092
Document CCC Sequel migration support
ismasan
committed
8daadae
handle_batch -> handle_claim
ismasan
committed
3938e9f
Make reactors support .handle_batch
ismasan
committed
fad69ed
no need for argument
ismasan
committed
6d0c253
Replicate with_reactor RSpec helper for CCC
ismasan
committed
b6f034e
Lazy-load CCC::Store
ismasan
committed
f92f298
Update offsets in a transaction to avoid locking on SQLite's single writer
ismasan
committed
e20bc1c

Commits on Mar 13, 2026

Add CCC::CommandContext for building commands from raw attributes

ismasan
and
claude
committed
3076cef
Add order: :desc option to Store#read_all for reverse-chronological browsing

ismasan
and
claude
committed
95a3314
Return ReadAllResult from Store#read_all with Enumerable, to_enum, and last_position

ismasan
and
claude
committed
cd92ea1
Change QueryCondition to support compound attrs with AND semantics

ismasan
and
claude
committed
67c3d9d
Extract condition_position_subqueries to deduplicate query_messages and max_position_for

ismasan
and
claude
committed
7bb9685
Change partition_values from Array to Hash for self-documenting key access

ismasan
and
claude
committed
bb0c9de
Fix composite partition false positives in find_and_claim_partition

ismasan
and
claude
committed
064f01e
Add index on offsets(consumer_group_id, claimed) for faster partition claiming

ismasan
and
claude
committed
19fb368
Logline
ismasan
committed
78d5ad7

Commits on Mar 14, 2026

CCC::Sync.after_sync actions run after the DB transaction
ismasan
committed
b03b4d4
Document
ismasan
committed
68f55ce
Add missing specs for CCC::Message

ismasan
and
claude
committed
c4137bb
Add specs for CCC::Message#with_payload

ismasan
and
claude
committed
c3a7825
Add per-message and `any` callback hooks to CCC::CommandContext

ismasan
and
claude
committed
e911969
Support multiple message types in CommandContext.on

ismasan
and
claude
committed
5fdcf72
Allow multiple `on` blocks per command type in CommandContext

ismasan
and
claude
committed
2c06711
Run CCC::CommandContext hooks in context of instance
ismasan
committed
36db6d1

Commits on Mar 15, 2026

Lazy offset discovery in CCC::Store#claim_next

ismasan
and
claude
committed
fa9a31d
Replace CROSS JOIN with streaming iteration in find_and_claim_partition

ismasan
and
claude
committed
8c31b49
Order discovery results by min_pos to prevent skipping partitions

ismasan
and
claude
committed
e16b897
Use CTEs in discovery and fetch queries to halve key_pairs JOINs

ismasan
and
claude
committed
b8afa24
Skip caught-up offsets in find_and_claim_partition

ismasan
and
claude
committed
c1831be
Add timing logs to CCC::Router for profiling

ismasan
and
claude
committed
dd4d40f
Short-circuit idle polls in claim_next via types_max_pos check

ismasan
and
claude
committed
bc8f029
Add scaling benchmark with HTML charts

ismasan
and
claude
committed
6fc497e
Add scenario descriptions to scaling benchmark charts

ismasan
and
claude
committed
999f77b
Skip offset scan when undiscovered messages exist

ismasan
and
claude
committed
1b3659f
Remove known_keys Set from discovery — rely on INSERT OR IGNORE

ismasan
and
claude
committed
bd5af3d

Commits on Mar 16, 2026

Add Store#append benchmark as baseline for eager offset creation

ismasan
and
claude
committed
85c2e9b
Optimise append: eliminate redundant SELECT queries

ismasan
and
claude
committed
c556cad
Fix claim_next short-circuit and add eager offset creation

ismasan
and
claude
committed
0153cfa
Scaling bench
ismasan
committed
6afd4a8
Bench results
ismasan
committed
7b6303f
Fix idle poll regression: replace broken min/max short-circuit with cached watermark

ismasan
and
claude
committed
4af46ab
Add consumer group lifecycle hooks via Router

ismasan
and
claude
committed
935c0a5

Commits on Mar 17, 2026

Make CCC::Store#read_all from_position inclusive

ismasan
and
claude
committed
939910a
Add CCC::Store#read_offsets for paginated offset inspection

ismasan
and
claude
committed
985568a

Commits on Mar 18, 2026

Remove logging
ismasan
committed
d568007
Rename from_position: to after_position: in CCC::Store#read call stack

ismasan
and
claude
committed
f3af89a
Add CCC::Message::Registry#all for recursive enumeration

ismasan
and
claude
committed
af56568

Commits on Apr 14, 2026

Add conditions filter to CCC::Store#read_all

ismasan
and
claude
committed
c184ac5
Encapsulate Dispatcher setup and spawning into class level CCC::Dispatcher.spawn_into(task)
ismasan
committed
c2a54a4
Remove redundant names
ismasan
committed
003548d

Commits on Apr 15, 2026

PositionedMessage#to_message and Message.===
ismasan
committed
23a3433
Make all #handle_batch signatures the same so that GWT helpers work for any reactor
ismasan
committed
109ee36
Re-implement DurableWorkflow for CCC
ismasan
committed
9985ffa
Implement CCC::DurableWorkflow#handle_batch and rewrite tests to use GWT helpers
ismasan
committed
235b365
Promote CCC to top-level Sourced namespace

ismasan
and
claude
committed
d0e0540
Simplify
ismasan
committed
05bf988
Improve README
ismasan
committed
582e163
Untrack examples/app

ismasan
and
claude
committed
053a75c
Untrack bench files

ismasan
and
claude
committed
931d53a
Ignore bench/ for now
ismasan
committed
e1a6a78
Update CLAUDE.md to reflect CCC APIs
ismasan
committed
d95dd57
Update README
ismasan
committed
42135c3

Commits on Apr 16, 2026

Style tweaks
ismasan
committed
e76d3b1
Defer reactions in Decider.handle_batch

ismasan
and
claude
committed
f621f7b
Move correlation into Actions::Append/Schedule

ismasan
and
claude
committed
03fd28f

Commits on Apr 24, 2026

Sourced.load(upto:) loads history up to specific position number
ismasan
committed
1ae600e

Commits on Apr 30, 2026

Dispatcher.spawn_into(task) => Dispatcher.start(task)
ismasan
committed
cda8e6a

Commits on May 7, 2026

Block error strategy config
ismasan
committed
f5388b1

Commits on May 14, 2026

Commits on Jun 4, 2026

Commits on Jun 6, 2026

Require new Sourced::Message gem.
ismasan
committed
bd065f1

Commits on Jun 8, 2026

Nicer Sourced::Store#inspect
ismasan
committed
5ffebee

Commits on Jun 17, 2026

Add arm64-darwin-25 platform
ismasan
committed
b40b977

Commits on Jul 9, 2026

Reactor.queue_mode causes acked messaged to be deleted
ismasan
committed
6c6cd09
Make Sourced a durable-messaging runtime for third-party reactors

ismasan
and
claude
committed
b26d1c1
Simplify
ismasan
committed
60394eb
Fix index-basis resolution and drained-offset reaping

ismasan
and
claude
committed
689471c
Require exclusive for all id-partitioned reactors

ismasan
and
claude
committed
dac1f9b

Commits on Jul 10, 2026

Commits on Jul 13, 2026

Use IMMEDIATE transactions to avoid BUSY_SNAPSHOT
ismasan
committed
ffc0d8f
Store#transaction(&) handles immediate mode for us. Revert PRAGMA application. Sequel already applies per-connection
ismasan
committed
c8aaafe
Don't apply the nil-claim short-circuit on the eager offset path

ismasan
and
claude
committed
6b6e1e4
Collapse find_and_claim_partition into a single query

ismasan
and
claude
committed
02b4f0b
Restore an O(1) idle claim gate via trigger-invalidated scan versions

ismasan
and
claude
committed
4c1dc73
Keep SQLite planner statistics fresh: Store#optimize! at boot + periodically

ismasan
and
claude
committed
fadad78

Commits on Aug 7, 2026

WiP message codecs
ismasan
committed
b0dc23e

Commits on Aug 8, 2026

Store uses Plumb::Codec::JSON to decode/encode into DB, transparently
ismasan
committed
4ba14ba

Commits on Aug 10, 2026

Commits on Aug 22, 2026

Add link to Rubyforum page
ismasan
committed
ff71030