Documentation
¶
Overview ¶
Package jskv holds JetStream KV primitives shared across the CAS-backed substrate packages (internal/holds, internal/tasks, and any future Phase 4 consumer — presence, subscriber registry). The package stays deliberately tiny: its only job is to prevent the same ten-line conflict predicate and the same eight-retry bound from drifting between call sites. A third duplicate is the point at which this extraction earns its weight (see agent-infra-5o0).
Index ¶
Constants ¶
const MaxRetries = 8
MaxRetries caps any read-decide-write CAS loop built on JetStream KV. Each retry costs one KV Get plus one conditional write, and every loss means another caller advanced the revision — so the bound is really "how much concurrent churn on a single key before we surrender." Eight is generous: even pathological contention should converge in two or three rounds in practice, and the hard cap keeps a stuck loop from stalling its caller indefinitely. A bounded loop is TigerStyle; this is the bound.
Variables ¶
This section is empty.
Functions ¶
func IsConflict ¶
IsConflict reports whether err is a JetStream KV revision-guard rejection — either a Create on a key that already exists or an Update whose expected-last-sequence did not match the current sequence. Both surface as the server API error code JSErrCodeStreamWrongLastSequence (10071); ErrKeyExists carries that same code, so errors.Is covers the Update path too via the jsError/APIError unwrap chain. We additionally compare the raw APIError code so a future library change that ungroups the two sentinels won't silently turn CAS conflicts into "unknown error".
Types ¶
This section is empty.
Source Files