store

func (*DBStore) CreateAgent ¶

func (s *DBStore) CreateAgent(ctx context.Context, a config.Agent) error

func (*DBStore) CreateAgentWithCredentials ¶ added in v0.61.0

func (s *DBStore) CreateAgentWithCredentials(ctx context.Context, a config.Agent, creds []providercred.Encrypted) error

CreateAgentWithCredentials inserts the Agent and all its credential rows in one transaction. A plain (non-upsert) credential insert means a duplicate (agent_id, provider_id) aborts the whole transaction, so a partial write can never leave an Agent with some of its credentials.

func (*DBStore) CreateChannel ¶ added in v0.61.0

func (s *DBStore) CreateChannel(ctx context.Context, ch config.Channel) error

func (*DBStore) CreateProvider ¶

func (s *DBStore) CreateProvider(ctx context.Context, p config.Provider) error

func (*DBStore) DeleteAgent ¶

func (s *DBStore) DeleteAgent(ctx context.Context, id string) error

func (*DBStore) DeleteAgentProviderCredential ¶ added in v0.61.0

func (s *DBStore) DeleteAgentProviderCredential(ctx context.Context, agentID, providerID string) error

DeleteAgentProviderCredential removes one credential. It is idempotent: a DELETE affecting zero rows is not an error.

func (*DBStore) DeleteChannel ¶

func (s *DBStore) DeleteChannel(ctx context.Context, id string) error

func (*DBStore) DeleteChatAgent ¶

func (s *DBStore) DeleteChatAgent(ctx context.Context, channelID, platform, chatID string) error

func (*DBStore) DeleteManifestPluginOverride ¶

func (s *DBStore) DeleteManifestPluginOverride(ctx context.Context, pluginID string) error

func (*DBStore) DeletePlugin ¶

func (s *DBStore) DeletePlugin(ctx context.Context, id string) error

func (*DBStore) DeleteProvider ¶

func (s *DBStore) DeleteProvider(ctx context.Context, id string) error

func (*DBStore) GetAgent ¶

func (s *DBStore) GetAgent(ctx context.Context, id string) (config.Agent, error)

func (*DBStore) GetAgentProviderCredential ¶ added in v0.61.0

func (s *DBStore) GetAgentProviderCredential(ctx context.Context, agentID, providerID string) (providercred.Encrypted, bool, error)

GetAgentProviderCredential returns one credential's ciphertext, or found=false when the Agent has no override for that Provider.

func (*DBStore) GetChannel ¶

func (s *DBStore) GetChannel(ctx context.Context, id string) (config.Channel, error)

func (*DBStore) GetChatAgent ¶

func (s *DBStore) GetChatAgent(ctx context.Context, channelID, platform, chatID string) (string, error)

func (*DBStore) GetManifestPluginOverride ¶

func (s *DBStore) GetManifestPluginOverride(ctx context.Context, pluginID string) (config.ManifestPluginOverride, bool, error)

func (*DBStore) GetPlugin ¶

func (s *DBStore) GetPlugin(ctx context.Context, id string) (config.Plugin, error)

func (*DBStore) GetProvider ¶

func (s *DBStore) GetProvider(ctx context.Context, id string) (config.Provider, error)

func (*DBStore) GetSetting ¶

func (s *DBStore) GetSetting(ctx context.Context, key string) (string, error)

func (*DBStore) ListAccessibleAgents ¶

func (s *DBStore) ListAccessibleAgents(ctx context.Context, userID string) ([]config.Agent, error)

func (*DBStore) ListAgentProviderCredentials ¶ added in v0.61.0

func (s *DBStore) ListAgentProviderCredentials(ctx context.Context, agentID string) ([]providercred.Metadata, error)

ListAgentProviderCredentials returns secret-free metadata for one Agent. The underlying query never selects api_key_enc.

func (*DBStore) ListAgents ¶

func (s *DBStore) ListAgents(ctx context.Context) ([]config.Agent, error)

func (*DBStore) ListCachedModels ¶ added in v0.60.0

func (s *DBStore) ListCachedModels(ctx context.Context) ([]config.CachedModel, error)

func (*DBStore) ListChannels ¶

func (s *DBStore) ListChannels(ctx context.Context) ([]config.Channel, error)

