storage

Jul 19, 2026

Changes in this version

type FileDeleteRequest

+ ResourceScope sessionctx.ResourceScope

type FileListRequest

+ Cursor string

+ ResourceScope sessionctx.ResourceScope

type FileListResult

+ NextCursor string

type FileReadRequest

+ ResourceScope sessionctx.ResourceScope

type FileWriteRequest

+ ResourceScope sessionctx.ResourceScope

type KVDeleteRequest

+ ResourceScope sessionctx.ResourceScope

type KVGetRequest

+ ResourceScope sessionctx.ResourceScope

type KVListRequest

+ Cursor string

+ ResourceScope sessionctx.ResourceScope

type KVListResult

+ NextCursor string

type KVPutRequest

+ ResourceScope sessionctx.ResourceScope

type NamespaceRecord

+ GenerationID string

type SQLiteExecRequest

+ ResourceScope sessionctx.ResourceScope

type SQLiteQueryRequest

+ ResourceScope sessionctx.ResourceScope

Jul 12, 2026

Changes in this version

+ const MaxKVKeyBytes

+ var ErrArchiveNotFound = errors.New("storage archive not found")

+ var ErrFileNotFound = errors.New("storage file not found")

+ var ErrFileTooLarge = errors.New("storage file too large")

+ var ErrInvalidFilePath = errors.New("storage file path is invalid")

+ var ErrInvalidKVKey = errors.New("storage kv key is invalid")

+ var ErrInvalidNamespace = errors.New("storage namespace is invalid")

+ var ErrInvalidSQLite = errors.New("storage sqlite request is invalid")

+ var ErrKVKeyNotFound = errors.New("storage kv key not found")

+ var ErrKVValueTooLarge = errors.New("storage kv value too large")

+ var ErrNamespaceAlreadyExists = errors.New("storage namespace already exists")

+ var ErrNamespaceNotFound = errors.New("storage namespace not found")

+ var ErrNamespaceNotRetained = errors.New("storage namespace is not retained")

+ var ErrQuotaExceeded = errors.New("storage quota exceeded")

+ var ErrSQLiteResultTooLarge = errors.New("storage sqlite result too large")

+ type ArchiveRecord struct

+ ArchiveRef string

+ CreatedAt time.Time

+ IncludeSecrets bool

+ Namespaces []NamespaceRecord

+ SourcePluginInstanceID string

+ type BindRetainedRequest struct

+ DryRun bool

+ Now time.Time

+ SourcePluginInstanceID string

+ TargetNamespaces []Namespace

+ TargetPluginInstanceID string

+ type Broker interface

+ DeleteNamespace func(ctx context.Context, pluginInstanceID string, deleteData bool) error

+ EnsureNamespace func(ctx context.Context, ns Namespace) error

+ ExportData func(ctx context.Context, req ExportRequest) (string, error)

+ ImportData func(ctx context.Context, req ImportRequest) error

+ type ExportRequest struct

+ IncludeSecrets bool

+ PluginInstanceID string

+ type FileBroker struct

+ func NewFileBroker(root string) (*FileBroker, error)

+ func (b *FileBroker) BindRetainedNamespace(ctx context.Context, req BindRetainedRequest) error

+ func (b *FileBroker) DeleteFile(ctx context.Context, req FileDeleteRequest) error

+ func (b *FileBroker) DeleteKV(ctx context.Context, req KVDeleteRequest) error

+ func (b *FileBroker) DeleteNamespace(ctx context.Context, pluginInstanceID string, deleteData bool) error

+ func (b *FileBroker) DeleteRetainedNamespace(ctx context.Context, pluginInstanceID string) error

+ func (b *FileBroker) EnsureNamespace(ctx context.Context, ns Namespace) error

+ func (b *FileBroker) ExecSQLite(ctx context.Context, req SQLiteExecRequest) (SQLiteExecResult, error)

+ func (b *FileBroker) ExportData(ctx context.Context, req ExportRequest) (string, error)

+ func (b *FileBroker) GetKV(ctx context.Context, req KVGetRequest) (KVGetResult, error)

