Documentation
¶
Overview ¶
Package local provides filesystem and in-memory implementations of the application package's infrastructure ports for local SDD deployments.
Index ¶
- type FilesystemGraphStore
- func (s *FilesystemGraphStore) Apply(ctx context.Context, expectedRevision string, batch app.MutationBatch, ...) (app.ApplyResult, error)
- func (s *FilesystemGraphStore) Current(ctx context.Context) (*app.Snapshot, error)
- func (s *FilesystemGraphStore) ReadAttachmentPage(_ context.Context, entryID, filename string, offset int64, maxBytes int) (app.AttachmentPage, error)
- func (s *FilesystemGraphStore) Reconcile(_ context.Context, mutationID, batchDigest string) (app.ApplyResult, error)
- type FilesystemGraphStoreOptions
- type FilesystemSessionStore
- func (s *FilesystemSessionStore) Append(_ context.Context, id app.SessionID, expectedVersion uint64, ...) (uint64, error)
- func (s *FilesystemSessionStore) Create(_ context.Context, metadata app.SessionMetadata) (app.StoredSession, error)
- func (s *FilesystemSessionStore) List(_ context.Context, filter app.SessionFilter) ([]app.StoredSession, error)
- func (s *FilesystemSessionStore) Load(_ context.Context, id app.SessionID) (app.StoredSession, error)
- type FilesystemStagedBlobStore
- func (s *FilesystemStagedBlobStore) Open(_ context.Context, owner app.BlobOwner, id string) (io.ReadCloser, error)
- func (s *FilesystemStagedBlobStore) Release(_ context.Context, owner app.BlobOwner, retentionID string) error
- func (s *FilesystemStagedBlobStore) Retain(_ context.Context, owner app.BlobOwner, retentionID string, ids []string) error
- func (s *FilesystemStagedBlobStore) Stage(_ context.Context, owner app.BlobOwner, filename string, content io.Reader) (app.StagedBlob, error)
- func (s *FilesystemStagedBlobStore) Stat(_ context.Context, owner app.BlobOwner, id string) (app.StagedBlob, error)
- type MemorySearchIndexStore
- func (s *MemorySearchIndexStore) Manifest(_ context.Context, namespace app.IndexNamespace) ([]app.StoredChunkRef, error)
- func (s *MemorySearchIndexStore) Nearest(_ context.Context, namespaces []app.IndexNamespace, vector []float32, ...) ([]app.ScoredChunkHit, error)
- func (s *MemorySearchIndexStore) Reconcile(_ context.Context, namespace app.IndexNamespace, _ string, ...) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type FilesystemGraphStore ¶
type FilesystemGraphStore struct {
// contains filtered or unexported fields
}
FilesystemGraphStore is the local canonical graph authority. It owns its revision cache and never requires callers to invalidate snapshots.
func NewFilesystemGraphStore ¶
func NewFilesystemGraphStore(options FilesystemGraphStoreOptions) (*FilesystemGraphStore, error)
func (*FilesystemGraphStore) Apply ¶
func (s *FilesystemGraphStore) Apply(ctx context.Context, expectedRevision string, batch app.MutationBatch, blobs app.StagedBlobReader) (app.ApplyResult, error)
func (*FilesystemGraphStore) ReadAttachmentPage ¶
func (s *FilesystemGraphStore) ReadAttachmentPage(_ context.Context, entryID, filename string, offset int64, maxBytes int) (app.AttachmentPage, error)
func (*FilesystemGraphStore) Reconcile ¶
func (s *FilesystemGraphStore) Reconcile(_ context.Context, mutationID, batchDigest string) (app.ApplyResult, error)
type FilesystemSessionStore ¶
type FilesystemSessionStore struct {
// contains filtered or unexported fields
}
FilesystemSessionStore persists each session as append-only JSONL. Events stay opaque and every append is version-CAS protected.
func NewFilesystemSessionStore ¶
func NewFilesystemSessionStore(dir string) (*FilesystemSessionStore, error)
func (*FilesystemSessionStore) Append ¶
func (s *FilesystemSessionStore) Append(_ context.Context, id app.SessionID, expectedVersion uint64, appendData app.SessionAppend) (uint64, error)
func (*FilesystemSessionStore) Create ¶
func (s *FilesystemSessionStore) Create(_ context.Context, metadata app.SessionMetadata) (app.StoredSession, error)
func (*FilesystemSessionStore) List ¶
func (s *FilesystemSessionStore) List(_ context.Context, filter app.SessionFilter) ([]app.StoredSession, error)
func (*FilesystemSessionStore) Load ¶
func (s *FilesystemSessionStore) Load(_ context.Context, id app.SessionID) (app.StoredSession, error)
type FilesystemStagedBlobStore ¶
type FilesystemStagedBlobStore struct {
// contains filtered or unexported fields
}
func NewFilesystemStagedBlobStore ¶
func NewFilesystemStagedBlobStore(dir string) (*FilesystemStagedBlobStore, error)
func (*FilesystemStagedBlobStore) Open ¶
func (s *FilesystemStagedBlobStore) Open(_ context.Context, owner app.BlobOwner, id string) (io.ReadCloser, error)
type MemorySearchIndexStore ¶
type MemorySearchIndexStore struct {
// contains filtered or unexported fields
}
MemorySearchIndexStore is a process-local mechanical vector index. It is useful for embedded compositions that want root-owned lazy reconciliation without operating a separate persistent index service.
func NewMemorySearchIndexStore ¶
func NewMemorySearchIndexStore() *MemorySearchIndexStore
func (*MemorySearchIndexStore) Manifest ¶
func (s *MemorySearchIndexStore) Manifest(_ context.Context, namespace app.IndexNamespace) ([]app.StoredChunkRef, error)
func (*MemorySearchIndexStore) Nearest ¶
func (s *MemorySearchIndexStore) Nearest(_ context.Context, namespaces []app.IndexNamespace, vector []float32, limit int) ([]app.ScoredChunkHit, error)
func (*MemorySearchIndexStore) Reconcile ¶
func (s *MemorySearchIndexStore) Reconcile(_ context.Context, namespace app.IndexNamespace, _ string, upserts []app.IndexedChunk, deletes []string) error
Source Files
Click to show internal directories.
Click to hide internal directories.