postgres

package

Go to main page

Versions in this module

v0

v0.1.9

Apr 15, 2026

v0.1.8

Apr 15, 2026

v0.1.7

Apr 15, 2026

Changes in this version

+ type AssetDedupRepository struct

+ func NewAssetDedupRepository(db *DB) *AssetDedupRepository

+ func (r *AssetDedupRepository) ApproveAndMerge(ctx context.Context, reviewID string, reviewedBy string) error

+ func (r *AssetDedupRepository) GetMergeLog(ctx context.Context, tenantID string, limit int) ([]map[string]any, error)

+ func (r *AssetDedupRepository) ListPendingReviews(ctx context.Context, tenantID string) ([]AssetDedupReview, error)

+ func (r *AssetDedupRepository) RejectReview(ctx context.Context, reviewID string, reviewedBy string) error

+ type AssetDedupReview struct

+ AssetType string

+ CreatedAt time.Time

+ ID string

+ KeepAssetID string

+ KeepAssetName string

+ KeepFindingCount int

+ MergeAssetIDs []string

+ MergeAssetNames []string

+ MergeFindingCount int

+ MergedAt *time.Time

+ NormalizedName string

+ ReviewedAt *time.Time

+ ReviewedBy *string

+ Status string

+ TenantID string

type AssetRelationshipRepository

+ func (r *AssetRelationshipRepository) ListAllEdges(ctx context.Context, tenantID shared.ID) ([]asset.RelationshipEdge, error)

type AssetRepository

+ func (r *AssetRepository) FindByExternalID(ctx context.Context, tenantID shared.ID, externalID string) (*asset.Asset, error)

+ func (r *AssetRepository) FindByIPs(ctx context.Context, tenantID shared.ID, ips []string) (map[string][]*asset.Asset, error)

+ func (r *AssetRepository) FindByPropertyValue(ctx context.Context, tenantID shared.ID, key, value string) (*asset.Asset, error)

+ func (r *AssetRepository) ListAllNodes(ctx context.Context, tenantID shared.ID) ([]asset.AssetNode, error)

type BranchRepository

+ func (r *BranchRepository) CompareBranches(ctx context.Context, repositoryID shared.ID, baseBranch, compareBranch string) (*branch.BranchComparison, error)

type ControlTestRepository

+ func (r *ControlTestRepository) ListOverdue(ctx context.Context, staleDays int, limit int) ([]*simulation.OverdueControlTest, error)

+ func (r *ControlTestRepository) MarkOverdue(ctx context.Context, tenantID, id shared.ID) error

type FindingRepository

+ func (r *FindingRepository) GetByWorkItemURI(ctx context.Context, tenantID shared.ID, uri string) (*vulnerability.Finding, error)

+ func (r *FindingRepository) UpdateWorkItemURIs(ctx context.Context, tenantID, id shared.ID, uris []string) error

+ type KEVEscalator struct

+ func NewKEVEscalator(db *DB) *KEVEscalator

+ func (e *KEVEscalator) EscalateKEVFindings(ctx context.Context) (int, error)

+ type RelationshipSuggestionRepository struct

+ func NewRelationshipSuggestionRepository(db *DB) *RelationshipSuggestionRepository

+ func (r *RelationshipSuggestionRepository) ApproveAll(ctx context.Context, tenantID, reviewerID shared.ID) ([]*relationship.Suggestion, error)

+ func (r *RelationshipSuggestionRepository) CountPending(ctx context.Context, tenantID shared.ID) (int64, error)

+ func (r *RelationshipSuggestionRepository) Create(ctx context.Context, s *relationship.Suggestion) error

+ func (r *RelationshipSuggestionRepository) CreateBatch(ctx context.Context, suggestions []*relationship.Suggestion) (int, error)

+ func (r *RelationshipSuggestionRepository) DeleteByAssetID(ctx context.Context, tenantID, assetID shared.ID) error

+ func (r *RelationshipSuggestionRepository) DeletePending(ctx context.Context, tenantID shared.ID) error

+ func (r *RelationshipSuggestionRepository) GetByID(ctx context.Context, tenantID, id shared.ID) (*relationship.Suggestion, error)

+ func (r *RelationshipSuggestionRepository) ListPending(ctx context.Context, tenantID shared.ID, search string, ...) (pagination.Result[*relationship.Suggestion], error)

+ func (r *RelationshipSuggestionRepository) UpdateRelationshipType(ctx context.Context, tenantID, id shared.ID, relType string) error

+ func (r *RelationshipSuggestionRepository) UpdateStatus(ctx context.Context, s *relationship.Suggestion) error

+ type ReportScheduleRepository struct

+ func NewReportScheduleRepository(db *DB) *ReportScheduleRepository

+ func (r *ReportScheduleRepository) Create(ctx context.Context, s *reportschedule.ReportSchedule) error

+ func (r *ReportScheduleRepository) Delete(ctx context.Context, tenantID, id shared.ID) error

+ func (r *ReportScheduleRepository) GetByID(ctx context.Context, tenantID, id shared.ID) (*reportschedule.ReportSchedule, error)

+ func (r *ReportScheduleRepository) List(ctx context.Context, filter reportschedule.ScheduleFilter, ...) (pagination.Result[*reportschedule.ReportSchedule], error)

+ func (r *ReportScheduleRepository) ListDue(ctx context.Context, now time.Time) ([]*reportschedule.ReportSchedule, error)

+ func (r *ReportScheduleRepository) Update(ctx context.Context, s *reportschedule.ReportSchedule) error

v0.1.6

Apr 14, 2026

Changes in this version

type AssetRepository

+ func (r *AssetRepository) FindByHostname(ctx context.Context, tenantID shared.ID, hostname string) (*asset.Asset, error)

+ func (r *AssetRepository) FindByIP(ctx context.Context, tenantID shared.ID, ip string) (*asset.Asset, error)

+ func (r *AssetRepository) GetPropertyFacets(ctx context.Context, tenantID shared.ID, types []string, subType string) ([]asset.PropertyFacet, error)

+ type AttachmentRepository struct

+ func NewAttachmentRepository(db *DB) *AttachmentRepository

+ func (r *AttachmentRepository) Create(ctx context.Context, att *attachment.Attachment) error

+ func (r *AttachmentRepository) Delete(ctx context.Context, tenantID, id shared.ID) error

+ func (r *AttachmentRepository) FindByHash(ctx context.Context, tenantID shared.ID, ...) (*attachment.Attachment, error)

+ func (r *AttachmentRepository) GetByID(ctx context.Context, tenantID, id shared.ID) (*attachment.Attachment, error)

+ func (r *AttachmentRepository) LinkToContext(ctx context.Context, tenantID shared.ID, ids []shared.ID, uploaderID shared.ID, ...) (int64, error)

+ func (r *AttachmentRepository) ListByContext(ctx context.Context, tenantID shared.ID, contextType, contextID string) ([]*attachment.Attachment, error)

+ type BusinessUnitRepository struct

+ func NewBusinessUnitRepository(db *DB) *BusinessUnitRepository

+ func (r *BusinessUnitRepository) AddAsset(ctx context.Context, tenantID, buID, assetID shared.ID) error

+ func (r *BusinessUnitRepository) Create(ctx context.Context, bu *businessunit.BusinessUnit) error

+ func (r *BusinessUnitRepository) Delete(ctx context.Context, tenantID, id shared.ID) error

+ func (r *BusinessUnitRepository) GetByID(ctx context.Context, tenantID, id shared.ID) (*businessunit.BusinessUnit, error)

+ func (r *BusinessUnitRepository) List(ctx context.Context, filter businessunit.Filter, page pagination.Pagination) (pagination.Result[*businessunit.BusinessUnit], error)

+ func (r *BusinessUnitRepository) ListAssetIDs(ctx context.Context, tenantID, buID shared.ID) ([]shared.ID, error)

+ func (r *BusinessUnitRepository) RemoveAsset(ctx context.Context, tenantID, buID, assetID shared.ID) error

+ func (r *BusinessUnitRepository) Update(ctx context.Context, bu *businessunit.BusinessUnit) error

+ type ControlTestRepository struct

+ func NewControlTestRepository(db *DB) *ControlTestRepository

+ func (r *ControlTestRepository) Create(ctx context.Context, ct *simulation.ControlTest) error

+ func (r *ControlTestRepository) Delete(ctx context.Context, tenantID, id shared.ID) error

+ func (r *ControlTestRepository) GetByID(ctx context.Context, tenantID, id shared.ID) (*simulation.ControlTest, error)

+ func (r *ControlTestRepository) GetStatsByFramework(ctx context.Context, tenantID shared.ID) ([]simulation.FrameworkStats, error)

+ func (r *ControlTestRepository) List(ctx context.Context, filter simulation.ControlTestFilter, ...) (pagination.Result[*simulation.ControlTest], error)

+ func (r *ControlTestRepository) Update(ctx context.Context, ct *simulation.ControlTest) error

type DashboardRepository

+ func (r *DashboardRepository) GetMTTRMetrics(ctx context.Context, tenantID shared.ID) (map[string]float64, error)

+ func (r *DashboardRepository) GetRiskVelocity(ctx context.Context, tenantID shared.ID, weeks int) ([]app.RiskVelocityPoint, error)

type PentestCampaignMemberRepository

+ func (r *PentestCampaignMemberRepository) RemoveCampaignMemberSafely(ctx context.Context, tenantID, campaignID, targetUserID, actorUserID string) (pentest.CampaignRole, error)

+ type RemediationCampaignRepository struct

+ func NewRemediationCampaignRepository(db *DB) *RemediationCampaignRepository

+ func (r *RemediationCampaignRepository) Create(ctx context.Context, c *remediation.Campaign) error

+ func (r *RemediationCampaignRepository) Delete(ctx context.Context, tenantID, id shared.ID) error

+ func (r *RemediationCampaignRepository) GetByID(ctx context.Context, tenantID, id shared.ID) (*remediation.Campaign, error)

+ func (r *RemediationCampaignRepository) List(ctx context.Context, filter remediation.CampaignFilter, ...) (pagination.Result[*remediation.Campaign], error)

+ func (r *RemediationCampaignRepository) Update(ctx context.Context, c *remediation.Campaign) error

type RoleRepository

+ func (r *RoleRepository) GetUsersRoles(ctx context.Context, tenantID role.ID, userIDs []role.ID) (map[string][]*role.Role, error)

+ type SimulationRepository struct

+ func NewSimulationRepository(db *DB) *SimulationRepository

+ func (r *SimulationRepository) Create(ctx context.Context, sim *simulation.Simulation) error

+ func (r *SimulationRepository) Delete(ctx context.Context, tenantID, id shared.ID) error

+ func (r *SimulationRepository) GetByID(ctx context.Context, tenantID, id shared.ID) (*simulation.Simulation, error)

+ func (r *SimulationRepository) List(ctx context.Context, filter simulation.SimulationFilter, ...) (pagination.Result[*simulation.Simulation], error)

+ func (r *SimulationRepository) Update(ctx context.Context, sim *simulation.Simulation) error

type TenantRepository

+ func (r *TenantRepository) GetUserMembershipsWithStatus(ctx context.Context, userID shared.ID) (*tenant.UserMembershipsByStatus, error)

+ type ThreatActorRepository struct

+ func NewThreatActorRepository(db *DB) *ThreatActorRepository

+ func (r *ThreatActorRepository) Create(ctx context.Context, actor *threatactor.ThreatActor) error

+ func (r *ThreatActorRepository) Delete(ctx context.Context, tenantID, id shared.ID) error

+ func (r *ThreatActorRepository) GetByID(ctx context.Context, tenantID, id shared.ID) (*threatactor.ThreatActor, error)

+ func (r *ThreatActorRepository) LinkCVE(ctx context.Context, cve *threatactor.ThreatActorCVE) error

+ func (r *ThreatActorRepository) List(ctx context.Context, filter threatactor.Filter, page pagination.Pagination) (pagination.Result[*threatactor.ThreatActor], error)

+ func (r *ThreatActorRepository) ListActorsByCVE(ctx context.Context, tenantID shared.ID, cveID string) ([]*threatactor.ThreatActor, error)

+ func (r *ThreatActorRepository) ListCVEsByActor(ctx context.Context, tenantID, actorID shared.ID) ([]*threatactor.ThreatActorCVE, error)

+ func (r *ThreatActorRepository) Update(ctx context.Context, actor *threatactor.ThreatActor) error

v0.1.5

Apr 9, 2026

Changes in this version

type AgentRepository

+ func (r *AgentRepository) GetTenantAgentStats(ctx context.Context, tenantID shared.ID) (*agent.TenantAgentStats, error)

type AssetRelationshipRepository

+ func (r *AssetRelationshipRepository) CountByType(ctx context.Context, tenantID shared.ID) (map[asset.RelationshipType]int64, error)

type CommandRepository

+ func (r *CommandRepository) CancelByPipelineRunID(ctx context.Context, tenantID, runID shared.ID) (int64, error)

type PipelineRunRepository

+ func (r *PipelineRunRepository) ListPendingRetries(ctx context.Context, limit int) ([]pipeline.RetryCandidate, error)

+ func (r *PipelineRunRepository) MarkTimedOutRuns(ctx context.Context) (int64, error)

type ScanProfileRepository

+ func (r *ScanProfileRepository) GetAccessibleByID(ctx context.Context, tenantID, id shared.ID) (*scanprofile.ScanProfile, error)

type ScanRepository

+ func (r *ScanRepository) TryLockScanForScheduler(ctx context.Context, id shared.ID) (bool, error)

+ func (r *ScanRepository) UnlockScanForScheduler(ctx context.Context, id shared.ID) error

type TenantRepository

+ func (r *TenantRepository) DeletePendingInvitationsByUserID(ctx context.Context, tenantID, userID shared.ID) (int64, error)

+ func (r *TenantRepository) GetUserSuspendedMemberships(ctx context.Context, userID shared.ID) ([]tenant.UserMembership, error)

+ func (r *TenantRepository) UpdateMembershipStatus(ctx context.Context, m *tenant.Membership) error

v0.1.4

Apr 7, 2026

v0.1.3

Apr 7, 2026

Changes in this version

type AccessControlRepository

+ func (r *AccessControlRepository) BatchListFindingGroupIDs(ctx context.Context, tenantID shared.ID, findingIDs []shared.ID) (map[shared.ID][]shared.ID, error)

type AssetGroupRepository

+ func (r *AssetGroupRepository) GetByTenantAndID(ctx context.Context, tenantID, id shared.ID) (*assetgroup.AssetGroup, error)

type AssetRepository

+ func (r *AssetRepository) BulkUpdateStatus(ctx context.Context, tenantID shared.ID, assetIDs []shared.ID, ...) (int64, error)

+ func (r *AssetRepository) GetAggregateStats(ctx context.Context, tenantID shared.ID, types []string) (*asset.AggregateStats, error)

type AuditRepository

+ func (r *AuditRepository) GetByTenantAndID(ctx context.Context, tenantID, id shared.ID) (*audit.AuditLog, error)

type CapabilityRepository

+ func (r *CapabilityRepository) GetByTenantAndID(ctx context.Context, tenantID, id shared.ID) (*capability.Capability, error)

type ExposureRepository

+ func (r *ExposureRepository) GetByTenantAndID(ctx context.Context, tenantID, id shared.ID) (*exposure.ExposureEvent, error)

type FindingRepository

+ func (r *FindingRepository) BulkUpdateStatusByFilter(ctx context.Context, tenantID shared.ID, filter vulnerability.FindingFilter, ...) (int64, error)

+ func (r *FindingRepository) FindRelatedCVEs(ctx context.Context, tenantID shared.ID, cveID string, ...) ([]vulnerability.RelatedCVE, error)

+ func (r *FindingRepository) GetByIDs(ctx context.Context, tenantID shared.ID, ids []shared.ID) ([]*vulnerability.Finding, error)

+ func (r *FindingRepository) ListByStatusAndAssets(ctx context.Context, tenantID shared.ID, status vulnerability.FindingStatus, ...) ([]*vulnerability.Finding, error)

+ func (r *FindingRepository) ListFindingGroups(ctx context.Context, tenantID shared.ID, groupBy string, ...) (pagination.Result[*vulnerability.FindingGroup], error)

type GroupRepository

+ func (r *GroupRepository) GetByTenantAndID(ctx context.Context, tenantID, id shared.ID) (*group.Group, error)

+ type PentestCampaignMemberRepository struct

+ func NewPentestCampaignMemberRepository(db *DB) *PentestCampaignMemberRepository

+ func (r *PentestCampaignMemberRepository) BatchListByCampaignIDs(ctx context.Context, tenantID string, campaignIDs []string) (map[string][]*pentest.CampaignMember, error)

+ func (r *PentestCampaignMemberRepository) CountByRoleInTx(ctx context.Context, tx *sql.Tx, tenantID, campaignID string, ...) (int64, error)

+ func (r *PentestCampaignMemberRepository) Create(ctx context.Context, m *pentest.CampaignMember) error

+ func (r *PentestCampaignMemberRepository) Delete(ctx context.Context, tenantID, id shared.ID) error

+ func (r *PentestCampaignMemberRepository) DeleteByUserID(ctx context.Context, tenantID, campaignID, userID string) error

+ func (r *PentestCampaignMemberRepository) GetByID(ctx context.Context, tenantID, id shared.ID) (*pentest.CampaignMember, error)

+ func (r *PentestCampaignMemberRepository) GetUserRole(ctx context.Context, tenantID, campaignID, userID string) (pentest.CampaignRole, error)

+ func (r *PentestCampaignMemberRepository) ListByCampaign(ctx context.Context, tenantID, campaignID string) ([]*pentest.CampaignMember, error)

+ func (r *PentestCampaignMemberRepository) ListByUser(ctx context.Context, tenantID, userID string) ([]*pentest.CampaignMember, error)

+ func (r *PentestCampaignMemberRepository) UpdateRole(ctx context.Context, tenantID, id shared.ID, role pentest.CampaignRole) error

type PermissionSetRepository

+ func (r *PermissionSetRepository) GetByTenantAndID(ctx context.Context, tenantID, id shared.ID) (*permissionset.PermissionSet, error)

type RuleBundleRepository

+ func (r *RuleBundleRepository) GetByTenantAndID(ctx context.Context, tenantID, id shared.ID) (*rule.Bundle, error)

type RuleRepository

+ func (r *RuleRepository) GetByTenantAndID(ctx context.Context, tenantID, id shared.ID) (*rule.Rule, error)

type SLAPolicyRepository

+ func (r *SLAPolicyRepository) GetByTenantAndID(ctx context.Context, tenantID, id shared.ID) (*sla.Policy, error)

v0.1.2

Mar 17, 2026

Changes in this version

type AccessControlRepository

+ func (r *AccessControlRepository) BulkCreateAssetOwners(ctx context.Context, owners []*accesscontrol.AssetOwner) (int, error)

+ func (r *AccessControlRepository) BulkCreateAssetOwnersWithSource(ctx context.Context, owners []*accesscontrol.AssetOwner, source string, ...) (int, error)

+ func (r *AccessControlRepository) BulkCreateFindingGroupAssignments(ctx context.Context, fgas []*accesscontrol.FindingGroupAssignment) (int, error)

+ func (r *AccessControlRepository) BulkDeleteAutoAssignedForAssets(ctx context.Context, assetIDs []shared.ID, groupID shared.ID) (int, error)

+ func (r *AccessControlRepository) CountAssetsByGroups(ctx context.Context, groupIDs []shared.ID) (map[shared.ID]int, error)

+ func (r *AccessControlRepository) CountFindingsByGroupFromRules(ctx context.Context, tenantID, groupID shared.ID) (int64, error)

+ func (r *AccessControlRepository) CountScopeRules(ctx context.Context, tenantID, groupID shared.ID, ...) (int64, error)

+ func (r *AccessControlRepository) CreateAssetOwnerWithSource(ctx context.Context, ao *accesscontrol.AssetOwner, source string, ...) error

+ func (r *AccessControlRepository) CreateScopeRule(ctx context.Context, rule *accesscontrol.ScopeRule) error

+ func (r *AccessControlRepository) DeleteAutoAssignedByRule(ctx context.Context, tenantID, ruleID shared.ID) (int, error)

+ func (r *AccessControlRepository) DeleteAutoAssignedForAsset(ctx context.Context, assetID, groupID shared.ID) error

+ func (r *AccessControlRepository) DeleteScopeRule(ctx context.Context, tenantID, id shared.ID) error

+ func (r *AccessControlRepository) DeleteScopeRuleWithCleanup(ctx context.Context, tenantID, ruleID shared.ID) (int, error)

+ func (r *AccessControlRepository) FindAssetsByAssetGroupMatch(ctx context.Context, tenantID shared.ID, assetGroupIDs []shared.ID) ([]shared.ID, error)

+ func (r *AccessControlRepository) FindAssetsByTagMatch(ctx context.Context, tenantID shared.ID, tags []string, ...) ([]shared.ID, error)

+ func (r *AccessControlRepository) GetPrimaryOwnerBrief(ctx context.Context, tenantID, assetID shared.ID) (*accesscontrol.OwnerBrief, error)

+ func (r *AccessControlRepository) GetPrimaryOwnersByAssetIDs(ctx context.Context, tenantID shared.ID, assetIDs []shared.ID) (map[string]*accesscontrol.OwnerBrief, error)

+ func (r *AccessControlRepository) GetScopeRule(ctx context.Context, tenantID, id shared.ID) (*accesscontrol.ScopeRule, error)

+ func (r *AccessControlRepository) HasAnyScopeAssignment(ctx context.Context, tenantID, userID shared.ID) (bool, error)

