Claim a datastore key with store_exclusive, control subscription buffering, and refresh repositories in parallel.
Released on October 19, 2026
Breaking changes
peppylib.clock.subscribenow takes aTopicBufferargument; passTopicBuffer.KeepLatest(keep the newest ticks, dropping the oldest when full) orTopicBuffer.Backpressure(wait for the reader) on every call.
Datastore
- Store a datastore key with
store_exclusiveto make the calling instance its only writer until its process ends, refusing every other instance'sstoreandremoveof that key. datastore.listreturns its entries in key order.
Testing
- Generated test-harness and pairing-mock subscriptions keep the newest unread messages, so a test can read emitted topics late, or never, without holding up the session.
Repositories
peppy repo refreshreads up to 8 repositories at once, taking about as long as its slowest repository, and reports discovered items in priority order once every repository is read.
Node links
peppy node runandpeppy node add --runrefuse a--linkto a target instance with no process (one that is restarting, finished, or failed).