+ func (b *FileBroker) ImportData(ctx context.Context, req ImportRequest) error

+ func (b *FileBroker) ListFiles(ctx context.Context, req FileListRequest) (FileListResult, error)

+ func (b *FileBroker) ListKV(ctx context.Context, req KVListRequest) (KVListResult, error)

+ func (b *FileBroker) ListNamespaces(ctx context.Context, pluginInstanceID string) ([]NamespaceRecord, error)

+ func (b *FileBroker) NamespacePath(ctx context.Context, pluginInstanceID string, storeID string) (string, error)

+ func (b *FileBroker) PutKV(ctx context.Context, req KVPutRequest) (KVPutResult, error)

+ func (b *FileBroker) QuerySQLite(ctx context.Context, req SQLiteQueryRequest) (SQLiteQueryResult, error)

+ func (b *FileBroker) ReadFile(ctx context.Context, req FileReadRequest) (FileReadResult, error)

+ func (b *FileBroker) Root() string

+ func (b *FileBroker) Usage(ctx context.Context, pluginInstanceID string, storeID string) (Usage, error)

+ func (b *FileBroker) WriteFile(ctx context.Context, req FileWriteRequest) (FileWriteResult, error)

+ type FileDeleteRequest struct

+ Path string

+ PluginInstanceID string

+ Recursive bool

+ StoreID string

+ type FileEntry struct

+ Dir bool

+ Path string

+ SizeBytes int64

+ UpdatedAt time.Time

+ type FileListRequest struct

+ MaxEntries int

+ Path string

+ PluginInstanceID string

+ StoreID string

+ type FileListResult struct

+ Entries []FileEntry

+ Path string

+ Usage Usage

+ type FileReadRequest struct

+ MaxBytes int64

+ Path string

+ PluginInstanceID string

+ StoreID string

+ type FileReadResult struct

+ Data []byte

+ Path string

+ SizeBytes int64

+ Usage Usage

+ type FileWriteRequest struct

+ Data []byte

+ Path string

+ PluginInstanceID string

+ StoreID string

+ type FileWriteResult struct

+ Path string

+ SizeBytes int64

+ Usage Usage

+ type FilesBroker interface

+ DeleteFile func(ctx context.Context, req FileDeleteRequest) error

+ ListFiles func(ctx context.Context, req FileListRequest) (FileListResult, error)

+ ReadFile func(ctx context.Context, req FileReadRequest) (FileReadResult, error)

+ WriteFile func(ctx context.Context, req FileWriteRequest) (FileWriteResult, error)

+ type ImportRequest struct

+ ArchiveRef string

+ DeleteExisting bool

+ PluginInstanceID string

+ TargetNamespaces []Namespace

+ type Inspector interface

+ ListNamespaces func(ctx context.Context, pluginInstanceID string) ([]NamespaceRecord, error)

+ Usage func(ctx context.Context, pluginInstanceID string, storeID string) (Usage, error)

+ type KVBroker interface

+ DeleteKV func(ctx context.Context, req KVDeleteRequest) error

+ GetKV func(ctx context.Context, req KVGetRequest) (KVGetResult, error)

+ ListKV func(ctx context.Context, req KVListRequest) (KVListResult, error)

+ PutKV func(ctx context.Context, req KVPutRequest) (KVPutResult, error)

+ type KVDeleteRequest struct

+ Key string

+ PluginInstanceID string

+ StoreID string

+ type KVEntry struct

+ Key string

+ SizeBytes int64

+ UpdatedAt time.Time

+ type KVGetRequest struct

+ Key string

+ MaxBytes int64

+ PluginInstanceID string

+ StoreID string

+ type KVGetResult struct

+ Key string

+ SizeBytes int64

+ Usage Usage

+ Value []byte

+ type KVListRequest struct

+ MaxEntries int

+ PluginInstanceID string

+ Prefix string

+ StoreID string

+ type KVListResult struct

+ Entries []KVEntry

+ Prefix string

+ Usage Usage

+ type KVPutRequest struct

+ Key string

+ PluginInstanceID string