+ func (r *AccessControlRepository) ListActiveScopeRulesByGroup(ctx context.Context, tenantID, groupID shared.ID) ([]*accesscontrol.ScopeRule, error)

+ func (r *AccessControlRepository) ListActiveScopeRulesByTenant(ctx context.Context, tenantID shared.ID) ([]*accesscontrol.ScopeRule, error)

+ func (r *AccessControlRepository) ListAssetOwnersByGroupWithDetails(ctx context.Context, groupID shared.ID, limit, offset int) ([]*accesscontrol.AssetOwnerWithAsset, int64, error)

+ func (r *AccessControlRepository) ListAssetOwnersWithNames(ctx context.Context, tenantID, assetID shared.ID) ([]*accesscontrol.AssetOwnerWithNames, error)

+ func (r *AccessControlRepository) ListAutoAssignedAssets(ctx context.Context, tenantID, groupID shared.ID) ([]shared.ID, error)

+ func (r *AccessControlRepository) ListAutoAssignedGroupsForAsset(ctx context.Context, assetID shared.ID) ([]shared.ID, error)

+ func (r *AccessControlRepository) ListFindingGroupAssignments(ctx context.Context, tenantID, findingID shared.ID) ([]*accesscontrol.FindingGroupAssignment, error)

+ func (r *AccessControlRepository) ListGroupsWithActiveScopeRules(ctx context.Context, tenantID shared.ID) ([]shared.ID, error)

+ func (r *AccessControlRepository) ListGroupsWithAssetGroupMatchRule(ctx context.Context, assetGroupID shared.ID) ([]shared.ID, error)

+ func (r *AccessControlRepository) ListScopeRules(ctx context.Context, tenantID, groupID shared.ID, ...) ([]*accesscontrol.ScopeRule, error)

+ func (r *AccessControlRepository) ListTenantsWithActiveScopeRules(ctx context.Context) ([]shared.ID, error)

+ func (r *AccessControlRepository) RefreshAccessForAssetAssign(ctx context.Context, groupID, assetID shared.ID, ownershipType string) error

+ func (r *AccessControlRepository) RefreshAccessForAssetUnassign(ctx context.Context, groupID, assetID shared.ID) error

+ func (r *AccessControlRepository) RefreshAccessForDirectOwnerAdd(ctx context.Context, assetID, userID shared.ID, ownershipType string) error

+ func (r *AccessControlRepository) RefreshAccessForDirectOwnerRemove(ctx context.Context, assetID, userID shared.ID) error

+ func (r *AccessControlRepository) RefreshAccessForMemberAdd(ctx context.Context, groupID, userID shared.ID) error

+ func (r *AccessControlRepository) RefreshAccessForMemberRemove(ctx context.Context, groupID, userID shared.ID) error

+ func (r *AccessControlRepository) UpdateScopeRule(ctx context.Context, tenantID shared.ID, rule *accesscontrol.ScopeRule) error

+ func (r *AccessControlRepository) ValidateAssetGroupsBelongToTenant(ctx context.Context, tenantID shared.ID, assetGroupIDs []shared.ID) error

type AgentRepository

+ func (r *AgentRepository) GetPlatformAgentStats(ctx context.Context, tenantID shared.ID) (*agent.PlatformAgentStatsResult, error)

type AssetRelationshipRepository

+ func (r *AssetRelationshipRepository) CreateBatchIgnoreConflicts(ctx context.Context, rels []*asset.Relationship) (int, error)

type AssetRepository

+ func (r *AssetRepository) BatchUpdateRiskScores(ctx context.Context, tenantID shared.ID, assets []*asset.Asset) error

+ func (r *AssetRepository) GetAssetTypeBreakdown(ctx context.Context, tenantID shared.ID) (map[string]asset.AssetTypeStats, error)

+ func (r *AssetRepository) GetAverageRiskScore(ctx context.Context, tenantID shared.ID) (float64, error)

+ func (r *AssetRepository) ListDistinctTags(ctx context.Context, tenantID shared.ID, prefix string, limit int) ([]string, error)

+ type ComplianceAssessmentRepository struct

+ func NewComplianceAssessmentRepository(db *DB) *ComplianceAssessmentRepository

+ func (r *ComplianceAssessmentRepository) GetByTenantAndControl(ctx context.Context, tenantID, controlID shared.ID) (*compliance.Assessment, error)

+ func (r *ComplianceAssessmentRepository) GetOverdueCount(ctx context.Context, tenantID shared.ID) (int64, error)

+ func (r *ComplianceAssessmentRepository) GetStatsByFramework(ctx context.Context, tenantID, frameworkID shared.ID) (*compliance.FrameworkStats, error)

+ func (r *ComplianceAssessmentRepository) ListByFramework(ctx context.Context, tenantID, frameworkID shared.ID, ...) (pagination.Result[*compliance.Assessment], error)

+ func (r *ComplianceAssessmentRepository) Upsert(ctx context.Context, a *compliance.Assessment) error

+ type ComplianceControlRepository struct

+ func NewComplianceControlRepository(db *DB) *ComplianceControlRepository

+ func (r *ComplianceControlRepository) CountByFramework(ctx context.Context, frameworkID shared.ID) (int64, error)

+ func (r *ComplianceControlRepository) Create(ctx context.Context, c *compliance.Control) error

+ func (r *ComplianceControlRepository) GetByID(ctx context.Context, id shared.ID) (*compliance.Control, error)

+ func (r *ComplianceControlRepository) ListByFramework(ctx context.Context, frameworkID shared.ID, page pagination.Pagination) (pagination.Result[*compliance.Control], error)

+ type ComplianceFrameworkRepository struct

+ func NewComplianceFrameworkRepository(db *DB) *ComplianceFrameworkRepository

+ func (r *ComplianceFrameworkRepository) Create(ctx context.Context, f *compliance.Framework) error

+ func (r *ComplianceFrameworkRepository) Delete(ctx context.Context, tenantID, id shared.ID) error

+ func (r *ComplianceFrameworkRepository) GetByID(ctx context.Context, tenantID, id shared.ID) (*compliance.Framework, error)

+ func (r *ComplianceFrameworkRepository) GetBySlug(ctx context.Context, slug string) (*compliance.Framework, error)

+ func (r *ComplianceFrameworkRepository) List(ctx context.Context, filter compliance.FrameworkFilter, ...) (pagination.Result[*compliance.Framework], error)

+ func (r *ComplianceFrameworkRepository) Update(ctx context.Context, tenantID shared.ID, f *compliance.Framework) error

+ type ComplianceMappingRepository struct

+ func NewComplianceMappingRepository(db *DB) *ComplianceMappingRepository

+ func (r *ComplianceMappingRepository) Create(ctx context.Context, m *compliance.FindingControlMapping) error

+ func (r *ComplianceMappingRepository) Delete(ctx context.Context, tenantID, id shared.ID) error

+ func (r *ComplianceMappingRepository) ListByControl(ctx context.Context, tenantID, controlID shared.ID) ([]*compliance.FindingControlMapping, error)

+ func (r *ComplianceMappingRepository) ListByFinding(ctx context.Context, tenantID, findingID shared.ID) ([]*compliance.FindingControlMapping, error)

type DashboardRepository

+ func (r *DashboardRepository) GetAllStats(ctx context.Context, tenantID shared.ID) (*app.DashboardAllStats, error)

+ func (r *DashboardRepository) GetFindingTrend(ctx context.Context, tenantID shared.ID, months int) ([]app.FindingTrendPoint, error)

type FindingActivityRepository

+ func (r *FindingActivityRepository) CreateBatch(ctx context.Context, activities []*vulnerability.FindingActivity) error

+ func (r *FindingActivityRepository) DeleteByCommentID(ctx context.Context, tenantID shared.ID, commentID string) error

+ func (r *FindingActivityRepository) UpdateContentByCommentID(ctx context.Context, tenantID shared.ID, commentID string, content string) error

+ type FindingApprovalRepository struct

+ func NewFindingApprovalRepository(db *DB) *FindingApprovalRepository

+ func (r *FindingApprovalRepository) Create(ctx context.Context, a *vulnerability.Approval) error

+ func (r *FindingApprovalRepository) GetByTenantAndID(ctx context.Context, tenantID, id shared.ID) (*vulnerability.Approval, error)

+ func (r *FindingApprovalRepository) ListByFinding(ctx context.Context, tenantID, findingID shared.ID) ([]*vulnerability.Approval, error)

+ func (r *FindingApprovalRepository) ListExpiredApproved(ctx context.Context, limit int) ([]*vulnerability.Approval, error)

+ func (r *FindingApprovalRepository) ListPending(ctx context.Context, tenantID shared.ID, page pagination.Pagination) (pagination.Result[*vulnerability.Approval], error)

+ func (r *FindingApprovalRepository) Update(ctx context.Context, a *vulnerability.Approval) error

type FindingRepository

+ func (r *FindingRepository) EnrichBatchByFingerprints(ctx context.Context, tenantID shared.ID, newFindings []*vulnerability.Finding, ...) (int64, error)

+ func (r *FindingRepository) GetByFingerprintsBatch(ctx context.Context, tenantID shared.ID, fingerprints []string) (map[string]*vulnerability.Finding, error)

type GroupRepository

+ func (r *GroupRepository) CountMembersByGroups(ctx context.Context, groupIDs []shared.ID) (map[shared.ID]int, error)

+ func (r *GroupRepository) CountUniqueMembers(ctx context.Context, groupIDs []shared.ID) (int, error)

+ type IdentityProviderRepository struct

+ func NewIdentityProviderRepository(db *DB) *IdentityProviderRepository

+ func (r *IdentityProviderRepository) Create(ctx context.Context, ip *identityprovider.IdentityProvider) error

+ func (r *IdentityProviderRepository) Delete(ctx context.Context, tenantID, id string) error

+ func (r *IdentityProviderRepository) GetByID(ctx context.Context, tenantID, id string) (*identityprovider.IdentityProvider, error)

+ func (r *IdentityProviderRepository) GetByTenantAndProvider(ctx context.Context, tenantID string, provider identityprovider.Provider) (*identityprovider.IdentityProvider, error)

+ func (r *IdentityProviderRepository) ListActiveByTenant(ctx context.Context, tenantID string) ([]*identityprovider.IdentityProvider, error)

+ func (r *IdentityProviderRepository) ListByTenant(ctx context.Context, tenantID string) ([]*identityprovider.IdentityProvider, error)

+ func (r *IdentityProviderRepository) Update(ctx context.Context, ip *identityprovider.IdentityProvider) error

type ModuleRepository

+ func (r *ModuleRepository) ListAllSubModules(ctx context.Context) (map[string][]*module.Module, error)

+ type NotificationRepository struct

+ func NewNotificationRepository(db *DB) *NotificationRepository

+ func (r *NotificationRepository) Create(ctx context.Context, n *notification.Notification) error

+ func (r *NotificationRepository) DeleteOlderThan(ctx context.Context, age time.Duration) (int64, error)

+ func (r *NotificationRepository) GetPreferences(ctx context.Context, tenantID, userID shared.ID) (*notification.Preferences, error)

+ func (r *NotificationRepository) List(ctx context.Context, tenantID, userID shared.ID, ...) (pagination.Result[*notification.Notification], error)

+ func (r *NotificationRepository) MarkAllAsRead(ctx context.Context, tenantID, userID shared.ID) error

+ func (r *NotificationRepository) MarkAsRead(ctx context.Context, tenantID shared.ID, notificationID notification.ID, ...) error

+ func (r *NotificationRepository) UnreadCount(ctx context.Context, tenantID, userID shared.ID) (int, error)

+ func (r *NotificationRepository) UpsertPreferences(ctx context.Context, tenantID, userID shared.ID, ...) (*notification.Preferences, error)

+ type OutboxEventRepository struct

+ func NewOutboxEventRepository(db *DB) *OutboxEventRepository

+ func (r *OutboxEventRepository) Create(ctx context.Context, event *outbox.Event) error

+ func (r *OutboxEventRepository) Delete(ctx context.Context, id outbox.ID) error

+ func (r *OutboxEventRepository) DeleteOldEvents(ctx context.Context, retentionDays int) (int64, error)

+ func (r *OutboxEventRepository) GetByID(ctx context.Context, id outbox.ID) (*outbox.Event, error)

+ func (r *OutboxEventRepository) GetStats(ctx context.Context, tenantID *shared.ID) (*outbox.EventStats, error)

+ func (r *OutboxEventRepository) ListByIntegration(ctx context.Context, integrationID string, limit, offset int) ([]*outbox.Event, int64, error)

+ func (r *OutboxEventRepository) ListByTenant(ctx context.Context, tenantID shared.ID, filter outbox.EventFilter) ([]*outbox.Event, int64, error)

+ type OutboxRepository struct

+ func NewOutboxRepository(db *DB) *OutboxRepository

+ func (r *OutboxRepository) CountByStatus(ctx context.Context, tenantID shared.ID) (map[outbox.OutboxStatus]int64, error)

+ func (r *OutboxRepository) Create(ctx context.Context, entry *outbox.Outbox) error

+ func (r *OutboxRepository) CreateInTx(ctx context.Context, tx *sql.Tx, entry *outbox.Outbox) error

+ func (r *OutboxRepository) Delete(ctx context.Context, id outbox.ID) error

+ func (r *OutboxRepository) DeleteOldCompleted(ctx context.Context, olderThanDays int) (int64, error)

+ func (r *OutboxRepository) DeleteOldFailed(ctx context.Context, olderThanDays int) (int64, error)

+ func (r *OutboxRepository) FetchPendingBatch(ctx context.Context, workerID string, batchSize int) ([]*outbox.Outbox, error)

+ func (r *OutboxRepository) GetByAggregateID(ctx context.Context, aggregateType string, aggregateID string) ([]*outbox.Outbox, error)

+ func (r *OutboxRepository) GetByID(ctx context.Context, id outbox.ID) (*outbox.Outbox, error)

+ func (r *OutboxRepository) GetStats(ctx context.Context, tenantID *shared.ID) (*outbox.OutboxStats, error)

+ func (r *OutboxRepository) List(ctx context.Context, filter outbox.OutboxFilter, page pagination.Pagination) (pagination.Result[*outbox.Outbox], error)

+ func (r *OutboxRepository) ListByTenant(ctx context.Context, tenantID shared.ID, filter outbox.OutboxFilter) ([]*outbox.Outbox, int64, error)

+ func (r *OutboxRepository) UnlockStale(ctx context.Context, olderThanMinutes int) (int64, error)

+ func (r *OutboxRepository) Update(ctx context.Context, entry *outbox.Outbox) error

+ type PentestCampaignRepository struct

+ func NewPentestCampaignRepository(db *DB) *PentestCampaignRepository

+ func (r *PentestCampaignRepository) Create(ctx context.Context, c *pentest.Campaign) error

+ func (r *PentestCampaignRepository) Delete(ctx context.Context, tenantID, id shared.ID) error

+ func (r *PentestCampaignRepository) GetByID(ctx context.Context, tenantID, id shared.ID) (*pentest.Campaign, error)

+ func (r *PentestCampaignRepository) List(ctx context.Context, filter pentest.CampaignFilter, page pagination.Pagination) (pagination.Result[*pentest.Campaign], error)

+ func (r *PentestCampaignRepository) Update(ctx context.Context, c *pentest.Campaign) error

+ type PentestFindingRepository struct

+ func NewPentestFindingRepository(db *DB) *PentestFindingRepository

+ func (r *PentestFindingRepository) CountByCampaign(ctx context.Context, tenantID, campaignID shared.ID) (int64, error)

+ func (r *PentestFindingRepository) Create(ctx context.Context, f *pentest.Finding) error

+ func (r *PentestFindingRepository) Delete(ctx context.Context, tenantID, id shared.ID) error

+ func (r *PentestFindingRepository) GetByID(ctx context.Context, tenantID, id shared.ID) (*pentest.Finding, error)

+ func (r *PentestFindingRepository) GetStatsByCampaign(ctx context.Context, tenantID, campaignID shared.ID) (*pentest.CampaignStats, error)

+ func (r *PentestFindingRepository) GetStatsByCampaignIDs(ctx context.Context, tenantID shared.ID, campaignIDs []shared.ID) (map[string]*pentest.CampaignStats, error)

+ func (r *PentestFindingRepository) List(ctx context.Context, filter pentest.FindingFilter, page pagination.Pagination) (pagination.Result[*pentest.Finding], error)

+ func (r *PentestFindingRepository) Update(ctx context.Context, f *pentest.Finding) error

+ type PentestReportRepository struct

+ func NewPentestReportRepository(db *DB) *PentestReportRepository

+ func (r *PentestReportRepository) Create(ctx context.Context, rpt *pentest.Report) error

+ func (r *PentestReportRepository) Delete(ctx context.Context, tenantID, id shared.ID) error

+ func (r *PentestReportRepository) GetByID(ctx context.Context, tenantID, id shared.ID) (*pentest.Report, error)

+ func (r *PentestReportRepository) List(ctx context.Context, filter pentest.ReportFilter, page pagination.Pagination) (pagination.Result[*pentest.Report], error)

+ func (r *PentestReportRepository) Update(ctx context.Context, rpt *pentest.Report) error

+ type PentestRetestRepository struct

+ func NewPentestRetestRepository(db *DB) *PentestRetestRepository

+ func (r *PentestRetestRepository) CountByFinding(ctx context.Context, tenantID, findingID shared.ID) (int64, error)

+ func (r *PentestRetestRepository) Create(ctx context.Context, rt *pentest.Retest) error

+ func (r *PentestRetestRepository) GetByID(ctx context.Context, tenantID, id shared.ID) (*pentest.Retest, error)

+ func (r *PentestRetestRepository) ListByFinding(ctx context.Context, tenantID, findingID shared.ID) ([]*pentest.Retest, error)

+ func (r *PentestRetestRepository) Update(ctx context.Context, rt *pentest.Retest) error

+ type PentestTemplateRepository struct

+ func NewPentestTemplateRepository(db *DB) *PentestTemplateRepository

+ func (r *PentestTemplateRepository) Create(ctx context.Context, t *pentest.Template) error

+ func (r *PentestTemplateRepository) Delete(ctx context.Context, tenantID, id shared.ID) error

+ func (r *PentestTemplateRepository) GetByID(ctx context.Context, tenantID, id shared.ID) (*pentest.Template, error)

+ func (r *PentestTemplateRepository) IncrementUsageCount(ctx context.Context, tenantID, id shared.ID) error

+ func (r *PentestTemplateRepository) List(ctx context.Context, filter pentest.TemplateFilter, page pagination.Pagination) (pagination.Result[*pentest.Template], error)

+ func (r *PentestTemplateRepository) Update(ctx context.Context, tenantID shared.ID, t *pentest.Template) error

type RepositoryExtensionRepository

+ func (r *RepositoryExtensionRepository) GetByAssetIDs(ctx context.Context, assetIDs []shared.ID) (map[shared.ID]*asset.RepositoryExtension, error)

+ type TenantModuleRepository struct

+ func NewTenantModuleRepository(db *DB) *TenantModuleRepository

+ func (r *TenantModuleRepository) DeleteByTenant(ctx context.Context, tenantID shared.ID) error

+ func (r *TenantModuleRepository) ListByTenant(ctx context.Context, tenantID shared.ID) ([]*module.TenantModuleOverride, error)

+ func (r *TenantModuleRepository) UpsertBatch(ctx context.Context, tenantID shared.ID, updates []module.TenantModuleUpdate, ...) error

v0.1.1

Feb 12, 2026

v0.1.0

Feb 12, 2026

Changes in this version

+ const DefaultBatchChunkSize

+ const MaxLicenseNameLength

+ const MaxLicensesPerComponent

+ var ErrAccountLocked = errors.New("account is locked due to too many failed login attempts")

+ type AITriageRepository struct

+ func NewAITriageRepository(db *DB) *AITriageRepository

+ func (r *AITriageRepository) AcquireTriageSlot(ctx context.Context, tenantID, resultID shared.ID) (*aitriage.TriageContext, error)

+ func (r *AITriageRepository) CountByTenantThisMonth(ctx context.Context, tenantID shared.ID) (int, error)

+ func (r *AITriageRepository) Create(ctx context.Context, result *aitriage.TriageResult) error

+ func (r *AITriageRepository) FindStuckJobs(ctx context.Context, stuckDuration time.Duration, limit int) ([]*aitriage.TriageResult, error)

+ func (r *AITriageRepository) GetByFindingID(ctx context.Context, tenantID, findingID shared.ID) (*aitriage.TriageResult, error)

+ func (r *AITriageRepository) GetByID(ctx context.Context, tenantID, id shared.ID) (*aitriage.TriageResult, error)

+ func (r *AITriageRepository) GetPendingJobs(ctx context.Context, limit int) ([]*aitriage.TriageResult, error)

+ func (r *AITriageRepository) GetPendingJobsByTenant(ctx context.Context, tenantID shared.ID, limit int) ([]*aitriage.TriageResult, error)

+ func (r *AITriageRepository) GetTenantsWithPendingJobs(ctx context.Context, limit int) ([]shared.ID, error)

+ func (r *AITriageRepository) GetTriageContext(ctx context.Context, tenantID, resultID shared.ID) (*aitriage.TriageContext, error)

+ func (r *AITriageRepository) HasPendingOrProcessing(ctx context.Context, tenantID, findingID shared.ID) (bool, error)

+ func (r *AITriageRepository) ListByFindingID(ctx context.Context, tenantID, findingID shared.ID, limit, offset int) ([]*aitriage.TriageResult, int, error)

