Documentation
¶
Index ¶
- type BackendKernel
- func (kernel *BackendKernel) ActiveToolset(ctx context.Context, scopeID, provider, model string) (result cache.ToolsetSnapshot, found bool, err error)
- func (kernel *BackendKernel) AppendProviderRequest(ctx context.Context, value cache.ProviderRequestRecord) error
- func (kernel *BackendKernel) AppendProviderResponse(ctx context.Context, value cache.ProviderResponseRecord) error
- func (kernel *BackendKernel) AppendSegment(ctx context.Context, value cache.Segment) error
- func (kernel *BackendKernel) AppendToolset(ctx context.Context, value cache.ToolsetSnapshot) error
- func (kernel *BackendKernel) CancelTurn(ctx context.Context, request sessiontree.CancelTurnRequest) (result sessiontree.CancelTurnResult, err error)
- func (kernel *BackendKernel) Checkpoint(ctx context.Context) error
- func (kernel *BackendKernel) DeletePromptScopes(ctx context.Context, scopeIDs ...string) error
- func (kernel *BackendKernel) DeleteRootTree(ctx context.Context, rootThreadID string) (result sessiontree.DeleteRootTreeResult, err error)
- func (kernel *BackendKernel) FinishTurn(ctx context.Context, request sessiontree.FinishTurnRequest) (result sessiontree.FinishTurnResult, err error)
- func (kernel *BackendKernel) LatestPressureAnchor(ctx context.Context, scopeID, provider, model string) (result cache.PressureAnchorState, found bool, err error)
- func (kernel *BackendKernel) ProviderRequests(ctx context.Context, scopeID string) (result []cache.ProviderRequestRecord, err error)
- func (kernel *BackendKernel) ProviderResponses(ctx context.Context, scopeID string) (result []cache.ProviderResponseRecord, err error)
- func (kernel *BackendKernel) Segments(ctx context.Context, scopeID, provider, model string) (result []cache.Segment, err error)
Constants ¶
This section is empty.
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)
NewBackendKernel opens all canonical Floret domain state.
func NewBackendKernelInTransaction ¶ added in v4.0.12
func NewBackendKernelInTransaction(ctx context.Context, backend spi.Backend, tx spi.WriteTx, now func() time.Time) (*BackendKernel, error)
NewBackendKernelInTransaction opens all canonical Floret domain state in the caller's startup transaction.
func (*BackendKernel) ActiveToolset ¶
func (kernel *BackendKernel) ActiveToolset(ctx context.Context, scopeID, provider, model string) (result cache.ToolsetSnapshot, found bool, err 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 (*BackendKernel) AppendToolset ¶
func (kernel *BackendKernel) AppendToolset(ctx context.Context, value cache.ToolsetSnapshot) error
func (*BackendKernel) CancelTurn ¶ added in v4.0.19
func (kernel *BackendKernel) CancelTurn(ctx context.Context, request sessiontree.CancelTurnRequest) (result sessiontree.CancelTurnResult, err error)
CancelTurn commits the user Stop terminal and clears prompt continuation in the same checkpoint. It is the cancellation counterpart of FinishTurn.
func (*BackendKernel) Checkpoint ¶
func (kernel *BackendKernel) Checkpoint(ctx context.Context) error
Checkpoint flushes both canonical domain state and memory-resident prompt observations during graceful shutdown or an explicit recovery barrier.
func (*BackendKernel) DeletePromptScopes ¶
func (kernel *BackendKernel) DeletePromptScopes(ctx context.Context, scopeIDs ...string) error
func (*BackendKernel) DeleteRootTree ¶
func (kernel *BackendKernel) DeleteRootTree(ctx context.Context, rootThreadID string) (result sessiontree.DeleteRootTreeResult, err error)
func (*BackendKernel) FinishTurn ¶
func (kernel *BackendKernel) FinishTurn(ctx context.Context, request sessiontree.FinishTurnRequest) (result sessiontree.FinishTurnResult, err error)
FinishTurn commits the terminal semantic state and the accumulated prompt observations in one checkpoint. Prompt segments and provider diagnostics are memory-resident before this boundary so they never delay provider dispatch.
func (*BackendKernel) LatestPressureAnchor ¶
func (kernel *BackendKernel) LatestPressureAnchor(ctx context.Context, scopeID, provider, model string) (result cache.PressureAnchorState, found bool, err error)
func (*BackendKernel) ProviderRequests ¶
func (kernel *BackendKernel) ProviderRequests(ctx context.Context, scopeID string) (result []cache.ProviderRequestRecord, err error)
func (*BackendKernel) ProviderResponses ¶
func (kernel *BackendKernel) ProviderResponses(ctx context.Context, scopeID string) (result []cache.ProviderResponseRecord, err error)