sqlite

package
v0.31.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 26, 2026 License: MIT Imports: 28 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CanonicalDatabasePath added in v0.20.0 

func CanonicalDatabasePath(path string) (string, error)

func DefaultTestUIPath 

func DefaultTestUIPath(root string) string

Types

type MaintenanceError added in v0.26.0 

type MaintenanceError struct {
	Reason      MaintenanceErrorReason
	Retryable   bool
	SafeToRetry bool
	Err         error
}

func (*MaintenanceError) Error added in v0.26.0 

func (e *MaintenanceError) Error() string

func (*MaintenanceError) Unwrap added in v0.26.0 

func (e *MaintenanceError) Unwrap() error

type MaintenanceErrorReason added in v0.26.0 

type MaintenanceErrorReason string
const (
	MaintenanceErrorInvalidRequest MaintenanceErrorReason = "invalid_request"
	MaintenanceErrorCancelled      MaintenanceErrorReason = "cancelled"
	MaintenanceErrorBusy           MaintenanceErrorReason = "busy"
	MaintenanceErrorPermission     MaintenanceErrorReason = "permission_denied"
	MaintenanceErrorIO             MaintenanceErrorReason = "io_error"
	MaintenanceErrorCorrupt        MaintenanceErrorReason = "corrupt"
	MaintenanceErrorStale          MaintenanceErrorReason = "inspection_stale"
	MaintenanceErrorLeaseMismatch  MaintenanceErrorReason = "lease_policy_mismatch"
)

type MaintenanceInspection added in v0.26.0 

type MaintenanceInspection struct {
	Kind                 MaintenanceStoreKind
	State                MaintenanceState
	Exists               bool
	Empty                bool
	Observed             storage.StoreSchemaIdentity
	Current              storage.StoreSchemaIdentity
	Migratable           []storage.StoreSchemaMigrationSource
	PersistedLeasePolicy *sessiontree.LeasePolicy
	RequestedLeasePolicy sessiontree.LeasePolicy
	LeasePolicyMatches   bool
	AutomaticMigration   bool
	RequiresExclusive    bool
	Retryable            bool
	SafeToRetry          bool
	Reason               string
	SafeDetail           string
}

func Inspect added in v0.26.0 

func Inspect(ctx context.Context, path string, requested sessiontree.LeasePolicy) (MaintenanceInspection, error)

type MaintenancePhase added in v0.26.0 

type MaintenancePhase string
const (
	MaintenancePhasePreflight MaintenancePhase = "preflight"
	MaintenancePhaseWaiting   MaintenancePhase = "waiting_for_exclusive_access"
	MaintenancePhaseMigrating MaintenancePhase = "migrating"
	MaintenancePhaseVerifying MaintenancePhase = "verifying"
)

type MaintenanceProgress added in v0.26.0 

type MaintenanceProgress struct {
	Sequence     uint64
	Phase        MaintenancePhase
	Status       MaintenanceStatus
	Step         int
	Total        int
	SafeToCancel bool
	Committed    bool
	RolledBack   bool
	Retryable    bool
	SafeToRetry  bool
	Reason       string
}

type MaintenanceState added in v0.26.0 

type MaintenanceState string
const (
	MaintenanceStateMissing          MaintenanceState = "missing"
	MaintenanceStateEmpty            MaintenanceState = "empty"
	MaintenanceStateCurrent          MaintenanceState = "current"
	MaintenanceStateUpgradeable      MaintenanceState = "upgradeable"
	MaintenanceStateUnsupportedOlder MaintenanceState = "unsupported_older"
	MaintenanceStateFuture           MaintenanceState = "future"
	MaintenanceStateDrifted          MaintenanceState = "drifted"
	MaintenanceStateCorrupt          MaintenanceState = "corrupt"
	MaintenanceStateBusy             MaintenanceState = "busy"
	MaintenanceStatePermissionDenied MaintenanceState = "permission_denied"
	MaintenanceStateIOError          MaintenanceState = "io_error"
)

type MaintenanceStatus added in v0.26.0 

type MaintenanceStatus string
const (
	MaintenanceStatusRunning   MaintenanceStatus = "running"
	MaintenanceStatusReady     MaintenanceStatus = "ready"
	MaintenanceStatusFailed    MaintenanceStatus = "failed"
	MaintenanceStatusCancelled MaintenanceStatus = "cancelled"
)

