Take the account event feed into a durable ledger - #729

Merged

jorgemanrubia merged 49 commits into

mainfrom

connector-intake

Sep 17, 2026

Commits on Sep 17, 2026

Take the account event feed into a durable ledger
jorgemanrubia
committed
9716ef4
Keep intake's recovery paths from swallowing, stalling or skipping
jorgemanrubia
committed
e4852c2
Stop a repair walk from walking into the same 410 on every pass
jorgemanrubia
committed
076b24e
Keep the ledger private, refuse feed redirects, and hand off through a reconnect
jorgemanrubia
committed
a8e461b
Make the adapter the only policy boundary, and state the repair pass
jorgemanrubia
committed
224de40
Re-enter a refused position safely even from empty pages, and serve nothing new over MCP
jorgemanrubia
committed
99359c0
Retry the opening migration while SQLite reports the ledger busy
jorgemanrubia
committed
e1a91fc
Count what the poll lane served, and replay rather than skip on a filter change
jorgemanrubia
committed
b7cc7cf
Let the replay label cover only the replay
jorgemanrubia
committed
f58d62f
Deliver queue edges in order, report partial reconciliation honestly, keep timestamp precision
jorgemanrubia
committed
4bf12ba
Store ledger timestamps at fixed width, so retention compares them in time order
jorgemanrubia
committed
3279414
Test ledger retention in both directions across fractional-second widths
jorgemanrubia
committed
8226ec9
Take the SDK's live feed seams now that they have landed
jorgemanrubia
committed
7258711
Re-enter a restart at this filter set's own id, stop on a refused re-entry, close expired losses
jorgemanrubia
committed
81b4797
Bump the SDK to main for its live feed seams, and re-sync the model and vendorHash on the rebase
jorgemanrubia
committed
ae21cca
Regenerate the vendored model on main's policy
jorgemanrubia
committed
f999fbb
Restore the SQLite driver to go.mod and refresh the vendorHash on main's SDK pin
jorgemanrubia
committed
94a9d1e
Strip terminal controls from pointer lines, and share one whole-line writer with admission
jorgemanrubia
committed
de87973
Keep an explicit --since as the entry until a checkpoint supersedes it
jorgemanrubia
committed
b592064
Bound repair passes against cycles and endless pages, propagate cancellation, and pin SDK v0.19.0
jorgemanrubia
committed
00be65c
Re-apply this branch's requirements on main's dependency bump
jorgemanrubia
committed
3d93b57
One NDJSON writer per sink, and an unknown membership snapshot that says so
jorgemanrubia
committed
cd3c9b8
Repair a loss under the filters it was recorded with, and keep learned projects while the lister is down
jorgemanrubia
committed
0af1290
Key only reference-like sinks in the line-writer registry
jorgemanrubia
committed
c9f54c2
Tell a loss with no filters from a loss written before filters were stored
jorgemanrubia
committed
4228fa2
Own the filter set, bound repair fan-out, refuse an in-memory ledger, sanitize peer log text
jorgemanrubia
committed
ce1ffa8
Fix the repair pool's shutdown, and make a learned project revocable
jorgemanrubia
committed
4bcd8ef
Give each Run its own repair pool
jorgemanrubia
committed
b2aad2f
Hand over every record still unjudged on a start
jorgemanrubia
committed
38f439f
Say that a re-offered record's pointer line is not re-emitted
jorgemanrubia
committed
f4c4c8a
Derive a queue crossing from the operation that caused it, not a later read
jorgemanrubia
committed
0670c70
Wait as long as a throttled repair poll was told to
jorgemanrubia
committed
b76da16
A throttle is not a verdict, and a new Run starts clean
jorgemanrubia
committed
251aa9e
Never strand a loss, and never let a throttle spend its window
jorgemanrubia
committed
886ec7d
Pin the in-window postpone on its own
jorgemanrubia
committed
329be35
Use the walk's own context in the postpone test
jorgemanrubia
committed
458c064
Close the throttle, the pool's bookkeeping, and the stdout stream's last split
jorgemanrubia
committed
753affa
Report an absolute-deadline close for what it was, and unlatch the edge drain on a panic
jorgemanrubia
committed
e8a0d4f
Pair the edge drain's unlock with the lock it takes
jorgemanrubia
committed
8e1e98c
Make the instance lock a lock, and the pause edges ordered
jorgemanrubia
committed
a10a38c
Validate the ledger this process opens, and let no committed event stop
jorgemanrubia
committed
20eba38
Report the create that fails, and forget only what was offered
jorgemanrubia
committed
f022c1a
Make terminal mean terminal
jorgemanrubia
committed
3963d28
Let a refused position die with the epoch that refused it
jorgemanrubia
committed
9c89aca
Build the verdict stream's writer before the workers exist
jorgemanrubia
committed
f427ce7
Keep a server's patience inside the deadline it is asking against
jorgemanrubia
committed
0d84ab6
Let a panicking callback cost the report, not the queue
jorgemanrubia
committed
90e644a
Refuse a filter this lane cannot honor, and say where a panic went
jorgemanrubia
committed
5e448b8
Adopt the queue's logger under the queue's lock
jorgemanrubia
committed
d13fda8