+ func (r *AITriageRepository) MarkStuckAsFailed(ctx context.Context, id shared.ID, errorMessage string) (bool, error)

+ func (r *AITriageRepository) SumTokensByTenantThisMonth(ctx context.Context, tenantID shared.ID) (int, error)

+ func (r *AITriageRepository) Update(ctx context.Context, result *aitriage.TriageResult) error

+ type APIKeyRepository struct

+ func NewAPIKeyRepository(db *DB) *APIKeyRepository

+ func (r *APIKeyRepository) Create(ctx context.Context, key *apikey.APIKey) error

+ func (r *APIKeyRepository) Delete(ctx context.Context, id, tenantID apikey.ID) error

+ func (r *APIKeyRepository) GetByHash(ctx context.Context, hash string) (*apikey.APIKey, error)

+ func (r *APIKeyRepository) GetByID(ctx context.Context, id, tenantID apikey.ID) (*apikey.APIKey, error)

+ func (r *APIKeyRepository) List(ctx context.Context, filter apikey.Filter) (apikey.ListResult, error)

+ func (r *APIKeyRepository) Update(ctx context.Context, key *apikey.APIKey) error

+ type AccessControlRepository struct

+ func NewAccessControlRepository(db *DB) *AccessControlRepository

+ func (r *AccessControlRepository) CanAccessAsset(ctx context.Context, userID, assetID shared.ID) (bool, error)

+ func (r *AccessControlRepository) CountAssetOwners(ctx context.Context, assetID shared.ID) (int64, error)

+ func (r *AccessControlRepository) CountAssignmentRules(ctx context.Context, tenantID shared.ID, ...) (int64, error)

+ func (r *AccessControlRepository) CreateAssetOwner(ctx context.Context, ao *accesscontrol.AssetOwner) error

+ func (r *AccessControlRepository) CreateAssignmentRule(ctx context.Context, rule *accesscontrol.AssignmentRule) error

+ func (r *AccessControlRepository) CreateGroupPermission(ctx context.Context, gp *accesscontrol.GroupPermission) error

+ func (r *AccessControlRepository) DeleteAssetOwner(ctx context.Context, assetID, groupID shared.ID) error

+ func (r *AccessControlRepository) DeleteAssetOwnerByID(ctx context.Context, id shared.ID) error

+ func (r *AccessControlRepository) DeleteAssetOwnerByUser(ctx context.Context, assetID, userID shared.ID) error

+ func (r *AccessControlRepository) DeleteAssignmentRule(ctx context.Context, id shared.ID) error

+ func (r *AccessControlRepository) DeleteGroupPermission(ctx context.Context, groupID shared.ID, permissionID string) error

+ func (r *AccessControlRepository) GetAssetOwner(ctx context.Context, assetID, groupID shared.ID) (*accesscontrol.AssetOwner, error)

+ func (r *AccessControlRepository) GetAssetOwnerByID(ctx context.Context, id shared.ID) (*accesscontrol.AssetOwner, error)

+ func (r *AccessControlRepository) GetAssetOwnerByUser(ctx context.Context, assetID, userID shared.ID) (*accesscontrol.AssetOwner, error)

+ func (r *AccessControlRepository) GetAssignmentRule(ctx context.Context, id shared.ID) (*accesscontrol.AssignmentRule, error)

+ func (r *AccessControlRepository) GetGroupPermission(ctx context.Context, groupID shared.ID, permissionID string) (*accesscontrol.GroupPermission, error)

+ func (r *AccessControlRepository) GetUserAssetAccess(ctx context.Context, userID, assetID shared.ID) (*accesscontrol.UserAssetAccess, error)

+ func (r *AccessControlRepository) HasPrimaryOwner(ctx context.Context, assetID shared.ID) (bool, error)

+ func (r *AccessControlRepository) ListAccessibleAssets(ctx context.Context, tenantID, userID shared.ID) ([]shared.ID, error)

+ func (r *AccessControlRepository) ListActiveRulesByPriority(ctx context.Context, tenantID shared.ID) ([]*accesscontrol.AssignmentRule, error)

+ func (r *AccessControlRepository) ListAssetOwners(ctx context.Context, assetID shared.ID) ([]*accesscontrol.AssetOwner, error)

+ func (r *AccessControlRepository) ListAssetsByGroup(ctx context.Context, groupID shared.ID) ([]shared.ID, error)

+ func (r *AccessControlRepository) ListAssetsByUser(ctx context.Context, userID shared.ID) ([]shared.ID, error)

+ func (r *AccessControlRepository) ListAssignmentRules(ctx context.Context, tenantID shared.ID, ...) ([]*accesscontrol.AssignmentRule, error)

+ func (r *AccessControlRepository) ListGroupPermissions(ctx context.Context, groupID shared.ID) ([]*accesscontrol.GroupPermission, error)

+ func (r *AccessControlRepository) ListGroupPermissionsByEffect(ctx context.Context, groupID shared.ID, effect accesscontrol.PermissionEffect) ([]*accesscontrol.GroupPermission, error)

+ func (r *AccessControlRepository) ListGroupsByAsset(ctx context.Context, assetID shared.ID) ([]shared.ID, error)

+ func (r *AccessControlRepository) ListUsersByAsset(ctx context.Context, assetID shared.ID) ([]shared.ID, error)

+ func (r *AccessControlRepository) RefreshUserAccessibleAssets(ctx context.Context) error

+ func (r *AccessControlRepository) UpdateAssetOwner(ctx context.Context, ao *accesscontrol.AssetOwner) error

+ func (r *AccessControlRepository) UpdateAssignmentRule(ctx context.Context, rule *accesscontrol.AssignmentRule) error

+ func (r *AccessControlRepository) UpdateGroupPermission(ctx context.Context, gp *accesscontrol.GroupPermission) error

+ type AdminRepository struct

+ func NewAdminRepository(db *DB) *AdminRepository

+ func (r *AdminRepository) AuthenticateByAPIKey(ctx context.Context, rawKey string) (*admin.AdminUser, error)

+ func (r *AdminRepository) Count(ctx context.Context, filter admin.Filter) (int, error)

+ func (r *AdminRepository) CountByRole(ctx context.Context, role admin.AdminRole) (int, error)

+ func (r *AdminRepository) Create(ctx context.Context, a *admin.AdminUser) error

+ func (r *AdminRepository) Delete(ctx context.Context, id shared.ID) error

+ func (r *AdminRepository) GetByAPIKeyPrefix(ctx context.Context, prefix string) (*admin.AdminUser, error)

+ func (r *AdminRepository) GetByEmail(ctx context.Context, email string) (*admin.AdminUser, error)

+ func (r *AdminRepository) GetByID(ctx context.Context, id shared.ID) (*admin.AdminUser, error)

+ func (r *AdminRepository) List(ctx context.Context, filter admin.Filter, page pagination.Pagination) (pagination.Result[*admin.AdminUser], error)

+ func (r *AdminRepository) RecordUsage(ctx context.Context, id shared.ID, ip string) error

+ func (r *AdminRepository) Update(ctx context.Context, a *admin.AdminUser) error

+ type AgentRepository struct

+ func NewAgentRepository(db *DB) *AgentRepository

+ func (r *AgentRepository) ClaimJob(ctx context.Context, id shared.ID) error

+ func (r *AgentRepository) CountByTenant(ctx context.Context, tenantID shared.ID) (int, error)

+ func (r *AgentRepository) Create(ctx context.Context, a *agent.Agent) error

+ func (r *AgentRepository) Delete(ctx context.Context, id shared.ID) error

+ func (r *AgentRepository) FindAvailable(ctx context.Context, tenantID shared.ID, capabilities []string, tool string) ([]*agent.Agent, error)

+ func (r *AgentRepository) FindAvailableWithCapacity(ctx context.Context, tenantID shared.ID, capabilities []string, tool string) ([]*agent.Agent, error)

+ func (r *AgentRepository) FindAvailableWithTool(ctx context.Context, tenantID shared.ID, tool string) (*agent.Agent, error)

+ func (r *AgentRepository) FindByCapabilities(ctx context.Context, tenantID shared.ID, capabilities []string, tool string) ([]*agent.Agent, error)

+ func (r *AgentRepository) GetAgentsOfflineSince(ctx context.Context, since time.Time) ([]*agent.Agent, error)

+ func (r *AgentRepository) GetAvailableCapabilitiesForTenant(ctx context.Context, tenantID shared.ID) ([]string, error)

+ func (r *AgentRepository) GetAvailableToolsForTenant(ctx context.Context, tenantID shared.ID) ([]string, error)

+ func (r *AgentRepository) GetByAPIKeyHash(ctx context.Context, hash string) (*agent.Agent, error)

+ func (r *AgentRepository) GetByID(ctx context.Context, id shared.ID) (*agent.Agent, error)

+ func (r *AgentRepository) GetByTenantAndID(ctx context.Context, tenantID, id shared.ID) (*agent.Agent, error)

+ func (r *AgentRepository) HasAgentForCapability(ctx context.Context, tenantID shared.ID, capability string) (bool, error)

+ func (r *AgentRepository) HasAgentForTool(ctx context.Context, tenantID shared.ID, tool string) (bool, error)

+ func (r *AgentRepository) IncrementStats(ctx context.Context, id shared.ID, findings, scans, errors int64) error

+ func (r *AgentRepository) List(ctx context.Context, filter agent.Filter, page pagination.Pagination) (pagination.Result[*agent.Agent], error)

+ func (r *AgentRepository) MarkStaleAgentsOffline(ctx context.Context, timeout time.Duration) ([]shared.ID, error)

+ func (r *AgentRepository) MarkStaleAsOffline(ctx context.Context, timeout time.Duration) (int64, error)

+ func (r *AgentRepository) ReleaseJob(ctx context.Context, id shared.ID) error

+ func (r *AgentRepository) Update(ctx context.Context, a *agent.Agent) error

+ func (r *AgentRepository) UpdateLastSeen(ctx context.Context, id shared.ID) error

+ func (r *AgentRepository) UpdateOfflineTimestamp(ctx context.Context, id shared.ID) error

+ type AssetGroupRepository struct

+ func NewAssetGroupRepository(db *DB) *AssetGroupRepository

+ func (r *AssetGroupRepository) AddAssets(ctx context.Context, groupID shared.ID, assetIDs []shared.ID) error

+ func (r *AssetGroupRepository) Count(ctx context.Context, filter assetgroup.Filter) (int64, error)

+ func (r *AssetGroupRepository) CountAssetsByType(ctx context.Context, groupID shared.ID) (map[string]int64, error)

+ func (r *AssetGroupRepository) Create(ctx context.Context, g *assetgroup.AssetGroup) error

+ func (r *AssetGroupRepository) Delete(ctx context.Context, id shared.ID) error

+ func (r *AssetGroupRepository) ExistsByName(ctx context.Context, tenantID shared.ID, name string) (bool, error)

+ func (r *AssetGroupRepository) GetByID(ctx context.Context, id shared.ID) (*assetgroup.AssetGroup, error)

+ func (r *AssetGroupRepository) GetDistinctAssetTypes(ctx context.Context, groupID shared.ID) ([]string, error)

+ func (r *AssetGroupRepository) GetDistinctAssetTypesMultiple(ctx context.Context, groupIDs []shared.ID) ([]string, error)

+ func (r *AssetGroupRepository) GetGroupAssets(ctx context.Context, groupID shared.ID, page pagination.Pagination) (pagination.Result[*assetgroup.GroupAsset], error)

+ func (r *AssetGroupRepository) GetGroupFindings(ctx context.Context, groupID shared.ID, page pagination.Pagination) (pagination.Result[*assetgroup.GroupFinding], error)

+ func (r *AssetGroupRepository) GetGroupIDsByAssetID(ctx context.Context, assetID shared.ID) ([]shared.ID, error)

+ func (r *AssetGroupRepository) GetStats(ctx context.Context, tenantID shared.ID) (*assetgroup.Stats, error)

+ func (r *AssetGroupRepository) List(ctx context.Context, filter assetgroup.Filter, opts assetgroup.ListOptions, ...) (pagination.Result[*assetgroup.AssetGroup], error)

+ func (r *AssetGroupRepository) RecalculateCounts(ctx context.Context, groupID shared.ID) error

+ func (r *AssetGroupRepository) RemoveAssets(ctx context.Context, groupID shared.ID, assetIDs []shared.ID) error

+ func (r *AssetGroupRepository) Update(ctx context.Context, g *assetgroup.AssetGroup) error

+ type AssetRelationshipRepository struct

+ func NewAssetRelationshipRepository(db *DB) *AssetRelationshipRepository

+ func (r *AssetRelationshipRepository) CountByAsset(ctx context.Context, tenantID, assetID shared.ID) (int64, error)

+ func (r *AssetRelationshipRepository) Create(ctx context.Context, rel *asset.Relationship) error

+ func (r *AssetRelationshipRepository) Delete(ctx context.Context, tenantID, id shared.ID) error

+ func (r *AssetRelationshipRepository) Exists(ctx context.Context, tenantID, sourceID, targetID shared.ID, ...) (bool, error)

+ func (r *AssetRelationshipRepository) GetByID(ctx context.Context, tenantID, id shared.ID) (*asset.RelationshipWithAssets, error)

+ func (r *AssetRelationshipRepository) ListByAsset(ctx context.Context, tenantID, assetID shared.ID, ...) ([]*asset.RelationshipWithAssets, int64, error)

+ func (r *AssetRelationshipRepository) Update(ctx context.Context, rel *asset.Relationship) error

+ type AssetRepository struct

+ func NewAssetRepository(db *DB) *AssetRepository

+ func (r *AssetRepository) Count(ctx context.Context, filter asset.Filter) (int64, error)

+ func (r *AssetRepository) Create(ctx context.Context, a *asset.Asset) error

+ func (r *AssetRepository) Delete(ctx context.Context, tenantID, assetID shared.ID) error

+ func (r *AssetRepository) ExistsByName(ctx context.Context, tenantID shared.ID, name string) (bool, error)

+ func (r *AssetRepository) FindRepositoryByFullName(ctx context.Context, tenantID shared.ID, fullName string) (*asset.Asset, error)

+ func (r *AssetRepository) FindRepositoryByRepoName(ctx context.Context, tenantID shared.ID, repoName string) (*asset.Asset, error)

+ func (r *AssetRepository) GetByExternalID(ctx context.Context, tenantID shared.ID, provider asset.Provider, ...) (*asset.Asset, error)

+ func (r *AssetRepository) GetByID(ctx context.Context, tenantID, assetID shared.ID) (*asset.Asset, error)

+ func (r *AssetRepository) GetByName(ctx context.Context, tenantID shared.ID, name string) (*asset.Asset, error)

+ func (r *AssetRepository) GetByNames(ctx context.Context, tenantID shared.ID, names []string) (map[string]*asset.Asset, error)

+ func (r *AssetRepository) List(ctx context.Context, filter asset.Filter, opts asset.ListOptions, ...) (pagination.Result[*asset.Asset], error)

+ func (r *AssetRepository) Update(ctx context.Context, a *asset.Asset) error

+ func (r *AssetRepository) UpdateFindingCounts(ctx context.Context, tenantID shared.ID, assetIDs []shared.ID) error

+ func (r *AssetRepository) UpsertBatch(ctx context.Context, assets []*asset.Asset) (created int, updated int, err error)

+ type AssetServiceRepository struct

+ func NewAssetServiceRepository(db *DB) *AssetServiceRepository

+ func (r *AssetServiceRepository) CountByAsset(ctx context.Context, tenantID, assetID shared.ID) (int, error)

+ func (r *AssetServiceRepository) CountByTenant(ctx context.Context, tenantID shared.ID) (int64, error)

+ func (r *AssetServiceRepository) CountPublic(ctx context.Context, tenantID shared.ID) (int64, error)

+ func (r *AssetServiceRepository) Create(ctx context.Context, service *asset.AssetService) error

+ func (r *AssetServiceRepository) Delete(ctx context.Context, tenantID, id shared.ID) error

+ func (r *AssetServiceRepository) DeleteByAssetID(ctx context.Context, tenantID, assetID shared.ID) error

+ func (r *AssetServiceRepository) GetByAssetAndPort(ctx context.Context, tenantID, assetID shared.ID, port int, ...) (*asset.AssetService, error)

+ func (r *AssetServiceRepository) GetByAssetID(ctx context.Context, tenantID, assetID shared.ID) ([]*asset.AssetService, error)

+ func (r *AssetServiceRepository) GetByID(ctx context.Context, tenantID, id shared.ID) (*asset.AssetService, error)

+ func (r *AssetServiceRepository) GetPortCounts(ctx context.Context, tenantID shared.ID, topN int) (map[int]int, error)

+ func (r *AssetServiceRepository) GetServiceTypeCounts(ctx context.Context, tenantID shared.ID) (map[asset.ServiceType]int, error)

+ func (r *AssetServiceRepository) List(ctx context.Context, tenantID shared.ID, opts asset.ListAssetServicesOptions) ([]*asset.AssetService, int, error)

+ func (r *AssetServiceRepository) ListByServiceType(ctx context.Context, tenantID shared.ID, serviceType asset.ServiceType, ...) ([]*asset.AssetService, int, error)

+ func (r *AssetServiceRepository) ListHighRisk(ctx context.Context, tenantID shared.ID, minRiskScore int, limit, offset int) ([]*asset.AssetService, int, error)

+ func (r *AssetServiceRepository) ListPublic(ctx context.Context, tenantID shared.ID, limit, offset int) ([]*asset.AssetService, int, error)

+ func (r *AssetServiceRepository) SearchByCPE(ctx context.Context, tenantID shared.ID, cpe string, limit int) ([]*asset.AssetService, error)

+ func (r *AssetServiceRepository) SearchByProduct(ctx context.Context, tenantID shared.ID, product string, limit int) ([]*asset.AssetService, error)

+ func (r *AssetServiceRepository) SearchByVersion(ctx context.Context, tenantID shared.ID, version string, limit int) ([]*asset.AssetService, error)

+ func (r *AssetServiceRepository) Update(ctx context.Context, service *asset.AssetService) error

+ func (r *AssetServiceRepository) UpdateFindingCounts(ctx context.Context, counts map[shared.ID]int) error

+ func (r *AssetServiceRepository) UpsertBatch(ctx context.Context, services []*asset.AssetService) (created int, updated int, err error)

+ type AssetSourceRepository struct

+ func NewAssetSourceRepository(db *DB) *AssetSourceRepository

+ func (r *AssetSourceRepository) CountBySource(ctx context.Context, sourceID shared.ID) (int64, error)

+ func (r *AssetSourceRepository) Create(ctx context.Context, as *datasource.AssetSource) error

+ func (r *AssetSourceRepository) Delete(ctx context.Context, id shared.ID) error

+ func (r *AssetSourceRepository) DeleteByAsset(ctx context.Context, assetID shared.ID) error

+ func (r *AssetSourceRepository) DeleteBySource(ctx context.Context, sourceID shared.ID) error

+ func (r *AssetSourceRepository) GetByAsset(ctx context.Context, assetID shared.ID) ([]*datasource.AssetSource, error)

+ func (r *AssetSourceRepository) GetByAssetAndSource(ctx context.Context, assetID shared.ID, sourceType datasource.SourceType, ...) (*datasource.AssetSource, error)

+ func (r *AssetSourceRepository) GetByID(ctx context.Context, id shared.ID) (*datasource.AssetSource, error)

+ func (r *AssetSourceRepository) GetPrimaryByAsset(ctx context.Context, assetID shared.ID) (*datasource.AssetSource, error)

+ func (r *AssetSourceRepository) List(ctx context.Context, filter datasource.AssetSourceFilter, ...) (datasource.AssetSourceListResult, error)

+ func (r *AssetSourceRepository) SetPrimary(ctx context.Context, assetSourceID shared.ID) error

+ func (r *AssetSourceRepository) Update(ctx context.Context, as *datasource.AssetSource) error

+ func (r *AssetSourceRepository) Upsert(ctx context.Context, as *datasource.AssetSource) error

+ type AssetStateHistoryRepository struct

+ func NewAssetStateHistoryRepository(db *DB) *AssetStateHistoryRepository

+ func (r *AssetStateHistoryRepository) CountBySource(ctx context.Context, tenantID shared.ID, since time.Time) (map[asset.ChangeSource]int, error)

+ func (r *AssetStateHistoryRepository) CountByType(ctx context.Context, tenantID shared.ID, since time.Time) (map[asset.StateChangeType]int, error)

+ func (r *AssetStateHistoryRepository) Create(ctx context.Context, change *asset.AssetStateChange) error

+ func (r *AssetStateHistoryRepository) CreateBatch(ctx context.Context, changes []*asset.AssetStateChange) error

+ func (r *AssetStateHistoryRepository) GetActivityTimeline(ctx context.Context, tenantID shared.ID, from, to time.Time) ([]asset.DailyActivityCount, error)

+ func (r *AssetStateHistoryRepository) GetByAssetID(ctx context.Context, tenantID, assetID shared.ID, ...) ([]*asset.AssetStateChange, int, error)

+ func (r *AssetStateHistoryRepository) GetByID(ctx context.Context, tenantID, id shared.ID) (*asset.AssetStateChange, error)

+ func (r *AssetStateHistoryRepository) GetChangesByUser(ctx context.Context, tenantID, userID shared.ID, ...) ([]*asset.AssetStateChange, int, error)

+ func (r *AssetStateHistoryRepository) GetComplianceChanges(ctx context.Context, tenantID shared.ID, since time.Time, limit int) ([]*asset.AssetStateChange, error)