type MaintenanceStoreKind added in v0.26.0 

type MaintenanceStoreKind string
const (
	MaintenanceStoreKindUnknown MaintenanceStoreKind = "unknown"
	MaintenanceStoreKindFloret  MaintenanceStoreKind = "floret"
)

type MaintenanceVerification added in v0.26.0 

type MaintenanceVerification struct {
	Inspection MaintenanceInspection
	Checks     []VerificationCheck
}

func Verify added in v0.26.0 

func Verify(ctx context.Context, path string, requested sessiontree.LeasePolicy) (MaintenanceVerification, error)

type MigrationMode added in v0.26.0 

type MigrationMode string
const (
	MigrationModePlan  MigrationMode = "plan"
	MigrationModeApply MigrationMode = "apply"
)

type MigrationRequest added in v0.26.0 

type MigrationRequest struct {
	Mode           MigrationMode
	ExpectedSchema storage.StoreSchemaIdentity
	LeasePolicy    sessiontree.LeasePolicy
	Progress       func(MaintenanceProgress)
}

type MigrationResult added in v0.26.0 

type MigrationResult struct {
	Mode        MigrationMode
	Before      MaintenanceInspection
	After       MaintenanceInspection
	Steps       []MigrationStep
	Status      MaintenanceStatus
	Changed     bool
	Committed   bool
	RolledBack  bool
	Retryable   bool
	SafeToRetry bool
	Reason      string
}

func Migrate added in v0.26.0 

func Migrate(ctx context.Context, path string, request MigrationRequest) (result MigrationResult, resultErr error)

type MigrationStep added in v0.26.0 

type MigrationStep struct {
	From storage.StoreSchemaIdentity
	To   storage.StoreSchemaIdentity
	Code string
}

type OpenPrecondition added in v0.27.0 

type OpenPrecondition struct {
	State    MaintenanceState
	Observed storage.StoreSchemaIdentity
}

OpenPrecondition binds a Store open to a previously observed maintenance state. It is internal to Floret's public runtime adapter.

type Option 

type Option func(*options)

func WithAuthorityClock added in v0.18.0 

func WithAuthorityClock(now func() time.Time) Option

func WithLeasePolicy added in v0.18.0 

func WithLeasePolicy(policy sessiontree.LeasePolicy) Option

func WithOpenPrecondition added in v0.27.0 

func WithOpenPrecondition(precondition OpenPrecondition) Option

type Store 

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

func Open 

func Open(path string, opts ...Option) (*Store, error)

func OpenContext added in v0.27.0 

func OpenContext(ctx context.Context, path string, opts ...Option) (*Store, error)

func (*Store) AcquireTurnLease 

func (s *Store) AcquireTurnLease(ctx context.Context, request sessiontree.TurnLease) (sessiontree.TurnLease, error)

func (*Store) ActiveToolset 

func (s *Store) ActiveToolset(ctx context.Context, promptScopeID, provider, model string) (cache.ToolsetSnapshot, bool, error)

func (*Store) ActiveTurnLease 

func (s *Store) ActiveTurnLease(ctx context.Context, threadID string) (sessiontree.TurnLease, bool, error)

func (*Store) AdmitPendingToolCompletion added in v0.18.0 

func (s *Store) AdmitPendingToolCompletion(ctx context.Context, req sessiontree.AdmitPendingToolCompletionRequest) (sessiontree.AdmitPendingToolCompletionResult, error)

func (*Store) AdmitSubAgentInput added in v0.18.0 

func (s *Store) AdmitSubAgentInput(ctx context.Context, req sessiontree.AdmitSubAgentInputRequest) (sessiontree.AdmitSubAgentInputResult, error)

func (*Store) AdmitTurn added in v0.18.0 

func (s *Store) AdmitTurn(ctx context.Context, req sessiontree.AdmitTurnRequest) (sessiontree.AdmitTurnResult, error)

func (*Store) Append 

func (s *Store) Append(ctx context.Context, entry sessiontree.Entry, opts sessiontree.AppendOptions) (sessiontree.Entry, error)

func (*Store) AppendProviderRequest 

func (s *Store) AppendProviderRequest(ctx context.Context, req cache.ProviderRequestRecord) error

func (*Store) AppendProviderResponse 

