b5coordinator

type Analysis struct {
	Facts          b5dml.StatementFacts
	TreeDigest     [32]byte
	ManifestDigest [32]byte
	ClosureDigest  [32]byte
	Decision       Decision
	EstimatedRows  int64
	EstimatedWork  uint64
	Artifact       any
}

type Analyzer interface {
	Analyze(context.Context, StatementRequest, int) (Analysis, error)
}

type ApprovalConsumeRequest struct {
	ApprovalID, TransactionID, RequestID string
	PlanDigest                           [32]byte
	OwnerEpoch                           uint64
	Now                                  time.Time
}

type ApprovalLease struct {
	ID                   string
	Generation           uint64
	ApprovedBoundsDigest [32]byte
	ExpiresAt            time.Time
}

type ApprovalStore interface {
	Consume(context.Context, ApprovalConsumeRequest) (ApprovalLease, error)
	MarkBeginFailed(context.Context, ApprovalLease, string) error
	MarkActive(context.Context, ApprovalLease, string) error
}

type AuditEvent struct {
	Kind                                AuditKind
	TransactionID, SessionID, RequestID string
	Sequence                            uint64
	PlanDigest                          [32]byte
	StatementOrdinal                    int
	Action                              b5.DMLAction
	AffectedRows                        int64
	DBOutcome                           b5.DBOutcome
	ErrorCode                           b5.ErrorCode
	EvidenceDigest                      [32]byte
}

type AuditKind string

type AuditResult struct {
	Durability  b5.AuditDurability
	EventDigest [32]byte
}

type Auditor interface {
	Barrier(context.Context, AuditEvent) (AuditResult, error)
}

type BackendIdentity struct {
	PID                                   int
	SecretDigest                          [32]byte
	StartedAt                             time.Time
	ConnectionGeneration, LeaseGeneration uint64
}

type BeginCapability interface {
	BeginNative(context.Context) (b5dml.BeginAttemptEvidence, error)
	FixContext(context.Context, time.Time) error
	BindAndSeal(context.Context, Plan) ([32]byte, error)
	Activate() (Capability, error)
	CleanupBegin(context.Context, *b5terminal.TerminalOwner, b5dml.BeginCleanupDecision) (TerminalResult, error)
}

type BeginRequest struct {
	Session                              SessionAuthorization
	TransactionID, RequestID, ApprovalID string
	Plan                                 PlanRequest
}

type Capability interface {
	Execute(context.Context, PlannedStatement) (StatementResult, error)
	Cancel(context.Context) (b5terminal.CancelEmission, error)
	FinishCommit(context.Context, *b5terminal.TerminalOwner, b5terminal.TerminalAttempt) (TerminalResult, error)
	FinishRollback(context.Context, *b5terminal.TerminalOwner, b5terminal.TerminalAttempt, b5terminal.NoCommitEverSent) (TerminalResult, error)
	Discard(context.Context) (b5.ConnectionDisposition, error)
}

type Clock interface{ Now() time.Time }

type Config struct {
	Transactions TransactionStore
	Approvals    ApprovalStore
	Sessions     SessionGate
	Engine       Engine
	Audit        Auditor
	Clock        Clock
}

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

type Decision uint8

type DirectorySessionGate struct{ Directory *b5session.Directory }

type Engine interface {
	Pin(context.Context, Plan, *b5dml.BeginMachine) (BeginCapability, BackendIdentity, error)
}

type ExecuteRequest struct {
	Session                               SessionAuthorization
	TransactionID, RequestID, OperationID string
	Ordinal                               int
}

type Failure struct {
	Code  b5.ErrorCode
	Cause error
}

type FinishRequest struct {
	Session                  SessionAuthorization
	TransactionID, RequestID string
}

type MemoryApproval struct {
	ID            string
	PlanDigest    [32]byte
	BoundsDigest  [32]byte
	ExpiresAt     time.Time
	Status        string
	Generation    uint64
	TransactionID string
}

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

type MemoryAuditor struct {
	Events     []AuditEvent
	Fail       func(AuditEvent) error
	Durability func(AuditEvent) b5.AuditDurability
	// contains filtered or unexported fields
}

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

type OperationEvidence struct {
	Ordinal                 int      `json:"ordinal"`
	OperationID             string   `json:"operation_id"`
	AffectedRows            int64    `json:"affected_rows"`
	StatementEvidenceDigest [32]byte `json:"statement_evidence_digest"`
	AuditEventDigest        [32]byte `json:"audit_event_digest"`
}

type Plan struct {
	SchemaID, TenantID, PrincipalID, AgentID, DatasourceID string
	SchemaVersion                                          uint16
	KeyRevision, DatasourceRevision, PolicyRevision        uint64
	Dialect                                                string
	ServerMajor                                            int
	Isolation, BinderABI, ClosurePolicy                    string
	Limits                                                 ResourceLimits
	Statements                                             []PlannedStatement
	Digest                                                 [32]byte
	RequiresApproval                                       bool
}

type PlanAnalyzerResolver interface {
	AnalyzerFor(context.Context, PlanRequest) (Analyzer, error)
}

type PlanRequest struct {
	TenantID, PrincipalID, AgentID, DatasourceID    string
	KeyRevision, DatasourceRevision, PolicyRevision uint64
	Dialect                                         string
	ServerMajor                                     int
	Isolation, BinderABI, ClosurePolicy             string
	Statements                                      []StatementRequest
	Limits                                          ResourceLimits
}

type PlannedStatement struct {
	Ordinal        int
	OperationID    string
	SQL            string
	RawSQLDigest   [32]byte
	ReasonDigest   [32]byte
	TreeDigest     [32]byte
	ManifestDigest [32]byte
	ClosureDigest  [32]byte
	Action         b5.DMLAction
	Writes         []b5dml.WriteTarget
	References     []b5dml.Reference
	Decision       Decision
	EstimatedRows  int64
	EstimatedWork  uint64
	// contains filtered or unexported fields
}

type ResourceLimits struct {
	MaxStatements     int
	MaxSQLBytes       int
	MaxPlanBytes      int
	MaxAffectedRows   int64
	MaxEstimatedWork  uint64
	IdleTimeout       time.Duration
	WallTimeout       time.Duration
	StatementTimeout  time.Duration
	OperationWatchdog time.Duration
	QuiesceGrace      time.Duration
}

type Result struct {
	TransactionID         string                   `json:"transaction_id"`
	Status                b5.TransactionStatus     `json:"status"`
	Phase                 b5.TransactionPhase      `json:"phase"`
	Code                  b5.ErrorCode             `json:"error_code,omitempty"`
	Effect                b5.TxEffect              `json:"tx_effect"`
	DBOutcome             b5.DBOutcome             `json:"db_outcome,omitempty"`
	AuditDurability       b5.AuditDurability       `json:"audit_durability,omitempty"`
	ConnectionDisposition b5.ConnectionDisposition `json:"connection_disposition,omitempty"`
	NextOrdinal           int                      `json:"next_ordinal"`
	AffectedRows          int64                    `json:"affected_rows"`
	Evidence              []OperationEvidence      `json:"evidence,omitempty"`
}

type SessionAuthorization struct {
	SessionID, McpSessionID, PrincipalID, InstanceID string
	Method, RequestID, Proof                         string
	OwnerEpoch                                       uint64
	ExpectedSeq                                      *uint64
	BodyDigest                                       [32]byte
}

type SessionFailure struct{ Code b5.ErrorCode }

type SessionGate interface {
	Validate(context.Context, SessionAuthorization) error
}

type StatementRequest struct {
	OperationID string
	SQL         string
	Reason      string
}

type StatementResult struct {
	AffectedRows      int64
	EvidenceDigest    [32]byte
	Decision          Decision
	CapabilityCertain bool
}

type StaticSessionGate struct {
	SessionID  string
	OwnerEpoch uint64
}

type TerminalResult struct {
	Resolution             b5terminal.TerminalResolution
	EvidenceDigest         [32]byte
	DispositionProofDigest [32]byte
	CancelEmission         b5terminal.CancelEmission
}

type TransactionStore interface {
	store.B5TransactionStore
}

type WALAuditor struct {
	Service *b5wal.Service
	// contains filtered or unexported fields
}