controlstore

package

Go to main page

Versions in this module

v1

v1.1.4

Aug 15, 2026

Changes in this version

type ExecutionView

+ func (v ExecutionView) ListPendingExternalInstallActivations(ctx context.Context, owner ExecutionOwner) ([]ExternalInstallActivation, error)

+ type ExternalInstallActivation struct

+ ActivationRequest registry.ReleaseInstallActivationRequest

+ EntriesSHA256 string

+ Execution execution.Execution

+ InstalledManagementRevision uint64

+ ManifestSHA256 string

+ PackageSHA256 string

+ PluginInstanceID string

+ type ExternalInstallActivationRequest struct

+ Activation registry.ReleaseInstallActivationRequest

+ ExecutionID string

+ Now time.Time

+ Owner ExecutionOwner

type RegistryView

+ func (v RegistryView) InstallExternalPackageWithActivation(ctx context.Context, ownerEnvHash string, ...) (registry.PluginRecord, ExternalInstallActivation, error)

v1.1.3

Aug 14, 2026

v1.1.2

Aug 14, 2026

v1.1.1

Aug 14, 2026

v1.1.0

Aug 14, 2026

v1.0.0

Aug 13, 2026

retracted

Changes in this version

+ var ErrIncompatible = errors.New("control store is incompatible")

+ var ErrMigration = errors.New("control store migration failed")

+ var ErrRecordNotFound = errors.New("control store record not found")

+ var ErrRequestsBlocked = errors.New("control store is not ready; requests are blocked")

+ var ErrRevisionConflict = errors.New("control store revision conflict")

+ var ErrStateConflict = errors.New("control store state conflict")

+ func SourceDigest(path string) (string, error)

+ type Config struct

+ Faults Faults

+ Path string

+ Sources []Source

+ type Confirmation struct

+ ExpiresAt int64

+ ID string

+ OwnerEnvHash string

+ OwnerSessionHash string

+ OwnerUserHash string

+ PluginInstanceID string

+ RawJSON json.RawMessage

+ SessionChannelIDHash string

+ Status string

+ type ConfirmationRevocation struct

+ RawJSON json.RawMessage

+ RevokedCount int

+ TeardownOperationID string

+ type ConfirmationView struct

+ func (v ConfirmationView) ConsumeConfirmationIntentRecord(ctx context.Context, id string, scope sessionctx.SessionScope, now time.Time) (security.ConfirmationIntentRecord, error)

+ func (v ConfirmationView) FinalizeSessionConfirmationIntentRevocation(ctx context.Context, scope sessionctx.SessionScope, operationID string) error

+ func (v ConfirmationView) Generation() uint64

+ func (v ConfirmationView) Get(ctx context.Context, id string) (Confirmation, error)

+ func (v ConfirmationView) ListConfirmationIntentRecords(ctx context.Context, pluginInstanceID string) ([]security.ConfirmationIntentRecord, error)

+ func (v ConfirmationView) Put(ctx context.Context, value Confirmation) error

+ func (v ConfirmationView) PutConfirmationIntentRecord(ctx context.Context, record security.ConfirmationIntentRecord, now time.Time, ...) error

+ func (v ConfirmationView) RejectConfirmationIntentRecord(ctx context.Context, req security.RejectConfirmationIntentRequest) (security.ConfirmationIntentRecord, error)

+ func (v ConfirmationView) Resolve(ctx context.Context, id, status string, now time.Time) (Confirmation, error)

+ func (v ConfirmationView) RevokePluginConfirmationIntentRecords(ctx context.Context, ownerEnvHash, pluginInstanceID string) (int, error)

+ func (v ConfirmationView) RevokeSession(ctx context.Context, value ConfirmationRevocation) (int, error)

+ func (v ConfirmationView) RevokeSessionConfirmationIntentRecords(ctx context.Context, scope sessionctx.SessionScope, operationID string, ...) (int, error)

+ type Event = executionmodel.Event

+ type Execution = executionmodel.Execution

+ type ExecutionOwner struct

+ OwnerEnvHash string

+ OwnerSessionHash string

+ OwnerUserHash string

+ SessionChannelIDHash string

+ func (owner ExecutionOwner) Valid() bool

+ type ExecutionPruneRequest struct

+ Before time.Time

+ Limit int

+ MaxTerminalRecordsPerPlugin int

+ type ExecutionPruneResult struct

+ Deleted int

+ type ExecutionReconcileResult struct

+ Canceled int

+ Orphaned int

+ Records []execution.Execution

+ type ExecutionView struct

+ func (v ExecutionView) Append(ctx context.Context, event execution.Event) error

+ func (v ExecutionView) Create(ctx context.Context, value execution.Execution) error

+ func (v ExecutionView) CreateOwned(ctx context.Context, value execution.Execution, owner ExecutionOwner) error

+ func (v ExecutionView) EventsAfter(ctx context.Context, id string, cursor uint64, limit int) ([]execution.Event, error)