func (s *Store) AppendProviderResponse(ctx context.Context, resp cache.ProviderResponseRecord) error

func (*Store) AppendSegment 

func (s *Store) AppendSegment(ctx context.Context, seg cache.Segment) error

func (*Store) AppendToolset 

func (s *Store) AppendToolset(ctx context.Context, snap cache.ToolsetSnapshot) error

func (*Store) Approval added in v0.20.0 

func (s *Store) Approval(ctx context.Context, approvalID string) (sessiontree.ApprovalRecord, error)

func (*Store) ArtifactClosure added in v0.18.0 

func (s *Store) ArtifactClosure(ctx context.Context, req sessiontree.ArtifactClosureRequest) (artifact.Closure, error)

func (*Store) AuthorityLeasePolicy added in v0.18.0 

func (s *Store) AuthorityLeasePolicy() sessiontree.LeasePolicy

func (*Store) BeginAutomaticThreadTitle added in v0.20.0 

func (s *Store) BeginAutomaticThreadTitle(ctx context.Context, req sessiontree.BeginAutomaticThreadTitleRequest) (sessiontree.ThreadTitleMutationResult, error)

func (*Store) BeginCompaction added in v0.18.0 

func (s *Store) BeginCompaction(ctx context.Context, req sessiontree.BeginCompactionRequest) (sessiontree.BeginCompactionResult, error)

func (*Store) BeginEffectDispatch added in v0.18.0 

func (s *Store) BeginEffectDispatch(ctx context.Context, req sessiontree.BeginEffectDispatchRequest) (sessiontree.EffectAttempt, error)

func (*Store) CancelApprovalBatch added in v0.20.0 

func (s *Store) CancelApprovalBatch(ctx context.Context, req sessiontree.CancelApprovalBatchRequest) (sessiontree.CancelApprovalBatchResult, error)

func (*Store) CanonicalTurnEntries added in v0.20.0 

func (s *Store) CanonicalTurnEntries(ctx context.Context, threadID, turnID, runID string) ([]sessiontree.Entry, bool, error)

func (*Store) Close 

func (s *Store) Close() error

func (*Store) CommitApprovalDispatch added in v0.20.0 

func (s *Store) CommitApprovalDispatch(ctx context.Context, req sessiontree.CommitApprovalDispatchRequest) (sessiontree.CommitApprovalDispatchResult, error)

func (*Store) CommitForkOperation added in v0.18.0 

func (s *Store) CommitForkOperation(ctx context.Context, req storage.ForkOperationCommitRequest) (storage.ForkOperationRecord, bool, error)

func (*Store) CompareAndSwapAgentTodoState added in v0.11.0 

func (s *Store) CompareAndSwapAgentTodoState(ctx context.Context, state sessiontree.AgentTodoState, expectedVersion int64) (sessiontree.AgentTodoState, error)

func (*Store) CompleteAutomaticThreadTitle added in v0.20.0 

func (s *Store) CompleteAutomaticThreadTitle(ctx context.Context, req sessiontree.CompleteAutomaticThreadTitleRequest) (sessiontree.ThreadTitleMutationResult, error)

func (*Store) CreateRoot added in v0.18.0 

func (s *Store) CreateRoot(ctx context.Context, req sessiontree.CreateRootRequest) (sessiontree.CreateRootResult, error)

func (*Store) CreateThread 

func (s *Store) CreateThread(ctx context.Context, meta sessiontree.ThreadMeta) (sessiontree.ThreadMeta, error)

func (*Store) CreateThreadWithInitialEntry added in v0.18.0 

func (s *Store) CreateThreadWithInitialEntry(ctx context.Context, meta sessiontree.ThreadMeta, initial sessiontree.Entry) (sessiontree.ThreadMeta, sessiontree.Entry, error)

func (*Store) DBPath 

func (s *Store) DBPath() string

func (*Store) DeleteMetadata 

func (s *Store) DeleteMetadata(ctx context.Context, namespace, id string) error

func (*Store) DeletePromptScopes 

func (s *Store) DeletePromptScopes(ctx context.Context, promptScopeIDs ...string) error

func (*Store) DeleteProviderState added in v0.10.0 

func (s *Store) DeleteProviderState(ctx context.Context, threadID string) error

func (*Store) DeleteRootTree added in v0.18.0 

func (s *Store) DeleteRootTree(ctx context.Context, rootThreadID string) (sessiontree.DeleteRootTreeResult, error)