+ func (r *AssetStateHistoryRepository) GetExposureChanges(ctx context.Context, tenantID shared.ID, since time.Time, limit int) ([]*asset.AssetStateChange, error)

+ func (r *AssetStateHistoryRepository) GetLatestByAsset(ctx context.Context, tenantID shared.ID, changeTypes []asset.StateChangeType) (map[shared.ID]*asset.AssetStateChange, error)

+ func (r *AssetStateHistoryRepository) GetNewlyExposedAssets(ctx context.Context, tenantID shared.ID, since time.Time, limit int) ([]*asset.AssetStateChange, error)

+ func (r *AssetStateHistoryRepository) GetRecentAppearances(ctx context.Context, tenantID shared.ID, since time.Time, limit int) ([]*asset.AssetStateChange, error)

+ func (r *AssetStateHistoryRepository) GetRecentDisappearances(ctx context.Context, tenantID shared.ID, since time.Time, limit int) ([]*asset.AssetStateChange, error)

+ func (r *AssetStateHistoryRepository) GetShadowITCandidates(ctx context.Context, tenantID shared.ID, since time.Time, limit int) ([]*asset.AssetStateChange, error)

+ func (r *AssetStateHistoryRepository) List(ctx context.Context, tenantID shared.ID, opts asset.ListStateHistoryOptions) ([]*asset.AssetStateChange, int, error)

+ type AssetTypeCategoryRepository struct

+ func NewAssetTypeCategoryRepository(db *DB) *AssetTypeCategoryRepository

+ func (r *AssetTypeCategoryRepository) Create(ctx context.Context, c *assettype.Category) error

+ func (r *AssetTypeCategoryRepository) Delete(ctx context.Context, id shared.ID) error

+ func (r *AssetTypeCategoryRepository) GetByCode(ctx context.Context, code string) (*assettype.Category, error)

+ func (r *AssetTypeCategoryRepository) GetByID(ctx context.Context, id shared.ID) (*assettype.Category, error)

+ func (r *AssetTypeCategoryRepository) List(ctx context.Context, filter assettype.CategoryFilter, ...) (pagination.Result[*assettype.Category], error)

+ func (r *AssetTypeCategoryRepository) ListActive(ctx context.Context) ([]*assettype.Category, error)

+ func (r *AssetTypeCategoryRepository) Update(ctx context.Context, c *assettype.Category) error

+ type AssetTypeRepository struct

+ func NewAssetTypeRepository(db *DB) *AssetTypeRepository

+ func (r *AssetTypeRepository) ExistsByCode(ctx context.Context, code string) (bool, error)

+ func (r *AssetTypeRepository) GetByCode(ctx context.Context, code string) (*assettype.AssetType, error)

+ func (r *AssetTypeRepository) GetByID(ctx context.Context, id shared.ID) (*assettype.AssetType, error)

+ func (r *AssetTypeRepository) List(ctx context.Context, filter assettype.Filter, opts assettype.ListOptions, ...) (pagination.Result[*assettype.AssetType], error)

+ func (r *AssetTypeRepository) ListActive(ctx context.Context) ([]*assettype.AssetType, error)

+ func (r *AssetTypeRepository) ListActiveByCategory(ctx context.Context, categoryID shared.ID) ([]*assettype.AssetType, error)

+ func (r *AssetTypeRepository) ListWithCategory(ctx context.Context, filter assettype.Filter, opts assettype.ListOptions, ...) (pagination.Result[*assettype.AssetTypeWithCategory], error)

+ type AuditLogRepository struct

+ func NewAuditLogRepository(db *DB) *AuditLogRepository

+ func (r *AuditLogRepository) Count(ctx context.Context, filter admin.AuditLogFilter) (int64, error)

+ func (r *AuditLogRepository) CountOlderThan(ctx context.Context, olderThan time.Time) (int64, error)

+ func (r *AuditLogRepository) Create(ctx context.Context, log *admin.AuditLog) error

+ func (r *AuditLogRepository) DeleteOlderThan(ctx context.Context, olderThan time.Time) (int64, error)

+ func (r *AuditLogRepository) GetByID(ctx context.Context, id shared.ID) (*admin.AuditLog, error)

+ func (r *AuditLogRepository) GetFailedActions(ctx context.Context, since time.Duration, limit int) ([]*admin.AuditLog, error)

+ func (r *AuditLogRepository) GetRecentActions(ctx context.Context, limit int) ([]*admin.AuditLog, error)

+ func (r *AuditLogRepository) List(ctx context.Context, filter admin.AuditLogFilter, page pagination.Pagination) (pagination.Result[*admin.AuditLog], error)

+ func (r *AuditLogRepository) ListByAdmin(ctx context.Context, adminID shared.ID, page pagination.Pagination) (pagination.Result[*admin.AuditLog], error)

+ func (r *AuditLogRepository) ListByResource(ctx context.Context, resourceType string, resourceID shared.ID, ...) (pagination.Result[*admin.AuditLog], error)

+ type AuditRepository struct

+ func NewAuditRepository(db *DB) *AuditRepository

+ func (r *AuditRepository) Count(ctx context.Context, filter audit.Filter) (int64, error)

+ func (r *AuditRepository) CountByAction(ctx context.Context, tenantID *shared.ID, action audit.Action, since time.Time) (int64, error)

+ func (r *AuditRepository) Create(ctx context.Context, log *audit.AuditLog) error

+ func (r *AuditRepository) CreateBatch(ctx context.Context, logs []*audit.AuditLog) error

+ func (r *AuditRepository) DeleteOlderThan(ctx context.Context, before time.Time) (int64, error)

+ func (r *AuditRepository) GetByID(ctx context.Context, id shared.ID) (*audit.AuditLog, error)

+ func (r *AuditRepository) GetLatestByResource(ctx context.Context, resourceType audit.ResourceType, resourceID string) (*audit.AuditLog, error)

+ func (r *AuditRepository) List(ctx context.Context, filter audit.Filter, page pagination.Pagination) (pagination.Result[*audit.AuditLog], error)

+ func (r *AuditRepository) ListByActor(ctx context.Context, actorID shared.ID, page pagination.Pagination) (pagination.Result[*audit.AuditLog], error)

+ func (r *AuditRepository) ListByResource(ctx context.Context, resourceType audit.ResourceType, resourceID string, ...) (pagination.Result[*audit.AuditLog], error)

+ type BranchRepository struct

+ func NewBranchRepository(db *DB) *BranchRepository

+ func (r *BranchRepository) Count(ctx context.Context, filter branch.Filter) (int64, error)

+ func (r *BranchRepository) Create(ctx context.Context, b *branch.Branch) error

+ func (r *BranchRepository) Delete(ctx context.Context, id shared.ID) error

+ func (r *BranchRepository) ExistsByName(ctx context.Context, repositoryID shared.ID, name string) (bool, error)

+ func (r *BranchRepository) GetByID(ctx context.Context, id shared.ID) (*branch.Branch, error)

+ func (r *BranchRepository) GetByName(ctx context.Context, repositoryID shared.ID, name string) (*branch.Branch, error)

+ func (r *BranchRepository) GetDefaultBranch(ctx context.Context, repositoryID shared.ID) (*branch.Branch, error)

+ func (r *BranchRepository) List(ctx context.Context, filter branch.Filter, opts branch.ListOptions, ...) (pagination.Result[*branch.Branch], error)

+ func (r *BranchRepository) ListByRepository(ctx context.Context, repositoryID shared.ID) ([]*branch.Branch, error)

+ func (r *BranchRepository) SetDefaultBranch(ctx context.Context, repositoryID shared.ID, branchID shared.ID) error

+ func (r *BranchRepository) Update(ctx context.Context, b *branch.Branch) error

+ type CapabilityRepository struct

+ func NewCapabilityRepository(db *DB) *CapabilityRepository

+ func (r *CapabilityRepository) CountByTenant(ctx context.Context, tenantID shared.ID) (int64, error)

+ func (r *CapabilityRepository) Create(ctx context.Context, c *capability.Capability) error

+ func (r *CapabilityRepository) Delete(ctx context.Context, id shared.ID) error

+ func (r *CapabilityRepository) ExistsByName(ctx context.Context, tenantID *shared.ID, name string) (bool, error)

+ func (r *CapabilityRepository) GetByID(ctx context.Context, id shared.ID) (*capability.Capability, error)

+ func (r *CapabilityRepository) GetByName(ctx context.Context, tenantID *shared.ID, name string) (*capability.Capability, error)

+ func (r *CapabilityRepository) GetCategories(ctx context.Context) ([]string, error)

+ func (r *CapabilityRepository) GetUsageStats(ctx context.Context, capabilityID shared.ID) (*capability.CapabilityUsageStats, error)

+ func (r *CapabilityRepository) GetUsageStatsBatch(ctx context.Context, capabilityIDs []shared.ID) (map[shared.ID]*capability.CapabilityUsageStats, error)

+ func (r *CapabilityRepository) List(ctx context.Context, filter capability.Filter, page pagination.Pagination) (pagination.Result[*capability.Capability], error)

+ func (r *CapabilityRepository) ListAll(ctx context.Context, tenantID *shared.ID) ([]*capability.Capability, error)

+ func (r *CapabilityRepository) ListByCategory(ctx context.Context, tenantID *shared.ID, category string) ([]*capability.Capability, error)

+ func (r *CapabilityRepository) ListByNames(ctx context.Context, tenantID *shared.ID, names []string) ([]*capability.Capability, error)

+ func (r *CapabilityRepository) Update(ctx context.Context, c *capability.Capability) error

+ type CommandRepository struct

+ func NewCommandRepository(db *DB) *CommandRepository

+ func (r *CommandRepository) CountActivePlatformJobsByTenant(ctx context.Context, tenantID shared.ID) (int, error)

+ func (r *CommandRepository) CountQueuedPlatformJobs(ctx context.Context) (int, error)

+ func (r *CommandRepository) CountQueuedPlatformJobsByTenant(ctx context.Context, tenantID shared.ID) (int, error)

+ func (r *CommandRepository) Create(ctx context.Context, cmd *command.Command) error

+ func (r *CommandRepository) Delete(ctx context.Context, id shared.ID) error

+ func (r *CommandRepository) ExpireOldCommands(ctx context.Context) (int64, error)

+ func (r *CommandRepository) ExpireOldPlatformJobs(ctx context.Context, maxQueueMinutes int) (int64, error)

+ func (r *CommandRepository) FailExhaustedCommands(ctx context.Context, maxRetries int) (int64, error)

+ func (r *CommandRepository) FindExpired(ctx context.Context) ([]*command.Command, error)

+ func (r *CommandRepository) GetByAuthTokenHash(ctx context.Context, hash string) (*command.Command, error)

+ func (r *CommandRepository) GetByID(ctx context.Context, id shared.ID) (*command.Command, error)

+ func (r *CommandRepository) GetByTenantAndID(ctx context.Context, tenantID, id shared.ID) (*command.Command, error)

+ func (r *CommandRepository) GetNextPlatformJob(ctx context.Context, agentID shared.ID, capabilities []string, tools []string) (*command.Command, error)

+ func (r *CommandRepository) GetPendingForAgent(ctx context.Context, tenantID shared.ID, agentID *shared.ID, limit int) ([]*command.Command, error)

+ func (r *CommandRepository) GetPlatformJobsByAgent(ctx context.Context, agentID shared.ID, status *command.CommandStatus) ([]*command.Command, error)

+ func (r *CommandRepository) GetQueuePosition(ctx context.Context, commandID shared.ID) (*command.QueuePosition, error)

+ func (r *CommandRepository) GetQueuedPlatformJobs(ctx context.Context, limit int) ([]*command.Command, error)

+ func (r *CommandRepository) GetStatsByTenant(ctx context.Context, tenantID shared.ID) (command.CommandStats, error)

+ func (r *CommandRepository) List(ctx context.Context, filter command.Filter, page pagination.Pagination) (pagination.Result[*command.Command], error)

+ func (r *CommandRepository) ListPlatformJobsAdmin(ctx context.Context, agentID, tenantID *shared.ID, ...) (pagination.Result[*command.Command], error)

+ func (r *CommandRepository) ListPlatformJobsByTenant(ctx context.Context, tenantID shared.ID, page pagination.Pagination) (pagination.Result[*command.Command], error)

+ func (r *CommandRepository) RecoverStuckJobs(ctx context.Context, stuckThresholdMinutes int, maxRetries int) (int64, error)

+ func (r *CommandRepository) RecoverStuckTenantCommands(ctx context.Context, stuckThresholdMinutes int, maxRetries int) (int64, error)

+ func (r *CommandRepository) Update(ctx context.Context, cmd *command.Command) error

+ func (r *CommandRepository) UpdateQueuePriorities(ctx context.Context) (int64, error)

+ type ComponentRepository struct

+ func NewComponentRepository(db *DB) *ComponentRepository

+ func (r *ComponentRepository) DeleteByAssetID(ctx context.Context, assetID shared.ID) error

+ func (r *ComponentRepository) DeleteDependency(ctx context.Context, id shared.ID) error

+ func (r *ComponentRepository) GetByID(ctx context.Context, id shared.ID) (*component.Component, error)

+ func (r *ComponentRepository) GetByPURL(ctx context.Context, purl string) (*component.Component, error)

+ func (r *ComponentRepository) GetDependency(ctx context.Context, id shared.ID) (*component.AssetDependency, error)

+ func (r *ComponentRepository) GetEcosystemStats(ctx context.Context, tenantID shared.ID) ([]component.EcosystemStats, error)

+ func (r *ComponentRepository) GetExistingDependencyByComponentID(ctx context.Context, assetID shared.ID, componentID shared.ID, path string) (*component.AssetDependency, error)

+ func (r *ComponentRepository) GetExistingDependencyByPURL(ctx context.Context, assetID shared.ID, purl string) (*component.AssetDependency, error)

+ func (r *ComponentRepository) GetLicenseStats(ctx context.Context, tenantID shared.ID) ([]component.LicenseStats, error)

+ func (r *ComponentRepository) GetStats(ctx context.Context, tenantID shared.ID) (*component.ComponentStats, error)

+ func (r *ComponentRepository) GetVulnerableComponents(ctx context.Context, tenantID shared.ID, limit int) ([]component.VulnerableComponent, error)

+ func (r *ComponentRepository) LinkAsset(ctx context.Context, dep *component.AssetDependency) error

+ func (r *ComponentRepository) LinkLicenses(ctx context.Context, componentID shared.ID, licenses []string) (int, error)

+ func (r *ComponentRepository) ListComponents(ctx context.Context, filter component.Filter, page pagination.Pagination) (pagination.Result[*component.Component], error)

+ func (r *ComponentRepository) ListDependencies(ctx context.Context, assetID shared.ID, page pagination.Pagination) (pagination.Result[*component.AssetDependency], error)

+ func (r *ComponentRepository) UpdateAssetDependencyParent(ctx context.Context, id shared.ID, parentID shared.ID, depth int) error

+ func (r *ComponentRepository) UpdateDependency(ctx context.Context, dep *component.AssetDependency) error

+ func (r *ComponentRepository) Upsert(ctx context.Context, comp *component.Component) (shared.ID, error)

+ type DB struct

+ func New(cfg *config.DatabaseConfig) (*DB, error)

+ func (db *DB) Close() error

+ func (db *DB) HealthCheck(ctx context.Context) error

+ func (db *DB) Ping(ctx context.Context) error

+ func (db *DB) Transaction(ctx context.Context, fn func(tx *sql.Tx) error) error

+ type DashboardRepository struct

+ func NewDashboardRepository(db *sql.DB) *DashboardRepository

+ func (r *DashboardRepository) GetAssetStats(ctx context.Context, tenantID shared.ID) (app.AssetStatsData, error)

+ func (r *DashboardRepository) GetFilteredAssetStats(ctx context.Context, tenantIDs []string) (app.AssetStatsData, error)

+ func (r *DashboardRepository) GetFilteredFindingStats(ctx context.Context, tenantIDs []string) (app.FindingStatsData, error)

+ func (r *DashboardRepository) GetFilteredRecentActivity(ctx context.Context, tenantIDs []string, limit int) ([]app.ActivityItem, error)

+ func (r *DashboardRepository) GetFilteredRepositoryStats(ctx context.Context, tenantIDs []string) (app.RepositoryStatsData, error)

+ func (r *DashboardRepository) GetFindingStats(ctx context.Context, tenantID shared.ID) (app.FindingStatsData, error)

+ func (r *DashboardRepository) GetGlobalAssetStats(ctx context.Context) (app.AssetStatsData, error)

+ func (r *DashboardRepository) GetGlobalFindingStats(ctx context.Context) (app.FindingStatsData, error)

+ func (r *DashboardRepository) GetGlobalRecentActivity(ctx context.Context, limit int) ([]app.ActivityItem, error)

+ func (r *DashboardRepository) GetGlobalRepositoryStats(ctx context.Context) (app.RepositoryStatsData, error)

+ func (r *DashboardRepository) GetRecentActivity(ctx context.Context, tenantID shared.ID, limit int) ([]app.ActivityItem, error)

+ func (r *DashboardRepository) GetRepositoryStats(ctx context.Context, tenantID shared.ID) (app.RepositoryStatsData, error)

+ type DataFlowRepository struct

+ func NewDataFlowRepository(db *DB) *DataFlowRepository

+ func (r *DataFlowRepository) CreateDataFlow(ctx context.Context, flow *vulnerability.FindingDataFlow) error

+ func (r *DataFlowRepository) CreateDataFlowBatch(ctx context.Context, flows []*vulnerability.FindingDataFlow) error

+ func (r *DataFlowRepository) CreateFlowLocation(ctx context.Context, location *vulnerability.FindingFlowLocation) error

+ func (r *DataFlowRepository) CreateFlowLocationBatch(ctx context.Context, locations []*vulnerability.FindingFlowLocation) error

+ func (r *DataFlowRepository) DeleteDataFlowsByFinding(ctx context.Context, findingID shared.ID) error

+ func (r *DataFlowRepository) DeleteFlowLocationsByDataFlow(ctx context.Context, dataFlowID shared.ID) error

+ func (r *DataFlowRepository) GetDataFlowByID(ctx context.Context, id shared.ID) (*vulnerability.FindingDataFlow, error)

+ func (r *DataFlowRepository) GetDataFlowsWithLocations(ctx context.Context, findingID shared.ID) ([]*vulnerability.FindingDataFlow, ...)

+ func (r *DataFlowRepository) GetDataFlowsWithLocationsByTenant(ctx context.Context, findingID, tenantID shared.ID) ([]*vulnerability.FindingDataFlow, ...)

+ func (r *DataFlowRepository) GetFlowLocationByID(ctx context.Context, id shared.ID) (*vulnerability.FindingFlowLocation, error)

+ func (r *DataFlowRepository) ListDataFlowsByFinding(ctx context.Context, findingID shared.ID) ([]*vulnerability.FindingDataFlow, error)

+ func (r *DataFlowRepository) ListFlowLocationsByDataFlow(ctx context.Context, dataFlowID shared.ID) ([]*vulnerability.FindingFlowLocation, error)

+ func (r *DataFlowRepository) ListFlowLocationsByFile(ctx context.Context, tenantID shared.ID, filePath string, ...) (pagination.Result[*vulnerability.FindingFlowLocation], error)

+ func (r *DataFlowRepository) ListFlowLocationsByFunction(ctx context.Context, tenantID shared.ID, functionName string, ...) (pagination.Result[*vulnerability.FindingFlowLocation], error)

+ func (r *DataFlowRepository) ListSourcesAndSinks(ctx context.Context, findingID shared.ID) ([]*vulnerability.FindingFlowLocation, error)

+ type DataSourceRepository struct

+ func NewDataSourceRepository(db *DB) *DataSourceRepository

+ func (r *DataSourceRepository) Count(ctx context.Context, filter datasource.Filter) (int64, error)

+ func (r *DataSourceRepository) Create(ctx context.Context, ds *datasource.DataSource) error

+ func (r *DataSourceRepository) Delete(ctx context.Context, id shared.ID) error

+ func (r *DataSourceRepository) GetActiveByTenant(ctx context.Context, tenantID shared.ID) ([]*datasource.DataSource, error)

+ func (r *DataSourceRepository) GetByAPIKeyPrefix(ctx context.Context, prefix string) (*datasource.DataSource, error)

+ func (r *DataSourceRepository) GetByID(ctx context.Context, id shared.ID) (*datasource.DataSource, error)

+ func (r *DataSourceRepository) GetByTenantAndName(ctx context.Context, tenantID shared.ID, name string) (*datasource.DataSource, error)

+ func (r *DataSourceRepository) List(ctx context.Context, filter datasource.Filter, opts datasource.ListOptions) (datasource.ListResult, error)

+ func (r *DataSourceRepository) MarkStaleAsInactive(ctx context.Context, tenantID shared.ID, staleThresholdMinutes int) (int, error)

+ func (r *DataSourceRepository) Update(ctx context.Context, ds *datasource.DataSource) error

+ type EPSSRepository struct

+ func (r *EPSSRepository) Count(ctx context.Context) (int64, error)

+ func (r *EPSSRepository) DeleteAll(ctx context.Context) error

+ func (r *EPSSRepository) GetByCVEID(ctx context.Context, cveID string) (*threatintel.EPSSScore, error)

+ func (r *EPSSRepository) GetByCVEIDs(ctx context.Context, cveIDs []string) ([]*threatintel.EPSSScore, error)

+ func (r *EPSSRepository) GetHighRisk(ctx context.Context, threshold float64, limit int) ([]*threatintel.EPSSScore, error)

