equivalence

type MemoryRef ¶

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

MemoryRef is a deterministic in-memory implementation of Reference, used as the source-of-truth in equivalence tests. Backed by a nested map keyed by (sync_id, external_id). All operations are linearizable under MemoryRef.mu.

Iteration order is by external_id (lexicographic) for stable ordering across runs.

func NewMemoryRef() *MemoryRef

func (m *MemoryRef) DeleteGrantRecord(_ context.Context, externalID string) error

func (m *MemoryRef) GetGrantRecord(_ context.Context, externalID string) (*v3.GrantRecord, error)

func (m *MemoryRef) IterateGrants(_ context.Context, yield func(*v3.GrantRecord) bool) error

func (m *MemoryRef) IterateGrantsByEntitlement(_ context.Context, entitlementID string, yield func(*v3.GrantRecord) bool) error

func (m *MemoryRef) IterateGrantsByPrincipal(_ context.Context, principalRT, principalID string, yield func(*v3.GrantRecord) bool) error

func (m *MemoryRef) PutGrantRecord(_ context.Context, r *v3.GrantRecord) error

func (m *MemoryRef) SetCurrentSync(ctx context.Context, syncID string) error

type Op ¶

type Op struct {
	Kind             OpKind
	Record           *v3.GrantRecord // nil for OpDelete
	DeleteExternalID string
}

Op is one operation in a workload.

type OpKind ¶

type OpKind int

OpKind discriminates Op types.

const (
	OpPut OpKind = iota
	OpDelete
)

type Reference ¶

type Reference interface {
	PutGrantRecord(ctx context.Context, r *v3.GrantRecord) error
	GetGrantRecord(ctx context.Context, externalID string) (*v3.GrantRecord, error)
	IterateGrants(ctx context.Context, yield func(*v3.GrantRecord) bool) error
	IterateGrantsByEntitlement(ctx context.Context, entitlementID string, yield func(*v3.GrantRecord) bool) error
	IterateGrantsByPrincipal(ctx context.Context, principalRT, principalID string, yield func(*v3.GrantRecord) bool) error
}

Reference is the minimal store contract the equivalence runner drives. Both the Pebble engine and the in-memory reference satisfy it; future SQLite + translation shims can be wired in by adding a new adapter.

type Result ¶

type Result struct {
	BySyncCount        int
	ByEntitlementCount map[string]int
	ByPrincipalCount   map[string]int
	GetSpotChecks      map[string]bool // externalID -> present
}

Result is the per-Reference output collected at the end of a workload, in a form that's directly comparable across implementations.

func RunWorkload(ctx context.Context, ref Reference, w Workload) (*Result, error)

type Workload ¶

type Workload struct {
	Name   string
	SyncID string
	Ops    []Op
}

Workload is a deterministic sequence of operations the runner replays into each Reference. Each op is replayed in order; the runner does not assume associativity or commutativity.