func (*Store) Entries 

func (s *Store) Entries(ctx context.Context, threadID string) ([]sessiontree.Entry, error)

func (*Store) Entry 

func (s *Store) Entry(ctx context.Context, threadID, entryID string) (sessiontree.Entry, error)

func (*Store) FailAutomaticThreadTitle added in v0.20.0 

func (s *Store) FailAutomaticThreadTitle(ctx context.Context, req sessiontree.FailAutomaticThreadTitleRequest) (sessiontree.ThreadTitleMutationResult, error)

func (*Store) FailForkOperation added in v0.18.0 

func (s *Store) FailForkOperation(ctx context.Context, req storage.ForkOperationFailureRequest) (storage.ForkOperationRecord, bool, error)

func (*Store) FinalizeApproval added in v0.20.0 

func (s *Store) FinalizeApproval(ctx context.Context, req sessiontree.FinalizeApprovalRequest) (sessiontree.FinalizeApprovalResult, error)

func (*Store) FinishCompaction added in v0.18.0 

func (s *Store) FinishCompaction(ctx context.Context, req sessiontree.FinishCompactionRequest) (sessiontree.FinishCompactionResult, error)

func (*Store) FinishEffectDispatch added in v0.18.0 

func (s *Store) FinishEffectDispatch(ctx context.Context, req sessiontree.FinishEffectDispatchRequest) (sessiontree.FinishEffectDispatchResult, error)

func (*Store) FinishSubAgentClose added in v0.18.0 

func (s *Store) FinishSubAgentClose(ctx context.Context, req sessiontree.FinishSubAgentCloseRequest) (sessiontree.FinishSubAgentCloseResult, error)

func (*Store) FinishTurn added in v0.18.0 

func (s *Store) FinishTurn(ctx context.Context, req sessiontree.FinishTurnRequest) (sessiontree.FinishTurnResult, error)

func (*Store) Fork 

func (s *Store) Fork(ctx context.Context, opts sessiontree.ForkOptions) (sessiontree.ThreadMeta, error)

func (*Store) ForkOperation added in v0.5.0 

func (s *Store) ForkOperation(ctx context.Context, operationID string) (storage.ForkOperationRecord, error)

func (*Store) ForkWithInitialEntry added in v0.18.0 

func (s *Store) ForkWithInitialEntry(ctx context.Context, opts sessiontree.ForkOptions, initial sessiontree.Entry) (sessiontree.ThreadMeta, sessiontree.Entry, error)

func (*Store) InspectSubAgentThreadAuthority added in v0.19.0 

func (s *Store) InspectSubAgentThreadAuthority(ctx context.Context, parentThreadID, childThreadID string) (sessiontree.SubAgentThreadAuthoritySnapshot, error)

func (*Store) InspectThreadAuthority added in v0.18.0 

func (s *Store) InspectThreadAuthority(ctx context.Context, threadID string) (sessiontree.ThreadAuthoritySnapshot, error)

func (*Store) LatestPressureAnchor 

func (s *Store) LatestPressureAnchor(ctx context.Context, promptScopeID, providerName, model string) (cache.PressureAnchorState, bool, error)

func (*Store) ListCanonicalTurns added in v0.20.0 

func (s *Store) ListCanonicalTurns(ctx context.Context, opts sessiontree.ListCanonicalTurnsOptions) (sessiontree.CanonicalTurnsPage, error)

func (*Store) ListMetadata 

func (s *Store) ListMetadata(ctx context.Context, namespace string) ([]storage.MetadataRecord, error)

func (*Store) ListSubAgentInputs added in v0.18.0 

func (s *Store) ListSubAgentInputs(ctx context.Context, childThreadID string, state sessiontree.SubAgentInputState) ([]sessiontree.SubAgentInputRecord, error)

func (*Store) ListThreads 

func (s *Store) ListThreads(ctx context.Context, opts sessiontree.ListThreadsOptions) ([]sessiontree.ThreadMeta, error)

func (*Store) MarkEffectUnknown added in v0.18.0 

func (s *Store) MarkEffectUnknown(ctx context.Context, req sessiontree.MarkEffectUnknownRequest) (sessiontree.EffectAttempt, error)

func (*Store) Metadata 

func (s *Store) Metadata(ctx context.Context, namespace, id string) (storage.MetadataRecord, error)