+ StoreID string

+ Value []byte

+ type KVPutResult struct

+ Key string

+ SizeBytes int64

+ Usage Usage

+ type MemoryBroker struct

+ func NewMemoryBroker() *MemoryBroker

+ func (b *MemoryBroker) Archive(ref string) (ArchiveRecord, bool)

+ func (b *MemoryBroker) BindRetainedNamespace(_ context.Context, req BindRetainedRequest) error

+ func (b *MemoryBroker) DeleteKV(_ context.Context, req KVDeleteRequest) error

+ func (b *MemoryBroker) DeleteNamespace(_ context.Context, pluginInstanceID string, deleteData bool) error

+ func (b *MemoryBroker) DeleteRetainedNamespace(_ context.Context, pluginInstanceID string) error

+ func (b *MemoryBroker) EnsureNamespace(_ context.Context, ns Namespace) error

+ func (b *MemoryBroker) ExportData(_ context.Context, req ExportRequest) (string, error)

+ func (b *MemoryBroker) GetKV(_ context.Context, req KVGetRequest) (KVGetResult, error)

+ func (b *MemoryBroker) ImportData(_ context.Context, req ImportRequest) error

+ func (b *MemoryBroker) ListKV(_ context.Context, req KVListRequest) (KVListResult, error)

+ func (b *MemoryBroker) ListNamespaces(_ context.Context, pluginInstanceID string) ([]NamespaceRecord, error)

+ func (b *MemoryBroker) PutKV(_ context.Context, req KVPutRequest) (KVPutResult, error)

+ func (b *MemoryBroker) SetUsage(_ context.Context, pluginInstanceID string, storeID string, usageBytes int64) error

+ func (b *MemoryBroker) Usage(_ context.Context, pluginInstanceID string, storeID string) (Usage, error)

+ type Namespace struct

+ Kind StoreKind

+ PluginInstanceID string

+ QuotaBytes int64

+ QuotaFiles int64

+ SchemaVersion int

+ Scope string

+ StoreID string

+ type NamespacePathResolver interface

+ NamespacePath func(ctx context.Context, pluginInstanceID string, storeID string) (string, error)

+ type NamespaceRecord struct

+ CreatedAt time.Time

+ RetainedAt *time.Time

+ State NamespaceState

+ UpdatedAt time.Time

+ UsageBytes int64

+ UsageFiles int64

+ type NamespaceState string

+ const NamespaceActive

+ const NamespaceRetained

+ type RetainedBinder interface

+ BindRetainedNamespace func(ctx context.Context, req BindRetainedRequest) error

+ type RetainedDeleter interface

+ DeleteRetainedNamespace func(ctx context.Context, pluginInstanceID string) error

+ type SQLiteBroker interface

+ ExecSQLite func(ctx context.Context, req SQLiteExecRequest) (SQLiteExecResult, error)

+ QuerySQLite func(ctx context.Context, req SQLiteQueryRequest) (SQLiteQueryResult, error)

+ type SQLiteExecRequest struct

+ Args []SQLiteValue

+ Database string

+ PluginInstanceID string

+ SQL string

+ StoreID string

+ Timeout time.Duration

+ type SQLiteExecResult struct

+ Database string

+ LastInsertID int64

+ RowsAffected int64

+ Usage Usage

+ type SQLiteQueryRequest struct

+ Args []SQLiteValue

+ Database string

+ MaxResponseBytes int64

+ MaxRows int

+ PluginInstanceID string

+ SQL string

+ StoreID string

+ Timeout time.Duration

+ type SQLiteQueryResult struct

+ Columns []string

+ Database string

+ Rows [][]SQLiteValue

+ Usage Usage

+ type SQLiteValue struct

+ Blob []byte

+ Float *float64

+ Int *int64

+ Null bool

+ Text *string

+ type StoreKind string

+ const StoreFiles

+ const StoreKV

+ const StoreSQLite

+ type Usage struct

+ PluginInstanceID string

+ QuotaBytes int64

+ QuotaFiles int64

+ StoreID string

+ UsageBytes int64

+ UsageFiles int64