corestore

type ActionKind string

type AuthorityHead struct {
	AuthorityEpoch   string
	HeadGeneration   int64
	LastEventSeq     int64
	SignerGeneration int64
}

type BackupInfo struct {
	Path          string
	SchemaVersion int
	Head          AuthorityHead
	Integrity     IntegrityReport
}

type BrokerScope struct {
	ScopeKey string
	Endpoint string
	ClientID int
	Account  string
	Mode     string
}

type CapitalEventProjection struct{ Kind, AmountBaseText, EffectiveAt, ReportID string }

type CheckpointResult struct {
	Busy               int
	LogFrames          int
	CheckpointedFrames int
}

type EventDiscardSelector struct {
	ScopeKey  string
	EventType string
	Predicate string
}

type EventDiscardSummary struct {
	MigrationVersion    int
	MigrationName       string
	Selector            EventDiscardSelector
	RemovedRows         int64
	PayloadBytes        int64
	OrderedDigestSHA256 string
}

type EventInput struct {
	ScopeKey    string
	EventKey    string
	Type        string
	Action      string
	Origin      string
	OccurredAt  time.Time
	PayloadJSON []byte
	Projection  EventProjection
}

type EventProjection struct {
	RegimeDecision   *RegimeDecisionProjection
	RuleTransition   *RuleTransitionProjection
	StressTransition *StressTransitionProjection
	CapitalEvent     *CapitalEventProjection
	RiskPolicyEvent  *RiskPolicyEventProjection
	ProposalOutcome  *ProposalOutcomeProjection
}

type EventQuery struct {
	ScopeKey      string
	Type          string
	FromAtMS      int64
	ToAtMS        int64
	AfterEventSeq int64
	Limit         int
}

type EventReceipt struct {
	EventSeq   int64
	RecordedAt time.Time
	Head       AuthorityHead
}

type EventRecord struct {
	EventSeq    int64
	ScopeKey    string
	EventKey    string
	Type        string
	Action      string
	Origin      string
	OccurredAt  time.Time
	RecordedAt  time.Time
	PayloadJSON []byte
}

type ForeignKeyViolation struct {
	Table       string
	RowID       *int64
	ParentTable string
	ForeignKey  int64
}

type Health struct {
	Ready            bool
	Code             string
	BlockedAt        time.Time
	RecoveryEligible bool
}

type InspectOptions struct {
	Path          string
	MinimumHead   *AuthorityHead
	TargetVersion int
}

type Inspection struct {
	Path           string
	SchemaVersion  int
	TargetVersion  int
	Status         InspectionStatus
	Head           AuthorityHead
	Integrity      IntegrityReport
	HeadTransition UpgradeHeadTransition
}

type InspectionStatus string

type IntegrityReport struct {
	QuickCheckResults    []string
	ForeignKeyViolations []ForeignKeyViolation
}

type LegacyConsumedToken struct {
	Scope          BrokerScope
	PreviewTokenID string
	ConsumedAt     time.Time
}

type LegacyOrderFloor struct {
	Scope BrokerScope
	Floor int64
}

type LegacyOrderImport struct {
	SourceFingerprint string
	GlobalFloor       int64
	ScopedFloors      []LegacyOrderFloor
	ConsumedTokens    []LegacyConsumedToken
	Events            []OrderEventRecord
}

type LegacyOrderImportResult struct {
	Imported  bool
	EventSeqs []int64
	Head      AuthorityHead
}

type LifecycleCommit struct {
	Scope  BrokerScope
	Events []OrderEventRecord
	State  *StateDocumentCAS
}

type LifecycleResult struct {
	EventSeqs []int64
	State     *StateDocument
	Head      AuthorityHead
}

type Observation struct {
	ID            int64
	ScopeKey      string
	Source        string
	Kind          string
	ObservedAt    time.Time
	RecordedAt    time.Time
	ContentType   string
	Payload       []byte
	PayloadSHA256 [sha256.Size]byte
	MetadataJSON  []byte
	// DecisionEligible is a typed authority boundary. Imported legacy
	// observations are false and must never seed current runtime state.
	DecisionEligible bool
}

type ObservationDiscardSelector struct {
	ScopeKey string
	Source   string
	Kind     string
}

type ObservationDiscardSummary struct {
	MigrationVersion    int
	MigrationName       string
	Selector            ObservationDiscardSelector
	RemovedRows         int64
	PayloadBytes        int64
	OrderedDigestSHA256 string
}

type ObservationInput struct {
	ScopeKey         string
	Source           string
	Kind             string
	ObservedAt       time.Time
	ContentType      string
	Payload          []byte
	MetadataJSON     []byte
	DecisionEligible bool
}

type ObservationQuery struct {
	ScopeKey           string
	Source             string
	Kind               string
	FromObservedAtMS   int64
	ToObservedAtMS     int64
	AfterObservationID int64
	DecisionEligible   *bool
	Limit              int
}

type ObservationReceipt struct {
	ID            int64
	PayloadSHA256 [sha256.Size]byte
	RecordedAt    time.Time
}

type OperationalPruneSelector struct {
	Predicate string
}

type OperationalPruneSummary struct {
	MigrationVersion int
	MigrationName    string
	Selector         OperationalPruneSelector

	RemovedObservationRows         int64
	RemovedObservationPayloadBytes int64
	ObservationDigestSHA256        string
	RemovedEventRows               int64
	RemovedEventPayloadBytes       int64
	EventDigestSHA256              string

	RemovedRegimeDecisionRows   int64
	RemovedRegimeIndicatorRows  int64
	RemovedRuleTransitionRows   int64
	RemovedStressTransitionRows int64
}