func (*Store) MoveLeaf 

func (s *Store) MoveLeaf(ctx context.Context, threadID, entryID string) error

func (*Store) Path 

func (s *Store) Path(ctx context.Context, threadID, leafID string) ([]sessiontree.Entry, error)

func (*Store) PathPage added in v0.11.4 

func (s *Store) PathPage(ctx context.Context, threadID, leafID, beforeEntryID string, limit int) (sessiontree.PathPage, error)

func (*Store) PendingAutomaticThreadTitles added in v0.20.0 

func (s *Store) PendingAutomaticThreadTitles(ctx context.Context) ([]sessiontree.ThreadMeta, error)

func (*Store) PrepareApprovalBatch added in v0.20.0 

func (s *Store) PrepareApprovalBatch(ctx context.Context, req sessiontree.PrepareApprovalBatchRequest) (sessiontree.PrepareApprovalBatchResult, error)

func (*Store) PrepareEffectAttempt added in v0.18.0 

func (s *Store) PrepareEffectAttempt(ctx context.Context, req sessiontree.PrepareEffectAttemptRequest) (sessiontree.PrepareEffectAttemptResult, error)

func (*Store) PrepareForkOperation added in v0.5.0 

func (s *Store) PrepareForkOperation(ctx context.Context, rec storage.ForkOperationRecord) (storage.ForkOperationRecord, bool, error)

func (*Store) PrepareSubAgentClose added in v0.18.0 

func (s *Store) PrepareSubAgentClose(ctx context.Context, req sessiontree.PrepareSubAgentCloseRequest) (sessiontree.PrepareSubAgentCloseResult, error)

func (*Store) ProviderRequests 

func (s *Store) ProviderRequests(ctx context.Context, promptScopeID string) ([]cache.ProviderRequestRecord, error)

func (*Store) ProviderResponses 

func (s *Store) ProviderResponses(ctx context.Context, promptScopeID string) ([]cache.ProviderResponseRecord, error)

func (*Store) ProviderState added in v0.10.0 

func (s *Store) ProviderState(ctx context.Context, threadID string) (sessiontree.ProviderStateRecord, error)

func (*Store) PublishSubAgent added in v0.18.0 

func (s *Store) PublishSubAgent(ctx context.Context, req sessiontree.PublishSubAgentRequest) (sessiontree.PublishSubAgentResult, error)

func (*Store) PublishSubAgentInput added in v0.18.0 

func (s *Store) PublishSubAgentInput(ctx context.Context, req sessiontree.PublishSubAgentInputRequest) (sessiontree.SubAgentInputRecord, bool, error)

func (*Store) PublishSubAgentPendingToolCompletion added in v0.18.0 

func (s *Store) PublishSubAgentPendingToolCompletion(ctx context.Context, req sessiontree.PublishSubAgentPendingToolCompletionRequest) (sessiontree.PublishSubAgentPendingToolCompletionResult, error)

func (*Store) PutMetadata 

func (s *Store) PutMetadata(ctx context.Context, rec storage.MetadataRecord) error

func (*Store) PutProviderState added in v0.10.0 

func (s *Store) PutProviderState(ctx context.Context, record sessiontree.ProviderStateRecord) error

func (*Store) ReadAgentTodoState added in v0.11.0 

func (s *Store) ReadAgentTodoState(ctx context.Context, threadID string) (sessiontree.AgentTodoState, error)

func (*Store) ReadApprovalQueue added in v0.20.0 

func (s *Store) ReadApprovalQueue(ctx context.Context, threadID string) (sessiontree.ApprovalQueue, error)

func (*Store) ReadArtifact added in v0.18.0 

func (s *Store) ReadArtifact(ctx context.Context, req sessiontree.ArtifactReadRequest) (sessiontree.ArtifactContent, error)

func (*Store) ReadCanonicalTurn added in v0.31.0 

func (s *Store) ReadCanonicalTurn(ctx context.Context, threadID, turnID string) (sessiontree.CanonicalTurnRead, error)

func (*Store) ReadCompaction added in v0.18.0 

func (s *Store) ReadCompaction(ctx context.Context, threadID, requestID string) (sessiontree.CompactionOperation, bool, error)

func (*Store) ReadPendingToolCompletion added in v0.18.0 

