b5session

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

type AbsenceProof struct {
	SchemaID       string
	SchemaVersion  uint16
	Digest         [32]byte
	InventoryEpoch uint64
	ObservedAt     time.Time
}

type BackendIdentity struct {
	ServerID       string
	Database       string
	PID            int32
	BackendStarted time.Time
	DialToken      string
}

type BackendInventory interface {
	ObservePermit(context.Context, string) (InventoryObservation, error)
	Terminate(context.Context, BackendIdentity) error
}

type Budget struct {
	DatasourceID          string
	HardLimit             int
	AdminEmergencyReserve int
	ConnectionUnitsUsed   int
	PlanBytesLimit        int64
	PlanBytesUsed         int64
	Revision              int64
}

type Claim struct {
	ID, DatasourceID                  string
	Kind                              ClaimKind
	OwnerInstanceID, OwnerIncarnation string
	Generation                        uint64
	ClaimedCapacity, MaxOpenConns     int
	State                             ClaimState
	Revision                          int64
}

type ClaimKind string

type ClaimRequest struct {
	ClaimID, DatasourceID             string
	Kind                              ClaimKind
	OwnerInstanceID, OwnerIncarnation string
	Capacity, MaxOpenConns            int
}

type ClaimState string

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

type CreateSession struct {
	AgentID, TenantID, PrincipalID string
	OwnerInstanceID, StickyRoute   string
}

type CreatedSession struct {
	Session store.B5Session
	// ContinuationSecret is returned exactly once and is never persisted.
	ContinuationSecret string
}

type DialIdentity struct {
	PermitID        string
	ApplicationName string
	OwnerHash       [8]byte
}

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

type DialPermitIssuer struct {
	Ledger LedgerStore
	Codec  *DialIdentityCodec
}

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

type DirectoryConfig struct {
	Store       SessionStore
	Sealer      KeySealer
	IdleTTL     time.Duration
	AbsoluteTTL time.Duration
	Now         func() time.Time
}

type DispositionProof struct {
	SchemaID       string
	SchemaVersion  uint16
	Disposition    b5.ConnectionDisposition
	Digest         [32]byte
	PoolTransfer   bool
	BackendAbsence bool
	InventoryEpoch uint64
	SourceDigest   [32]byte
}

type InventoryObservation struct {
	Epoch      uint64
	ObservedAt time.Time
	Backends   []BackendIdentity
}

type KeySealer interface {
	Seal(plaintext, aad []byte) (string, error)
	Open(ciphertext string, aad []byte) ([]byte, error)
	KeyID() string
}

type Lease struct {
	ID, ClaimID, DatasourceID         string
	OwnerInstanceID, OwnerIncarnation string
	ClaimGeneration, Generation       uint64
	DialPermitID, DialToken           string
	DialAttempted                     bool
	State                             LeaseState
	Backend                           BackendIdentity
	Disposition                       b5.ConnectionDisposition
	ProofSchemaID                     string
	ProofSchemaVersion                uint16
	ProofDigest                       [32]byte
	InventoryEpoch                    uint64
	Charged                           bool
	Revision                          int64
}

type LeaseState string

type LedgerStore interface {
	ConfigureBudget(context.Context, Budget) (Budget, error)
	Budget(context.Context, string) (Budget, error)
	AcquireClaim(context.Context, ClaimRequest) (Claim, error)
	Claim(context.Context, string) (Claim, error)
	ReservePlan(context.Context, PlanLease) error
	ReleasePlan(context.Context, string) error
	IssueDialPermit(context.Context, string, uint64, string, string) (Lease, error)
	MarkDialStarted(context.Context, string, uint64) (Lease, error)
	BindBackend(context.Context, string, uint64, BackendIdentity) (Lease, error)
	AcquireFree(context.Context, string, uint64, string, string) (Lease, error)
	BeginTermination(context.Context, string, uint64) (Lease, error)
	ApplyDisposition(context.Context, string, uint64, DispositionProof) (Lease, error)
	FenceOwner(context.Context, string, string) ([]Claim, error)
	ListClaimLeases(context.Context, string) ([]Lease, error)
	AbandonUndialed(context.Context, string, uint64, [32]byte) (Lease, error)
	ReconcileAbsence(context.Context, string, uint64, AbsenceProof) (Lease, error)
	ShrinkFencedClaim(context.Context, string, uint64) (Claim, error)
}

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

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

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

type PlanLease struct {
	ID, DatasourceID                  string
	OwnerInstanceID, OwnerIncarnation string
	Bytes                             int64
}

type ReapReport struct {
	FencedClaims, ReconciledChildren, TerminatedBackends int
	ClaimsReleased, CapacityReleased                     int
	InventoryBlocked                                     bool
}

type Reaper struct {
	Ledger    LedgerStore
	Inventory BackendInventory
}

type RouteDecision struct {
	Session          store.B5Session
	Code             b5.ErrorCode
	RetrySameRequest bool
	StickyRoute      string
	Authorized       bool
}

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

type SessionStore interface {
	Create(context.Context, store.B5Session) (store.B5Session, error)
	Get(context.Context, string) (store.B5Session, error)
	CASStatus(context.Context, string, int64, b5.SessionStatus, b5.SessionStatus, time.Time) (store.B5Session, error)
	CASOwner(context.Context, string, int64, string, uint64, string, string, string, []byte) (store.B5Session, error)
	ListExpired(context.Context, time.Time, int) ([]store.B5Session, error)
}

type TerminalDisposition struct {
	Schema        string
	SchemaVersion uint16
	Disposition   b5.ConnectionDisposition
}

type Tombstone struct {
	ID              string
	SessionIDDigest [32]byte
	TerminalCode    string
	FinalSeq        uint64
	OwnerEpoch      uint64
	EventDigest     [32]byte
	ExpiresAt       time.Time
}

type TombstoneBudget struct {
	MaxEntries, MaxChurnPerSecond int
	MaxBytes                      int64
}