storeadapter

package
v0.2.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 4, 2026 License: MIT Imports: 5 Imported by: 0

Documentation

Overview

Package storeadapter 是 Captain 在 STORE / SERVER 两条 lane 合并后的唯一接线点： 把 *store.Store 接到 internal/server/storeport.PluginStore 端口。

storeport 刻意不 import internal/store（并行开发期依赖倒置），因此本包是唯一 同时认识两者的薄映射层：只做行字段互转与哨兵错误归一，不含任何业务逻辑。 语义不变量（事务边界、配额整体失败、purge 语义、secret 只存 handle）全部由 internal/store 实现并由其暗卷测试覆盖，本适配器不重复也不削弱它们。

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func New 

func New(st *store.Store) storeport.PluginStore

New 返回端口实现；st 为 nil 时返回 nil，调用方按「未接线」安全降级。

Types

type Adapter 

type Adapter struct {
	// contains filtered or unexported fields
}

Adapter 把 *store.Store 适配为 storeport.PluginStore。

func (*Adapter) CountPluginInstances 

func (a *Adapter) CountPluginInstances(tenantID int64) (int, error)

func (*Adapter) CreatePluginInstance 

func (a *Adapter) CreatePluginInstance(row storeport.PluginInstanceRow) (uint64, error)

func (*Adapter) DeletePluginInstance 

func (a *Adapter) DeletePluginInstance(tenantID int64, edgeID, instanceID string, purge bool) (uint64, error)

func (*Adapter) GetPluginEdgeRevision 

func (a *Adapter) GetPluginEdgeRevision(tenantID int64, edgeID string) (storeport.PluginEdgeRevisionRow, error)

func (*Adapter) GetPluginInstance 

func (a *Adapter) GetPluginInstance(tenantID int64, edgeID, instanceID string) (storeport.PluginInstanceRow, bool, error)

func (*Adapter) GetTenantPolicy 

func (a *Adapter) GetTenantPolicy(tenantID int64) (storeport.TenantPolicyRow, error)

func (*Adapter) ListPluginInstallationsTenant 

func (a *Adapter) ListPluginInstallationsTenant(tenantID int64) ([]storeport.PluginInstallationRow, error)

func (*Adapter) ListPluginInstancesTenant 

func (a *Adapter) ListPluginInstancesTenant(tenantID int64) ([]storeport.PluginInstanceRow, error)

func (*Adapter) ListPluginObservationsTenant 

func (a *Adapter) ListPluginObservationsTenant(tenantID int64) ([]storeport.PluginObservationRow, error)

func (*Adapter) PluginDesiredRevision 

func (a *Adapter) PluginDesiredRevision(tenantID int64, edgeID string) (uint64, error)

func (*Adapter) SetPluginEdgeApplied 

func (a *Adapter) SetPluginEdgeApplied(tenantID int64, edgeID, bootID string, seq, appliedRevision uint64, at int64) error

func (*Adapter) SetPluginEdgeReport 

func (a *Adapter) SetPluginEdgeReport(tenantID int64, edgeID, bootID string, seq uint64, at int64) error

func (*Adapter) SetTenantPolicy 

func (a *Adapter) SetTenantPolicy(tenantID int64, p storeport.TenantPolicyRow) error

func (*Adapter) UpdatePluginInstance 

func (a *Adapter) UpdatePluginInstance(row storeport.PluginInstanceRow) (uint64, error)

func (*Adapter) UpsertPluginInstallations 

func (a *Adapter) UpsertPluginInstallations(tenantID int64, edgeID string, rows []api.PluginInstallationStatusData) error

func (*Adapter) UpsertPluginObservations 

func (a *Adapter) UpsertPluginObservations(tenantID int64, edgeID string, rows []api.PluginObservedInstanceData, reportedAt int64) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.