+ func (v ExecutionView) EventsAfterOwned(ctx context.Context, id string, owner ExecutionOwner, cursor uint64, limit int) ([]execution.Event, error)

+ func (v ExecutionView) Finish(ctx context.Context, id, status, failureCode string, event execution.Event, ...) error

+ func (v ExecutionView) Generation() uint64

+ func (v ExecutionView) Get(ctx context.Context, id string) (execution.Execution, error)

+ func (v ExecutionView) GetOwned(ctx context.Context, id string, owner ExecutionOwner) (execution.Execution, error)

+ func (v ExecutionView) GetReleaseInstall(ctx context.Context, ownerEnvHash, executionID string) (registry.ReleaseInstallOperation, error)

+ func (v ExecutionView) GetReleaseInstallByRequest(ctx context.Context, ownerEnvHash, requestID string) (registry.ReleaseInstallOperation, error)

+ func (v ExecutionView) List(ctx context.Context, pluginInstanceID string) ([]execution.Execution, error)

+ func (v ExecutionView) ListOwned(ctx context.Context, pluginInstanceID string, owner ExecutionOwner, ...) ([]execution.Execution, uint64, error)

+ func (v ExecutionView) ListReleaseInstalls(ctx context.Context, ownerEnvHash string) ([]registry.ReleaseInstallOperation, error)

+ func (v ExecutionView) PruneTerminal(ctx context.Context, req ExecutionPruneRequest) (ExecutionPruneResult, error)

+ func (v ExecutionView) ReconcileOrphans(ctx context.Context, now time.Time) (ExecutionReconcileResult, error)

+ func (v ExecutionView) RequestCancel(ctx context.Context, id string, now time.Time) error

+ func (v ExecutionView) RequestCancelOwned(ctx context.Context, id string, owner ExecutionOwner, now time.Time) (execution.Execution, error)

+ func (v ExecutionView) StartReleaseInstall(ctx context.Context, owner ExecutionOwner, ...) (registry.ReleaseInstallOperation, bool, error)

+ func (v ExecutionView) UpdateReleaseInstall(ctx context.Context, ownerEnvHash string, ...) (registry.ReleaseInstallOperation, error)

+ type Faults struct

+ AfterImport error

+ AfterPublish error

+ BeforePublish error

+ SyncDirectory func(string) error

+ type Grant struct

+ CapabilityID string

+ RawJSON json.RawMessage

+ Revision uint64

+ type PluginInstall struct

+ Grants []Grant

+ Policy *Policy

+ Record PluginRecord

+ type PluginRecord struct

+ ActiveFingerprint string

+ DeletedAt *int64

+ DisabledReason string

+ EnabledAt *int64

+ EntriesSHA256 string

+ InstalledAt int64

+ ManagementRevision uint64

+ ManifestSHA256 string

+ OwnerEnvHash string

+ PackageSHA256 string

+ PluginID string

+ PluginInstanceID string

+ PolicyRevision uint64

+ PublisherID string

+ RawJSON json.RawMessage

+ RevokeEpoch uint64

+ State string

+ UpdatedAt int64

+ Version string

+ type PluginSnapshot struct

+ Grants []Grant

+ Policy *Policy

+ Record PluginRecord

+ type Policy struct

+ RawJSON json.RawMessage

+ Revision uint64

+ UpdatedAt int64

+ type RegistryView struct

+ func (v RegistryView) AbortInstall(ctx context.Context, ownerEnvHash, pluginInstanceID string) error

+ func (v RegistryView) Generation() uint64

+ func (v RegistryView) Get(ctx context.Context, ownerEnvHash, pluginInstanceID string) (PluginSnapshot, error)

+ func (v RegistryView) GetAuthorization(ctx context.Context, ownerEnvHash, pluginInstanceID string) (registry.AuthorizationSnapshot, error)

+ func (v RegistryView) GetPlugin(ctx context.Context, ownerEnvHash, pluginInstanceID string) (registry.PluginRecord, error)

+ func (v RegistryView) Install(ctx context.Context, value PluginInstall) error

+ func (v RegistryView) InstallExternalPackage(ctx context.Context, ownerEnvHash string, ...) (registry.PluginRecord, error)

+ func (v RegistryView) ListAuthorization(ctx context.Context, ownerEnvHash string) ([]registry.AuthorizationSnapshot, error)

+ func (v RegistryView) ListPlugins(ctx context.Context, ownerEnvHash string) ([]registry.PluginRecord, error)

+ func (v RegistryView) PutPlugin(ctx context.Context, ownerEnvHash string, record registry.PluginRecord, ...) (registry.PluginRecord, error)

+ func (v RegistryView) ReplaceAuthorization(ctx context.Context, record PluginRecord, ...) error

+ func (v RegistryView) ReplaceAuthorizationSnapshot(ctx context.Context, snapshot registry.AuthorizationSnapshot, ...) error

