storeport

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

type PluginEdgeRevisionRow struct {
	TenantID        int64
	EdgeID          string
	DesiredRevision uint64
	AppliedRevision uint64
	BootID          string
	LastSequence    uint64
	LastReportAt    int64
	LastAckAt       int64
}

type PluginInstallationRow struct {
	TenantID          int64
	EdgeID            string
	PluginID          string
	Version           string
	Kind              string
	Protocol          int
	Digest            string
	TrustMode         string
	Verified          bool
	VerifiedPublisher string
	PermissionsJSON   string
	ContributionsJSON string
	CapabilitiesJSON  string
	ReportedAt        int64
}

type PluginInstanceRow struct {
	TenantID   int64
	EdgeID     string
	InstanceID string
	PluginID   string
	Version    string
	Enabled    bool
	Isolation  string
	ConfigJSON string
	SecretRefs string
	Revision   uint64
	CreatedAt  int64
	UpdatedAt  int64
}

type PluginObservationRow struct {
	TenantID     int64
	EdgeID       string
	InstanceID   string
	PluginID     string
	Version      string
	HostOnline   bool
	State        string
	Health       string
	Detail       string
	RestartCount int
	LastHealthy  int64
	MessageRate  float64
	ReportedAt   int64
}

type PluginStore interface {
	// ---- 插件期望态（Server 权威）----
	ListPluginInstancesTenant(tenantID int64) ([]PluginInstanceRow, error)
	GetPluginInstance(tenantID int64, edgeID, instanceID string) (PluginInstanceRow, bool, error)
	CreatePluginInstance(row PluginInstanceRow) (uint64, error)
	UpdatePluginInstance(row PluginInstanceRow) (uint64, error)
	// DeletePluginInstance 删除期望态并 +1 revision（Edge 需要收敛「实例已移除」）。
	// purge=false 必须保留该实例的 observed 投影、领域记录、定时任务与全部审计；
	// purge=true 才在同一事务中清除该实例的 observed 投影、领域记录和定时任务。
	DeletePluginInstance(tenantID int64, edgeID, instanceID string, purge bool) (uint64, error)
	PluginDesiredRevision(tenantID int64, edgeID string) (uint64, error)

	// ---- Edge revision / applied 投影 ----
	GetPluginEdgeRevision(tenantID int64, edgeID string) (PluginEdgeRevisionRow, error)
	// SetPluginEdgeApplied 写入 applied_revision 与 ack 时间。rejected/failed 的 ack
	// 也会调用它，但传入的是**未变化的** appliedRevision（只刷新 LastAckAt）。
	SetPluginEdgeApplied(tenantID int64, edgeID, bootID string, seq, appliedRevision uint64, at int64) error
	SetPluginEdgeReport(tenantID int64, edgeID, bootID string, seq uint64, at int64) error

	// ---- Edge 上报的只读投影 ----
	UpsertPluginInstallations(tenantID int64, edgeID string, rows []api.PluginInstallationStatusData) error
	UpsertPluginObservations(tenantID int64, edgeID string, rows []api.PluginObservedInstanceData, reportedAt int64) error
	ListPluginObservationsTenant(tenantID int64) ([]PluginObservationRow, error)
	ListPluginInstallationsTenant(tenantID int64) ([]PluginInstallationRow, error)

	// ---- 租户策略 / 配额 / 保留期 ----
	GetTenantPolicy(tenantID int64) (TenantPolicyRow, error)
	SetTenantPolicy(tenantID int64, p TenantPolicyRow) error
	CountPluginInstances(tenantID int64) (int, error)
}

type TenantPolicyRow struct {
	TenantID              int64
	RetentionEvents       int
	RetentionCommands     int
	RetentionAudit        int
	RetentionTokens       int
	RetentionObservations int
	QuotaDevices          int
	QuotaEdges            int
	QuotaBrowserWS        int
	QuotaTokens           int
	QuotaUsers            int
	QuotaEventsPerMinute  int
	QuotaPluginInstances  int
	UpdatedAt             int64
}