type Options struct {
	Path        string
	BusyTimeout time.Duration
	// MinimumHead, when non-nil, prevents opening an older copy of the same
	// authority. It is intended for restore/backup selection boundaries.
	MinimumHead *AuthorityHead
	// CommitObserver runs synchronously after every successful durable
	// mutation while the store's write lock is still held. Production uses it
	// to persist an external monotonic head; an observer failure is returned
	// to the caller and latches the store unhealthy without rolling back the
	// already-committed SQLite transaction.
	CommitObserver func(AuthorityHead) error
}

type OrderEventRecord struct {
	EventSeq        int64
	Scope           BrokerScope
	EventKey        string
	AtMS            int64
	Type            string
	Action          ActionKind
	Origin          TransmitOrigin
	OrderRef        string
	PreviewTokenID  string
	ReservedOrderID int64
	PermID          int64
	Status          string
	RawJSON         []byte
}

type OrderQuery struct {
	ScopeKey        string
	FromAtMS        int64
	ToAtMS          int64
	AfterEventSeq   int64
	OrderRef        string
	ReservedOrderID *int64
	PermID          *int64
	PreviewTokenID  string
	Limit           int
}

type PreTransmitRequest struct {
	Scope                 BrokerScope
	TokenDigest           PreviewTokenDigest
	AuthorityEpoch        string
	SignerGeneration      int64
	RequestedOrderIDFloor int64
	ReservedOrderID       int64
	// ExpectedOrderEventSeq binds a modify to the exact durable per-order
	// frontier it validated. Nil leaves place/cancel/other actions unconditional.
	ExpectedOrderEventSeq *int64
	Action                ActionKind
	Origin                TransmitOrigin
	Events                []OrderEventRecord
}

type PreTransmitResult struct {
	EffectiveOrderIDFloor int64
	EventSeqs             []int64
	Head                  AuthorityHead
}

type PreviewTokenDigest [sha256.Size]byte

type ProposalOutcomeProjection struct{ ProposalKey, Revision, Bucket, Symbol, SecType, Action, State string }

type QuiesceOptions struct {
	Path                  string
	ExpectedSchemaVersion int
	ExpectedHead          AuthorityHead
}

type RecomputeUpgradeMaintenanceOptions struct {
	SourcePath            string
	ExpectedSchemaVersion int
	TargetVersion         int
	ExpectedHead          AuthorityHead
}

type RegimeDecisionProjection struct {
	DecisionKey string
	Stage       string
	Severity    string
	Readiness   string
	Confidence  string
	Verdict     string
	Fingerprint string
	Indicators  []RegimeIndicatorProjection
}

type RegimeIndicatorProjection struct {
	Indicator       string
	Status          string
	Band            string
	Value           *float64
	Depth           *float64
	StreakSessions  *int64
	Freshness       string
	Eligible        *bool
	Latched         bool
	ThresholdsLabel string
}

type RevisionConflictError struct {
	Expected int64
	Actual   int64
	Exists   bool
}

type RiskPolicyEventProjection struct {
	Kind, PolicyID, PolicyFingerprint string
	PolicyVersion                     *int64
}

type RuleTransitionProjection struct {
	RuleID, Status, PreviousStatus, PolicyID, PolicyFingerprint string
	PolicyVersion                                               *int64
}

type StateDocument struct {
	ScopeKey  string
	Kind      string
	Revision  int64
	JSON      []byte
	UpdatedAt time.Time
}

type StateDocumentCAS struct {
	ScopeKey         string
	Kind             string
	ExpectedRevision int64
	JSON             []byte
	// UpdatedAtNotBefore is an optional atomic commit-clock floor. The store
	// compares it with the exact timestamp it will persist inside the same
	// critical mutation, before touching the document or authority head. It is
	// zero for ordinary callers.
	UpdatedAtNotBefore time.Time
}

type StatementEquityDayRecord struct {
	ID                  int64
	ScopeKey            string
	AccountKey          string
	Day                 string
	EquityBaseText      string
	StatementFileKey    string
	StatementFileSHA256 [sha256.Size]byte
	GeneratedAt         time.Time
	RawJSON             []byte
}

type StatementFileRecord struct {
	ScopeKey             string
	FileKey              string
	SizeBytes            int64
	SHA256               [sha256.Size]byte
	Status               string
	StatementGeneratedAt *time.Time
	IngestedAt           *time.Time
	UpdatedAt            time.Time
}

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

type StressTransitionProjection struct {
	Action, Severity, Direction, MarketStage, InputHealth string
	PortfolioAlertRelevant                                *bool
}

type TransmitOrigin string

type UpgradeHeadTransition string

type UpgradeMaintenanceResult struct {
	Discards                       []ObservationDiscardSummary
	EventDiscards                  []EventDiscardSummary
	OperationalPrunes              []OperationalPruneSummary
	Compacted                      bool
	SourceBackupRetirementRequired bool
}

type UpgradeOptions struct {
	SourcePath            string
	BackupPath            string
	CandidatePath         string
	MinimumHead           *AuthorityHead
	TargetVersion         int
	ReplaceCandidate      bool
	ResetUnboundArtifacts bool
}

type UpgradeRequiredError struct {
	CurrentVersion int
	TargetVersion  int
}

type UpgradeResult struct {
	Source         Inspection
	Backup         BackupInfo
	Candidate      Inspection
	TargetBackup   *BackupInfo
	Maintenance    UpgradeMaintenanceResult
	HeadTransition UpgradeHeadTransition
}

type UpgradeTargetBackupOptions struct {
	SourcePath            string
	BackupPath            string
	ExpectedSchemaVersion int
	ExpectedHead          AuthorityHead
}