+ func (v RegistryView) SetEnableState(ctx context.Context, ownerEnvHash, pluginInstanceID string, ...) (registry.PluginRecord, error)

+ type SessionFence struct

+ ProofSHA256 []byte

+ RawJSON json.RawMessage

+ State string

+ UpdatedAt int64

+ type SessionKey struct

+ OwnerEnvHash string

+ OwnerSessionHash string

+ OwnerUserHash string

+ SessionChannelIDHash string

+ type SessionPhase struct

+ Phase string

+ RawJSON json.RawMessage

+ type SessionView struct

+ func (v SessionView) AccumulateSessionControl(ctx context.Context, scope sessionctx.SessionScope, delta sessionscope.Counts, ...) (sessionscope.ControlRecord, error)

+ func (v SessionView) AccumulateSessionControlPhase(ctx context.Context, scope sessionctx.SessionScope, phase sessionscope.Phase, ...) (sessionscope.ControlRecord, error)

+ func (v SessionView) BeginSessionControlTeardown(ctx context.Context, proposed sessionscope.ControlRecord, maxScopes int) (sessionscope.ControlRecord, error)

+ func (v SessionView) DeriveSessionTeardownIdentity(ctx context.Context, key SessionKey) (string, []byte, error)

+ func (v SessionView) FinalizeSessionControl(ctx context.Context, scope sessionctx.SessionScope, operationID string, ...) error

+ func (v SessionView) Generation() uint64

+ func (v SessionView) Get(ctx context.Context, key SessionKey) (SessionFence, []SessionPhase, error)

+ func (v SessionView) GetSessionControlRecord(ctx context.Context, scope sessionctx.SessionScope) (sessionscope.ControlRecord, error)

+ func (v SessionView) ListSessionControlRecords(ctx context.Context) ([]sessionscope.ControlRecord, error)

+ func (v SessionView) PutFence(ctx context.Context, value SessionFence) error

+ func (v SessionView) PutPhase(ctx context.Context, value SessionPhase) error

+ func (v SessionView) TransitionFence(ctx context.Context, value SessionFence, expectedState string) error

+ func (v SessionView) TransitionSessionControl(ctx context.Context, scope sessionctx.SessionScope, ...) (sessionscope.ControlRecord, error)

+ type Source struct

+ Kind string

+ Name string

+ Path string

+ Version int

+ type Store struct

+ func Migrate(ctx context.Context, cfg Config) (*Store, error)

+ func Open(ctx context.Context, cfg Config) (*Store, error)

+ func (s *Store) AppendEvent(ctx context.Context, event Event) error

+ func (s *Store) BindRetained(ctx context.Context, expected plugindata.Binding, ...) (plugindata.Binding, error)

+ func (s *Store) CleanupExpired(ctx context.Context, now time.Time, expected []plugindata.Binding) ([]plugindata.Binding, error)

+ func (s *Store) Close() error

+ func (s *Store) CommitEnable(ctx context.Context, expectedManagementRevision uint64, ...) error

+ func (s *Store) CommitUninstall(ctx context.Context, req plugindata.CommitUninstallRequest) (plugindata.CommitUninstallResult, error)

+ func (s *Store) Confirmations() ConfirmationView

+ func (s *Store) CreateExecution(ctx context.Context, execution Execution) error

+ func (s *Store) CreateObject(ctx context.Context, scope sessionctx.ScopeKind, object plugindata.Object) error

+ func (s *Store) DeleteObject(ctx context.Context, scope sessionctx.ScopeKind, ...) error

+ func (s *Store) DeleteRetained(ctx context.Context, expected plugindata.Binding) error

+ func (s *Store) Executions() ExecutionView

+ func (s *Store) Generation() uint64

+ func (s *Store) GetBinding(ctx context.Context, pluginInstanceID string) (plugindata.Binding, bool, error)

+ func (s *Store) GetExecution(ctx context.Context, id string) (Execution, error)

+ func (s *Store) GetObject(ctx context.Context, scope sessionctx.ScopeKind, ...) (plugindata.Object, bool, error)

+ func (s *Store) ListAllBindingsForMaintenance(ctx context.Context, cursor string, limit int) ([]plugindata.MaintenanceBinding, string, error)

+ func (s *Store) ListAllObjectsForMaintenance(ctx context.Context, cursor string, limit int) ([]plugindata.MaintenanceObject, string, error)

+ func (s *Store) ListBindings(ctx context.Context, cursor string, limit int) ([]plugindata.Binding, string, error)

+ func (s *Store) ListObjects(ctx context.Context, scope sessionctx.ScopeKind, ...) ([]plugindata.Object, string, error)

+ func (s *Store) Ready() bool

+ func (s *Store) Registry() RegistryView

+ func (s *Store) Sessions() SessionView

+ func (s *Store) SwapImport(ctx context.Context, expectedManagementRevision uint64, ...) error

Other modules containing this package

github.com/floegence/redevplugin/v2

github.com/floegence/redevplugin/v3

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