+ func (r *EPSSRepository) GetTopPercentile(ctx context.Context, percentile float64, limit int) ([]*threatintel.EPSSScore, error)

+ func (r *EPSSRepository) Upsert(ctx context.Context, score *threatintel.EPSSScore) error

+ func (r *EPSSRepository) UpsertBatch(ctx context.Context, scores []*threatintel.EPSSScore) error

+ type ExposureRepository struct

+ func NewExposureRepository(db *DB) *ExposureRepository

+ func (r *ExposureRepository) BulkUpsert(ctx context.Context, events []*exposure.ExposureEvent) error

+ func (r *ExposureRepository) Count(ctx context.Context, filter exposure.Filter) (int64, error)

+ func (r *ExposureRepository) CountBySeverity(ctx context.Context, tenantID shared.ID) (map[exposure.Severity]int64, error)

+ func (r *ExposureRepository) CountByState(ctx context.Context, tenantID shared.ID) (map[exposure.State]int64, error)

+ func (r *ExposureRepository) Create(ctx context.Context, event *exposure.ExposureEvent) error

+ func (r *ExposureRepository) CreateInTx(ctx context.Context, tx *sql.Tx, event *exposure.ExposureEvent) error

+ func (r *ExposureRepository) Delete(ctx context.Context, id shared.ID) error

+ func (r *ExposureRepository) ExistsByFingerprint(ctx context.Context, tenantID shared.ID, fingerprint string) (bool, error)

+ func (r *ExposureRepository) GetByFingerprint(ctx context.Context, tenantID shared.ID, fingerprint string) (*exposure.ExposureEvent, error)

+ func (r *ExposureRepository) GetByID(ctx context.Context, id shared.ID) (*exposure.ExposureEvent, error)

+ func (r *ExposureRepository) List(ctx context.Context, filter exposure.Filter, opts exposure.ListOptions, ...) (pagination.Result[*exposure.ExposureEvent], error)

+ func (r *ExposureRepository) ListByAsset(ctx context.Context, assetID shared.ID, page pagination.Pagination) (pagination.Result[*exposure.ExposureEvent], error)

+ func (r *ExposureRepository) Update(ctx context.Context, event *exposure.ExposureEvent) error

+ func (r *ExposureRepository) Upsert(ctx context.Context, event *exposure.ExposureEvent) error

+ type ExposureStateHistoryRepository struct

+ func NewExposureStateHistoryRepository(db *DB) *ExposureStateHistoryRepository

+ func (r *ExposureStateHistoryRepository) Create(ctx context.Context, history *exposure.StateHistory) error

+ func (r *ExposureStateHistoryRepository) GetLatest(ctx context.Context, exposureEventID shared.ID) (*exposure.StateHistory, error)

+ func (r *ExposureStateHistoryRepository) ListByExposureEvent(ctx context.Context, exposureEventID shared.ID) ([]*exposure.StateHistory, error)

+ type FindingActivityRepository struct

+ func NewFindingActivityRepository(db *DB) *FindingActivityRepository

+ func (r *FindingActivityRepository) CountByFinding(ctx context.Context, findingID shared.ID, tenantID shared.ID, ...) (int64, error)

+ func (r *FindingActivityRepository) Create(ctx context.Context, activity *vulnerability.FindingActivity) error

+ func (r *FindingActivityRepository) GetByID(ctx context.Context, id shared.ID) (*vulnerability.FindingActivity, error)

+ func (r *FindingActivityRepository) ListByFinding(ctx context.Context, findingID shared.ID, tenantID shared.ID, ...) (pagination.Result[*vulnerability.FindingActivity], error)

+ func (r *FindingActivityRepository) ListByTenant(ctx context.Context, tenantID shared.ID, ...) (pagination.Result[*vulnerability.FindingActivity], error)

+ type FindingCommentRepository struct

+ func NewFindingCommentRepository(db *DB) *FindingCommentRepository

+ func (r *FindingCommentRepository) CountByFinding(ctx context.Context, findingID shared.ID) (int, error)

+ func (r *FindingCommentRepository) Create(ctx context.Context, comment *vulnerability.FindingComment) error

+ func (r *FindingCommentRepository) Delete(ctx context.Context, id shared.ID) error

+ func (r *FindingCommentRepository) GetByID(ctx context.Context, id shared.ID) (*vulnerability.FindingComment, error)

+ func (r *FindingCommentRepository) ListByFinding(ctx context.Context, findingID shared.ID) ([]*vulnerability.FindingComment, error)

+ func (r *FindingCommentRepository) Update(ctx context.Context, comment *vulnerability.FindingComment) error

+ type FindingDataSourceRepository struct

+ func NewFindingDataSourceRepository(db *DB) *FindingDataSourceRepository

+ func (r *FindingDataSourceRepository) CountBySource(ctx context.Context, sourceID shared.ID) (int64, error)

+ func (r *FindingDataSourceRepository) Create(ctx context.Context, fs *datasource.FindingDataSource) error

+ func (r *FindingDataSourceRepository) Delete(ctx context.Context, id shared.ID) error

+ func (r *FindingDataSourceRepository) DeleteByFinding(ctx context.Context, findingID shared.ID) error

+ func (r *FindingDataSourceRepository) DeleteBySource(ctx context.Context, sourceID shared.ID) error

+ func (r *FindingDataSourceRepository) GetByFinding(ctx context.Context, findingID shared.ID) ([]*datasource.FindingDataSource, error)

+ func (r *FindingDataSourceRepository) GetByFindingAndSource(ctx context.Context, findingID shared.ID, sourceType datasource.SourceType, ...) (*datasource.FindingDataSource, error)

+ func (r *FindingDataSourceRepository) GetByID(ctx context.Context, id shared.ID) (*datasource.FindingDataSource, error)

+ func (r *FindingDataSourceRepository) GetPrimaryByFinding(ctx context.Context, findingID shared.ID) (*datasource.FindingDataSource, error)

+ func (r *FindingDataSourceRepository) List(ctx context.Context, filter datasource.FindingDataSourceFilter, ...) (datasource.FindingDataSourceListResult, error)

+ func (r *FindingDataSourceRepository) SetPrimary(ctx context.Context, findingDataSourceID shared.ID) error

+ func (r *FindingDataSourceRepository) Update(ctx context.Context, fs *datasource.FindingDataSource) error

+ func (r *FindingDataSourceRepository) Upsert(ctx context.Context, fs *datasource.FindingDataSource) error

+ type FindingRepository struct

+ func NewFindingRepository(db *DB) *FindingRepository

+ func (r *FindingRepository) AutoReopenByFingerprint(ctx context.Context, tenantID shared.ID, fingerprint string) (*shared.ID, error)

+ func (r *FindingRepository) AutoReopenByFingerprintsBatch(ctx context.Context, tenantID shared.ID, fingerprints []string) (map[string]shared.ID, error)

+ func (r *FindingRepository) AutoResolveStale(ctx context.Context, tenantID shared.ID, assetID shared.ID, toolName string, ...) ([]shared.ID, error)

+ func (r *FindingRepository) BatchCountByAssetIDs(ctx context.Context, tenantID shared.ID, assetIDs []shared.ID) (map[shared.ID]int64, error)

+ func (r *FindingRepository) CheckFingerprintsExist(ctx context.Context, tenantID shared.ID, fingerprints []string) (map[string]bool, error)

+ func (r *FindingRepository) Count(ctx context.Context, filter vulnerability.FindingFilter) (int64, error)

+ func (r *FindingRepository) CountByAssetID(ctx context.Context, tenantID, assetID shared.ID) (int64, error)

+ func (r *FindingRepository) CountBySeverityForScan(ctx context.Context, tenantID shared.ID, scanID string) (vulnerability.SeverityCounts, error)

+ func (r *FindingRepository) CountOpenByAssetID(ctx context.Context, tenantID, assetID shared.ID) (int64, error)

+ func (r *FindingRepository) Create(ctx context.Context, finding *vulnerability.Finding) error

+ func (r *FindingRepository) CreateBatch(ctx context.Context, findings []*vulnerability.Finding) error

+ func (r *FindingRepository) CreateBatchWithResult(ctx context.Context, findings []*vulnerability.Finding) (*vulnerability.BatchCreateResult, error)

+ func (r *FindingRepository) CreateInTx(ctx context.Context, tx *sql.Tx, finding *vulnerability.Finding) error

+ func (r *FindingRepository) Delete(ctx context.Context, tenantID, id shared.ID) error

+ func (r *FindingRepository) DeleteByAssetID(ctx context.Context, tenantID, assetID shared.ID) error

+ func (r *FindingRepository) DeleteByScanID(ctx context.Context, tenantID shared.ID, scanID string) error

+ func (r *FindingRepository) ExistsByFingerprint(ctx context.Context, tenantID shared.ID, fingerprint string) (bool, error)

+ func (r *FindingRepository) ExistsByIDs(ctx context.Context, tenantID shared.ID, ids []shared.ID) (map[shared.ID]bool, error)

+ func (r *FindingRepository) ExpireFeatureBranchFindings(ctx context.Context, tenantID shared.ID, defaultExpiryDays int) (int64, error)

+ func (r *FindingRepository) GetByFingerprint(ctx context.Context, tenantID shared.ID, fingerprint string) (*vulnerability.Finding, error)

+ func (r *FindingRepository) GetByID(ctx context.Context, tenantID, id shared.ID) (*vulnerability.Finding, error)

+ func (r *FindingRepository) GetStats(ctx context.Context, tenantID shared.ID) (*vulnerability.FindingStats, error)

+ func (r *FindingRepository) List(ctx context.Context, filter vulnerability.FindingFilter, ...) (pagination.Result[*vulnerability.Finding], error)

+ func (r *FindingRepository) ListByAssetID(ctx context.Context, tenantID, assetID shared.ID, ...) (pagination.Result[*vulnerability.Finding], error)

+ func (r *FindingRepository) ListByComponentID(ctx context.Context, tenantID, compID shared.ID, ...) (pagination.Result[*vulnerability.Finding], error)

+ func (r *FindingRepository) ListByVulnerabilityID(ctx context.Context, tenantID, vulnID shared.ID, ...) (pagination.Result[*vulnerability.Finding], error)

+ func (r *FindingRepository) Update(ctx context.Context, finding *vulnerability.Finding) error

+ func (r *FindingRepository) UpdateScanIDBatchByFingerprints(ctx context.Context, tenantID shared.ID, fingerprints []string, scanID string) (int64, error)

+ func (r *FindingRepository) UpdateSnippetBatchByFingerprints(ctx context.Context, tenantID shared.ID, snippets map[string]string) (int64, error)

+ func (r *FindingRepository) UpdateStatusBatch(ctx context.Context, tenantID shared.ID, ids []shared.ID, ...) error

+ type FindingSourceCategoryRepository struct

+ func NewFindingSourceCategoryRepository(db *DB) *FindingSourceCategoryRepository

+ func (r *FindingSourceCategoryRepository) Create(ctx context.Context, c *findingsource.Category) error

+ func (r *FindingSourceCategoryRepository) Delete(ctx context.Context, id shared.ID) error

+ func (r *FindingSourceCategoryRepository) GetByCode(ctx context.Context, code string) (*findingsource.Category, error)

+ func (r *FindingSourceCategoryRepository) GetByID(ctx context.Context, id shared.ID) (*findingsource.Category, error)

+ func (r *FindingSourceCategoryRepository) List(ctx context.Context, filter findingsource.CategoryFilter, ...) (pagination.Result[*findingsource.Category], error)

+ func (r *FindingSourceCategoryRepository) ListActive(ctx context.Context) ([]*findingsource.Category, error)

+ func (r *FindingSourceCategoryRepository) Update(ctx context.Context, c *findingsource.Category) error

+ type FindingSourceRepository struct

+ func NewFindingSourceRepository(db *DB) *FindingSourceRepository

+ func (r *FindingSourceRepository) ExistsByCode(ctx context.Context, code string) (bool, error)

+ func (r *FindingSourceRepository) GetByCode(ctx context.Context, code string) (*findingsource.FindingSource, error)

+ func (r *FindingSourceRepository) GetByID(ctx context.Context, id shared.ID) (*findingsource.FindingSource, error)

+ func (r *FindingSourceRepository) IsValidCode(ctx context.Context, code string) (bool, error)

+ func (r *FindingSourceRepository) List(ctx context.Context, filter findingsource.Filter, ...) (pagination.Result[*findingsource.FindingSource], error)

+ func (r *FindingSourceRepository) ListActive(ctx context.Context) ([]*findingsource.FindingSource, error)

+ func (r *FindingSourceRepository) ListActiveByCategory(ctx context.Context, categoryID shared.ID) ([]*findingsource.FindingSource, error)

+ func (r *FindingSourceRepository) ListActiveWithCategory(ctx context.Context) ([]*findingsource.FindingSourceWithCategory, error)

+ func (r *FindingSourceRepository) ListWithCategory(ctx context.Context, filter findingsource.Filter, ...) (pagination.Result[*findingsource.FindingSourceWithCategory], error)

+ type GroupRepository struct

+ func NewGroupRepository(db *DB) *GroupRepository

+ func (r *GroupRepository) AddMember(ctx context.Context, member *group.Member) error

+ func (r *GroupRepository) AssignPermissionSet(ctx context.Context, groupID, permissionSetID shared.ID, assignedBy *shared.ID) error

+ func (r *GroupRepository) Count(ctx context.Context, tenantID shared.ID, filter group.ListFilter) (int64, error)

+ func (r *GroupRepository) CountMembers(ctx context.Context, groupID shared.ID) (int64, error)

+ func (r *GroupRepository) Create(ctx context.Context, g *group.Group) error

+ func (r *GroupRepository) Delete(ctx context.Context, id shared.ID) error

+ func (r *GroupRepository) ExistsBySlug(ctx context.Context, tenantID shared.ID, slug string) (bool, error)

+ func (r *GroupRepository) GetByExternalID(ctx context.Context, tenantID shared.ID, source group.ExternalSource, ...) (*group.Group, error)

+ func (r *GroupRepository) GetByID(ctx context.Context, id shared.ID) (*group.Group, error)

+ func (r *GroupRepository) GetBySlug(ctx context.Context, tenantID shared.ID, slug string) (*group.Group, error)

+ func (r *GroupRepository) GetMember(ctx context.Context, groupID, userID shared.ID) (*group.Member, error)

+ func (r *GroupRepository) GetMemberStats(ctx context.Context, groupID shared.ID) (*group.MemberStats, error)

+ func (r *GroupRepository) IsMember(ctx context.Context, groupID, userID shared.ID) (bool, error)

+ func (r *GroupRepository) List(ctx context.Context, tenantID shared.ID, filter group.ListFilter) ([]*group.Group, error)

+ func (r *GroupRepository) ListByIDs(ctx context.Context, ids []shared.ID) ([]*group.Group, error)

+ func (r *GroupRepository) ListGroupIDsByUser(ctx context.Context, tenantID, userID shared.ID) ([]shared.ID, error)

+ func (r *GroupRepository) ListGroupsByUser(ctx context.Context, tenantID, userID shared.ID) ([]*group.GroupWithRole, error)

+ func (r *GroupRepository) ListGroupsWithPermissionSet(ctx context.Context, permissionSetID shared.ID) ([]*group.Group, error)

+ func (r *GroupRepository) ListMembers(ctx context.Context, groupID shared.ID) ([]*group.Member, error)

+ func (r *GroupRepository) ListMembersWithUserInfo(ctx context.Context, groupID shared.ID) ([]*group.MemberWithUser, error)

+ func (r *GroupRepository) ListPermissionSetIDs(ctx context.Context, groupID shared.ID) ([]shared.ID, error)

+ func (r *GroupRepository) RemoveMember(ctx context.Context, groupID, userID shared.ID) error

+ func (r *GroupRepository) RemovePermissionSet(ctx context.Context, groupID, permissionSetID shared.ID) error

+ func (r *GroupRepository) Update(ctx context.Context, g *group.Group) error

+ func (r *GroupRepository) UpdateMember(ctx context.Context, member *group.Member) error

+ type IntegrationNotificationExtensionRepository struct

+ func NewIntegrationNotificationExtensionRepository(db *DB, integrationRepo *IntegrationRepository) *IntegrationNotificationExtensionRepository

+ func (r *IntegrationNotificationExtensionRepository) Create(ctx context.Context, ext *integration.NotificationExtension) error

+ func (r *IntegrationNotificationExtensionRepository) Delete(ctx context.Context, integrationID integration.ID) error

+ func (r *IntegrationNotificationExtensionRepository) GetByIntegrationID(ctx context.Context, integrationID integration.ID) (*integration.NotificationExtension, error)

+ func (r *IntegrationNotificationExtensionRepository) GetIntegrationWithNotification(ctx context.Context, id integration.ID) (*integration.IntegrationWithNotification, error)

+ func (r *IntegrationNotificationExtensionRepository) ListIntegrationsWithNotification(ctx context.Context, tenantID integration.ID) ([]*integration.IntegrationWithNotification, error)

+ func (r *IntegrationNotificationExtensionRepository) Update(ctx context.Context, ext *integration.NotificationExtension) error

+ type IntegrationRepository struct

+ func NewIntegrationRepository(db *DB) *IntegrationRepository

+ func (r *IntegrationRepository) Count(ctx context.Context, filter integration.Filter) (int64, error)

+ func (r *IntegrationRepository) Create(ctx context.Context, i *integration.Integration) error

+ func (r *IntegrationRepository) Delete(ctx context.Context, id integration.ID) error

+ func (r *IntegrationRepository) GetByID(ctx context.Context, id integration.ID) (*integration.Integration, error)

+ func (r *IntegrationRepository) GetByTenantAndName(ctx context.Context, tenantID integration.ID, name string) (*integration.Integration, error)

+ func (r *IntegrationRepository) List(ctx context.Context, filter integration.Filter) (integration.ListResult, error)

+ func (r *IntegrationRepository) ListByCategory(ctx context.Context, tenantID integration.ID, category integration.Category) ([]*integration.Integration, error)

+ func (r *IntegrationRepository) ListByProvider(ctx context.Context, tenantID integration.ID, provider integration.Provider) ([]*integration.Integration, error)

+ func (r *IntegrationRepository) ListByTenant(ctx context.Context, tenantID integration.ID) ([]*integration.Integration, error)

+ func (r *IntegrationRepository) Update(ctx context.Context, i *integration.Integration) error

+ type IntegrationSCMExtensionRepository struct

+ func NewIntegrationSCMExtensionRepository(db *DB, integrationRepo *IntegrationRepository) *IntegrationSCMExtensionRepository

+ func (r *IntegrationSCMExtensionRepository) Create(ctx context.Context, ext *integration.SCMExtension) error

+ func (r *IntegrationSCMExtensionRepository) Delete(ctx context.Context, integrationID integration.ID) error

+ func (r *IntegrationSCMExtensionRepository) GetByIntegrationID(ctx context.Context, integrationID integration.ID) (*integration.SCMExtension, error)

+ func (r *IntegrationSCMExtensionRepository) GetIntegrationWithSCM(ctx context.Context, id integration.ID) (*integration.IntegrationWithSCM, error)

+ func (r *IntegrationSCMExtensionRepository) ListIntegrationsWithSCM(ctx context.Context, tenantID integration.ID) ([]*integration.IntegrationWithSCM, error)

+ func (r *IntegrationSCMExtensionRepository) Update(ctx context.Context, ext *integration.SCMExtension) error

+ type KEVRepository struct

+ func (r *KEVRepository) Count(ctx context.Context) (int64, error)

+ func (r *KEVRepository) DeleteAll(ctx context.Context) error

+ func (r *KEVRepository) ExistsByCVEID(ctx context.Context, cveID string) (bool, error)

+ func (r *KEVRepository) ExistsByCVEIDs(ctx context.Context, cveIDs []string) (map[string]bool, error)

+ func (r *KEVRepository) GetByCVEID(ctx context.Context, cveID string) (*threatintel.KEVEntry, error)

+ func (r *KEVRepository) GetByCVEIDs(ctx context.Context, cveIDs []string) ([]*threatintel.KEVEntry, error)

+ func (r *KEVRepository) GetPastDue(ctx context.Context, limit int) ([]*threatintel.KEVEntry, error)

+ func (r *KEVRepository) GetRansomwareRelated(ctx context.Context, limit int) ([]*threatintel.KEVEntry, error)

+ func (r *KEVRepository) GetRecentlyAdded(ctx context.Context, days, limit int) ([]*threatintel.KEVEntry, error)

+ func (r *KEVRepository) Upsert(ctx context.Context, entry *threatintel.KEVEntry) error

+ func (r *KEVRepository) UpsertBatch(ctx context.Context, entries []*threatintel.KEVEntry) error

+ type ModuleRepository struct

+ func NewModuleRepository(db *DB) *ModuleRepository

+ func (r *ModuleRepository) GetModuleByID(ctx context.Context, id string) (*module.Module, error)

+ func (r *ModuleRepository) GetSubModules(ctx context.Context, parentModuleID string) ([]*module.Module, error)

+ func (r *ModuleRepository) ListActiveModules(ctx context.Context) ([]*module.Module, error)

+ func (r *ModuleRepository) ListAllModules(ctx context.Context) ([]*module.Module, error)

+ type NotificationEventRepository struct

+ func NewNotificationEventRepository(db *DB) *NotificationEventRepository

+ func (r *NotificationEventRepository) Create(ctx context.Context, event *notification.Event) error

+ func (r *NotificationEventRepository) Delete(ctx context.Context, id notification.ID) error