func (*DBStore) ListChannelsByType ¶

func (s *DBStore) ListChannelsByType(ctx context.Context, channelType string) ([]config.Channel, error)

func (*DBStore) ListEnabledAgents ¶

func (s *DBStore) ListEnabledAgents(ctx context.Context) ([]config.Agent, error)

func (*DBStore) ListEnabledPlugins ¶

func (s *DBStore) ListEnabledPlugins(ctx context.Context) ([]config.Plugin, error)

func (*DBStore) ListManifestPluginOverrides ¶

func (s *DBStore) ListManifestPluginOverrides(ctx context.Context) ([]config.ManifestPluginOverride, error)

func (*DBStore) ListPluginOverrides ¶

func (s *DBStore) ListPluginOverrides(ctx context.Context) ([]config.Plugin, error)

func (*DBStore) ListPlugins ¶

func (s *DBStore) ListPlugins(ctx context.Context) ([]config.Plugin, error)

func (*DBStore) ListPluginsByKind ¶

func (s *DBStore) ListPluginsByKind(ctx context.Context, kind string) ([]config.Plugin, error)

func (*DBStore) ListProviderIDs ¶ added in v0.61.0

func (s *DBStore) ListProviderIDs(ctx context.Context) ([]string, error)

ListProviderIDs returns canonical Provider row IDs without loading Provider config, which contains the deployment-global API key.

func (*DBStore) ListProviders ¶

func (s *DBStore) ListProviders(ctx context.Context) ([]config.Provider, error)

func (*DBStore) ReplaceCachedModels ¶ added in v0.60.0

func (s *DBStore) ReplaceCachedModels(ctx context.Context, providerID string, modelIDs []string) error

func (*DBStore) Seed ¶

func (s *DBStore) Seed(ctx context.Context) error

Seed removes legacy configuration and creates Stella only for an empty agent catalog.

func (*DBStore) SetChannelPluginConfig ¶ added in v0.63.2

func (s *DBStore) SetChannelPluginConfig(ctx context.Context, id, kind, name string, cfg map[string]any) error

func (*DBStore) SetChatAgent ¶

func (s *DBStore) SetChatAgent(ctx context.Context, channelID, platform, chatID, agentID string) error

func (*DBStore) SetPluginConfig ¶

func (s *DBStore) SetPluginConfig(ctx context.Context, id string, cfg map[string]any) error

func (*DBStore) SetPluginEnabled ¶

func (s *DBStore) SetPluginEnabled(ctx context.Context, id string, enabled bool) error

SetPluginEnabled and SetPluginConfig each write one column. They are the admin kill switch and the channel credential mirror, and those two run concurrently: a read-modify-write of the whole row would let either one silently restore the other's previous value. The read stays only to name a row that may not exist yet.

func (*DBStore) SetSetting ¶

func (s *DBStore) SetSetting(ctx context.Context, key, value string) error

func (*DBStore) Snapshot ¶

func (s *DBStore) Snapshot(ctx context.Context, agentID string) (*config.Snapshot, error)

func (*DBStore) UpdateAgent ¶

func (s *DBStore) UpdateAgent(ctx context.Context, a config.Agent) error

func (*DBStore) UpdateChannel ¶ added in v0.61.0

func (s *DBStore) UpdateChannel(ctx context.Context, ch config.Channel) error

func (*DBStore) UpdateProvider ¶

func (s *DBStore) UpdateProvider(ctx context.Context, p config.Provider) error

func (*DBStore) UpsertAgentProviderCredential ¶ added in v0.61.0

func (s *DBStore) UpsertAgentProviderCredential(ctx context.Context, agentID string, cred providercred.Encrypted) (providercred.Metadata, error)

UpsertAgentProviderCredential writes or atomically rotates one credential.

func (*DBStore) UpsertChannel ¶

func (s *DBStore) UpsertChannel(ctx context.Context, ch config.Channel) error

func (*DBStore) UpsertManifestPluginOverride ¶

func (s *DBStore) UpsertManifestPluginOverride(ctx context.Context, ov config.ManifestPluginOverride) error

func (*DBStore) UpsertPlugin ¶

func (s *DBStore) UpsertPlugin(ctx context.Context, p config.Plugin) error