b2bua

type ALegRecord ¶

type ALegRecord struct {
	ALegID                string
	ContinuityKey         string
	CreatedAt             time.Time
	LastSeenAt            time.Time
	WeightedFirstConsumed bool
}

ALegRecord is the core-owned logical session row for routing and lineage.

type ALegRetirementObserver ¶

type ALegRetirementObserver interface {
	SetALegRetirementObserver(func(string))
}

InterleavedStateStore is the narrow optional contract for persisting thinker cycle state and memo references under A-leg continuity authority.

It is intentionally separate from Store so pkg/lipsdk/continuity can mirror only the base continuity contract without importing internal/core/interleavedstate (archtests forbid pkg/lipsdk from depending on internal/). Durable and in-memory stores implement this in addition to Store; callers type-assert or accept this interface explicitly. A zero-value state is valid and means "no thinker state", which is backward-compatible with A-legs created before interleaved thinking. ALegRetirementObserver is an optional lifecycle seam. Stores call the observer only after completing the eviction mutation and releasing their own locks.

type BLegRecord ¶

type BLegRecord struct {
	BLegID string
	ALegID string
	Seq    int
}

BLegRecord identifies one backend attempt slot within an A-leg.

type ContinuityScenarioSpec ¶

type ContinuityScenarioSpec struct {
	ID               string
	InvariantSummary string
	TestName         string // exists in internal/core/b2bua/*_test.go
}

ContinuityScenarioSpec links a stable scenario identifier to continuity/B2BUA store behavior and the primary regression test that exercises it (specification bundle).

func SpecBundleContinuityScenarios() []ContinuityScenarioSpec

type InterleavedStateStore ¶

type InterleavedStateStore interface {
	SetInterleavedState(ctx context.Context, aLegID string, state interleavedstate.State) error
	FetchInterleavedState(ctx context.Context, aLegID string) (interleavedstate.State, error)
}

type MemoryStore ¶

type MemoryStore struct {
	// contains filtered or unexported fields
}

MemoryStore is a mutex-protected in-memory Store with lazy TTL eviction.

func NewMemoryStore(opts MemoryStoreOptions) (*MemoryStore, error)

func (s *MemoryStore) Clear(ctx context.Context, aLegID string, now time.Time) (routeoverride.State, error)

func (s *MemoryStore) CreateALeg(ctx context.Context, continuityKey string) (ALegRecord, error)

func (s *MemoryStore) FetchALeg(ctx context.Context, aLegID string) (ALegRecord, error)

func (s *MemoryStore) FetchInterleavedState(ctx context.Context, aLegID string) (interleavedstate.State, error)

func (s *MemoryStore) Get(ctx context.Context, aLegID string) (routeoverride.State, error)

func (s *MemoryStore) LoadAttempts(ctx context.Context, aLegID string) ([]lipapi.AttemptRecord, error)

func (s *MemoryStore) NextBLeg(ctx context.Context, aLegID string) (BLegRecord, error)

func (s *MemoryStore) RecordAttempt(ctx context.Context, rec lipapi.AttemptRecord) error

func (s *MemoryStore) Replace(ctx context.Context, aLegID, selector string, now time.Time) (routeoverride.State, error)

func (s *MemoryStore) ResolveALeg(ctx context.Context, continuityKey string) (ALegRecord, error)

func (s *MemoryStore) SetALegRetirementObserver(observer func(string))

func (s *MemoryStore) SetInterleavedState(ctx context.Context, aLegID string, state interleavedstate.State) error

func (s *MemoryStore) SetWeightedFirstConsumed(ctx context.Context, aLegID string, consumed bool) error

func (s *MemoryStore) Snapshot(ctx context.Context, aLegID string) (routeoverride.State, error)

type MemoryStoreOptions ¶

type MemoryStoreOptions struct {
	// TTL after LastSeenAt after which an A-leg is lazily evicted. Zero disables expiry.
	// Non-zero TTL also enables a sweep on CreateALeg so idle sessions that are never
	// touched again (e.g. anonymous one-shot A-legs) are still reclaimed.
	TTL time.Duration
	// MaxLegs caps how many concurrent A-leg rows may be retained. Zero selects
	// DefaultMemoryStoreMaxLegsWithoutTTL (including when TTL-based expiry is enabled).
	// Negative values are rejected by NewMemoryStore.
	MaxLegs int
	// Now returns the current time; when nil, NewMemoryStore uses time.Now.
	Now func() time.Time
}

MemoryStoreOptions configures the in-memory implementation.

type Store ¶

type Store interface {
	ResolveALeg(ctx context.Context, continuityKey string) (ALegRecord, error)
	CreateALeg(ctx context.Context, continuityKey string) (ALegRecord, error)
	FetchALeg(ctx context.Context, aLegID string) (ALegRecord, error)
	SetWeightedFirstConsumed(ctx context.Context, aLegID string, consumed bool) error
	NextBLeg(ctx context.Context, aLegID string) (BLegRecord, error)
	RecordAttempt(ctx context.Context, rec lipapi.AttemptRecord) error
	LoadAttempts(ctx context.Context, aLegID string) ([]lipapi.AttemptRecord, error)
}

Store persists A-leg continuity, allocates B-leg sequence numbers, and records attempt lineage.