+ func (r *NotificationEventRepository) DeleteOldEvents(ctx context.Context, retentionDays int) (int64, error)

+ func (r *NotificationEventRepository) GetByID(ctx context.Context, id notification.ID) (*notification.Event, error)

+ func (r *NotificationEventRepository) GetStats(ctx context.Context, tenantID *shared.ID) (*notification.EventStats, error)

+ func (r *NotificationEventRepository) ListByIntegration(ctx context.Context, integrationID string, limit, offset int) ([]*notification.Event, int64, error)

+ func (r *NotificationEventRepository) ListByTenant(ctx context.Context, tenantID shared.ID, filter notification.EventFilter) ([]*notification.Event, int64, error)

+ type NotificationOutboxRepository struct

+ func NewNotificationOutboxRepository(db *DB) *NotificationOutboxRepository

+ func (r *NotificationOutboxRepository) CountByStatus(ctx context.Context, tenantID shared.ID) (map[notification.OutboxStatus]int64, error)

+ func (r *NotificationOutboxRepository) Create(ctx context.Context, outbox *notification.Outbox) error

+ func (r *NotificationOutboxRepository) CreateInTx(ctx context.Context, tx *sql.Tx, outbox *notification.Outbox) error

+ func (r *NotificationOutboxRepository) Delete(ctx context.Context, id notification.ID) error

+ func (r *NotificationOutboxRepository) DeleteOldCompleted(ctx context.Context, olderThanDays int) (int64, error)

+ func (r *NotificationOutboxRepository) DeleteOldFailed(ctx context.Context, olderThanDays int) (int64, error)

+ func (r *NotificationOutboxRepository) FetchPendingBatch(ctx context.Context, workerID string, batchSize int) ([]*notification.Outbox, error)

+ func (r *NotificationOutboxRepository) GetByAggregateID(ctx context.Context, aggregateType string, aggregateID string) ([]*notification.Outbox, error)

+ func (r *NotificationOutboxRepository) GetByID(ctx context.Context, id notification.ID) (*notification.Outbox, error)

+ func (r *NotificationOutboxRepository) GetStats(ctx context.Context, tenantID *shared.ID) (*notification.OutboxStats, error)

+ func (r *NotificationOutboxRepository) List(ctx context.Context, filter notification.OutboxFilter, ...) (pagination.Result[*notification.Outbox], error)

+ func (r *NotificationOutboxRepository) ListByTenant(ctx context.Context, tenantID shared.ID, filter notification.OutboxFilter) ([]*notification.Outbox, int64, error)

+ func (r *NotificationOutboxRepository) UnlockStale(ctx context.Context, olderThanMinutes int) (int64, error)

+ func (r *NotificationOutboxRepository) Update(ctx context.Context, outbox *notification.Outbox) error

+ type NullableJSON []byte

+ func (n NullableJSON) Value() (driver.Value, error)

+ type PermissionRepository struct

+ func NewPermissionRepository(db *DB) *PermissionRepository

+ func (r *PermissionRepository) Exists(ctx context.Context, id string) (bool, error)

+ func (r *PermissionRepository) GetByID(ctx context.Context, id string) (*role.Permission, error)

+ func (r *PermissionRepository) ListModulesWithPermissions(ctx context.Context) ([]*role.Module, error)

+ func (r *PermissionRepository) ListPermissions(ctx context.Context) ([]*role.Permission, error)

+ func (r *PermissionRepository) ValidatePermissions(ctx context.Context, ids []string) (bool, []string, error)

+ type PermissionSetRepository struct

+ func NewPermissionSetRepository(db *DB) *PermissionSetRepository

+ func (r *PermissionSetRepository) AddItem(ctx context.Context, item *permissionset.Item) error

+ func (r *PermissionSetRepository) BatchAddItems(ctx context.Context, items []*permissionset.Item) error

+ func (r *PermissionSetRepository) Count(ctx context.Context, filter permissionset.ListFilter) (int64, error)

+ func (r *PermissionSetRepository) CountGroupsUsing(ctx context.Context, permissionSetID shared.ID) (int64, error)

+ func (r *PermissionSetRepository) Create(ctx context.Context, ps *permissionset.PermissionSet) error

+ func (r *PermissionSetRepository) CreateVersion(ctx context.Context, version *permissionset.Version) error

+ func (r *PermissionSetRepository) Delete(ctx context.Context, id shared.ID) error

+ func (r *PermissionSetRepository) ExistsBySlug(ctx context.Context, tenantID *shared.ID, slug string) (bool, error)

+ func (r *PermissionSetRepository) GetByID(ctx context.Context, id shared.ID) (*permissionset.PermissionSet, error)

+ func (r *PermissionSetRepository) GetBySlug(ctx context.Context, tenantID *shared.ID, slug string) (*permissionset.PermissionSet, error)

+ func (r *PermissionSetRepository) GetInheritanceChain(ctx context.Context, permissionSetID shared.ID) ([]*permissionset.PermissionSet, error)

+ func (r *PermissionSetRepository) GetLatestVersion(ctx context.Context, permissionSetID shared.ID) (*permissionset.Version, error)

+ func (r *PermissionSetRepository) GetParent(ctx context.Context, permissionSetID shared.ID) (*permissionset.PermissionSet, error)

+ func (r *PermissionSetRepository) GetWithItems(ctx context.Context, id shared.ID) (*permissionset.PermissionSetWithItems, error)

+ func (r *PermissionSetRepository) List(ctx context.Context, filter permissionset.ListFilter) ([]*permissionset.PermissionSet, error)

+ func (r *PermissionSetRepository) ListByIDs(ctx context.Context, ids []shared.ID) ([]*permissionset.PermissionSet, error)

+ func (r *PermissionSetRepository) ListByTenant(ctx context.Context, tenantID shared.ID, includeSystem bool) ([]*permissionset.PermissionSet, error)

+ func (r *PermissionSetRepository) ListChildren(ctx context.Context, parentSetID shared.ID) ([]*permissionset.PermissionSet, error)

+ func (r *PermissionSetRepository) ListGroupIDsUsing(ctx context.Context, permissionSetID shared.ID) ([]shared.ID, error)

+ func (r *PermissionSetRepository) ListItems(ctx context.Context, permissionSetID shared.ID) ([]*permissionset.Item, error)

+ func (r *PermissionSetRepository) ListSystemSets(ctx context.Context) ([]*permissionset.PermissionSet, error)

+ func (r *PermissionSetRepository) ListVersions(ctx context.Context, permissionSetID shared.ID) ([]*permissionset.Version, error)

+ func (r *PermissionSetRepository) RemoveItem(ctx context.Context, permissionSetID shared.ID, permissionID string) error

+ func (r *PermissionSetRepository) ReplaceItems(ctx context.Context, permissionSetID shared.ID, items []*permissionset.Item) error

+ func (r *PermissionSetRepository) Update(ctx context.Context, ps *permissionset.PermissionSet) error

+ type PipelineRunRepository struct

+ func NewPipelineRunRepository(db *DB) *PipelineRunRepository

+ func (r *PipelineRunRepository) CountActiveByPipelineID(ctx context.Context, pipelineID shared.ID) (int, error)

+ func (r *PipelineRunRepository) CountActiveByScanID(ctx context.Context, scanID shared.ID) (int, error)

+ func (r *PipelineRunRepository) CountActiveByTenantID(ctx context.Context, tenantID shared.ID) (int, error)

+ func (r *PipelineRunRepository) Create(ctx context.Context, run *pipeline.Run) error

+ func (r *PipelineRunRepository) CreateRunIfUnderLimit(ctx context.Context, run *pipeline.Run, maxPerScan, maxPerTenant int) error

+ func (r *PipelineRunRepository) Delete(ctx context.Context, id shared.ID) error

+ func (r *PipelineRunRepository) GetActiveByAssetID(ctx context.Context, assetID shared.ID) ([]*pipeline.Run, error)

+ func (r *PipelineRunRepository) GetActiveByPipelineID(ctx context.Context, pipelineID shared.ID) ([]*pipeline.Run, error)

+ func (r *PipelineRunRepository) GetByID(ctx context.Context, id shared.ID) (*pipeline.Run, error)

+ func (r *PipelineRunRepository) GetByTenantAndID(ctx context.Context, tenantID, id shared.ID) (*pipeline.Run, error)

+ func (r *PipelineRunRepository) GetStatsByTenant(ctx context.Context, tenantID shared.ID) (pipeline.RunStats, error)

+ func (r *PipelineRunRepository) GetWithStepRuns(ctx context.Context, id shared.ID) (*pipeline.Run, error)

+ func (r *PipelineRunRepository) List(ctx context.Context, filter pipeline.RunFilter, page pagination.Pagination) (pagination.Result[*pipeline.Run], error)

+ func (r *PipelineRunRepository) ListByScanID(ctx context.Context, scanID shared.ID, page, perPage int) ([]*pipeline.Run, int64, error)

+ func (r *PipelineRunRepository) Update(ctx context.Context, run *pipeline.Run) error

+ func (r *PipelineRunRepository) UpdateStats(ctx context.Context, id shared.ID, completed, failed, skipped, findings int) error

+ func (r *PipelineRunRepository) UpdateStatus(ctx context.Context, id shared.ID, status pipeline.RunStatus, ...) error

+ type PipelineStepRepository struct

+ func NewPipelineStepRepository(db *DB) *PipelineStepRepository

+ func (r *PipelineStepRepository) Create(ctx context.Context, s *pipeline.Step) error

+ func (r *PipelineStepRepository) CreateBatch(ctx context.Context, steps []*pipeline.Step) error

+ func (r *PipelineStepRepository) Delete(ctx context.Context, id shared.ID) error

+ func (r *PipelineStepRepository) DeleteByPipelineID(ctx context.Context, pipelineID shared.ID) error

+ func (r *PipelineStepRepository) DeleteByPipelineIDInTx(ctx context.Context, tx *sql.Tx, pipelineID shared.ID) error

+ func (r *PipelineStepRepository) FindPipelineIDsByToolName(ctx context.Context, toolName string) ([]shared.ID, error)

+ func (r *PipelineStepRepository) GetByID(ctx context.Context, id shared.ID) (*pipeline.Step, error)

+ func (r *PipelineStepRepository) GetByKey(ctx context.Context, pipelineID shared.ID, stepKey string) (*pipeline.Step, error)

+ func (r *PipelineStepRepository) GetByPipelineID(ctx context.Context, pipelineID shared.ID) ([]*pipeline.Step, error)

+ func (r *PipelineStepRepository) Reorder(ctx context.Context, pipelineID shared.ID, stepOrders map[string]int) error

+ func (r *PipelineStepRepository) Update(ctx context.Context, s *pipeline.Step) error

+ type PipelineTemplateRepository struct

+ func NewPipelineTemplateRepository(db *DB) *PipelineTemplateRepository

+ func (r *PipelineTemplateRepository) Create(ctx context.Context, t *pipeline.Template) error

+ func (r *PipelineTemplateRepository) Delete(ctx context.Context, id shared.ID) error

+ func (r *PipelineTemplateRepository) DeleteInTx(ctx context.Context, tx *sql.Tx, id shared.ID) error

+ func (r *PipelineTemplateRepository) GetByID(ctx context.Context, id shared.ID) (*pipeline.Template, error)

+ func (r *PipelineTemplateRepository) GetByName(ctx context.Context, tenantID shared.ID, name string, version int) (*pipeline.Template, error)

+ func (r *PipelineTemplateRepository) GetByTenantAndID(ctx context.Context, tenantID, id shared.ID) (*pipeline.Template, error)

+ func (r *PipelineTemplateRepository) GetSystemTemplateByID(ctx context.Context, id shared.ID) (*pipeline.Template, error)

+ func (r *PipelineTemplateRepository) GetWithSteps(ctx context.Context, id shared.ID) (*pipeline.Template, error)

+ func (r *PipelineTemplateRepository) List(ctx context.Context, filter pipeline.TemplateFilter, ...) (pagination.Result[*pipeline.Template], error)

+ func (r *PipelineTemplateRepository) ListWithSystemTemplates(ctx context.Context, tenantID shared.ID, filter pipeline.TemplateFilter, ...) (pagination.Result[*pipeline.Template], error)

+ func (r *PipelineTemplateRepository) Update(ctx context.Context, t *pipeline.Template) error

+ type RefreshTokenRepository struct

+ func NewRefreshTokenRepository(db *sql.DB) *RefreshTokenRepository

+ func (r *RefreshTokenRepository) Create(ctx context.Context, token *session.RefreshToken) error

+ func (r *RefreshTokenRepository) Delete(ctx context.Context, id shared.ID) error

+ func (r *RefreshTokenRepository) DeleteExpired(ctx context.Context) (int64, error)

+ func (r *RefreshTokenRepository) GetByFamily(ctx context.Context, family shared.ID) ([]*session.RefreshToken, error)

+ func (r *RefreshTokenRepository) GetByID(ctx context.Context, id shared.ID) (*session.RefreshToken, error)

+ func (r *RefreshTokenRepository) GetByTokenHash(ctx context.Context, hash string) (*session.RefreshToken, error)

+ func (r *RefreshTokenRepository) RevokeByFamily(ctx context.Context, family shared.ID) error

+ func (r *RefreshTokenRepository) RevokeBySessionID(ctx context.Context, sessionID shared.ID) error

+ func (r *RefreshTokenRepository) RevokeByUserID(ctx context.Context, userID shared.ID) error

+ func (r *RefreshTokenRepository) Update(ctx context.Context, token *session.RefreshToken) error

+ type RepositoryExtensionRepository struct

+ func NewRepositoryExtensionRepository(db *DB) *RepositoryExtensionRepository

+ func (r *RepositoryExtensionRepository) Create(ctx context.Context, repo *asset.RepositoryExtension) error

+ func (r *RepositoryExtensionRepository) Delete(ctx context.Context, assetID shared.ID) error

+ func (r *RepositoryExtensionRepository) GetByAssetID(ctx context.Context, assetID shared.ID) (*asset.RepositoryExtension, error)

+ func (r *RepositoryExtensionRepository) GetByFullName(ctx context.Context, tenantID shared.ID, fullName string) (*asset.RepositoryExtension, error)

+ func (r *RepositoryExtensionRepository) ListByTenant(ctx context.Context, tenantID shared.ID, opts asset.ListOptions, ...) (pagination.Result[*asset.RepositoryExtension], error)

+ func (r *RepositoryExtensionRepository) Update(ctx context.Context, repo *asset.RepositoryExtension) error

+ type RoleRepository struct

+ func NewRoleRepository(db *DB) *RoleRepository

+ func (r *RoleRepository) AssignRole(ctx context.Context, tenantID, userID, roleID role.ID, assignedBy *role.ID) error

+ func (r *RoleRepository) BulkAssignRoleToUsers(ctx context.Context, tenantID, roleID role.ID, userIDs []role.ID, ...) error

+ func (r *RoleRepository) CountUsersWithRole(ctx context.Context, roleID role.ID) (int, error)

+ func (r *RoleRepository) Create(ctx context.Context, ro *role.Role) error

+ func (r *RoleRepository) Delete(ctx context.Context, id role.ID) error

+ func (r *RoleRepository) GetByID(ctx context.Context, id role.ID) (*role.Role, error)

+ func (r *RoleRepository) GetBySlug(ctx context.Context, tenantID *role.ID, slug string) (*role.Role, error)

+ func (r *RoleRepository) GetUserPermissions(ctx context.Context, tenantID, userID role.ID) ([]string, error)

+ func (r *RoleRepository) GetUserRoles(ctx context.Context, tenantID, userID role.ID) ([]*role.Role, error)

+ func (r *RoleRepository) HasFullDataAccess(ctx context.Context, tenantID, userID role.ID) (bool, error)

+ func (r *RoleRepository) ListForTenant(ctx context.Context, tenantID role.ID) ([]*role.Role, error)

+ func (r *RoleRepository) ListRoleMembers(ctx context.Context, tenantID, roleID role.ID) ([]*role.UserRole, error)

+ func (r *RoleRepository) ListSystemRoles(ctx context.Context) ([]*role.Role, error)

+ func (r *RoleRepository) RemoveRole(ctx context.Context, tenantID, userID, roleID role.ID) error

+ func (r *RoleRepository) SetUserRoles(ctx context.Context, tenantID, userID role.ID, roleIDs []role.ID, ...) error

+ func (r *RoleRepository) Update(ctx context.Context, ro *role.Role) error

+ type RuleBundleRepository struct

+ func NewRuleBundleRepository(db *DB) *RuleBundleRepository

+ func (r *RuleBundleRepository) Create(ctx context.Context, bundle *rule.Bundle) error

+ func (r *RuleBundleRepository) Delete(ctx context.Context, id shared.ID) error

+ func (r *RuleBundleRepository) DeleteExpired(ctx context.Context) (int64, error)

+ func (r *RuleBundleRepository) GetByContentHash(ctx context.Context, hash string) (*rule.Bundle, error)

+ func (r *RuleBundleRepository) GetByID(ctx context.Context, id shared.ID) (*rule.Bundle, error)

+ func (r *RuleBundleRepository) GetLatest(ctx context.Context, tenantID, toolID shared.ID) (*rule.Bundle, error)

+ func (r *RuleBundleRepository) List(ctx context.Context, filter rule.BundleFilter) ([]*rule.Bundle, error)

+ func (r *RuleBundleRepository) Update(ctx context.Context, bundle *rule.Bundle) error

+ type RuleOverrideRepository struct

+ func NewRuleOverrideRepository(db *DB) *RuleOverrideRepository

+ func (r *RuleOverrideRepository) Create(ctx context.Context, override *rule.Override) error

+ func (r *RuleOverrideRepository) Delete(ctx context.Context, id shared.ID) error

+ func (r *RuleOverrideRepository) DeleteExpired(ctx context.Context) (int64, error)

+ func (r *RuleOverrideRepository) GetByID(ctx context.Context, id shared.ID) (*rule.Override, error)

+ func (r *RuleOverrideRepository) GetByTenantAndID(ctx context.Context, tenantID, id shared.ID) (*rule.Override, error)

+ func (r *RuleOverrideRepository) List(ctx context.Context, filter rule.OverrideFilter, page pagination.Pagination) (pagination.Result[*rule.Override], error)

+ func (r *RuleOverrideRepository) ListByTenantAndTool(ctx context.Context, tenantID shared.ID, toolID *shared.ID) ([]*rule.Override, error)

+ func (r *RuleOverrideRepository) Update(ctx context.Context, override *rule.Override) error

+ type RuleRepository struct

+ func NewRuleRepository(db *DB) *RuleRepository

+ func (r *RuleRepository) CountBySource(ctx context.Context, sourceID shared.ID) (int, error)

+ func (r *RuleRepository) CountByTenantAndTool(ctx context.Context, tenantID shared.ID, toolID *shared.ID) (int, error)

+ func (r *RuleRepository) Create(ctx context.Context, rl *rule.Rule) error

+ func (r *RuleRepository) CreateBatch(ctx context.Context, rules []*rule.Rule) error

+ func (r *RuleRepository) Delete(ctx context.Context, id shared.ID) error

+ func (r *RuleRepository) DeleteBySource(ctx context.Context, sourceID shared.ID) error

+ func (r *RuleRepository) GetByID(ctx context.Context, id shared.ID) (*rule.Rule, error)

+ func (r *RuleRepository) GetBySourceAndRuleID(ctx context.Context, sourceID shared.ID, ruleID string) (*rule.Rule, error)

+ func (r *RuleRepository) List(ctx context.Context, filter rule.RuleFilter, page pagination.Pagination) (pagination.Result[*rule.Rule], error)

+ func (r *RuleRepository) ListBySource(ctx context.Context, sourceID shared.ID) ([]*rule.Rule, error)

+ func (r *RuleRepository) Update(ctx context.Context, rl *rule.Rule) error

+ func (r *RuleRepository) UpsertBatch(ctx context.Context, rules []*rule.Rule) error

+ type RuleSourceRepository struct

+ func NewRuleSourceRepository(db *DB) *RuleSourceRepository

+ func (r *RuleSourceRepository) Create(ctx context.Context, source *rule.Source) error

+ func (r *RuleSourceRepository) Delete(ctx context.Context, id shared.ID) error

+ func (r *RuleSourceRepository) GetByID(ctx context.Context, id shared.ID) (*rule.Source, error)

+ func (r *RuleSourceRepository) GetByTenantAndID(ctx context.Context, tenantID, id shared.ID) (*rule.Source, error)

+ func (r *RuleSourceRepository) List(ctx context.Context, filter rule.SourceFilter, page pagination.Pagination) (pagination.Result[*rule.Source], error)

+ func (r *RuleSourceRepository) ListByTenantAndTool(ctx context.Context, tenantID shared.ID, toolID *shared.ID) ([]*rule.Source, error)

+ func (r *RuleSourceRepository) ListNeedingSync(ctx context.Context, limit int) ([]*rule.Source, error)

+ func (r *RuleSourceRepository) Update(ctx context.Context, source *rule.Source) error

+ type RuleSyncHistoryRepository struct

+ func NewRuleSyncHistoryRepository(db *DB) *RuleSyncHistoryRepository

+ func (r *RuleSyncHistoryRepository) Create(ctx context.Context, history *rule.SyncHistory) error

+ func (r *RuleSyncHistoryRepository) ListBySource(ctx context.Context, sourceID shared.ID, limit int) ([]*rule.SyncHistory, error)

+ type SLAPolicyRepository struct

+ func NewSLAPolicyRepository(db *DB) *SLAPolicyRepository

+ func (r *SLAPolicyRepository) Create(ctx context.Context, policy *sla.Policy) error

+ func (r *SLAPolicyRepository) Delete(ctx context.Context, id shared.ID) error

+ func (r *SLAPolicyRepository) ExistsByAsset(ctx context.Context, assetID shared.ID) (bool, error)

+ func (r *SLAPolicyRepository) GetByAsset(ctx context.Context, tenantID, assetID shared.ID) (*sla.Policy, error)

+ func (r *SLAPolicyRepository) GetByID(ctx context.Context, id shared.ID) (*sla.Policy, error)

+ func (r *SLAPolicyRepository) GetTenantDefault(ctx context.Context, tenantID shared.ID) (*sla.Policy, error)

+ func (r *SLAPolicyRepository) ListByTenant(ctx context.Context, tenantID shared.ID) ([]*sla.Policy, error)

+ func (r *SLAPolicyRepository) Update(ctx context.Context, policy *sla.Policy) error

+ type ScanProfileRepository struct

+ func NewScanProfileRepository(db *DB) *ScanProfileRepository

+ func (r *ScanProfileRepository) ClearDefaultForTenant(ctx context.Context, tenantID shared.ID) error

+ func (r *ScanProfileRepository) CountByTenant(ctx context.Context, tenantID shared.ID) (int64, error)

+ func (r *ScanProfileRepository) Create(ctx context.Context, p *scanprofile.ScanProfile) error

+ func (r *ScanProfileRepository) Delete(ctx context.Context, id shared.ID) error

+ func (r *ScanProfileRepository) GetByID(ctx context.Context, id shared.ID) (*scanprofile.ScanProfile, error)

+ func (r *ScanProfileRepository) GetByIDWithSystemFallback(ctx context.Context, tenantID, id shared.ID) (*scanprofile.ScanProfile, error)

+ func (r *ScanProfileRepository) GetByTenantAndID(ctx context.Context, tenantID, id shared.ID) (*scanprofile.ScanProfile, error)

+ func (r *ScanProfileRepository) GetByTenantAndName(ctx context.Context, tenantID shared.ID, name string) (*scanprofile.ScanProfile, error)

+ func (r *ScanProfileRepository) GetDefaultByTenant(ctx context.Context, tenantID shared.ID) (*scanprofile.ScanProfile, error)

+ func (r *ScanProfileRepository) List(ctx context.Context, filter scanprofile.Filter, page pagination.Pagination) (pagination.Result[*scanprofile.ScanProfile], error)

+ func (r *ScanProfileRepository) ListWithSystemProfiles(ctx context.Context, tenantID shared.ID, filter scanprofile.Filter, ...) (pagination.Result[*scanprofile.ScanProfile], error)

+ func (r *ScanProfileRepository) Update(ctx context.Context, p *scanprofile.ScanProfile) error

+ type ScanRepository struct

+ func NewScanRepository(db *DB) *ScanRepository

+ func (r *ScanRepository) Count(ctx context.Context, filter scan.Filter) (int64, error)

+ func (r *ScanRepository) Create(ctx context.Context, s *scan.Scan) error

+ func (r *ScanRepository) Delete(ctx context.Context, id shared.ID) error

+ func (r *ScanRepository) GetByID(ctx context.Context, id shared.ID) (*scan.Scan, error)

+ func (r *ScanRepository) GetByName(ctx context.Context, tenantID shared.ID, name string) (*scan.Scan, error)

+ func (r *ScanRepository) GetByTenantAndID(ctx context.Context, tenantID, id shared.ID) (*scan.Scan, error)

+ func (r *ScanRepository) GetStats(ctx context.Context, tenantID shared.ID) (*scan.Stats, error)

+ func (r *ScanRepository) List(ctx context.Context, filter scan.Filter, page pagination.Pagination) (pagination.Result[*scan.Scan], error)

+ func (r *ScanRepository) ListByAssetGroupID(ctx context.Context, assetGroupID shared.ID) ([]*scan.Scan, error)

+ func (r *ScanRepository) ListByPipelineID(ctx context.Context, pipelineID shared.ID) ([]*scan.Scan, error)

+ func (r *ScanRepository) ListDueForExecution(ctx context.Context, now time.Time) ([]*scan.Scan, error)

+ func (r *ScanRepository) RecordRun(ctx context.Context, id shared.ID, runID shared.ID, status string) error

+ func (r *ScanRepository) Update(ctx context.Context, s *scan.Scan) error

+ func (r *ScanRepository) UpdateNextRunAt(ctx context.Context, id shared.ID, nextRunAt *time.Time) error

+ func (r *ScanRepository) UpdateStatusByAssetGroupID(ctx context.Context, assetGroupID shared.ID, status scan.Status) error

+ type ScanSessionRepository struct

+ func NewScanSessionRepository(db *DB) *ScanSessionRepository

+ func (r *ScanSessionRepository) Create(ctx context.Context, s *scansession.ScanSession) error

+ func (r *ScanSessionRepository) Delete(ctx context.Context, id shared.ID) error

+ func (r *ScanSessionRepository) FindBaseline(ctx context.Context, tenantID shared.ID, assetType, assetValue, branch string) (string, error)

+ func (r *ScanSessionRepository) GetByID(ctx context.Context, id shared.ID) (*scansession.ScanSession, error)

+ func (r *ScanSessionRepository) GetByTenantAndID(ctx context.Context, tenantID, id shared.ID) (*scansession.ScanSession, error)

+ func (r *ScanSessionRepository) GetStats(ctx context.Context, tenantID shared.ID, since time.Time) (*scansession.Stats, error)

+ func (r *ScanSessionRepository) List(ctx context.Context, filter scansession.Filter, page pagination.Pagination) (pagination.Result[*scansession.ScanSession], error)

+ func (r *ScanSessionRepository) ListRunning(ctx context.Context, tenantID shared.ID) ([]*scansession.ScanSession, error)

+ func (r *ScanSessionRepository) Update(ctx context.Context, s *scansession.ScanSession) error

+ type ScannerTemplateRepository struct

+ func NewScannerTemplateRepository(db *DB) *ScannerTemplateRepository

+ func (r *ScannerTemplateRepository) CountByTenant(ctx context.Context, tenantID shared.ID) (int64, error)

+ func (r *ScannerTemplateRepository) CountByType(ctx context.Context, tenantID shared.ID, ...) (int64, error)

+ func (r *ScannerTemplateRepository) Create(ctx context.Context, t *scannertemplate.ScannerTemplate) error

+ func (r *ScannerTemplateRepository) Delete(ctx context.Context, tenantID, id shared.ID) error

+ func (r *ScannerTemplateRepository) ExistsByName(ctx context.Context, tenantID shared.ID, ...) (bool, error)

+ func (r *ScannerTemplateRepository) GetByTenantAndID(ctx context.Context, tenantID, id shared.ID) (*scannertemplate.ScannerTemplate, error)

+ func (r *ScannerTemplateRepository) GetByTenantAndName(ctx context.Context, tenantID shared.ID, ...) (*scannertemplate.ScannerTemplate, error)

+ func (r *ScannerTemplateRepository) GetUsage(ctx context.Context, tenantID shared.ID) (*scannertemplate.TemplateUsage, error)

+ func (r *ScannerTemplateRepository) List(ctx context.Context, filter scannertemplate.Filter, page pagination.Pagination) (pagination.Result[*scannertemplate.ScannerTemplate], error)

+ func (r *ScannerTemplateRepository) ListByIDs(ctx context.Context, tenantID shared.ID, ids []shared.ID) ([]*scannertemplate.ScannerTemplate, error)

+ func (r *ScannerTemplateRepository) Update(ctx context.Context, t *scannertemplate.ScannerTemplate) error

+ type ScopeExclusionRepository struct

+ func NewScopeExclusionRepository(db *DB) *ScopeExclusionRepository

+ func (r *ScopeExclusionRepository) Count(ctx context.Context, filter scope.ExclusionFilter) (int64, error)

+ func (r *ScopeExclusionRepository) Create(ctx context.Context, exclusion *scope.Exclusion) error

+ func (r *ScopeExclusionRepository) Delete(ctx context.Context, id shared.ID) error

+ func (r *ScopeExclusionRepository) ExpireOld(ctx context.Context) error

+ func (r *ScopeExclusionRepository) GetByID(ctx context.Context, id shared.ID) (*scope.Exclusion, error)

+ func (r *ScopeExclusionRepository) List(ctx context.Context, filter scope.ExclusionFilter, page pagination.Pagination) (pagination.Result[*scope.Exclusion], error)

+ func (r *ScopeExclusionRepository) ListActive(ctx context.Context, tenantID shared.ID) ([]*scope.Exclusion, error)

+ func (r *ScopeExclusionRepository) Update(ctx context.Context, exclusion *scope.Exclusion) error

+ type ScopeScheduleRepository struct

+ func NewScopeScheduleRepository(db *DB) *ScopeScheduleRepository

+ func (r *ScopeScheduleRepository) Count(ctx context.Context, filter scope.ScheduleFilter) (int64, error)

+ func (r *ScopeScheduleRepository) Create(ctx context.Context, schedule *scope.Schedule) error

+ func (r *ScopeScheduleRepository) Delete(ctx context.Context, id shared.ID) error

+ func (r *ScopeScheduleRepository) GetByID(ctx context.Context, id shared.ID) (*scope.Schedule, error)

+ func (r *ScopeScheduleRepository) List(ctx context.Context, filter scope.ScheduleFilter, page pagination.Pagination) (pagination.Result[*scope.Schedule], error)

+ func (r *ScopeScheduleRepository) ListDue(ctx context.Context) ([]*scope.Schedule, error)

+ func (r *ScopeScheduleRepository) Update(ctx context.Context, schedule *scope.Schedule) error

+ type ScopeTargetRepository struct

+ func NewScopeTargetRepository(db *DB) *ScopeTargetRepository

+ func (r *ScopeTargetRepository) Count(ctx context.Context, filter scope.TargetFilter) (int64, error)

+ func (r *ScopeTargetRepository) Create(ctx context.Context, target *scope.Target) error

+ func (r *ScopeTargetRepository) Delete(ctx context.Context, id shared.ID) error

+ func (r *ScopeTargetRepository) ExistsByPattern(ctx context.Context, tenantID shared.ID, targetType scope.TargetType, ...) (bool, error)

+ func (r *ScopeTargetRepository) GetByID(ctx context.Context, id shared.ID) (*scope.Target, error)

+ func (r *ScopeTargetRepository) List(ctx context.Context, filter scope.TargetFilter, page pagination.Pagination) (pagination.Result[*scope.Target], error)

+ func (r *ScopeTargetRepository) ListActive(ctx context.Context, tenantID shared.ID) ([]*scope.Target, error)

+ func (r *ScopeTargetRepository) Update(ctx context.Context, target *scope.Target) error

+ type SecretStoreRepository struct

+ func NewSecretStoreRepository(db *DB) *SecretStoreRepository

+ func (r *SecretStoreRepository) CountByTenant(ctx context.Context, tenantID shared.ID) (int, error)

+ func (r *SecretStoreRepository) Create(ctx context.Context, c *secretstore.Credential) error

+ func (r *SecretStoreRepository) DeleteByTenantAndID(ctx context.Context, tenantID, id shared.ID) error

+ func (r *SecretStoreRepository) GetByTenantAndID(ctx context.Context, tenantID, id shared.ID) (*secretstore.Credential, error)

+ func (r *SecretStoreRepository) GetByTenantAndName(ctx context.Context, tenantID shared.ID, name string) (*secretstore.Credential, error)

+ func (r *SecretStoreRepository) List(ctx context.Context, input secretstore.ListInput) (*secretstore.ListOutput, error)

+ func (r *SecretStoreRepository) Update(ctx context.Context, c *secretstore.Credential) error

+ func (r *SecretStoreRepository) UpdateLastUsedByTenantAndID(ctx context.Context, tenantID, id shared.ID) error

+ type SessionRepository struct

+ func NewSessionRepository(db *sql.DB) *SessionRepository

+ func (r *SessionRepository) CountActiveByUserID(ctx context.Context, userID shared.ID) (int, error)

+ func (r *SessionRepository) Create(ctx context.Context, s *session.Session) error

+ func (r *SessionRepository) Delete(ctx context.Context, id shared.ID) error

+ func (r *SessionRepository) DeleteExpired(ctx context.Context) (int64, error)

+ func (r *SessionRepository) GetActiveByUserID(ctx context.Context, userID shared.ID) ([]*session.Session, error)

+ func (r *SessionRepository) GetByAccessTokenHash(ctx context.Context, hash string) (*session.Session, error)

+ func (r *SessionRepository) GetByID(ctx context.Context, id shared.ID) (*session.Session, error)

+ func (r *SessionRepository) GetOldestActiveByUserID(ctx context.Context, userID shared.ID) (*session.Session, error)

+ func (r *SessionRepository) RevokeAllByUserID(ctx context.Context, userID shared.ID) error

+ func (r *SessionRepository) RevokeAllByUserIDExcept(ctx context.Context, userID shared.ID, exceptSessionID shared.ID) error

+ func (r *SessionRepository) Update(ctx context.Context, s *session.Session) error

+ type StepRunRepository struct

+ func NewStepRunRepository(db *DB) *StepRunRepository

+ func (r *StepRunRepository) AssignAgent(ctx context.Context, id shared.ID, agentID, commandID shared.ID) error

+ func (r *StepRunRepository) Complete(ctx context.Context, id shared.ID, findingsCount int, output map[string]any) error

+ func (r *StepRunRepository) Create(ctx context.Context, sr *pipeline.StepRun) error

+ func (r *StepRunRepository) CreateBatch(ctx context.Context, stepRuns []*pipeline.StepRun) error

+ func (r *StepRunRepository) Delete(ctx context.Context, id shared.ID) error

+ func (r *StepRunRepository) GetByID(ctx context.Context, id shared.ID) (*pipeline.StepRun, error)

+ func (r *StepRunRepository) GetByPipelineRunID(ctx context.Context, pipelineRunID shared.ID) ([]*pipeline.StepRun, error)

+ func (r *StepRunRepository) GetByStepKey(ctx context.Context, pipelineRunID shared.ID, stepKey string) (*pipeline.StepRun, error)

+ func (r *StepRunRepository) GetPendingByDependencies(ctx context.Context, pipelineRunID shared.ID, completedStepKeys []string) ([]*pipeline.StepRun, error)

+ func (r *StepRunRepository) GetStatsByTenant(ctx context.Context, tenantID shared.ID) (pipeline.RunStats, error)

+ func (r *StepRunRepository) List(ctx context.Context, filter pipeline.StepRunFilter) ([]*pipeline.StepRun, error)

+ func (r *StepRunRepository) Update(ctx context.Context, sr *pipeline.StepRun) error

+ func (r *StepRunRepository) UpdateStatus(ctx context.Context, id shared.ID, status pipeline.StepRunStatus, ...) error

+ type SuppressionRepository struct

+ func NewSuppressionRepository(db *DB) *SuppressionRepository

+ func (r *SuppressionRepository) Delete(ctx context.Context, tenantID, id shared.ID) error

+ func (r *SuppressionRepository) ExpireRules(ctx context.Context) (int64, error)

+ func (r *SuppressionRepository) FindActiveByTenant(ctx context.Context, tenantID shared.ID) ([]*suppression.Rule, error)

+ func (r *SuppressionRepository) FindByID(ctx context.Context, tenantID, id shared.ID) (*suppression.Rule, error)

+ func (r *SuppressionRepository) FindByTenant(ctx context.Context, tenantID shared.ID, filter suppression.RuleFilter) ([]*suppression.Rule, error)

+ func (r *SuppressionRepository) FindMatchingRules(ctx context.Context, tenantID shared.ID, match suppression.FindingMatch) ([]*suppression.Rule, error)

+ func (r *SuppressionRepository) FindPendingByTenant(ctx context.Context, tenantID shared.ID) ([]*suppression.Rule, error)

+ func (r *SuppressionRepository) FindSuppressionsByFinding(ctx context.Context, findingID shared.ID) ([]*suppression.FindingSuppression, error)

+ func (r *SuppressionRepository) RecordAudit(ctx context.Context, ruleID shared.ID, action string, actorID *shared.ID, ...) error

+ func (r *SuppressionRepository) RecordSuppression(ctx context.Context, findingID, ruleID shared.ID, appliedBy string) error

+ func (r *SuppressionRepository) RemoveSuppression(ctx context.Context, findingID, ruleID shared.ID) error

+ func (r *SuppressionRepository) Save(ctx context.Context, rule *suppression.Rule) error

+ type SyncStatusRepository struct

+ func (r *SyncStatusRepository) GetAll(ctx context.Context) ([]*threatintel.SyncStatus, error)

+ func (r *SyncStatusRepository) GetBySource(ctx context.Context, source string) (*threatintel.SyncStatus, error)

+ func (r *SyncStatusRepository) GetDueForSync(ctx context.Context) ([]*threatintel.SyncStatus, error)

+ func (r *SyncStatusRepository) GetEnabled(ctx context.Context) ([]*threatintel.SyncStatus, error)

+ func (r *SyncStatusRepository) Update(ctx context.Context, status *threatintel.SyncStatus) error

+ type TargetMappingRepository struct

+ func NewTargetMappingRepository(db *DB) *TargetMappingRepository

+ func (r *TargetMappingRepository) CanToolScanAssetType(ctx context.Context, targetTypes []string, assetType asset.AssetType) (bool, error)

+ func (r *TargetMappingRepository) Create(ctx context.Context, m *tool.TargetAssetTypeMapping) error

+ func (r *TargetMappingRepository) Delete(ctx context.Context, id shared.ID) error

+ func (r *TargetMappingRepository) GetAssetTypesForTargets(ctx context.Context, targetTypes []string) ([]asset.AssetType, error)

+ func (r *TargetMappingRepository) GetByID(ctx context.Context, id shared.ID) (*tool.TargetAssetTypeMapping, error)

+ func (r *TargetMappingRepository) GetCompatibleAssetTypes(ctx context.Context, targetTypes []string, assetTypes []asset.AssetType) ([]asset.AssetType, error)

+ func (r *TargetMappingRepository) GetIncompatibleAssetTypes(ctx context.Context, targetTypes []string, assetTypes []asset.AssetType) ([]asset.AssetType, error)

+ func (r *TargetMappingRepository) GetTargetsForAssetType(ctx context.Context, assetType asset.AssetType) ([]string, error)

+ func (r *TargetMappingRepository) List(ctx context.Context, filter tool.TargetMappingFilter, ...) (pagination.Result[*tool.TargetAssetTypeMapping], error)

+ func (r *TargetMappingRepository) Update(ctx context.Context, m *tool.TargetAssetTypeMapping) error

+ type TemplateSourceRepository struct

+ func NewTemplateSourceRepository(db *DB) *TemplateSourceRepository

+ func (r *TemplateSourceRepository) CountByTenant(ctx context.Context, tenantID shared.ID) (int, error)

+ func (r *TemplateSourceRepository) Create(ctx context.Context, s *ts.TemplateSource) error

+ func (r *TemplateSourceRepository) Delete(ctx context.Context, id shared.ID) error

+ func (r *TemplateSourceRepository) GetByID(ctx context.Context, id shared.ID) (*ts.TemplateSource, error)

+ func (r *TemplateSourceRepository) GetByTenantAndID(ctx context.Context, tenantID, sourceID shared.ID) (*ts.TemplateSource, error)

+ func (r *TemplateSourceRepository) GetByTenantAndName(ctx context.Context, tenantID shared.ID, name string) (*ts.TemplateSource, error)

+ func (r *TemplateSourceRepository) List(ctx context.Context, input ts.ListInput) (*ts.ListOutput, error)

+ func (r *TemplateSourceRepository) ListAllNeedingSync(ctx context.Context) ([]*ts.TemplateSource, error)

+ func (r *TemplateSourceRepository) ListByTenantAndTemplateType(ctx context.Context, tenantID shared.ID, ...) ([]*ts.TemplateSource, error)

+ func (r *TemplateSourceRepository) ListEnabledForSync(ctx context.Context, tenantID shared.ID) ([]*ts.TemplateSource, error)

+ func (r *TemplateSourceRepository) Update(ctx context.Context, s *ts.TemplateSource) error

+ func (r *TemplateSourceRepository) UpdateSyncStatus(ctx context.Context, s *ts.TemplateSource) error

+ type TenantRepository struct

+ func NewTenantRepository(db *DB) *TenantRepository

+ func (r *TenantRepository) AcceptInvitationTx(ctx context.Context, inv *tenant.Invitation, m *tenant.Membership) error

+ func (r *TenantRepository) CountMembersByTenant(ctx context.Context, tenantID shared.ID) (int64, error)

+ func (r *TenantRepository) Create(ctx context.Context, t *tenant.Tenant) error

+ func (r *TenantRepository) CreateInvitation(ctx context.Context, inv *tenant.Invitation) error

+ func (r *TenantRepository) CreateMembership(ctx context.Context, m *tenant.Membership) error

+ func (r *TenantRepository) Delete(ctx context.Context, id shared.ID) error

+ func (r *TenantRepository) DeleteExpiredInvitations(ctx context.Context) (int64, error)

+ func (r *TenantRepository) DeleteInvitation(ctx context.Context, id shared.ID) error

+ func (r *TenantRepository) DeleteMembership(ctx context.Context, id shared.ID) error

+ func (r *TenantRepository) ExistsBySlug(ctx context.Context, slug string) (bool, error)

+ func (r *TenantRepository) GetByID(ctx context.Context, id shared.ID) (*tenant.Tenant, error)

