storage

package

v7.60.3 Latest Latest Go to latest Published: Oct 18, 2026 License: MIT Imports: 13 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/floegence/floret

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
type BackendKernel
- func NewBackendKernel(ctx context.Context, backend spi.Backend, now func() time.Time) (*BackendKernel, error)
- func NewBackendKernelInTransaction(ctx context.Context, backend spi.Backend, tx spi.WriteTx, now func() time.Time, ...) (*BackendKernel, error)
type StartupPhase
type StartupProgress

Constants ¶

View Source

const (
	StartupPhaseMigrating = sessiontree.StartupPhaseMigrating
	StartupPhaseVerifying = sessiontree.StartupPhaseVerifying
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type BackendKernel ¶

type BackendKernel struct {
	*sessiontree.BackendRepo
	// contains filtered or unexported fields
}

BackendKernel is the single domain kernel shared by every public Backend.

func NewBackendKernel ¶

func NewBackendKernel(ctx context.Context, backend spi.Backend, now func() time.Time) (*BackendKernel, error)

func NewBackendKernelInTransaction ¶

func NewBackendKernelInTransaction(ctx context.Context, backend spi.Backend, tx spi.WriteTx, now func() time.Time, allowPromptMigration bool, progress StartupProgress) (*BackendKernel, error)

func (*BackendKernel) ActiveToolset ¶

func (kernel *BackendKernel) ActiveToolset(ctx context.Context, scope, provider, model string) (cache.ToolsetSnapshot, bool, error)

func (*BackendKernel) AppendProviderRequest ¶

func (kernel *BackendKernel) AppendProviderRequest(ctx context.Context, value cache.ProviderRequestRecord) error

func (*BackendKernel) AppendProviderResponse ¶

func (kernel *BackendKernel) AppendProviderResponse(ctx context.Context, value cache.ProviderResponseRecord) error

func (*BackendKernel) AppendSegment ¶

func (kernel *BackendKernel) AppendSegment(ctx context.Context, value cache.Segment) error

func (*BackendKernel) AppendToolset ¶

func (kernel *BackendKernel) AppendToolset(ctx context.Context, value cache.ToolsetSnapshot) error

func (*BackendKernel) CancelTurn ¶

func (kernel *BackendKernel) CancelTurn(ctx context.Context, request sessiontree.CancelTurnRequest) (result sessiontree.CancelTurnResult, err error)

func (*BackendKernel) Checkpoint ¶

func (kernel *BackendKernel) Checkpoint(ctx context.Context) error

Checkpoint flushes only facts not committed by a provider or turn boundary.

func (*BackendKernel) CheckpointProviderRequest ¶

func (kernel *BackendKernel) CheckpointProviderRequest(ctx context.Context, segments []cache.Segment, toolsets []cache.ToolsetSnapshot, request cache.ProviderRequestRecord) error

Candidate facts stay local until the dispatch checkpoint commits. Existing pending observations survive a failed checkpoint and are safe to retry.

func (*BackendKernel) DeletePromptScopes ¶

func (kernel *BackendKernel) DeletePromptScopes(ctx context.Context, scopes ...string) error

func (*BackendKernel) DeleteRootTree ¶

func (kernel *BackendKernel) DeleteRootTree(ctx context.Context, root string) (result sessiontree.DeleteRootTreeResult, err error)

func (*BackendKernel) FailUnknownEffectTurn ¶

func (kernel *BackendKernel) FailUnknownEffectTurn(ctx context.Context, request sessiontree.FailUnknownEffectTurnRequest) (result sessiontree.FailUnknownEffectTurnResult, err error)

func (*BackendKernel) FinishTurn ¶

func (kernel *BackendKernel) FinishTurn(ctx context.Context, request sessiontree.FinishTurnRequest) (result sessiontree.FinishTurnResult, err error)

func (*BackendKernel) LatestPressureAnchor ¶

func (kernel *BackendKernel) LatestPressureAnchor(ctx context.Context, scope, provider, model string) (cache.PressureAnchorState, bool, error)

func (*BackendKernel) ProviderRequests ¶

func (kernel *BackendKernel) ProviderRequests(ctx context.Context, scope string) ([]cache.ProviderRequestRecord, error)

func (*BackendKernel) ProviderResponses ¶

func (kernel *BackendKernel) ProviderResponses(ctx context.Context, scope string) ([]cache.ProviderResponseRecord, error)

func (*BackendKernel) Segments ¶

func (kernel *BackendKernel) Segments(ctx context.Context, scope, provider, model string) ([]cache.Segment, error)

func (*BackendKernel) VerifyCurrentStateInTransaction ¶ added in v7.27.0

func (kernel *BackendKernel) VerifyCurrentStateInTransaction(ctx context.Context, tx spi.ReadTx) error

func (*BackendKernel) VerifyInspectionStateInTransaction ¶ added in v7.39.2

func (kernel *BackendKernel) VerifyInspectionStateInTransaction(ctx context.Context, tx spi.ReadTx) error

type StartupPhase ¶ added in v7.0.2

type StartupPhase = sessiontree.StartupPhase

type StartupProgress ¶ added in v7.0.2

type StartupProgress = sessiontree.StartupProgress

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL