driver_badgerdb

func (*BadgerDbDriver) Connect ¶

func (db *BadgerDbDriver) Connect() error

func (*BadgerDbDriver) DeleteCommand ¶ added in v0.29.0

func (db *BadgerDbDriver) DeleteCommand(command *model.Command) error

func (*BadgerDbDriver) DeleteConversation ¶ added in v0.29.0

func (db *BadgerDbDriver) DeleteConversation(conv *model.Conversation) error

func (*BadgerDbDriver) DeleteEventSink ¶ added in v0.28.0

func (db *BadgerDbDriver) DeleteEventSink(sink *model.EventSink) error

func (*BadgerDbDriver) DeleteGroup ¶

func (db *BadgerDbDriver) DeleteGroup(group *model.Group) error

func (*BadgerDbDriver) DeleteMCPServer ¶ added in v0.29.0

func (db *BadgerDbDriver) DeleteMCPServer(server *model.MCPServer) error

func (*BadgerDbDriver) DeletePoolDefinition ¶ added in v0.28.0

func (db *BadgerDbDriver) DeletePoolDefinition(pool *model.PoolDefinition) error

func (*BadgerDbDriver) DeleteResponse ¶ added in v0.23.0

func (db *BadgerDbDriver) DeleteResponse(response *model.Response) error

func (*BadgerDbDriver) DeleteRole ¶

func (db *BadgerDbDriver) DeleteRole(role *model.Role) error

func (*BadgerDbDriver) DeleteScript ¶ added in v0.23.0

func (db *BadgerDbDriver) DeleteScript(script *model.Script) error

func (*BadgerDbDriver) DeleteSkill ¶ added in v0.23.0

func (db *BadgerDbDriver) DeleteSkill(skill *model.Skill) error

func (*BadgerDbDriver) DeleteSpace ¶

func (db *BadgerDbDriver) DeleteSpace(space *model.Space) error

func (*BadgerDbDriver) DeleteStackDefinition ¶ added in v0.24.0

func (db *BadgerDbDriver) DeleteStackDefinition(def *model.StackDefinition) error

func (*BadgerDbDriver) DeleteTemplate ¶

func (db *BadgerDbDriver) DeleteTemplate(template *model.Template) error

func (*BadgerDbDriver) DeleteTemplateVar ¶

func (db *BadgerDbDriver) DeleteTemplateVar(templateVar *model.TemplateVar) error

func (*BadgerDbDriver) DeleteToken ¶

func (db *BadgerDbDriver) DeleteToken(token *model.Token) error

func (*BadgerDbDriver) DeleteTombstonedConversationsBefore ¶ added in v0.29.0

func (db *BadgerDbDriver) DeleteTombstonedConversationsBefore(before time.Time) error

scanConversations iterates a key prefix. When includeDeleted is false, soft-deleted conversations are skipped (the per-user list view). DeleteTombstonedConversationsBefore is the reaper: it hard-deletes only tombstoned conversations whose UpdatedAt predates the cutoff. (BadgerDB also has an hourly soft-delete reap in connect.go; this is the cross-driver backstop used by the daily retention sweep.)

func (*BadgerDbDriver) DeleteUser ¶

func (db *BadgerDbDriver) DeleteUser(user *model.User) error

func (*BadgerDbDriver) DeleteVolume ¶

func (db *BadgerDbDriver) DeleteVolume(volume *model.Volume) error

func (*BadgerDbDriver) GetAuditLogs ¶

func (db *BadgerDbDriver) GetAuditLogs(filter *model.AuditLogFilter, offset, limit int) ([]*model.AuditLogEntry, int, error)

func (*BadgerDbDriver) GetAuditLogsForExport ¶ added in v0.24.0

func (db *BadgerDbDriver) GetAuditLogsForExport(filter *model.AuditLogFilter) ([]*model.AuditLogEntry, error)

func (*BadgerDbDriver) GetCfgValue ¶

func (db *BadgerDbDriver) GetCfgValue(name string) (*model.CfgValue, error)

func (*BadgerDbDriver) GetCfgValues ¶

func (db *BadgerDbDriver) GetCfgValues() ([]*model.CfgValue, error)

func (*BadgerDbDriver) GetCommand ¶ added in v0.29.0

func (db *BadgerDbDriver) GetCommand(id string) (*model.Command, error)

func (*BadgerDbDriver) GetCommands ¶ added in v0.29.0

func (db *BadgerDbDriver) GetCommands() ([]*model.Command, error)

func (*BadgerDbDriver) GetCommandsByName ¶ added in v0.29.0

func (db *BadgerDbDriver) GetCommandsByName(name string) ([]*model.Command, error)

func (*BadgerDbDriver) GetCommandsByNameAndUser ¶ added in v0.29.0

func (db *BadgerDbDriver) GetCommandsByNameAndUser(name string, userId string) ([]*model.Command, error)

func (*BadgerDbDriver) GetConversation ¶ added in v0.29.0

func (db *BadgerDbDriver) GetConversation(userId string, id string) (*model.Conversation, error)

func (*BadgerDbDriver) GetConversations ¶ added in v0.29.0

func (db *BadgerDbDriver) GetConversations() ([]*model.Conversation, error)

func (*BadgerDbDriver) GetConversationsByUser ¶ added in v0.29.0

func (db *BadgerDbDriver) GetConversationsByUser(userId string) ([]*model.Conversation, error)

func (*BadgerDbDriver) GetEventSink ¶ added in v0.28.0

func (db *BadgerDbDriver) GetEventSink(id string) (*model.EventSink, error)

func (*BadgerDbDriver) GetEventSinks ¶ added in v0.28.0

func (db *BadgerDbDriver) GetEventSinks() ([]*model.EventSink, error)

func (*BadgerDbDriver) GetGroup ¶

func (db *BadgerDbDriver) GetGroup(id string) (*model.Group, error)

func (*BadgerDbDriver) GetGroups ¶

func (db *BadgerDbDriver) GetGroups() ([]*model.Group, error)

func (*BadgerDbDriver) GetMCPServer ¶ added in v0.29.0

func (db *BadgerDbDriver) GetMCPServer(id string) (*model.MCPServer, error)

func (*BadgerDbDriver) GetMCPServers ¶ added in v0.29.0

func (db *BadgerDbDriver) GetMCPServers() ([]*model.MCPServer, error)

func (*BadgerDbDriver) GetMCPServersByUser ¶ added in v0.29.0

func (db *BadgerDbDriver) GetMCPServersByUser(userId string) ([]*model.MCPServer, error)

func (*BadgerDbDriver) GetPoolDefinition ¶ added in v0.28.0

func (db *BadgerDbDriver) GetPoolDefinition(id string) (*model.PoolDefinition, error)

func (*BadgerDbDriver) GetPoolDefinitionByName ¶ added in v0.28.0

func (db *BadgerDbDriver) GetPoolDefinitionByName(userId, name string) (*model.PoolDefinition, error)

func (*BadgerDbDriver) GetPoolDefinitions ¶ added in v0.28.0

func (db *BadgerDbDriver) GetPoolDefinitions() ([]*model.PoolDefinition, error)

func (*BadgerDbDriver) GetPoolDefinitionsByUser ¶ added in v0.28.0

func (db *BadgerDbDriver) GetPoolDefinitionsByUser(userId string) ([]*model.PoolDefinition, error)

GetPoolDefinitionsByUser returns the live pools owned by a user by scanning only that user's PoolsByName keyspace rather than every pool.

func (*BadgerDbDriver) GetResponse ¶ added in v0.23.0

func (db *BadgerDbDriver) GetResponse(id string) (*model.Response, error)

func (*BadgerDbDriver) GetResponses ¶ added in v0.23.0

func (db *BadgerDbDriver) GetResponses() ([]*model.Response, error)

func (*BadgerDbDriver) GetResponsesByStatus ¶ added in v0.23.0

func (db *BadgerDbDriver) GetResponsesByStatus(status model.ResponseStatus) ([]*model.Response, error)

func (*BadgerDbDriver) GetResponsesByUser ¶ added in v0.23.0

func (db *BadgerDbDriver) GetResponsesByUser(userId string) ([]*model.Response, error)

func (*BadgerDbDriver) GetRole ¶

func (db *BadgerDbDriver) GetRole(id string) (*model.Role, error)

func (*BadgerDbDriver) GetRoles ¶

func (db *BadgerDbDriver) GetRoles() ([]*model.Role, error)

func (*BadgerDbDriver) GetScript ¶ added in v0.23.0

func (db *BadgerDbDriver) GetScript(id string) (*model.Script, error)

func (*BadgerDbDriver) GetScriptByName ¶ added in v0.23.0

func (db *BadgerDbDriver) GetScriptByName(name string) (*model.Script, error)

func (*BadgerDbDriver) GetScriptByNameAndUser ¶ added in v0.23.0

func (db *BadgerDbDriver) GetScriptByNameAndUser(name string, userId string) (*model.Script, error)

GetScriptByNameAndUser gets a script by name for a specific user If userId is empty, it searches for global scripts This supports the user script override functionality

func (*BadgerDbDriver) GetScripts ¶ added in v0.23.0

func (db *BadgerDbDriver) GetScripts() ([]*model.Script, error)

func (*BadgerDbDriver) GetScriptsByName ¶ added in v0.23.0

func (db *BadgerDbDriver) GetScriptsByName(name string) ([]*model.Script, error)

GetScriptsByName returns all scripts matching a name (for zone-specific overrides)

func (*BadgerDbDriver) GetScriptsByNameAndUser ¶ added in v0.23.0

func (db *BadgerDbDriver) GetScriptsByNameAndUser(name string, userId string) ([]*model.Script, error)

GetScriptsByNameAndUser returns all scripts matching a name and user_id (for zone-specific overrides)

func (*BadgerDbDriver) GetSkill ¶ added in v0.23.0

func (db *BadgerDbDriver) GetSkill(id string) (*model.Skill, error)

func (*BadgerDbDriver) GetSkills ¶ added in v0.23.0

func (db *BadgerDbDriver) GetSkills() ([]*model.Skill, error)

func (*BadgerDbDriver) GetSkillsByName ¶ added in v0.23.0

func (db *BadgerDbDriver) GetSkillsByName(name string) ([]*model.Skill, error)

func (*BadgerDbDriver) GetSkillsByNameAndUser ¶ added in v0.23.0

func (db *BadgerDbDriver) GetSkillsByNameAndUser(name string, userId string) ([]*model.Skill, error)

func (*BadgerDbDriver) GetSpace ¶

func (db *BadgerDbDriver) GetSpace(id string) (*model.Space, error)

func (*BadgerDbDriver) GetSpaceByName ¶

func (db *BadgerDbDriver) GetSpaceByName(userId string, spaceName string) (*model.Space, error)

func (*BadgerDbDriver) GetSpaceUsageSample ¶ added in v0.24.0

func (db *BadgerDbDriver) GetSpaceUsageSample(id string) (*model.SpaceUsageSample, error)

func (*BadgerDbDriver) GetSpaceUsageSamples ¶ added in v0.24.0

func (db *BadgerDbDriver) GetSpaceUsageSamples(spaceId string, bucketKind string, from time.Time, to time.Time) ([]*model.SpaceUsageSample, error)

func (*BadgerDbDriver) GetSpaces ¶

func (db *BadgerDbDriver) GetSpaces() ([]*model.Space, error)

func (*BadgerDbDriver) GetSpacesByTemplateId ¶

func (db *BadgerDbDriver) GetSpacesByTemplateId(templateId string) ([]*model.Space, error)

func (*BadgerDbDriver) GetSpacesForUser ¶

func (db *BadgerDbDriver) GetSpacesForUser(userId string) ([]*model.Space, error)

func (*BadgerDbDriver) GetStackDefinition ¶ added in v0.24.0

func (db *BadgerDbDriver) GetStackDefinition(id string) (*model.StackDefinition, error)

func (*BadgerDbDriver) GetStackDefinitionByName ¶ added in v0.24.0

func (db *BadgerDbDriver) GetStackDefinitionByName(name string, userId string) (*model.StackDefinition, error)

func (*BadgerDbDriver) GetStackDefinitions ¶ added in v0.24.0

func (db *BadgerDbDriver) GetStackDefinitions() ([]*model.StackDefinition, error)

func (*BadgerDbDriver) GetStackDefinitionsByUserId ¶ added in v0.24.0

func (db *BadgerDbDriver) GetStackDefinitionsByUserId(userId string) ([]*model.StackDefinition, error)

func (*BadgerDbDriver) GetStaleConversations ¶ added in v0.29.0

func (db *BadgerDbDriver) GetStaleConversations(before time.Time) ([]*model.Conversation, error)

GetStaleConversations returns live (non-deleted) conversations whose UpdatedAt predates the cutoff — candidates for retention tombstoning.

func (*BadgerDbDriver) GetTemplate ¶

func (db *BadgerDbDriver) GetTemplate(id string) (*model.Template, error)

func (*BadgerDbDriver) GetTemplateByName ¶ added in v0.23.0

func (db *BadgerDbDriver) GetTemplateByName(name string) (*model.Template, error)

func (*BadgerDbDriver) GetTemplateVar ¶

func (db *BadgerDbDriver) GetTemplateVar(id string) (*model.TemplateVar, error)

func (*BadgerDbDriver) GetTemplateVarByName ¶ added in v0.23.0

func (db *BadgerDbDriver) GetTemplateVarByName(name string) (*model.TemplateVar, error)

func (*BadgerDbDriver) GetTemplateVars ¶

func (db *BadgerDbDriver) GetTemplateVars() ([]*model.TemplateVar, error)

func (*BadgerDbDriver) GetTemplates ¶

func (db *BadgerDbDriver) GetTemplates() ([]*model.Template, error)

func (*BadgerDbDriver) GetToken ¶

func (db *BadgerDbDriver) GetToken(id string) (*model.Token, error)

func (*BadgerDbDriver) GetTokens ¶

func (db *BadgerDbDriver) GetTokens() ([]*model.Token, error)

func (*BadgerDbDriver) GetTokensForUser ¶

func (db *BadgerDbDriver) GetTokensForUser(userId string) ([]*model.Token, error)

func (*BadgerDbDriver) GetUser ¶

func (db *BadgerDbDriver) GetUser(id string) (*model.User, error)

func (*BadgerDbDriver) GetUserByEmail ¶

func (db *BadgerDbDriver) GetUserByEmail(email string) (*model.User, error)

func (*BadgerDbDriver) GetUserByProviderUID ¶ added in v0.23.7

func (db *BadgerDbDriver) GetUserByProviderUID(providerID, providerUID string) (*model.User, error)

func (*BadgerDbDriver) GetUserByUsername ¶

func (db *BadgerDbDriver) GetUserByUsername(name string) (*model.User, error)

func (*BadgerDbDriver) GetUsers ¶

func (db *BadgerDbDriver) GetUsers() ([]*model.User, error)

func (*BadgerDbDriver) GetVolume ¶

func (db *BadgerDbDriver) GetVolume(id string) (*model.Volume, error)

func (*BadgerDbDriver) GetVolumeByName ¶ added in v0.23.0

func (db *BadgerDbDriver) GetVolumeByName(name string) (*model.Volume, error)

func (*BadgerDbDriver) GetVolumes ¶

func (db *BadgerDbDriver) GetVolumes() ([]*model.Volume, error)

func (*BadgerDbDriver) HasAuditLog ¶

func (db *BadgerDbDriver) HasAuditLog() bool

func (*BadgerDbDriver) HasUsers ¶

func (db *BadgerDbDriver) HasUsers() (bool, error)

func (*BadgerDbDriver) SaveAuditLog ¶

func (db *BadgerDbDriver) SaveAuditLog(auditLog *model.AuditLogEntry) error

func (*BadgerDbDriver) SaveCfgValue ¶

func (db *BadgerDbDriver) SaveCfgValue(cfgValue *model.CfgValue) error

func (*BadgerDbDriver) SaveCommand ¶ added in v0.29.0

func (db *BadgerDbDriver) SaveCommand(command *model.Command, updateFields []string) error

func (*BadgerDbDriver) SaveConversation ¶ added in v0.29.0

func (db *BadgerDbDriver) SaveConversation(conv *model.Conversation) error

func (*BadgerDbDriver) SaveEventSink ¶ added in v0.28.0

func (db *BadgerDbDriver) SaveEventSink(sink *model.EventSink, updateFields []string) error

func (*BadgerDbDriver) SaveGroup ¶

func (db *BadgerDbDriver) SaveGroup(group *model.Group) error

func (*BadgerDbDriver) SaveMCPServer ¶ added in v0.29.0

func (db *BadgerDbDriver) SaveMCPServer(server *model.MCPServer, updateFields []string) error

func (*BadgerDbDriver) SavePoolDefinition ¶ added in v0.28.0

func (db *BadgerDbDriver) SavePoolDefinition(pool *model.PoolDefinition, updateFields []string) error

func (*BadgerDbDriver) SaveResponse ¶ added in v0.23.0

func (db *BadgerDbDriver) SaveResponse(response *model.Response) error

func (*BadgerDbDriver) SaveRole ¶

func (db *BadgerDbDriver) SaveRole(role *model.Role) error

func (*BadgerDbDriver) SaveScript ¶ added in v0.23.0

func (db *BadgerDbDriver) SaveScript(script *model.Script, updateFields []string) error

func (*BadgerDbDriver) SaveSkill ¶ added in v0.23.0

func (db *BadgerDbDriver) SaveSkill(skill *model.Skill, updateFields []string) error

func (*BadgerDbDriver) SaveSpace ¶

func (db *BadgerDbDriver) SaveSpace(space *model.Space, updateFields []string) error

func (*BadgerDbDriver) SaveSpaceUsageSample ¶ added in v0.24.0

func (db *BadgerDbDriver) SaveSpaceUsageSample(sample *model.SpaceUsageSample) error

func (*BadgerDbDriver) SaveStackDefinition ¶ added in v0.24.0

func (db *BadgerDbDriver) SaveStackDefinition(def *model.StackDefinition, updateFields []string) error

func (*BadgerDbDriver) SaveTemplate ¶

func (db *BadgerDbDriver) SaveTemplate(template *model.Template, updateFields []string) error

func (*BadgerDbDriver) SaveTemplateVar ¶

func (db *BadgerDbDriver) SaveTemplateVar(templateVar *model.TemplateVar) error

func (*BadgerDbDriver) SaveToken ¶

func (db *BadgerDbDriver) SaveToken(token *model.Token) error

func (*BadgerDbDriver) SaveUser ¶

func (db *BadgerDbDriver) SaveUser(user *model.User, updateFields []string) error

func (*BadgerDbDriver) SaveVolume ¶

func (db *BadgerDbDriver) SaveVolume(volume *model.Volume, updateFields []string) error