+ func (r *TenantRepository) GetBySlug(ctx context.Context, slug string) (*tenant.Tenant, error)

+ func (r *TenantRepository) GetInvitationByID(ctx context.Context, id shared.ID) (*tenant.Invitation, error)

+ func (r *TenantRepository) GetInvitationByToken(ctx context.Context, token string) (*tenant.Invitation, error)

+ func (r *TenantRepository) GetMemberByEmail(ctx context.Context, tenantID shared.ID, email string) (*tenant.MemberWithUser, error)

+ func (r *TenantRepository) GetMemberStats(ctx context.Context, tenantID shared.ID) (*tenant.MemberStats, error)

+ func (r *TenantRepository) GetMembership(ctx context.Context, userID shared.ID, tenantID shared.ID) (*tenant.Membership, error)

+ func (r *TenantRepository) GetMembershipByID(ctx context.Context, id shared.ID) (*tenant.Membership, error)

+ func (r *TenantRepository) GetPendingInvitationByEmail(ctx context.Context, tenantID shared.ID, email string) (*tenant.Invitation, error)

+ func (r *TenantRepository) GetUserMemberships(ctx context.Context, userID shared.ID) ([]tenant.UserMembership, error)

+ func (r *TenantRepository) ListActiveTenantIDs(ctx context.Context) ([]shared.ID, error)

+ func (r *TenantRepository) ListMembersByTenant(ctx context.Context, tenantID shared.ID) ([]*tenant.Membership, error)

+ func (r *TenantRepository) ListMembersWithUserInfo(ctx context.Context, tenantID shared.ID) ([]*tenant.MemberWithUser, error)

+ func (r *TenantRepository) ListPendingInvitationsByTenant(ctx context.Context, tenantID shared.ID) ([]*tenant.Invitation, error)

+ func (r *TenantRepository) ListTenantsByUser(ctx context.Context, userID shared.ID) ([]*tenant.TenantWithRole, error)

+ func (r *TenantRepository) SearchMembersWithUserInfo(ctx context.Context, tenantID shared.ID, filters tenant.MemberSearchFilters) (*tenant.MemberSearchResult, error)

+ func (r *TenantRepository) Update(ctx context.Context, t *tenant.Tenant) error

+ func (r *TenantRepository) UpdateInvitation(ctx context.Context, inv *tenant.Invitation) error

+ func (r *TenantRepository) UpdateMembership(ctx context.Context, m *tenant.Membership) error

+ type TenantToolConfigRepository struct

+ func NewTenantToolConfigRepository(db *DB) *TenantToolConfigRepository

+ func (r *TenantToolConfigRepository) BulkDisable(ctx context.Context, tenantID shared.ID, toolIDs []shared.ID) error

+ func (r *TenantToolConfigRepository) BulkEnable(ctx context.Context, tenantID shared.ID, toolIDs []shared.ID) error

+ func (r *TenantToolConfigRepository) Create(ctx context.Context, c *tool.TenantToolConfig) error

+ func (r *TenantToolConfigRepository) Delete(ctx context.Context, id shared.ID) error

+ func (r *TenantToolConfigRepository) GetByID(ctx context.Context, id shared.ID) (*tool.TenantToolConfig, error)

+ func (r *TenantToolConfigRepository) GetByTenantAndTool(ctx context.Context, tenantID, toolID shared.ID) (*tool.TenantToolConfig, error)

+ func (r *TenantToolConfigRepository) GetEffectiveConfig(ctx context.Context, tenantID, toolID shared.ID) (map[string]any, error)

+ func (r *TenantToolConfigRepository) List(ctx context.Context, filter tool.TenantToolConfigFilter, ...) (pagination.Result[*tool.TenantToolConfig], error)

+ func (r *TenantToolConfigRepository) ListEnabledTools(ctx context.Context, tenantID shared.ID) ([]*tool.TenantToolConfig, error)

+ func (r *TenantToolConfigRepository) ListToolsWithConfig(ctx context.Context, tenantID shared.ID, filter tool.ToolFilter, ...) (pagination.Result[*tool.ToolWithConfig], error)

+ func (r *TenantToolConfigRepository) Update(ctx context.Context, c *tool.TenantToolConfig) error

+ func (r *TenantToolConfigRepository) Upsert(ctx context.Context, c *tool.TenantToolConfig) error

+ type ThreatIntelRepository struct

+ func NewThreatIntelRepository(db *DB) *ThreatIntelRepository

+ func (r *ThreatIntelRepository) EPSS() threatintel.EPSSRepository

+ func (r *ThreatIntelRepository) EnrichCVE(ctx context.Context, cveID string) (*threatintel.ThreatIntelEnrichment, error)

+ func (r *ThreatIntelRepository) EnrichCVEs(ctx context.Context, cveIDs []string) (map[string]*threatintel.ThreatIntelEnrichment, error)

+ func (r *ThreatIntelRepository) KEV() threatintel.KEVRepository

+ func (r *ThreatIntelRepository) SyncStatus() threatintel.SyncStatusRepository

+ type ToolCapabilityRepository struct

+ func NewToolCapabilityRepository(db *DB) *ToolCapabilityRepository

+ func (r *ToolCapabilityRepository) AddCapabilityToTool(ctx context.Context, tenantID *shared.ID, toolID, capabilityID shared.ID) error

+ func (r *ToolCapabilityRepository) GetToolCapabilities(ctx context.Context, toolID shared.ID) ([]*capability.Capability, error)

+ func (r *ToolCapabilityRepository) GetToolsByCapability(ctx context.Context, capabilityID shared.ID) ([]shared.ID, error)

+ func (r *ToolCapabilityRepository) GetToolsByCapabilityName(ctx context.Context, capabilityName string) ([]shared.ID, error)

+ func (r *ToolCapabilityRepository) RemoveCapabilityFromTool(ctx context.Context, tenantID *shared.ID, toolID, capabilityID shared.ID) error

+ func (r *ToolCapabilityRepository) SetToolCapabilities(ctx context.Context, tenantID *shared.ID, toolID shared.ID, ...) error

+ func (r *ToolCapabilityRepository) ValidateCapabilitiesAccessible(ctx context.Context, tenantID *shared.ID, capabilityIDs []shared.ID) error

+ type ToolCategoryRepository struct

+ func NewToolCategoryRepository(db *DB) *ToolCategoryRepository

+ func (r *ToolCategoryRepository) CountByTenant(ctx context.Context, tenantID shared.ID) (int64, error)

+ func (r *ToolCategoryRepository) Create(ctx context.Context, tc *toolcategory.ToolCategory) error

+ func (r *ToolCategoryRepository) Delete(ctx context.Context, id shared.ID) error

+ func (r *ToolCategoryRepository) ExistsByName(ctx context.Context, tenantID *shared.ID, name string) (bool, error)

+ func (r *ToolCategoryRepository) GetByID(ctx context.Context, id shared.ID) (*toolcategory.ToolCategory, error)

+ func (r *ToolCategoryRepository) GetByName(ctx context.Context, tenantID *shared.ID, name string) (*toolcategory.ToolCategory, error)

+ func (r *ToolCategoryRepository) List(ctx context.Context, filter toolcategory.Filter, page pagination.Pagination) (pagination.Result[*toolcategory.ToolCategory], error)

+ func (r *ToolCategoryRepository) ListAll(ctx context.Context, tenantID *shared.ID) ([]*toolcategory.ToolCategory, error)

+ func (r *ToolCategoryRepository) Update(ctx context.Context, tc *toolcategory.ToolCategory) error

+ type ToolExecutionRepository struct

+ func NewToolExecutionRepository(db *DB) *ToolExecutionRepository

+ func (r *ToolExecutionRepository) Create(ctx context.Context, execution *tool.ToolExecution) error

+ func (r *ToolExecutionRepository) GetByID(ctx context.Context, id shared.ID) (*tool.ToolExecution, error)

+ func (r *ToolExecutionRepository) GetTenantStats(ctx context.Context, tenantID shared.ID, days int) (*tool.TenantToolStats, error)

+ func (r *ToolExecutionRepository) GetToolStats(ctx context.Context, tenantID, toolID shared.ID, days int) (*tool.ToolStats, error)

+ func (r *ToolExecutionRepository) List(ctx context.Context, filter tool.ToolExecutionFilter, ...) (pagination.Result[*tool.ToolExecution], error)

+ func (r *ToolExecutionRepository) Update(ctx context.Context, execution *tool.ToolExecution) error

+ type ToolRepository struct

+ func NewToolRepository(db *DB) *ToolRepository

+ func (r *ToolRepository) BulkCreate(ctx context.Context, tools []*tool.Tool) error

+ func (r *ToolRepository) BulkUpdateVersions(ctx context.Context, versions map[shared.ID]tool.VersionInfo) error

+ func (r *ToolRepository) Count(ctx context.Context, filter tool.ToolFilter) (int64, error)

+ func (r *ToolRepository) Create(ctx context.Context, t *tool.Tool) error

+ func (r *ToolRepository) Delete(ctx context.Context, id shared.ID) error

+ func (r *ToolRepository) DeleteTenantTool(ctx context.Context, tenantID, id shared.ID) error

+ func (r *ToolRepository) FindByCapabilities(ctx context.Context, tenantID shared.ID, capabilities []string) (*tool.Tool, error)

+ func (r *ToolRepository) GetAllCapabilities(ctx context.Context) ([]string, error)

+ func (r *ToolRepository) GetByID(ctx context.Context, id shared.ID) (*tool.Tool, error)

+ func (r *ToolRepository) GetByName(ctx context.Context, name string) (*tool.Tool, error)

+ func (r *ToolRepository) GetByTenantAndID(ctx context.Context, tenantID, id shared.ID) (*tool.Tool, error)

+ func (r *ToolRepository) GetByTenantAndName(ctx context.Context, tenantID shared.ID, name string) (*tool.Tool, error)

+ func (r *ToolRepository) GetPlatformToolByName(ctx context.Context, name string) (*tool.Tool, error)

+ func (r *ToolRepository) List(ctx context.Context, filter tool.ToolFilter, page pagination.Pagination) (pagination.Result[*tool.Tool], error)

+ func (r *ToolRepository) ListAvailableTools(ctx context.Context, tenantID shared.ID, filter tool.ToolFilter, ...) (pagination.Result[*tool.Tool], error)

+ func (r *ToolRepository) ListByCapability(ctx context.Context, capability string) ([]*tool.Tool, error)

+ func (r *ToolRepository) ListByCategoryID(ctx context.Context, categoryID shared.ID) ([]*tool.Tool, error)

+ func (r *ToolRepository) ListByCategoryName(ctx context.Context, categoryName string) ([]*tool.Tool, error)

+ func (r *ToolRepository) ListByNames(ctx context.Context, names []string) ([]*tool.Tool, error)

+ func (r *ToolRepository) ListPlatformTools(ctx context.Context, filter tool.ToolFilter, page pagination.Pagination) (pagination.Result[*tool.Tool], error)

+ func (r *ToolRepository) ListTenantCustomTools(ctx context.Context, tenantID shared.ID, filter tool.ToolFilter, ...) (pagination.Result[*tool.Tool], error)

+ func (r *ToolRepository) Update(ctx context.Context, t *tool.Tool) error

+ type UserRepository struct

+ func NewUserRepository(db *DB) *UserRepository

+ func (r *UserRepository) Count(ctx context.Context, filter user.Filter) (int64, error)

+ func (r *UserRepository) Create(ctx context.Context, u *user.User) error

+ func (r *UserRepository) Delete(ctx context.Context, id shared.ID) error

+ func (r *UserRepository) ExistsByEmail(ctx context.Context, email string) (bool, error)

+ func (r *UserRepository) ExistsByKeycloakID(ctx context.Context, keycloakID string) (bool, error)

+ func (r *UserRepository) GetByEmail(ctx context.Context, email string) (*user.User, error)

+ func (r *UserRepository) GetByEmailForAuth(ctx context.Context, email string) (*user.User, error)

+ func (r *UserRepository) GetByEmailVerificationToken(ctx context.Context, token string) (*user.User, error)

+ func (r *UserRepository) GetByID(ctx context.Context, id shared.ID) (*user.User, error)

+ func (r *UserRepository) GetByIDs(ctx context.Context, ids []shared.ID) ([]*user.User, error)

+ func (r *UserRepository) GetByKeycloakID(ctx context.Context, keycloakID string) (*user.User, error)

+ func (r *UserRepository) GetByPasswordResetToken(ctx context.Context, token string) (*user.User, error)

+ func (r *UserRepository) Update(ctx context.Context, u *user.User) error

+ func (r *UserRepository) UpsertFromKeycloak(ctx context.Context, keycloakID, email, name string) (*user.User, error)

+ type VulnerabilityRepository struct

+ func NewVulnerabilityRepository(db *DB) *VulnerabilityRepository

+ func (r *VulnerabilityRepository) Count(ctx context.Context, filter vulnerability.VulnerabilityFilter) (int64, error)

+ func (r *VulnerabilityRepository) Create(ctx context.Context, vuln *vulnerability.Vulnerability) error

+ func (r *VulnerabilityRepository) Delete(ctx context.Context, id shared.ID) error

+ func (r *VulnerabilityRepository) ExistsByCVE(ctx context.Context, cveID string) (bool, error)

+ func (r *VulnerabilityRepository) GetByCVE(ctx context.Context, cveID string) (*vulnerability.Vulnerability, error)

+ func (r *VulnerabilityRepository) GetByID(ctx context.Context, id shared.ID) (*vulnerability.Vulnerability, error)

+ func (r *VulnerabilityRepository) List(ctx context.Context, filter vulnerability.VulnerabilityFilter, ...) (pagination.Result[*vulnerability.Vulnerability], error)

+ func (r *VulnerabilityRepository) Update(ctx context.Context, vuln *vulnerability.Vulnerability) error

+ func (r *VulnerabilityRepository) UpsertByCVE(ctx context.Context, vuln *vulnerability.Vulnerability) error

+ type WebhookRepository struct

+ func NewWebhookRepository(db *DB) *WebhookRepository

+ func (r *WebhookRepository) Create(ctx context.Context, w *webhook.Webhook) error

+ func (r *WebhookRepository) Delete(ctx context.Context, id, tenantID webhook.ID) error

+ func (r *WebhookRepository) GetByID(ctx context.Context, id, tenantID webhook.ID) (*webhook.Webhook, error)

+ func (r *WebhookRepository) List(ctx context.Context, filter webhook.Filter) (webhook.ListResult, error)

+ func (r *WebhookRepository) ListDeliveries(ctx context.Context, filter webhook.DeliveryFilter) (webhook.DeliveryListResult, error)

+ func (r *WebhookRepository) Update(ctx context.Context, w *webhook.Webhook) error

+ type WorkflowEdgeRepository struct

+ func NewWorkflowEdgeRepository(db *DB) *WorkflowEdgeRepository

+ func (r *WorkflowEdgeRepository) Create(ctx context.Context, e *workflow.Edge) error

+ func (r *WorkflowEdgeRepository) CreateBatch(ctx context.Context, edges []*workflow.Edge) error

+ func (r *WorkflowEdgeRepository) Delete(ctx context.Context, id shared.ID) error

+ func (r *WorkflowEdgeRepository) DeleteByWorkflowID(ctx context.Context, workflowID shared.ID) error

+ func (r *WorkflowEdgeRepository) GetByID(ctx context.Context, id shared.ID) (*workflow.Edge, error)

+ func (r *WorkflowEdgeRepository) GetByWorkflowID(ctx context.Context, workflowID shared.ID) ([]*workflow.Edge, error)

+ type WorkflowNodeRepository struct

+ func NewWorkflowNodeRepository(db *DB) *WorkflowNodeRepository

+ func (r *WorkflowNodeRepository) Create(ctx context.Context, n *workflow.Node) error

+ func (r *WorkflowNodeRepository) CreateBatch(ctx context.Context, nodes []*workflow.Node) error

+ func (r *WorkflowNodeRepository) Delete(ctx context.Context, id shared.ID) error

+ func (r *WorkflowNodeRepository) DeleteByWorkflowID(ctx context.Context, workflowID shared.ID) error

+ func (r *WorkflowNodeRepository) GetByID(ctx context.Context, id shared.ID) (*workflow.Node, error)

+ func (r *WorkflowNodeRepository) GetByKey(ctx context.Context, workflowID shared.ID, nodeKey string) (*workflow.Node, error)

+ func (r *WorkflowNodeRepository) GetByWorkflowID(ctx context.Context, workflowID shared.ID) ([]*workflow.Node, error)

+ func (r *WorkflowNodeRepository) Update(ctx context.Context, n *workflow.Node) error

+ type WorkflowNodeRunRepository struct

+ func NewWorkflowNodeRunRepository(db *DB) *WorkflowNodeRunRepository

+ func (r *WorkflowNodeRunRepository) Complete(ctx context.Context, id shared.ID, output map[string]any) error

+ func (r *WorkflowNodeRunRepository) Create(ctx context.Context, nr *workflow.NodeRun) error

+ func (r *WorkflowNodeRunRepository) CreateBatch(ctx context.Context, nodeRuns []*workflow.NodeRun) error

+ func (r *WorkflowNodeRunRepository) Delete(ctx context.Context, id shared.ID) error

+ func (r *WorkflowNodeRunRepository) GetByID(ctx context.Context, id shared.ID) (*workflow.NodeRun, error)

+ func (r *WorkflowNodeRunRepository) GetByNodeKey(ctx context.Context, workflowRunID shared.ID, nodeKey string) (*workflow.NodeRun, error)

+ func (r *WorkflowNodeRunRepository) GetByWorkflowRunID(ctx context.Context, workflowRunID shared.ID) ([]*workflow.NodeRun, error)

+ func (r *WorkflowNodeRunRepository) GetPendingByDependencies(ctx context.Context, workflowRunID shared.ID, completedNodeKeys []string) ([]*workflow.NodeRun, error)

+ func (r *WorkflowNodeRunRepository) List(ctx context.Context, filter workflow.NodeRunFilter) ([]*workflow.NodeRun, error)

+ func (r *WorkflowNodeRunRepository) Update(ctx context.Context, nr *workflow.NodeRun) error

+ func (r *WorkflowNodeRunRepository) UpdateStatus(ctx context.Context, id shared.ID, status workflow.NodeRunStatus, ...) error

+ type WorkflowRepository struct

+ func NewWorkflowRepository(db *DB) *WorkflowRepository

+ func (r *WorkflowRepository) Create(ctx context.Context, w *workflow.Workflow) error

+ func (r *WorkflowRepository) Delete(ctx context.Context, id shared.ID) error

+ func (r *WorkflowRepository) GetByID(ctx context.Context, id shared.ID) (*workflow.Workflow, error)

+ func (r *WorkflowRepository) GetByName(ctx context.Context, tenantID shared.ID, name string) (*workflow.Workflow, error)

+ func (r *WorkflowRepository) GetByTenantAndID(ctx context.Context, tenantID, id shared.ID) (*workflow.Workflow, error)

+ func (r *WorkflowRepository) GetWithGraph(ctx context.Context, id shared.ID) (*workflow.Workflow, error)

+ func (r *WorkflowRepository) List(ctx context.Context, filter workflow.WorkflowFilter, ...) (pagination.Result[*workflow.Workflow], error)

+ func (r *WorkflowRepository) ListActiveWithTriggerType(ctx context.Context, tenantID shared.ID, triggerType workflow.TriggerType) ([]*workflow.Workflow, error)

+ func (r *WorkflowRepository) Update(ctx context.Context, w *workflow.Workflow) error

+ type WorkflowRunRepository struct

+ func NewWorkflowRunRepository(db *DB) *WorkflowRunRepository

+ func (r *WorkflowRunRepository) CountActiveByTenantID(ctx context.Context, tenantID shared.ID) (int, error)

+ func (r *WorkflowRunRepository) CountActiveByWorkflowID(ctx context.Context, workflowID shared.ID) (int, error)

+ func (r *WorkflowRunRepository) Create(ctx context.Context, run *workflow.Run) error

+ func (r *WorkflowRunRepository) CreateRunIfUnderLimit(ctx context.Context, run *workflow.Run, maxPerWorkflow, maxPerTenant int) error

+ func (r *WorkflowRunRepository) Delete(ctx context.Context, id shared.ID) error

+ func (r *WorkflowRunRepository) GetActiveByWorkflowID(ctx context.Context, workflowID shared.ID) ([]*workflow.Run, error)

+ func (r *WorkflowRunRepository) GetByID(ctx context.Context, id shared.ID) (*workflow.Run, error)

+ func (r *WorkflowRunRepository) GetByTenantAndID(ctx context.Context, tenantID, id shared.ID) (*workflow.Run, error)

+ func (r *WorkflowRunRepository) GetWithNodeRuns(ctx context.Context, id shared.ID) (*workflow.Run, error)

+ func (r *WorkflowRunRepository) List(ctx context.Context, filter workflow.RunFilter, page pagination.Pagination) (pagination.Result[*workflow.Run], error)

+ func (r *WorkflowRunRepository) ListByWorkflowID(ctx context.Context, workflowID shared.ID, pageNum, perPage int) ([]*workflow.Run, int64, error)

+ func (r *WorkflowRunRepository) Update(ctx context.Context, run *workflow.Run) error

+ func (r *WorkflowRunRepository) UpdateStats(ctx context.Context, id shared.ID, completed, failed int) error

+ func (r *WorkflowRunRepository) UpdateStatus(ctx context.Context, id shared.ID, status workflow.RunStatus, ...) error

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