func (s *Store) ReadPendingToolCompletion(ctx context.Context, req sessiontree.AdmitPendingToolCompletionRequest) (sessiontree.AdmitPendingToolCompletionResult, bool, error)

func (*Store) ReadSubAgentInput added in v0.30.0 

func (s *Store) ReadSubAgentInput(ctx context.Context, inputID string) (sessiontree.SubAgentInputRecord, bool, error)

func (*Store) ReadTurnAdmission added in v0.20.0 

func (s *Store) ReadTurnAdmission(ctx context.Context, threadID, turnID, runID string) (sessiontree.AdmitTurnResult, bool, error)

func (*Store) RecoverInterruptedTurn added in v0.18.0 

func (s *Store) RecoverInterruptedTurn(ctx context.Context, req sessiontree.RecoverInterruptedTurnRequest) (sessiontree.RecoverInterruptedTurnResult, error)

func (*Store) RejectEffectAttempt added in v0.18.0 

func (s *Store) RejectEffectAttempt(ctx context.Context, req sessiontree.RejectEffectAttemptRequest) (sessiontree.EffectAttempt, error)

func (*Store) ReleaseTurnLease 

func (s *Store) ReleaseTurnLease(ctx context.Context, proof sessiontree.TurnLease) error

func (*Store) RenewTurnLease added in v0.18.0 

func (s *Store) RenewTurnLease(ctx context.Context, proof sessiontree.TurnLease) (sessiontree.TurnLease, error)

func (*Store) ResolveApproval added in v0.20.0 

func (s *Store) ResolveApproval(ctx context.Context, req sessiontree.ResolveApprovalRequest) (sessiontree.ResolveApprovalResult, error)

func (*Store) SchemaVersion 

func (s *Store) SchemaVersion(ctx context.Context) (string, error)

func (*Store) Segments 

func (s *Store) Segments(ctx context.Context, promptScopeID, provider, model string) ([]cache.Segment, error)

func (*Store) SetThreadTitle added in v0.18.0 

func (s *Store) SetThreadTitle(ctx context.Context, req sessiontree.SetThreadTitleRequest) (sessiontree.ThreadTitleMutationResult, error)

func (*Store) SettlePendingToolRecovery added in v0.18.0 

func (s *Store) SettlePendingToolRecovery(ctx context.Context, req sessiontree.SettlePendingToolRecoveryRequest) (sessiontree.SettlePendingToolRecoveryResult, error)

func (*Store) TakeOverCompaction added in v0.18.0 

func (s *Store) TakeOverCompaction(ctx context.Context, req sessiontree.TakeOverCompactionRequest) (sessiontree.BeginCompactionResult, error)

func (*Store) Thread 

func (s *Store) Thread(ctx context.Context, threadID string) (sessiontree.ThreadMeta, error)

func (*Store) ThreadTombstone added in v0.18.0 

func (s *Store) ThreadTombstone(ctx context.Context, threadID string) (sessiontree.ThreadTombstone, error)

func (*Store) UpdateThread 

func (s *Store) UpdateThread(ctx context.Context, meta sessiontree.ThreadMeta) error

func (*Store) ValidateArtifactForkDestination added in v0.18.0 

func (s *Store) ValidateArtifactForkDestination(ctx context.Context, closure artifact.Closure) error

func (*Store) ValidateInterruptedTurnResolution added in v0.19.0 

func (s *Store) ValidateInterruptedTurnResolution(ctx context.Context, req sessiontree.RecoverInterruptedTurnRequest) error

func (*Store) WaitApprovalDecision added in v0.20.0 

func (s *Store) WaitApprovalDecision(ctx context.Context, approvalID string) (sessiontree.WaitApprovalDecisionResult, error)

type VerificationCheck added in v0.26.0 

type VerificationCheck struct {
	Code       string
	Passed     bool
	SafeDetail string
}

type WriterAdmission added in v0.20.0 

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

WriterAdmission serializes writers opened by this process for one physical SQLite database while keeping admission responsive to context cancellation.

func NewWriterAdmission added in v0.20.0 

func NewWriterAdmission(path string) (*WriterAdmission, error)

func (*WriterAdmission) Close added in v0.20.0 

func (a *WriterAdmission) Close()

func (*WriterAdmission) Reserve added in v0.20.0 

func (a *WriterAdmission) Reserve(ctx context.Context) (func(), error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.