app

package

Go to main page

Versions in this module

v0

v0.1.2

Mar 17, 2026

Changes in this version

+ var ErrSSODecryptionFailed = errors.New("failed to decrypt client secret")

+ var ErrSSODomainNotAllowed = errors.New("email domain not allowed for this SSO provider")

+ var ErrSSOExchangeFailed = errors.New("failed to exchange authorization code")

+ var ErrSSOInvalidDefaultRole = errors.New("invalid default role")

+ var ErrSSOInvalidRedirectURI = errors.New("invalid redirect URI")

+ var ErrSSOInvalidState = errors.New("invalid SSO state token")

+ var ErrSSONoActiveProviders = errors.New("no active SSO providers for this tenant")

+ var ErrSSONoEmail = errors.New("SSO provider did not return an email address")

+ var ErrSSOProviderInactive = errors.New("SSO provider is not active")

+ var ErrSSOProviderNotFound = errors.New("SSO provider not configured for this tenant")

+ var ErrSSOProviderUnsupported = errors.New("unsupported SSO provider type")

+ var ErrSSOTenantNotFound = errors.New("tenant not found")

+ var ErrSSOUserInfoFailed = errors.New("failed to get user info from SSO provider")

+ func MapTenantToAssetScoringConfig(s *tenant.RiskScoringSettings) *asset.RiskScoringConfig

type AgentService

+ func (s *AgentService) GetPlatformStats(ctx context.Context, tenantID shared.ID) (*PlatformStatsOutput, error)

+ type ApproveStatusInput struct

+ ApprovalID string

+ ApprovedBy string

+ TenantID string

type AssetGroupService

+ func (s *AssetGroupService) SetScopeRuleReconciler(fn ScopeRuleGroupReconcilerFunc)

type AssetService

+ func (s *AssetService) GetAssetWithScope(ctx context.Context, tenantID, assetID, actingUserID string, isAdmin bool) (*asset.Asset, error)

+ func (s *AssetService) GetRepositoryExtensionsByAssetIDs(ctx context.Context, assetIDs []shared.ID) (map[shared.ID]*asset.RepositoryExtension, error)

+ func (s *AssetService) InvalidateScoringConfigCache(tenantID shared.ID)

+ func (s *AssetService) ListTags(ctx context.Context, tenantID string, prefix string, limit int) ([]string, error)

+ func (s *AssetService) PreviewRiskScoreChanges(ctx context.Context, tenantID shared.ID, newConfig *asset.RiskScoringConfig) ([]RiskScorePreviewItem, int64, error)

+ func (s *AssetService) RecalculateAllRiskScores(ctx context.Context, tenantID shared.ID) (int, error)

+ func (s *AssetService) SetAccessControlRepository(repo accesscontrol.Repository)

+ func (s *AssetService) SetRedisClient(client *redis.Client)

+ func (s *AssetService) SetScopeRuleEvaluator(fn ScopeRuleEvaluatorFunc)

+ func (s *AssetService) SetScoringConfigProvider(provider asset.ScoringConfigProvider)

+ type AssignmentEngine struct

+ func NewAssignmentEngine(acRepo accesscontrol.Repository, log *logger.Logger) *AssignmentEngine

+ func (e *AssignmentEngine) EvaluateRules(ctx context.Context, tenantID shared.ID, finding *vulnerability.Finding) ([]AssignmentResult, error)

+ func (e *AssignmentEngine) MatchesConditions(conds accesscontrol.AssignmentConditions, finding *vulnerability.Finding, ...) bool

+ type AssignmentResult struct

+ GroupID shared.ID

+ Options accesscontrol.AssignmentOptions

+ RuleID shared.ID

+ type AssignmentRuleService struct

+ func NewAssignmentRuleService(acRepo accesscontrol.Repository, groupRepo group.Repository, ...) *AssignmentRuleService

+ func (s *AssignmentRuleService) CreateRule(ctx context.Context, input CreateRuleInput, createdBy string) (*accesscontrol.AssignmentRule, error)

+ func (s *AssignmentRuleService) DeleteRule(ctx context.Context, tenantIDStr, ruleID string) error

+ func (s *AssignmentRuleService) GetRule(ctx context.Context, tenantIDStr, ruleID string) (*accesscontrol.AssignmentRule, error)

+ func (s *AssignmentRuleService) ListRules(ctx context.Context, input ListAssignmentRulesInput) (*ListAssignmentRulesOutput, error)

+ func (s *AssignmentRuleService) SetAssignmentEngine(engine *AssignmentEngine)

+ func (s *AssignmentRuleService) SetFindingRepository(repo vulnerability.FindingRepository)

+ func (s *AssignmentRuleService) TestRule(ctx context.Context, tenantIDStr, ruleID string) (*TestRuleResult, error)

+ func (s *AssignmentRuleService) UpdateRule(ctx context.Context, tenantIDStr, ruleID string, input UpdateRuleInput) (*accesscontrol.AssignmentRule, error)

+ type BulkAssignAssetsInput struct

+ AssetIDs []string

+ GroupID string

+ OwnershipType string

+ type BulkAssignAssetsResult struct

+ FailedAssets []string

+ FailedCount int

+ SuccessCount int

+ type CancelApprovalInput struct

+ ApprovalID string

+ CanceledBy string

+ TenantID string

+ type ComplianceService struct

+ func NewComplianceService(frameworkRepo compliance.FrameworkRepository, ...) *ComplianceService

+ func (s *ComplianceService) GetComplianceStats(ctx context.Context, tenantID string) (*ComplianceStatsResponse, error)

+ func (s *ComplianceService) GetControl(ctx context.Context, tenantID, id string) (*compliance.Control, error)

+ func (s *ComplianceService) GetControlFindings(ctx context.Context, tenantID, controlID string) ([]*compliance.FindingControlMapping, error)

+ func (s *ComplianceService) GetFindingControls(ctx context.Context, tenantID, findingID string) ([]*compliance.FindingControlMapping, error)

+ func (s *ComplianceService) GetFramework(ctx context.Context, tenantID, id string) (*compliance.Framework, error)

+ func (s *ComplianceService) GetFrameworkBySlug(ctx context.Context, slug string) (*compliance.Framework, error)

+ func (s *ComplianceService) GetFrameworkStats(ctx context.Context, tenantID, frameworkID string) (*compliance.FrameworkStats, error)

+ func (s *ComplianceService) ListAssessments(ctx context.Context, tenantID, frameworkID string, page pagination.Pagination) (pagination.Result[*compliance.Assessment], error)

+ func (s *ComplianceService) ListControls(ctx context.Context, tenantID, frameworkID string, page pagination.Pagination) (pagination.Result[*compliance.Control], error)

+ func (s *ComplianceService) ListFrameworks(ctx context.Context, tenantID string, page pagination.Pagination) (pagination.Result[*compliance.Framework], error)

+ func (s *ComplianceService) MapFindingToControl(ctx context.Context, tenantID, findingID, controlID, actorID string, ...) (*compliance.FindingControlMapping, error)

+ func (s *ComplianceService) SetFindingRepository(repo vulnerability.FindingRepository)

+ func (s *ComplianceService) UnmapFindingFromControl(ctx context.Context, tenantID, mappingID string) error

+ func (s *ComplianceService) UpdateAssessment(ctx context.Context, input UpdateAssessmentInput) (*compliance.Assessment, error)

+ type ComplianceStatsResponse struct

+ OverdueControls int

+ TotalControls int

+ TotalFrameworks int

+ type CreateCampaignInput struct

+ ActorID string

+ AssetGroupIDs []string

+ AssetIDs []string

+ CampaignType string

+ ClientContact string

+ ClientName string

+ Description string

+ EndDate *string

+ LeadUserID *string

+ Methodology string

+ Name string

+ Objectives []string

+ Priority string

+ RulesOfEngagement map[string]any

+ ScopeItems []map[string]any

+ StartDate *string

+ Tags []string

+ TeamUserIDs []string

+ TenantID string

type CreateGroupInput

+ NotificationConfig *group.NotificationConfig

+ type CreateProviderInput struct

+ AllowedDomains []string

+ AutoProvision bool

+ ClientID string

+ ClientSecret string

+ CreatedBy string

+ DefaultRole string

+ DisplayName string

+ IssuerURL string

+ Provider string

+ Scopes []string

+ TenantID string

+ TenantIdentifier string

+ type CreateReportInput struct

+ ActorID string

+ CampaignID string

+ Format string

+ Name string

+ Options map[string]any

+ ReportType string

+ TenantID string

+ type CreateRetestInput struct

+ ActorID string

+ Evidence []map[string]any

+ FindingID string

+ Notes string

+ Status string

+ TenantID string

+ type CreateRuleInput struct

+ Conditions accesscontrol.AssignmentConditions

+ Description string

+ Name string

+ Options accesscontrol.AssignmentOptions

+ Priority int

+ TargetGroupID string

+ TenantID string

+ type CreateScopeRuleInput struct

+ Description string

+ GroupID string

+ MatchAssetGroupIDs []string

+ MatchLogic string

+ MatchTags []string

+ Name string

+ OwnershipType string

+ Priority int

+ RuleType string

+ TenantID string

+ type CreateTemplateInput struct

+ BusinessImpact string

+ CWEID string

+ Category string

+ Description string

+ Name string

+ OWASPCategory string

+ ReferenceURLs []string

+ Remediation string

+ Severity string

+ StepsToReproduce []string

+ Tags []string

+ TechnicalImpact string

+ type DashboardAllStats struct

+ Activity []ActivityItem

+ Assets AssetStatsData

+ Findings FindingStatsData

+ Repos RepositoryStatsData

type DashboardStats

+ FindingTrend []FindingTrendPoint

type DashboardStatsRepository

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

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

type ExposureService

+ func (s *ExposureService) SetOutboxService(db *sql.DB, svc *OutboxService)

type FindingActivityService

+ func (s *FindingActivityService) DeleteActivityByCommentID(ctx context.Context, tenantID string, commentID string) error

+ func (s *FindingActivityService) RecordBatchAutoReopened(ctx context.Context, tenantID shared.ID, findingIDs []shared.ID) error

+ func (s *FindingActivityService) RecordBatchAutoResolved(ctx context.Context, tenantID shared.ID, findingIDs []shared.ID, ...) error

+ func (s *FindingActivityService) UpdateActivityContentByCommentID(ctx context.Context, tenantID string, commentID string, content string) error

+ type FindingTrendPoint struct

+ Critical int

+ Date string

+ High int

+ Info int

+ Low int

+ Medium int

+ type GetFindingStatsInput struct

+ ActingUserID string

+ IsAdmin bool

+ TenantID string

+ type GroupCounts struct

+ AssetCount int

+ MemberCount int

type GroupService

+ func (s *GroupService) BulkAssignAssets(ctx context.Context, input BulkAssignAssetsInput, assignedBy shared.ID, ...) (*BulkAssignAssetsResult, error)

+ func (s *GroupService) CountUniqueMembers(ctx context.Context, groups []*group.Group) (int, error)

+ func (s *GroupService) GetGroupCounts(ctx context.Context, groups []*group.Group) (map[shared.ID]GroupCounts, error)

+ func (s *GroupService) SetNotificationService(ns *NotificationService)

+ type GroupSyncService struct

+ func NewGroupSyncService(groupRepo group.Repository, log *logger.Logger) *GroupSyncService

+ func (s *GroupSyncService) SyncAll(ctx context.Context, tenantID shared.ID) error

+ func (s *GroupSyncService) SyncFromProvider(ctx context.Context, tenantID shared.ID, provider string, ...) error

type HTTPRequestHandler

+ func (h *HTTPRequestHandler) AllowLocalhostForTesting()

+ func (h *HTTPRequestHandler) SetBlockedCIDRs(cidrs []string)

+ func (h *HTTPRequestHandler) SetClient(client *http.Client)

type IntegrationService

+ func (s *IntegrationService) SetOutboxEventRepository(repo outbox.EventRepository)

type ListAssetsInput

+ ActingUserID string

+ IsAdmin bool

+ type ListAssignmentRulesInput struct

+ IsActive *bool

+ Limit int

+ Offset int

+ OrderBy string

+ OrderDesc bool

+ Search string

+ TargetGroupID *string

+ TenantID string

+ type ListAssignmentRulesOutput struct

+ Rules []*accesscontrol.AssignmentRule

+ TotalCount int64

type ListFindingsInput

+ ActingUserID string

+ ExcludeStatuses []string

+ IsAdmin bool

type ModuleRepository

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

type ModuleService

+ func (s *ModuleService) GetTenantModuleConfig(ctx context.Context, tenantID string) (*TenantModuleConfigOutput, error)

+ func (s *ModuleService) ResetTenantModules(ctx context.Context, tenantID string, actx AuditContext) (*TenantModuleConfigOutput, error)

+ func (s *ModuleService) SetAuditService(svc *AuditService)

+ func (s *ModuleService) SetTenantModuleRepo(repo TenantModuleRepository)

+ func (s *ModuleService) UpdateTenantModules(ctx context.Context, tenantID string, updates []module.TenantModuleUpdate, ...) (*TenantModuleConfigOutput, error)

type NotificationService

+ func (s *NotificationService) CleanupOld(ctx context.Context, retentionDays int) (int64, error)

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

+ func (s *NotificationService) GetUnreadCount(ctx context.Context, tenantID, userID shared.ID) (int, error)

+ func (s *NotificationService) ListNotifications(ctx context.Context, tenantID, userID shared.ID, ...) (pagination.Result[*notification.Notification], error)

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

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

+ func (s *NotificationService) Notify(ctx context.Context, params notification.NotificationParams) error

+ func (s *NotificationService) UpdatePreferences(ctx context.Context, tenantID, userID shared.ID, input UpdatePreferencesInput) (*notification.Preferences, error)

+ type OutboxScheduler struct

+ func NewOutboxScheduler(service *OutboxService, config OutboxSchedulerConfig, log *logger.Logger) *OutboxScheduler

+ func (s *OutboxScheduler) Start()

+ func (s *OutboxScheduler) Stop()

+ type OutboxSchedulerConfig struct

+ BatchSize int

+ CleanupInterval time.Duration

+ CompletedRetentionDays int

+ EventRetentionDays int

+ FailedRetentionDays int

+ ProcessInterval time.Duration

+ StaleMinutes int

+ UnlockInterval time.Duration

+ func DefaultOutboxSchedulerConfig() OutboxSchedulerConfig

+ type OutboxService struct

+ func NewOutboxService(outboxRepo outbox.OutboxRepository, eventRepo outbox.EventRepository, ...) *OutboxService

+ func (s *OutboxService) CleanupOldEntries(ctx context.Context, completedDays, failedDays int) (deletedCompleted, deletedFailed int64, err error)

+ func (s *OutboxService) CleanupOldEvents(ctx context.Context, retentionDays int) (deleted int64, err error)

+ func (s *OutboxService) EnqueueNotification(ctx context.Context, params EnqueueNotificationParams) error

+ func (s *OutboxService) EnqueueNotificationInTx(ctx context.Context, tx *sql.Tx, params EnqueueNotificationParams) error

+ func (s *OutboxService) ProcessOutboxBatch(ctx context.Context, workerID string, batchSize int) (processed, failed int, err error)

+ func (s *OutboxService) UnlockStaleEntries(ctx context.Context, olderThanMinutes int) (unlocked int64, err error)

+ type PentestFindingInput struct

+ ActorID string

+ AffectedAssets []string

+ AffectedAssetsText []string

+ AssetID string

+ AssignedTo *string

+ BusinessImpact string

+ CVEID string

+ CVSSScore *float64

+ CVSSVector string

+ CWEID string

+ CampaignID string

+ Description string

+ Evidence []map[string]any

+ OWASPCategory string

+ PoCCode string

+ ReferenceURLs []string

+ RemediationDeadline *string

+ RemediationGuidance string

+ RequestResponses []map[string]any

+ ReviewedBy *string

+ Severity string

+ Status string

+ StepsToReproduce []string

+ Tags []string

+ TechnicalImpact string

+ TemplateID *string

+ TenantID string

+ Title string

+ type PentestService struct

+ func NewPentestService(campaignRepo pentest.CampaignRepository, findingRepo pentest.FindingRepository, ...) *PentestService

+ func (s *PentestService) CreateCampaign(ctx context.Context, input CreateCampaignInput) (*pentest.Campaign, error)

+ func (s *PentestService) CreateFinding(ctx context.Context, input PentestFindingInput) (*pentest.Finding, error)

+ func (s *PentestService) CreateReport(ctx context.Context, input CreateReportInput) (*pentest.Report, error)

+ func (s *PentestService) CreateRetest(ctx context.Context, input CreateRetestInput) (*pentest.Retest, error)

+ func (s *PentestService) CreateTemplate(ctx context.Context, tenantID string, input CreateTemplateInput) (*pentest.Template, error)

+ func (s *PentestService) CreateUnifiedFinding(ctx context.Context, input PentestFindingInput) (*vulnerability.Finding, error)

+ func (s *PentestService) DeleteCampaign(ctx context.Context, tenantID, campaignID string) error

+ func (s *PentestService) DeleteFinding(ctx context.Context, tenantID, findingID string) error

+ func (s *PentestService) DeleteReport(ctx context.Context, tenantID, reportID string) error

+ func (s *PentestService) DeleteTemplate(ctx context.Context, tenantID, id string) error

+ func (s *PentestService) GetBatchCampaignStats(ctx context.Context, tenantID string, campaignIDs []string) (map[string]*pentest.CampaignStats, error)

+ func (s *PentestService) GetCampaign(ctx context.Context, tenantID, campaignID string) (*pentest.Campaign, error)

+ func (s *PentestService) GetCampaignStats(ctx context.Context, tenantID, campaignID string) (*pentest.CampaignStats, error)

+ func (s *PentestService) GetFinding(ctx context.Context, tenantID, findingID string) (*pentest.Finding, error)

+ func (s *PentestService) GetReport(ctx context.Context, tenantID, reportID string) (*pentest.Report, error)

+ func (s *PentestService) GetTemplate(ctx context.Context, tenantID, id string) (*pentest.Template, error)

+ func (s *PentestService) GetUnifiedFinding(ctx context.Context, tenantID, findingID string) (*vulnerability.Finding, error)

+ func (s *PentestService) ListAllPentestFindings(ctx context.Context, tenantID, campaignID string, page pagination.Pagination) (pagination.Result[*vulnerability.Finding], error)

+ func (s *PentestService) ListCampaigns(ctx context.Context, tenantID string, filter pentest.CampaignFilter, ...) (pagination.Result[*pentest.Campaign], error)

+ func (s *PentestService) ListFindings(ctx context.Context, tenantID string, filter pentest.FindingFilter, ...) (pagination.Result[*pentest.Finding], error)

+ func (s *PentestService) ListReports(ctx context.Context, tenantID string, filter pentest.ReportFilter, ...) (pagination.Result[*pentest.Report], error)

+ func (s *PentestService) ListRetests(ctx context.Context, tenantID, findingID string) ([]*pentest.Retest, error)

+ func (s *PentestService) ListTemplates(ctx context.Context, tenantID string, filter pentest.TemplateFilter, ...) (pagination.Result[*pentest.Template], error)

+ func (s *PentestService) ListUnifiedCampaignFindings(ctx context.Context, tenantID, campaignID string, page pagination.Pagination) (pagination.Result[*vulnerability.Finding], error)

+ func (s *PentestService) SetUnifiedFindingRepository(repo vulnerability.FindingRepository)

+ func (s *PentestService) SetUserNotificationService(svc *NotificationService)

+ func (s *PentestService) UpdateCampaign(ctx context.Context, input UpdateCampaignInput) (*pentest.Campaign, error)

+ func (s *PentestService) UpdateCampaignStatus(ctx context.Context, tenantID, campaignID, newStatus string) (*pentest.Campaign, error)

+ func (s *PentestService) UpdateFinding(ctx context.Context, tenantID, findingID string, input PentestFindingInput) (*pentest.Finding, error)

+ func (s *PentestService) UpdateFindingStatus(ctx context.Context, tenantID, findingID, newStatus, actorID string) (*pentest.Finding, error)

+ func (s *PentestService) UpdatePentestFindingStatus(ctx context.Context, tenantID, findingID, newStatus, actorID string) (*vulnerability.Finding, error)

+ func (s *PentestService) UpdateTemplate(ctx context.Context, tenantID, id string, input CreateTemplateInput) (*pentest.Template, error)

+ func (s *PentestService) UpdateUnifiedFinding(ctx context.Context, tenantID, findingID string, input PentestFindingInput) (*vulnerability.Finding, error)

+ type PentestSourceMetadata struct

+ AffectedAssets []string

+ BusinessImpact string

+ CWEID string

+ Evidence []map[string]any

+ OWASPCategory string

+ PoCCode string

+ ReferenceURLs []string

+ RemediationGuidance string

+ RequestResponses []map[string]any

+ ReviewedBy string

+ StepsToReproduce []string

+ TechnicalImpact string

+ type PlatformStatsOutput struct

+ AccessibleTiers []string

+ AvailableSlots int

+ CurrentActive int

+ CurrentQueued int

+ Enabled bool

+ MaxConcurrent int

+ MaxQueued int

+ MaxTier string

+ TierStats map[string]PlatformTierStats

+ type PlatformTierStats struct

+ AvailableSlots int

+ CurrentLoad int

+ OfflineAgents int

+ OnlineAgents int

+ TotalAgents int

+ TotalCapacity int

+ type PreviewScopeRuleResult struct

+ AlreadyAssigned int

+ MatchingAssets int

+ RuleID string

+ RuleName string

+ WouldAdd int

+ type ReconcileGroupResult struct

+ AssetsAdded int

+ AssetsRemoved int

+ RulesEvaluated int

+ type RejectApprovalInput struct

+ ApprovalID string

+ Reason string

+ RejectedBy string

+ TenantID string

+ type RequestApprovalInput struct

+ ExpiresAt *string

+ FindingID string

+ Justification string

+ RequestedBy string

+ RequestedStatus string

+ TenantID string

+ type RiskScorePreviewItem struct

+ AssetID string

+ AssetName string

+ AssetType string

+ CurrentScore int

+ Delta int

+ NewScore int

+ type SSOAuthorizeInput struct

+ OrgSlug string

+ Provider string

+ RedirectURI string

+ type SSOAuthorizeResult struct

+ AuthorizationURL string

+ State string

+ type SSOCallbackInput struct

+ Code string

+ Provider string

+ RedirectURI string

+ State string

+ type SSOCallbackResult struct

+ AccessToken string

+ ExpiresIn int64

+ RefreshToken string

+ TenantID string

+ TenantSlug string

+ TokenType string

+ User *user.User

+ type SSOProviderInfo struct

+ DisplayName string

+ ID string

+ Provider string

+ type SSOService struct

+ func NewSSOService(ipRepo identityprovider.Repository, tenantRepo tenant.Repository, ...) *SSOService

+ func (s *SSOService) CreateProvider(ctx context.Context, input CreateProviderInput) (*identityprovider.IdentityProvider, error)

+ func (s *SSOService) DeleteProvider(ctx context.Context, tenantID, id string) error

+ func (s *SSOService) GenerateAuthorizeURL(ctx context.Context, input SSOAuthorizeInput) (*SSOAuthorizeResult, error)

+ func (s *SSOService) GetProvider(ctx context.Context, tenantID, id string) (*identityprovider.IdentityProvider, error)

+ func (s *SSOService) GetProvidersForTenant(ctx context.Context, orgSlug string) ([]SSOProviderInfo, error)

+ func (s *SSOService) HandleCallback(ctx context.Context, input SSOCallbackInput) (*SSOCallbackResult, error)

+ func (s *SSOService) ListProviders(ctx context.Context, tenantID string) ([]*identityprovider.IdentityProvider, error)

+ func (s *SSOService) SetTenantMemberRepo(repo TenantMemberCreator)

+ func (s *SSOService) UpdateProvider(ctx context.Context, input UpdateProviderInput) (*identityprovider.IdentityProvider, error)

+ type SSOUserInfo struct

+ AvatarURL string

+ Email string

+ Name string

+ type ScopeRuleBroadcaster interface

+ BroadcastScopeChange func(channel string, data any, tenantID string)

+ type ScopeRuleEvaluatorFunc func(ctx context.Context, tenantID, assetID shared.ID, tags []string, ...) error

+ type ScopeRuleGroupReconcilerFunc func(ctx context.Context, assetGroupID shared.ID)

+ type ScopeRuleService struct

+ func NewScopeRuleService(acRepo accesscontrol.Repository, groupRepo group.Repository, ...) *ScopeRuleService

+ func (s *ScopeRuleService) CreateScopeRule(ctx context.Context, input CreateScopeRuleInput, createdBy string) (*accesscontrol.ScopeRule, error)

+ func (s *ScopeRuleService) DeleteScopeRule(ctx context.Context, tenantID, ruleID string) error

+ func (s *ScopeRuleService) EvaluateAsset(ctx context.Context, tenantID shared.ID, assetID shared.ID, tags []string, ...) error

+ func (s *ScopeRuleService) GetScopeRule(ctx context.Context, tenantID, ruleID string) (*accesscontrol.ScopeRule, error)

+ func (s *ScopeRuleService) ListScopeRules(ctx context.Context, tenantID, groupID string, ...) ([]*accesscontrol.ScopeRule, int64, error)

+ func (s *ScopeRuleService) PreviewScopeRule(ctx context.Context, tenantID, ruleID string) (*PreviewScopeRuleResult, error)

+ func (s *ScopeRuleService) ReconcileByAssetGroup(ctx context.Context, assetGroupID shared.ID)

+ func (s *ScopeRuleService) ReconcileGroup(ctx context.Context, tenantID, groupID string) (*ReconcileGroupResult, error)

+ func (s *ScopeRuleService) ReconcileGroupByIDs(ctx context.Context, tenantID, groupID shared.ID) error

+ func (s *ScopeRuleService) SetAssetGroupValidator(v assetGroupValidator)

+ func (s *ScopeRuleService) SetBroadcaster(b ScopeRuleBroadcaster)

+ func (s *ScopeRuleService) UpdateScopeRule(ctx context.Context, tenantID, ruleID string, input UpdateScopeRuleInput) (*accesscontrol.ScopeRule, error)

type ScopeService

+ func (s *ScopeService) CheckPatternOverlaps(ctx context.Context, tenantID string, targetType string, pattern string) ([]string, error)

+ func (s *ScopeService) RunScheduleNow(ctx context.Context, scheduleID string, tenantID string) (*scope.Schedule, error)

+ type SubModuleInfo struct

+ IsEnabled bool

+ Module *module.Module

+ type TenantMemberCreator interface

+ CreateMembership func(ctx context.Context, m *tenant.Membership) error

+ type TenantModuleConfigOutput struct

+ Modules []*TenantModuleInfo

+ Summary TenantModuleSummary

+ type TenantModuleInfo struct

+ IsEnabled bool

+ Module *module.Module

+ SubModules []*SubModuleInfo

+ type TenantModuleRepository interface

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

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

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

+ type TenantModuleSummary struct

+ Core int

+ Disabled int

+ Enabled int

+ Total int

+ type TenantScoringConfigProvider struct

+ func NewTenantScoringConfigProvider(tenantRepo tenant.Repository) *TenantScoringConfigProvider

+ func (p *TenantScoringConfigProvider) GetScoringConfig(ctx context.Context, tenantID shared.ID) (*asset.RiskScoringConfig, error)

type TenantService

+ func (s *TenantService) GetPentestSettings(ctx context.Context, tenantID string) (*tenant.PentestSettings, error)

+ func (s *TenantService) GetRiskScoringSettings(ctx context.Context, tenantID string) (*tenant.RiskScoringSettings, error)

+ func (s *TenantService) LogAuditEvent(ctx context.Context, actx AuditContext, event AuditEvent)

+ func (s *TenantService) UpdatePentestSettings(ctx context.Context, tenantID string, input UpdatePentestSettingsInput, ...) (*tenant.Settings, error)

+ func (s *TenantService) UpdateRiskScoringSettings(ctx context.Context, tenantID string, rs tenant.RiskScoringSettings, ...) (*tenant.Settings, error)

+ type TestRuleFindingSummary struct

+ ID string

+ Message string

+ Severity string

+ Source string

+ ToolName string

+ type TestRuleResult struct

+ MatchingFindings int64

+ RuleID string

+ RuleName string

+ SampleFindings []TestRuleFindingSummary

+ TargetGroupID string

+ type UpdateAssessmentInput struct

+ ActorID string

+ ControlID string

+ DueDate *string

+ FrameworkID string

+ Notes string

+ Owner string

+ Priority string

+ Status string

+ TenantID string

+ type UpdateCampaignInput struct

+ AssetGroupIDs []string

+ AssetIDs []string

+ CampaignID string

+ CampaignType string

+ ClientContact string

+ ClientName string

+ Description string

+ EndDate *string

+ LeadUserID *string

+ Methodology string

+ Name string

+ Objectives []string

+ Priority string

+ RulesOfEngagement map[string]any

+ ScopeItems []map[string]any

+ StartDate *string

+ Tags []string

+ TeamUserIDs []string

+ TenantID string

type UpdateGroupInput

+ NotificationConfig *group.NotificationConfig

+ type UpdatePentestSettingsInput struct

+ CampaignTypes []tenant.ConfigOption

+ Methodologies []tenant.ConfigOption

+ type UpdatePreferencesInput struct

+ EmailDigest *string

+ InAppEnabled *bool

+ MinSeverity *string

+ MutedTypes []string

+ type UpdateProviderInput struct

+ AllowedDomains []string

+ AutoProvision *bool

+ ClientID *string

+ ClientSecret *string

+ DefaultRole *string

+ DisplayName *string

+ ID string

+ IsActive *bool

+ IssuerURL *string

+ Scopes []string

+ TenantID string

+ TenantIdentifier *string

+ type UpdateRuleInput struct

+ Conditions *accesscontrol.AssignmentConditions

+ Description *string

+ IsActive *bool

+ Name *string

+ Options *accesscontrol.AssignmentOptions

+ Priority *int

+ TargetGroupID *string

+ type UpdateScopeRuleInput struct

+ Description *string

+ IsActive *bool

+ MatchAssetGroupIDs []string

+ MatchLogic *string

+ MatchTags []string

+ Name *string

+ OwnershipType *string

+ Priority *int

type VulnerabilityService

+ func (s *VulnerabilityService) ApproveStatus(ctx context.Context, input ApproveStatusInput) (*vulnerability.Approval, error)

+ func (s *VulnerabilityService) BulkUpdateFindingStatus(ctx context.Context, tenantID shared.ID, ids []shared.ID, ...) error

+ func (s *VulnerabilityService) CancelApproval(ctx context.Context, input CancelApprovalInput) (*vulnerability.Approval, error)

+ func (s *VulnerabilityService) GetFindingStatsWithScope(ctx context.Context, input GetFindingStatsInput) (*vulnerability.FindingStats, error)

+ func (s *VulnerabilityService) GetFindingWithScope(ctx context.Context, tenantID, findingID, actingUserID string, isAdmin bool) (*vulnerability.Finding, error)

+ func (s *VulnerabilityService) ListFindingApprovals(ctx context.Context, tenantID, findingID string) ([]*vulnerability.Approval, error)

+ func (s *VulnerabilityService) ListPendingApprovals(ctx context.Context, tenantID string, page, perPage int) (pagination.Result[*vulnerability.Approval], error)

+ func (s *VulnerabilityService) RejectApproval(ctx context.Context, input RejectApprovalInput) (*vulnerability.Approval, error)

+ func (s *VulnerabilityService) RequestApproval(ctx context.Context, input RequestApprovalInput) (*vulnerability.Approval, error)

+ func (s *VulnerabilityService) SetAccessControlRepository(repo accesscontrol.Repository)

+ func (s *VulnerabilityService) SetApprovalRepository(repo vulnerability.ApprovalRepository)

+ func (s *VulnerabilityService) SetAssignmentEngine(engine *AssignmentEngine)

+ func (s *VulnerabilityService) SetOutboxService(db *sql.DB, svc *OutboxService)

+ func (s *VulnerabilityService) SetUserNotificationService(svc *NotificationService)

+ type WebSocketBroadcaster interface

+ BroadcastEvent func(channel string, data any, tenantID string)

type WorkflowExecutorOption

+ func WithExecutorOutboxService(svc *OutboxService) WorkflowExecutorOption

v0.1.1

Feb 12, 2026

v0.1.0

Feb 12, 2026

Changes in this version

+ const MaxChangesSize

+ const MaxConcurrentWorkflowRunsPerTenant

+ const MaxConcurrentWorkflowRunsPerWorkflow

+ const MaxSourcesPerTenant

+ const TypeAITriage

+ var AgentCommandsExecuted = metrics.AgentCommandsExecuted

+ var AgentHeartbeatLatency = metrics.AgentHeartbeatLatency

+ var AgentsOnline = metrics.AgentsOnline

+ var CommandDuration = metrics.CommandDuration

+ var CommandQueueSize = metrics.CommandQueueSize

+ var CommandsExpired = metrics.CommandsExpired

+ var CommandsTotal = metrics.CommandsTotal

+ var ErrAITriageAgentNotAvailable = errors.New("self-hosted agent mode is not available on your current plan")

+ var ErrAITriageBYOKNotAvailable = errors.New("BYOK mode is not available on your current plan")

+ var ErrAITriageNotAvailable = errors.New("AI triage is not available on your current plan")

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

+ var ErrAccountSuspended = errors.New("account is suspended")

+ var ErrAutoTriageNotAvailable = errors.New("auto AI triage is not available on your current plan")

+ var ErrBulkTriageNotAvailable = errors.New("bulk AI triage is not available on your current plan")

+ var ErrEmailAlreadyExists = errors.New("email already exists")

+ var ErrEmailNotVerified = errors.New("email is not verified")

+ var ErrInvalidCredentials = errors.New("invalid email or password")

+ var ErrInvalidProvider = errors.New("invalid OAuth provider")

+ var ErrInvalidResetToken = errors.New("invalid or expired reset token")

+ var ErrInvalidState = errors.New("invalid OAuth state")

+ var ErrInvalidVerificationToken = errors.New("invalid or expired verification token")

+ var ErrNoAgentAvailable = errors.New("no suitable agent available")

+ var ErrOAuthDisabled = errors.New("OAuth is disabled")

+ var ErrOAuthExchangeFailed = errors.New("failed to exchange OAuth code")

+ var ErrOAuthUserInfoFailed = errors.New("failed to get user info from OAuth provider")

+ var ErrPasswordMismatch = errors.New("current password is incorrect")

+ var ErrProviderDisabled = errors.New("OAuth provider is disabled")

+ var ErrRegistrationDisabled = errors.New("registration is disabled")

+ var ErrSessionLimitReached = errors.New("maximum number of active sessions reached")

+ var ErrTenantAccessDenied = errors.New("user does not have access to this tenant")

+ var ErrTenantRequired = errors.New("tenant_id is required")

+ var FindingsAutoResolved = metrics.FindingsAutoResolved

+ var FindingsExpired = metrics.FindingsExpired

+ var PipelineRunDuration = metrics.PipelineRunDuration

+ var PipelineRunsInProgress = metrics.PipelineRunsInProgress

+ var PipelineRunsTotal = metrics.PipelineRunsTotal

+ var ScanFindingsTotal = metrics.ScanFindingsTotal

+ var ScanSchedulerErrors = metrics.ScanSchedulerErrors

+ var ScanSchedulerLag = metrics.ScanSchedulerLag

+ var ScanTriggerDuration = metrics.ScanTriggerDuration

+ var ScansConcurrentRuns = metrics.ScansConcurrentRuns

+ var ScansQualityGateResults = metrics.ScansQualityGateResults

+ var ScansScheduled = metrics.ScansScheduled

+ var ScansTotal = metrics.ScansTotal

+ var StepRetryTotal = metrics.StepRetryTotal

+ var StepRunDuration = metrics.StepRunDuration

+ var StepRunsTotal = metrics.StepRunsTotal

+ var TemplateSyncDuration = metrics.TemplateSyncDuration

+ var TemplateSyncsFailedTotal = metrics.TemplateSyncsFailedTotal

+ var TemplateSyncsSuccessTotal = metrics.TemplateSyncsSuccessTotal

+ var TemplateSyncsTotal = metrics.TemplateSyncsTotal

+ var ValidTiers = []string

+ func CheckTokenLimit(usedTokens, limitTokens int) error

+ func ComputeContentHash(content []byte) string

+ func GenerateBundleVersion(timestamp time.Time, contentHash string) string

+ func MaskAPIKey(key string) string

+ func NewPipelineAgentSelectorAdapter(selector *AgentSelector) pipeline.AgentSelector

+ func NewPipelineAuditServiceAdapter(svc *AuditService) pipeline.AuditService

+ func NewPipelineSecurityValidatorAdapter(validator *SecurityValidator) pipeline.SecurityValidator

+ func NewScanAgentSelectorAdapter(selector *AgentSelector) scan.AgentSelector

+ func NewScanAuditServiceAdapter(svc *AuditService) scan.AuditService

+ func NewScanSecurityValidatorAdapter(validator *SecurityValidator) scan.SecurityValidator

+ func NewScanTemplateSyncerAdapter(syncer *TemplateSyncer) scan.TemplateSyncer

+ func RegisterAllActionHandlers(executor *WorkflowExecutor, vulnSvc *VulnerabilityService, ...)

+ func RegisterAllActionHandlersWithAI(executor *WorkflowExecutor, vulnSvc *VulnerabilityService, ...)

+ func SanitizeTier(tier string) string

+ func ValidateSourceFilter(ctx context.Context, config map[string]any, ...) error

+ type AIConfigInfo struct

+ AutoTriageEnabled bool

+ AutoTriageSeverities []string

+ IsEnabled bool

+ Mode string

+ Model string

+ MonthlyTokenLimit int

+ Provider string

+ TokensUsedThisMonth int

+ type AITriageActionHandler struct

+ func NewAITriageActionHandler(aiTriageSvc *AITriageService, log *logger.Logger) *AITriageActionHandler

+ func (h *AITriageActionHandler) Execute(ctx context.Context, input *ActionInput) (map[string]any, error)

+ type AITriageEvent struct

+ EventType workflow.TriggerType

+ FindingID shared.ID

+ TenantID shared.ID

+ TriageData map[string]any

+ TriageID shared.ID

+ type AITriageJobEnqueuer interface

+ EnqueueAITriage func(ctx context.Context, resultID, tenantID, findingID string, delay time.Duration) error

+ type AITriageModuleChecker interface

+ GetTenantModuleLimit func(ctx context.Context, tenantID, moduleID, metric string) (*GetModuleLimitOutput, error)

+ TenantHasModule func(ctx context.Context, tenantID, moduleID string) (bool, error)

+ type AITriageService struct

+ func NewAITriageService(triageRepo aitriage.Repository, findingRepo vulnerability.FindingRepository, ...) *AITriageService

+ func (s *AITriageService) EnqueueAutoTriage(ctx context.Context, tenantID, findingID shared.ID) error

+ func (s *AITriageService) GetAIConfig(ctx context.Context, tenantID string) (*AIConfigInfo, error)

+ func (s *AITriageService) GetLatestTriageByFinding(ctx context.Context, tenantID, findingID string) (*TriageResultResponse, error)

+ func (s *AITriageService) GetPlanTokenLimit(ctx context.Context, tenantID string) (int64, error)

+ func (s *AITriageService) GetTriageResult(ctx context.Context, tenantID, resultID string) (*TriageResultResponse, error)

+ func (s *AITriageService) ListTriageHistory(ctx context.Context, tenantID, findingID string, limit, offset int) ([]*TriageResultResponse, int, error)

+ func (s *AITriageService) ProcessTriage(ctx context.Context, resultID, tenantID, findingID shared.ID) error

+ func (s *AITriageService) RecoverStuckJobs(ctx context.Context, input RecoverStuckJobsInput) (*RecoverStuckJobsOutput, error)

+ func (s *AITriageService) RequestBulkTriage(ctx context.Context, req BulkTriageRequest) (*BulkTriageResponse, error)

+ func (s *AITriageService) RequestTriage(ctx context.Context, req TriageRequest) (*TriageResponse, error)

+ func (s *AITriageService) SetAuditService(auditSvc *AuditService)

+ func (s *AITriageService) SetJobEnqueuer(enqueuer AITriageJobEnqueuer)

+ func (s *AITriageService) SetLicenseChecker(checker AITriageModuleChecker)

+ func (s *AITriageService) SetTriageBroadcaster(broadcaster TriageBroadcaster)

+ func (s *AITriageService) SetWorkflowDispatcher(dispatcher WorkflowEventDispatcherInterface)

+ func (s *AITriageService) ShouldAutoTriage(ctx context.Context, tenantID shared.ID, severity string) (bool, error)

+ type APIKeyEncryptionService struct

+ func NewAPIKeyEncryptionService(encryptor crypto.Encryptor) *APIKeyEncryptionService

+ func (s *APIKeyEncryptionService) DecryptAPIKey(encryptedKey string) (string, error)

+ func (s *APIKeyEncryptionService) EncryptAPIKey(plainKey string) (string, error)

+ func (s *APIKeyEncryptionService) IsEncrypted(key string) bool

+ type APIKeyService struct

+ func NewAPIKeyService(repo apikey.Repository, log *logger.Logger) *APIKeyService

+ func (s *APIKeyService) CreateAPIKey(ctx context.Context, input CreateAPIKeyInput) (*CreateAPIKeyResult, error)

+ func (s *APIKeyService) DeleteAPIKey(ctx context.Context, id, tenantIDStr string) error

+ func (s *APIKeyService) GetAPIKey(ctx context.Context, id, tenantIDStr string) (*apikey.APIKey, error)

+ func (s *APIKeyService) ListAPIKeys(ctx context.Context, input ListAPIKeysInput) (apikey.ListResult, error)

+ func (s *APIKeyService) RevokeAPIKey(ctx context.Context, input RevokeAPIKeyInput) (*apikey.APIKey, error)

+ type AcceptInvitationWithRefreshTokenInput struct

+ InvitationToken string

+ RefreshToken string

+ type AcceptInvitationWithRefreshTokenResult struct

+ AccessToken string

+ ExpiresAt time.Time

+ RefreshToken string

+ Role string

+ Tenant TenantMembershipInfo

+ type ActionHandler interface

+ Execute func(ctx context.Context, input *ActionInput) (map[string]any, error)

+ type ActionInput struct

+ ActionConfig map[string]any

+ ActionType workflow.ActionType

+ Context map[string]any

+ NodeKey string

+ RunID shared.ID

+ TenantID shared.ID

+ TriggerData map[string]any

+ WorkflowID shared.ID

+ type ActivityBroadcaster interface

+ BroadcastActivity func(channel string, data any, tenantID string)

+ type ActivityItem struct

+ Description string

+ Timestamp time.Time

+ Title string

+ Type string

+ type AddCommentInput struct

+ AuthorID string

+ Content string

+ FindingID string

+ TenantID string

+ type AddEdgeInput struct

+ Label string

+ SourceHandle string

+ SourceNodeKey string

+ TargetNodeKey string

+ TenantID shared.ID

+ UserID shared.ID

+ WorkflowID shared.ID

+ type AddGroupMemberInput struct

+ GroupID string

+ Role string

+ UserID shared.ID

+ type AddMemberInput struct

+ Role string

+ UserID shared.ID

+ type AddNodeInput struct

+ Config workflow.NodeConfig

+ Description string

+ Name string

+ NodeKey string

+ NodeType workflow.NodeType

+ TenantID shared.ID

+ UIPositionX float64

+ UIPositionY float64

+ UserID shared.ID

+ WorkflowID shared.ID

+ type AddPermissionToSetInput struct

+ ModificationType string

+ PermissionID string

+ PermissionSetID string

+ type AddStatusChangeCommentInput struct

+ AuthorID string

+ Content string

+ FindingID string

+ NewStatus string

+ OldStatus string

+ type AgentAvailabilityResult struct

+ Available bool

+ HasTenantAgent bool

+ Message string

+ type AgentHeartbeatData struct

+ CPUPercent float64

+ CurrentJobs int

+ Hostname string

+ MemoryPercent float64

+ Region string

+ Version string

+ type AgentHeartbeatInput struct

+ AgentID shared.ID

+ Hostname string

+ IPAddress string

+ Message string

+ Status string

+ Version string

+ type AgentSelectionMode string

+ const SelectAny

+ const SelectTenantOnly

+ type AgentSelector struct

+ func NewAgentSelector(agentRepo agent.Repository, commandRepo command.Repository, ...) *AgentSelector

+ func (s *AgentSelector) CheckAgentAvailability(ctx context.Context, tenantID shared.ID, toolName string, tenantOnly bool) *AgentAvailabilityResult

+ func (s *AgentSelector) SelectAgent(ctx context.Context, req SelectAgentRequest) (*SelectAgentResult, error)

+ type AgentService struct

+ func NewAgentService(repo agent.Repository, auditService *AuditService, log *logger.Logger) *AgentService

+ func (s *AgentService) ActivateAgent(ctx context.Context, tenantID, agentID string, auditCtx *AuditContext) (*agent.Agent, error)

+ func (s *AgentService) AuthenticateByAPIKey(ctx context.Context, apiKey string) (*agent.Agent, error)

+ func (s *AgentService) ClaimJob(ctx context.Context, agentID shared.ID) error

+ func (s *AgentService) CreateAgent(ctx context.Context, input CreateAgentInput) (*CreateAgentOutput, error)

+ func (s *AgentService) DeleteAgent(ctx context.Context, tenantID, agentID string, auditCtx *AuditContext) error

+ func (s *AgentService) DisableAgent(ctx context.Context, tenantID, agentID, reason string, auditCtx *AuditContext) (*agent.Agent, error)

+ func (s *AgentService) FindAvailableAgents(ctx context.Context, tenantID shared.ID, capabilities []string, tool string) ([]*agent.Agent, error)

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

+ func (s *AgentService) GetAgent(ctx context.Context, tenantID, agentID string) (*agent.Agent, error)

+ func (s *AgentService) GetAvailableCapabilitiesForTenant(ctx context.Context, tenantID shared.ID) (*TenantAvailableCapabilitiesOutput, error)

+ func (s *AgentService) HasCapability(ctx context.Context, tenantID shared.ID, capability string) (bool, error)

+ func (s *AgentService) Heartbeat(ctx context.Context, input AgentHeartbeatInput) error

+ func (s *AgentService) IncrementStats(ctx context.Context, agentID shared.ID, findings, scans, errors int64) error

+ func (s *AgentService) ListAgents(ctx context.Context, input ListAgentsInput) (pagination.Result[*agent.Agent], error)

+ func (s *AgentService) RegenerateAPIKey(ctx context.Context, tenantID, agentID string, auditCtx *AuditContext) (string, error)

+ func (s *AgentService) ReleaseJob(ctx context.Context, agentID shared.ID) error

+ func (s *AgentService) RevokeAgent(ctx context.Context, tenantID, agentID, reason string, auditCtx *AuditContext) (*agent.Agent, error)

+ func (s *AgentService) UpdateAgent(ctx context.Context, input UpdateAgentInput) (*agent.Agent, error)

+ func (s *AgentService) UpdateHeartbeat(ctx context.Context, agentID shared.ID, data AgentHeartbeatData) error

+ type AssetChange struct

+ AssetName string

+ AssetType string

+ Timestamp time.Time

+ Type string

+ type AssetGroupService struct

+ func NewAssetGroupService(repo assetgroup.Repository, log *logger.Logger) *AssetGroupService

+ func (s *AssetGroupService) AddAssetsToGroup(ctx context.Context, groupID shared.ID, assetIDs []string) error

+ func (s *AssetGroupService) BulkDeleteAssetGroups(ctx context.Context, groupIDs []string) (int, error)

+ func (s *AssetGroupService) BulkUpdateAssetGroups(ctx context.Context, input BulkUpdateInput) (int, error)

+ func (s *AssetGroupService) CreateAssetGroup(ctx context.Context, input CreateAssetGroupInput) (*assetgroup.AssetGroup, error)

+ func (s *AssetGroupService) DeleteAssetGroup(ctx context.Context, id shared.ID) error

+ func (s *AssetGroupService) GetAssetGroup(ctx context.Context, id shared.ID) (*assetgroup.AssetGroup, error)

+ func (s *AssetGroupService) GetAssetGroupStats(ctx context.Context, tenantID string) (*assetgroup.Stats, error)

+ func (s *AssetGroupService) GetGroupAssets(ctx context.Context, groupID shared.ID, pageNum, perPage int) (pagination.Result[*assetgroup.GroupAsset], error)

+ func (s *AssetGroupService) GetGroupFindings(ctx context.Context, groupID shared.ID, pageNum, perPage int) (pagination.Result[*assetgroup.GroupFinding], error)

+ func (s *AssetGroupService) ListAssetGroups(ctx context.Context, input ListAssetGroupsInput) (*ListAssetGroupsOutput, error)

+ func (s *AssetGroupService) RemoveAssetsFromGroup(ctx context.Context, groupID shared.ID, assetIDs []string) error

+ func (s *AssetGroupService) UpdateAssetGroup(ctx context.Context, id shared.ID, input UpdateAssetGroupInput) (*assetgroup.AssetGroup, error)

+ type AssetRelationshipService struct

+ func NewAssetRelationshipService(relRepo asset.RelationshipRepository, assetRepo asset.Repository, ...) *AssetRelationshipService

+ func (s *AssetRelationshipService) CreateRelationship(ctx context.Context, input CreateRelationshipInput) (*asset.RelationshipWithAssets, error)

+ func (s *AssetRelationshipService) DeleteRelationship(ctx context.Context, tenantID, relationshipID string) error

+ func (s *AssetRelationshipService) GetRelationship(ctx context.Context, tenantID, relationshipID string) (*asset.RelationshipWithAssets, error)

+ func (s *AssetRelationshipService) ListAssetRelationships(ctx context.Context, tenantID, assetID string, filter asset.RelationshipFilter) ([]*asset.RelationshipWithAssets, int64, error)

+ func (s *AssetRelationshipService) UpdateRelationship(ctx context.Context, tenantID, relationshipID string, ...) (*asset.RelationshipWithAssets, error)

+ type AssetService struct

+ func NewAssetService(repo asset.Repository, log *logger.Logger) *AssetService

+ func (s *AssetService) ActivateAsset(ctx context.Context, tenantID, assetID string) (*asset.Asset, error)

+ func (s *AssetService) ArchiveAsset(ctx context.Context, tenantID, assetID string) (*asset.Asset, error)

+ func (s *AssetService) BulkUpdateAssetStatus(ctx context.Context, tenantID string, input BulkUpdateAssetStatusInput) (*BulkAssetStatusResult, error)

+ func (s *AssetService) CreateAsset(ctx context.Context, input CreateAssetInput) (*asset.Asset, error)

+ func (s *AssetService) CreateRepositoryAsset(ctx context.Context, input CreateRepositoryAssetInput) (*asset.Asset, *asset.RepositoryExtension, error)

+ func (s *AssetService) DeactivateAsset(ctx context.Context, tenantID, assetID string) (*asset.Asset, error)

+ func (s *AssetService) DeleteAsset(ctx context.Context, assetID string, tenantID string) error

+ func (s *AssetService) DisableRepositoryScan(ctx context.Context, assetID string) error

+ func (s *AssetService) EnableRepositoryScan(ctx context.Context, assetID string, schedule string) error

+ func (s *AssetService) GetAsset(ctx context.Context, tenantID, assetID string) (*asset.Asset, error)

+ func (s *AssetService) GetAssetByExternalID(ctx context.Context, tenantID, provider, externalID string) (*asset.Asset, error)

+ func (s *AssetService) GetAssetWithRepository(ctx context.Context, tenantID, assetID string) (*asset.Asset, *asset.RepositoryExtension, error)

+ func (s *AssetService) GetRepositoryExtension(ctx context.Context, tenantID, assetID string) (*asset.RepositoryExtension, error)

+ func (s *AssetService) HasRepositoryExtensionRepository() bool

+ func (s *AssetService) ListAssets(ctx context.Context, input ListAssetsInput) (pagination.Result[*asset.Asset], error)

+ func (s *AssetService) MarkAssetSyncFailed(ctx context.Context, tenantID, assetID string, syncError string) (*asset.Asset, error)

+ func (s *AssetService) MarkAssetSynced(ctx context.Context, tenantID, assetID string) (*asset.Asset, error)

+ func (s *AssetService) MarkAssetSyncing(ctx context.Context, tenantID, assetID string) (*asset.Asset, error)

+ func (s *AssetService) RecordRepositoryScan(ctx context.Context, assetID string) error

+ func (s *AssetService) SetAssetGroupRepository(repo assetgroup.Repository)

+ func (s *AssetService) SetRepositoryExtensionRepository(repo asset.RepositoryExtensionRepository)

+ func (s *AssetService) UpdateAsset(ctx context.Context, assetID string, tenantID string, input UpdateAssetInput) (*asset.Asset, error)

+ func (s *AssetService) UpdateFindingCount(ctx context.Context, tenantID, assetID string, count int) error

+ func (s *AssetService) UpdateRepositoryExtension(ctx context.Context, tenantID, assetID string, ...) (*asset.RepositoryExtension, error)

+ func (s *AssetService) UpdateRepositoryFindingCount(ctx context.Context, assetID string, count int) error

+ type AssetStatsData struct

+ AverageRiskScore float64

+ ByStatus map[string]int

+ ByType map[string]int

+ Total int

+ type AssetTypeBreakdown struct

+ Exposed int

+ Total int

+ Type string

+ type AssetTypeService struct

+ func NewAssetTypeService(repo assettype.Repository, categoryRepo assettype.CategoryRepository, ...) *AssetTypeService

+ func (s *AssetTypeService) GetAssetType(ctx context.Context, assetTypeID string) (*assettype.AssetType, error)

+ func (s *AssetTypeService) GetAssetTypeByCode(ctx context.Context, code string) (*assettype.AssetType, error)

+ func (s *AssetTypeService) GetCategory(ctx context.Context, categoryID string) (*assettype.Category, error)

+ func (s *AssetTypeService) GetCategoryByCode(ctx context.Context, code string) (*assettype.Category, error)

+ func (s *AssetTypeService) ListActiveAssetTypes(ctx context.Context) ([]*assettype.AssetType, error)

+ func (s *AssetTypeService) ListActiveAssetTypesByCategory(ctx context.Context, categoryID string) ([]*assettype.AssetType, error)

+ func (s *AssetTypeService) ListActiveCategories(ctx context.Context) ([]*assettype.Category, error)

+ func (s *AssetTypeService) ListAssetTypes(ctx context.Context, filter assettype.Filter, opts assettype.ListOptions, ...) (pagination.Result[*assettype.AssetType], error)

+ func (s *AssetTypeService) ListAssetTypesWithCategory(ctx context.Context, filter assettype.Filter, opts assettype.ListOptions, ...) (pagination.Result[*assettype.AssetTypeWithCategory], error)

+ func (s *AssetTypeService) ListCategories(ctx context.Context, filter assettype.CategoryFilter, ...) (pagination.Result[*assettype.Category], error)

+ type AssignAssetInput struct

+ AssetID string

+ GroupID string

+ OwnershipType string

+ type AssignPermissionSetInput struct

+ GroupID string

+ PermissionSetID string

+ type AssignRoleInput struct

+ RoleID string

+ TenantID string

+ UserID string

+ type AttackSurfaceRepository interface

+ GetExposedServices func(ctx context.Context, tenantID shared.ID, limit int) ([]ExposedService, error)

+ GetRecentChanges func(ctx context.Context, tenantID shared.ID, limit int) ([]AssetChange, error)

+ GetStats func(ctx context.Context, tenantID shared.ID) (*AttackSurfaceStatsData, error)

+ GetStatsWithTrends func(ctx context.Context, tenantID shared.ID) (*AttackSurfaceStatsData, error)

+ type AttackSurfaceService struct

+ func NewAttackSurfaceService(assetRepo asset.Repository, log *logger.Logger) *AttackSurfaceService

+ func (s *AttackSurfaceService) GetStats(ctx context.Context, tenantID shared.ID) (*AttackSurfaceStats, error)

+ type AttackSurfaceStats struct

+ AssetBreakdown []AssetTypeBreakdown

+ CriticalExposures int

+ CriticalExposuresChange int

+ ExposedServices int

+ ExposedServicesChange int

+ ExposedServicesList []ExposedService

+ RecentChanges []AssetChange

+ RiskScore float64

+ TotalAssets int

+ TotalAssetsChange int

+ type AttackSurfaceStatsData struct

+ AverageRiskScore float64

+ ByType map[string]int

+ CriticalExposures int

+ CriticalExposuresChange int

+ ExposedByType map[string]int

+ ExposedServices int

+ ExposedServicesChange int

+ TotalAssets int

+ TotalAssetsChange int

+ type AuditContext struct

+ ActorEmail string

+ ActorID string

+ ActorIP string

+ RequestID string

+ SessionID string

+ TenantID string

+ UserAgent string

+ type AuditEvent struct

+ Action audit.Action

+ Changes *audit.Changes

+ Message string

+ Metadata map[string]any

+ ResourceID string

+ ResourceName string

+ ResourceType audit.ResourceType

+ Result audit.Result

+ Severity audit.Severity

+ func NewDeniedEvent(action audit.Action, resourceType audit.ResourceType, resourceID string, ...) AuditEvent

+ func NewFailureEvent(action audit.Action, resourceType audit.ResourceType, resourceID string, ...) AuditEvent

+ func NewSuccessEvent(action audit.Action, resourceType audit.ResourceType, resourceID string) AuditEvent

+ func (e AuditEvent) WithChanges(changes *audit.Changes) AuditEvent

+ func (e AuditEvent) WithMessage(message string) AuditEvent

+ func (e AuditEvent) WithMetadata(key string, value any) AuditEvent

+ func (e AuditEvent) WithResourceName(name string) AuditEvent

+ func (e AuditEvent) WithSeverity(severity audit.Severity) AuditEvent

+ type AuditService struct

+ func NewAuditService(repo audit.Repository, log *logger.Logger) *AuditService

+ func (s *AuditService) CleanupOldLogs(ctx context.Context, retentionDays int) (int64, error)

+ func (s *AuditService) GetActionCount(ctx context.Context, tenantID string, action audit.Action, since time.Time) (int64, error)

+ func (s *AuditService) GetAuditLog(ctx context.Context, auditLogID string) (*audit.AuditLog, error)

+ func (s *AuditService) GetResourceHistory(ctx context.Context, resourceType, resourceID string, page, perPage int) (pagination.Result[*audit.AuditLog], error)

+ func (s *AuditService) GetUserActivity(ctx context.Context, userID string, page, perPage int) (pagination.Result[*audit.AuditLog], error)

+ func (s *AuditService) ListAuditLogs(ctx context.Context, input ListAuditLogsInput) (pagination.Result[*audit.AuditLog], error)

+ func (s *AuditService) LogAgentActivated(ctx context.Context, actx AuditContext, agentID, agentName string) error

+ func (s *AuditService) LogAgentConnected(ctx context.Context, actx AuditContext, agentID, agentName, ipAddress string) error

+ func (s *AuditService) LogAgentCreated(ctx context.Context, actx AuditContext, agentID, agentName, agentType string) error

+ func (s *AuditService) LogAgentDeactivated(ctx context.Context, actx AuditContext, agentID, agentName, reason string) error

+ func (s *AuditService) LogAgentDeleted(ctx context.Context, actx AuditContext, agentID, agentName string) error

+ func (s *AuditService) LogAgentDisconnected(ctx context.Context, actx AuditContext, agentID, agentName string) error

+ func (s *AuditService) LogAgentKeyRegenerated(ctx context.Context, actx AuditContext, agentID, agentName string) error

+ func (s *AuditService) LogAgentRevoked(ctx context.Context, actx AuditContext, agentID, agentName, reason string) error

+ func (s *AuditService) LogAgentUpdated(ctx context.Context, actx AuditContext, agentID, agentName string, ...) error

+ func (s *AuditService) LogAuthFailed(ctx context.Context, actx AuditContext, reason string) error

+ func (s *AuditService) LogCredentialAccessed(ctx context.Context, actx AuditContext, credID, name string) error

+ func (s *AuditService) LogCredentialCreated(ctx context.Context, actx AuditContext, credID, name, credType string) error

+ func (s *AuditService) LogCredentialDeleted(ctx context.Context, actx AuditContext, credID string) error

+ func (s *AuditService) LogCredentialUpdated(ctx context.Context, actx AuditContext, credID, name string) error

+ func (s *AuditService) LogEvent(ctx context.Context, actx AuditContext, event AuditEvent) error

+ func (s *AuditService) LogInvitationAccepted(ctx context.Context, actx AuditContext, invitationID, email string) error

+ func (s *AuditService) LogInvitationCreated(ctx context.Context, actx AuditContext, invitationID, email, role string) error

+ func (s *AuditService) LogMemberAdded(ctx context.Context, actx AuditContext, membershipID, email, role string) error

+ func (s *AuditService) LogMemberRemoved(ctx context.Context, actx AuditContext, membershipID, email string) error

+ func (s *AuditService) LogMemberRoleChanged(ctx context.Context, actx AuditContext, ...) error

+ func (s *AuditService) LogPermissionDenied(ctx context.Context, actx AuditContext, resourceType audit.ResourceType, ...) error

+ func (s *AuditService) LogRuleOverrideCreated(ctx context.Context, actx AuditContext, overrideID, pattern string) error

+ func (s *AuditService) LogRuleOverrideDeleted(ctx context.Context, actx AuditContext, overrideID, pattern string) error

+ func (s *AuditService) LogRuleOverrideUpdated(ctx context.Context, actx AuditContext, overrideID, pattern string) error

+ func (s *AuditService) LogRuleSourceCreated(ctx context.Context, actx AuditContext, sourceID, name, sourceType string) error

+ func (s *AuditService) LogRuleSourceDeleted(ctx context.Context, actx AuditContext, sourceID, name string) error

+ func (s *AuditService) LogRuleSourceUpdated(ctx context.Context, actx AuditContext, sourceID, name string) error

+ func (s *AuditService) LogUserCreated(ctx context.Context, actx AuditContext, userID, email string) error

+ func (s *AuditService) LogUserLogin(ctx context.Context, actx AuditContext, userID, email string) error

+ func (s *AuditService) LogUserLogout(ctx context.Context, actx AuditContext, userID, email string) error

+ func (s *AuditService) LogUserRegistered(ctx context.Context, actx AuditContext, userID, email string) error

+ func (s *AuditService) LogUserSuspended(ctx context.Context, actx AuditContext, userID, email, reason string) error

+ func (s *AuditService) LogUserUpdated(ctx context.Context, actx AuditContext, userID, email string, ...) error

+ type AuthService struct

+ func NewAuthService(userRepo user.Repository, sessionRepo session.Repository, ...) *AuthService

+ func (s *AuthService) AcceptInvitationWithRefreshToken(ctx context.Context, input AcceptInvitationWithRefreshTokenInput) (*AcceptInvitationWithRefreshTokenResult, error)

+ func (s *AuthService) ChangePassword(ctx context.Context, userID string, input ChangePasswordInput) error

+ func (s *AuthService) CreateFirstTeam(ctx context.Context, input CreateFirstTeamInput) (*CreateFirstTeamResult, error)

+ func (s *AuthService) ExchangeToken(ctx context.Context, input ExchangeTokenInput) (*ExchangeTokenResult, error)

+ func (s *AuthService) ForgotPassword(ctx context.Context, input ForgotPasswordInput) (*ForgotPasswordResult, error)

+ func (s *AuthService) GenerateWSToken(ctx context.Context, userID, tenantID string) (string, error)

+ func (s *AuthService) Login(ctx context.Context, input LoginInput) (*LoginResult, error)

+ func (s *AuthService) Logout(ctx context.Context, sessionID string) error

+ func (s *AuthService) RefreshToken(ctx context.Context, input RefreshTokenInput) (*RefreshTokenResult, error)

+ func (s *AuthService) Register(ctx context.Context, input RegisterInput) (*RegisterResult, error)

+ func (s *AuthService) ResetPassword(ctx context.Context, input ResetPasswordInput) error

+ func (s *AuthService) SetRoleService(roleService *RoleService)

+ func (s *AuthService) ValidateAccessToken(tokenString string) (*jwt.Claims, error)

+ func (s *AuthService) VerifyEmail(ctx context.Context, token string) error

+ type AuthorizationURLInput struct

+ FinalRedirect string

+ Provider OAuthProvider

+ RedirectURI string

+ type AuthorizationURLResult struct

+ AuthorizationURL string

+ State string

+ type BranchService struct

+ func NewBranchService(repo branch.Repository, log *logger.Logger) *BranchService

+ func (s *BranchService) CountRepositoryBranches(ctx context.Context, repositoryID string) (int64, error)

+ func (s *BranchService) CreateBranch(ctx context.Context, input CreateBranchInput) (*branch.Branch, error)

+ func (s *BranchService) DeleteBranch(ctx context.Context, branchID, repositoryID string) error

+ func (s *BranchService) GetBranch(ctx context.Context, branchID string) (*branch.Branch, error)

+ func (s *BranchService) GetBranchByName(ctx context.Context, repositoryID, name string) (*branch.Branch, error)

+ func (s *BranchService) GetDefaultBranch(ctx context.Context, repositoryID string) (*branch.Branch, error)

+ func (s *BranchService) ListBranches(ctx context.Context, input ListBranchesInput) (pagination.Result[*branch.Branch], error)

+ func (s *BranchService) ListRepositoryBranches(ctx context.Context, repositoryID string) ([]*branch.Branch, error)

+ func (s *BranchService) SetDefaultBranch(ctx context.Context, branchID, repositoryID string) (*branch.Branch, error)

+ func (s *BranchService) UpdateBranch(ctx context.Context, branchID, repositoryID string, input UpdateBranchInput) (*branch.Branch, error)

+ func (s *BranchService) UpdateBranchScanStatus(ctx context.Context, branchID, repositoryID string, ...) (*branch.Branch, error)

+ type BranchTypeRuleInput struct

+ BranchType string

+ MatchType string

+ Pattern string

+ type BroadcastNotificationInput struct

+ Body string

+ EventType integration.EventType

+ Fields map[string]string

+ Severity string

+ TenantID string

+ Title string

+ URL string

+ type BulkAssetStatusResult struct

+ Errors []string

+ Failed int

+ Updated int

+ type BulkAssignInput struct

+ AssignerID string

+ FindingIDs []string

+ UserID string

+ type BulkAssignRoleToUsersInput struct

+ RoleID string

+ TenantID string

+ UserIDs []string

+ type BulkAssignRoleToUsersResult struct

+ FailedCount int

+ FailedUsers []string

+ SuccessCount int

+ type BulkDisableToolsInput struct

+ TenantID string

+ ToolIDs []string

+ type BulkEnableToolsInput struct

+ TenantID string

+ ToolIDs []string

+ type BulkTriageJob struct

+ Error string

+ FindingID string

+ JobID string

+ Status string

+ type BulkTriageRequest struct

+ FindingIDs []string

+ TenantID string

+ UserID *string

+ type BulkTriageResponse struct

+ Failed int

+ Jobs []BulkTriageJob

+ Queued int

+ TotalCount int

+ type BulkUpdateAssetStatusInput struct

+ AssetIDs []string

+ Status string

+ type BulkUpdateInput struct

+ Criticality *string

+ Environment *string

+ GroupIDs []string

+ type BulkUpdateResult struct

+ Errors []string

+ Failed int

+ Updated int

+ type BulkUpdateStatusInput struct

+ ActorID string

+ FindingIDs []string

+ Resolution string

+ Status string

+ type CachedCategory struct

+ Code string

+ Description string

+ DisplayOrder int

+ ID string

+ Icon string

+ Name string

+ type CachedFindingSource struct

+ CategoryCode string

+ CategoryID string

+ CategoryName string

+ Code string

+ Color string

+ Description string

+ DisplayOrder int

+ ID string

+ Icon string

+ IsSystem bool

+ Name string

+ type CachedFindingSources struct

+ ByCategory map[string][]int

+ ByCode map[string]int

+ CachedAt time.Time

+ Categories []*CachedCategory

+ Sources []*CachedFindingSource

+ type CachedModule struct

+ Category string

+ Description string

+ DisplayOrder int

+ EventTypes []string

+ ID string

+ Icon string

+ IsActive bool

+ Name string

+ ParentModuleID *string

+ ReleaseStatus string

+ Slug string

+ type CachedTenantModules struct

+ CachedAt time.Time

+ EventTypes map[string][]string

+ ModuleIDs []string

+ Modules []*CachedModule

+ SubModules map[string][]*CachedModule

+ func (c *CachedTenantModules) ToModules() []*module.Module

+ func (c *CachedTenantModules) ToSubModulesMap() map[string][]*module.Module

+ type CallbackInput struct

+ Code string

+ Provider OAuthProvider

+ RedirectURI string

+ State string

+ type CallbackResult struct

+ AccessToken string

+ ExpiresIn int64

+ RefreshToken string

+ TokenType string

+ User *user.User

+ type CapabilityService struct

+ func NewCapabilityService(repo capability.Repository, auditService *AuditService, log *logger.Logger) *CapabilityService

+ func (s *CapabilityService) CreateCapability(ctx context.Context, input CreateCapabilityInput) (*capability.Capability, error)

+ func (s *CapabilityService) DeleteCapability(ctx context.Context, input DeleteCapabilityInput) error

+ func (s *CapabilityService) GetCapabilitiesUsageStatsBatch(ctx context.Context, tenantIDStr string, capabilityIDs []string) (map[string]*CapabilityUsageStatsOutput, error)

+ func (s *CapabilityService) GetCapability(ctx context.Context, id string) (*capability.Capability, error)

+ func (s *CapabilityService) GetCapabilityUsageStats(ctx context.Context, tenantIDStr string, capabilityID string) (*CapabilityUsageStatsOutput, error)

+ func (s *CapabilityService) GetCategories(ctx context.Context) ([]string, error)

+ func (s *CapabilityService) ListAllCapabilities(ctx context.Context, tenantID string) ([]*capability.Capability, error)

+ func (s *CapabilityService) ListCapabilities(ctx context.Context, input ListCapabilitiesInput) (pagination.Result[*capability.Capability], error)

+ func (s *CapabilityService) ListCapabilitiesByCategory(ctx context.Context, tenantID string, category string) ([]*capability.Capability, error)

+ func (s *CapabilityService) ListCapabilitiesByNames(ctx context.Context, tenantID string, names []string) ([]*capability.Capability, error)

+ func (s *CapabilityService) UpdateCapability(ctx context.Context, input UpdateCapabilityInput) (*capability.Capability, error)

+ type CapabilityUsageStatsOutput struct

+ AgentCount int

+ AgentNames []string

+ ToolCount int

+ ToolNames []string

+ type ChangePasswordInput struct

+ CurrentPassword string

+ NewPassword string

+ type ChangeStateInput struct

+ ExposureID string

+ NewState string

+ Reason string

+ UserID string

+ type ClassifyFindingInput struct

+ CVEID string

+ CVSSScore *float64

+ CVSSVector string

+ CWEIDs []string

+ OWASPIDs []string

+ type CloneScanProfileInput struct

+ NewName string

+ ProfileID string

+ TenantID string

+ UserID string

+ type CommandExpirationChecker struct

+ func NewCommandExpirationChecker(commandRepo command.Repository, pipelineService *pipeline.Service, ...) *CommandExpirationChecker

+ func (c *CommandExpirationChecker) Start()

+ func (c *CommandExpirationChecker) Stop()

+ type CommandExpirationCheckerConfig struct

+ CheckInterval time.Duration

+ type CommandService struct

+ func NewCommandService(repo command.Repository, log *logger.Logger) *CommandService

+ func (s *CommandService) AcknowledgeCommand(ctx context.Context, tenantID, commandID string) (*command.Command, error)

+ func (s *CommandService) CancelCommand(ctx context.Context, tenantID, commandID string) (*command.Command, error)

+ func (s *CommandService) CompleteCommand(ctx context.Context, input CompleteCommandInput) (*command.Command, error)

+ func (s *CommandService) CreateCommand(ctx context.Context, input CreateCommandInput) (*command.Command, error)

+ func (s *CommandService) DeleteCommand(ctx context.Context, tenantID, commandID string) error

+ func (s *CommandService) ExpireOldCommands(ctx context.Context) (int64, error)

+ func (s *CommandService) FailCommand(ctx context.Context, input FailCommandInput) (*command.Command, error)

+ func (s *CommandService) GetCommand(ctx context.Context, tenantID, commandID string) (*command.Command, error)

+ func (s *CommandService) ListCommands(ctx context.Context, input ListCommandsInput) (pagination.Result[*command.Command], error)

+ func (s *CommandService) PollCommands(ctx context.Context, input PollCommandsInput) ([]*command.Command, error)

+ func (s *CommandService) StartCommand(ctx context.Context, tenantID, commandID string) (*command.Command, error)

+ type CompleteBundleInput struct

+ BundleID string

+ ContentHash string

+ ExpiresAt *string

+ RuleCount int

+ SizeBytes int64

+ SourceCount int

+ SourceHashes map[string]string

+ Version string

+ type CompleteCommandInput struct

+ CommandID string

+ Result json.RawMessage

+ TenantID string

+ type CompleteToolExecutionInput struct

+ ExecutionID string

+ FindingsCount int

+ OutputSummary map[string]any

+ type ComponentService struct

+ func NewComponentService(repo component.Repository, log *logger.Logger) *ComponentService

+ func (s *ComponentService) CreateComponent(ctx context.Context, input CreateComponentInput) (*component.Component, error)

+ func (s *ComponentService) DeleteAssetComponents(ctx context.Context, assetID string) error

+ func (s *ComponentService) DeleteComponent(ctx context.Context, dependencyID string, tenantID string) error

+ func (s *ComponentService) GetComponent(ctx context.Context, componentID string) (*component.Component, error)

+ func (s *ComponentService) GetComponentByPURL(ctx context.Context, tenantID, purl string) (*component.Component, error)

+ func (s *ComponentService) GetComponentStats(ctx context.Context, tenantID string) (*component.ComponentStats, error)

+ func (s *ComponentService) GetEcosystemStats(ctx context.Context, tenantID string) ([]component.EcosystemStats, error)

+ func (s *ComponentService) GetLicenseStats(ctx context.Context, tenantID string) ([]component.LicenseStats, error)

+ func (s *ComponentService) GetVulnerableComponents(ctx context.Context, tenantID string, limit int) ([]component.VulnerableComponent, error)

+ func (s *ComponentService) ListAssetComponents(ctx context.Context, assetID string, page, perPage int) (pagination.Result[*component.AssetDependency], error)

+ func (s *ComponentService) ListComponents(ctx context.Context, input ListComponentsInput) (pagination.Result[*component.Component], error)

+ func (s *ComponentService) UpdateComponent(ctx context.Context, dependencyID string, tenantID string, ...) (*component.AssetDependency, error)

+ type ConditionEvaluator interface

+ Evaluate func(ctx context.Context, expression string, data map[string]any) (bool, error)

+ type CreateAPIKeyInput struct

+ CreatedBy string

+ Description string

+ ExpiresInDays int

+ Name string

+ RateLimit int

+ Scopes []string

+ TenantID string

+ UserID string

+ type CreateAPIKeyResult struct

+ Key *apikey.APIKey

+ Plaintext string

+ type CreateAgentInput struct

+ AuditContext *AuditContext

+ Capabilities []string

+ Description string

+ ExecutionMode string

+ MaxConcurrentJobs int

+ Name string

+ TenantID string

+ Tools []string

+ Type string

+ type CreateAgentOutput struct

+ APIKey string

+ Agent *agent.Agent

+ type CreateAssetGroupInput struct

+ AssetIDs []string

+ BusinessUnit string

+ Criticality string

+ Description string

+ Environment string

+ Name string

+ Owner string

+ OwnerEmail string

+ Tags []string

+ TenantID string

+ type CreateAssetInput struct

+ Criticality string

+ Description string

+ Exposure string

+ Name string

+ Scope string

+ Tags []string

+ TenantID string

+ Type string

+ type CreateBranchInput struct

+ BranchType string

+ IsDefault bool

+ IsProtected bool

+ LastCommitSHA string

+ Name string

+ RepositoryID string

+ type CreateBundleInput struct

+ SourceIDs []string

+ StoragePath string

+ TenantID string

+ ToolID string

+ type CreateCapabilityInput struct

+ AuditContext AuditContext

+ Category string

+ Color string

+ CreatedBy string

+ Description string

+ DisplayName string

+ Icon string

+ Name string

+ TenantID string

+ type CreateCategoryInput struct

+ Color string

+ CreatedBy string

+ Description string

+ DisplayName string

+ Icon string

+ Name string

+ TenantID string

+ type CreateCommandInput struct

+ AgentID string

+ ExpiresIn int

+ Payload json.RawMessage

+ Priority string

+ TenantID string

+ Type string

+ type CreateComponentInput struct

+ AssetID string

+ DependencyType string

+ Ecosystem string

+ License string

+ ManifestFile string

+ ManifestPath string

+ Name string

+ Namespace string

+ PackageManager string

+ TenantID string

+ Version string

+ type CreateCredentialInput struct

+ CredentialType secretstore.CredentialType

+ Data any

+ Description string

+ ExpiresAt *time.Time

+ Name string

+ TenantID shared.ID

+ UserID shared.ID

+ type CreateCustomToolInput struct

+ Capabilities []string

+ CategoryID string

+ ConfigSchema map[string]any

+ CreatedBy string

+ DefaultConfig map[string]any

+ Description string

+ DisplayName string

+ DocsURL string

+ GithubURL string

+ InstallCmd string

+ InstallMethod string

+ LogoURL string

+ Name string

+ OutputFormats []string

+ SupportedTargets []string

+ Tags []string

+ TenantID string

+ UpdateCmd string

+ VersionCmd string

+ VersionRegex string

+ type CreateEdgeInput struct

+ Label string

+ SourceHandle string

+ SourceNodeKey string

+ TargetNodeKey string

+ type CreateExclusionInput struct

+ CreatedBy string

+ ExclusionType string

+ ExpiresAt *time.Time

+ Pattern string

+ Reason string

+ TenantID string

+ type CreateExposureInput struct

+ AssetID string

+ Description string

+ Details map[string]any

+ EventType string

+ Severity string

+ Source string

+ TenantID string

+ Title string

+ type CreateFindingInput struct

+ AssetID string

+ BranchID string

+ ComponentID string

+ EndColumn int

+ EndLine int

+ FilePath string

+ Message string

+ RuleID string

+ ScanID string

+ Severity string

+ Snippet string

+ Source string

+ StartColumn int

+ StartLine int

+ TenantID string

+ ToolName string

+ ToolVersion string

+ VulnerabilityID string

+ type CreateFirstTeamInput struct

+ RefreshToken string

+ TeamName string

+ TeamSlug string

+ type CreateFirstTeamResult struct

+ AccessToken string

+ ExpiresAt time.Time

+ RefreshToken string

+ Tenant TenantMembershipInfo

+ type CreateGroupInput struct

+ Description string

+ GroupType string

+ Name string

+ Settings *group.GroupSettings

+ Slug string

+ TenantID string

+ type CreateGroupPermissionInput struct

+ Effect string

+ GroupID string

+ PermissionID string

+ type CreateIntegrationInput struct

+ AuthType string

+ BaseURL string

+ Category string

+ Credentials string

+ Description string

+ Name string

+ Provider string

+ SCMOrganization string

+ TenantID string

+ type CreateInvitationInput struct

+ Email string

+ Role string

+ RoleIDs []string

+ type CreateNodeInput struct

+ Config workflow.NodeConfig

+ Description string

+ Name string

+ NodeKey string

+ NodeType workflow.NodeType

+ UIPositionX float64

+ UIPositionY float64

+ type CreateNotificationIntegrationInput struct

+ AuthType string

+ ChannelID string

+ ChannelName string

+ Credentials string

+ Description string

+ EnabledEventTypes []string

+ EnabledSeverities []string

+ IncludeDetails bool

+ MessageTemplate string

+ MinIntervalMinutes int

+ Name string

+ Provider string

+ TenantID string

+ type CreateOverrideInput struct

+ AssetGroupID string

+ CreatedBy string

+ Enabled bool

+ ExpiresAt *string

+ IsPattern bool

+ Reason string

+ RulePattern string

+ ScanProfileID string

+ SeverityOverride string

+ TenantID string

+ ToolID string

+ type CreatePermissionSetInput struct

+ Description string

+ Name string

+ ParentSetID *string

+ Permissions []string

+ SetType string

+ Slug string

+ TenantID string

+ type CreateRelationshipInput struct

+ Confidence string

+ Description string

+ DiscoveryMethod string

+ ImpactWeight *int

+ SourceAssetID string

+ Tags []string

+ TargetAssetID string

+ TenantID string

+ Type string

+ type CreateRepositoryAssetInput struct

+ Classification string

+ CloneURL string

+ Criticality string

+ DefaultBranch string

+ Description string

+ Exposure string

+ ExternalID string

+ Forks int

+ FullName string

+ Language string

+ Languages map[string]int64

+ Name string

+ OpenIssues int

+ Provider string

+ RepoCreatedAt string

+ RepoID string

+ RepoPushedAt string

+ RepoUpdatedAt string

+ SCMOrganization string

+ SSHURL string

+ ScanEnabled bool

+ ScanSchedule string

+ Scope string

+ SizeKB int

+ Stars int

+ Tags []string

+ TenantID string

+ Topics []string

+ Visibility string

+ Watchers int

+ WebURL string

+ type CreateRoleInput struct

+ Description string

+ HasFullDataAccess bool

+ HierarchyLevel int

+ Name string

+ Permissions []string

+ Slug string

+ TenantID string

+ type CreateSLAPolicyInput struct

+ AssetID string

+ CriticalDays int

+ Description string

+ EscalationConfig map[string]any

+ EscalationEnabled bool

+ HighDays int

+ InfoDays int

+ IsDefault bool

+ LowDays int

+ MediumDays int

+ Name string

+ TenantID string

+ WarningThresholdPct int

+ type CreateScanProfileInput struct

+ Description string

+ Intensity string

+ IsDefault bool

+ MaxConcurrentScans int

+ Name string

+ QualityGate *scanprofile.QualityGate

+ Tags []string

+ TenantID string

+ TimeoutSeconds int

+ ToolsConfig map[string]scanprofile.ToolConfig

+ UserID string

+ type CreateScannerTemplateInput struct

+ Content string

+ Description string

+ Name string

+ Tags []string

+ TemplateType string

+ TenantID string

+ UserID string

+ type CreateScheduleInput struct

+ CreatedBy string

+ CronExpression string

+ Description string

+ IntervalHours int

+ Name string

+ NotificationChannels []string

+ NotifyOnCompletion bool

+ NotifyOnFindings bool

+ ScanType string

+ ScannerConfigs map[string]interface{}

+ ScheduleType string

+ TargetIDs []string

+ TargetScope string

+ TargetTags []string

+ TenantID string

+ type CreateSourceInput struct

+ Config []byte

+ CredentialsID string

+ Description string

+ Name string

+ Priority int

+ SourceType string

+ SyncEnabled bool

+ SyncIntervalMinutes int

+ TenantID string

+ ToolID string

+ type CreateTargetInput struct

+ CreatedBy string

+ Description string

+ Pattern string

+ Priority int

+ Tags []string

+ TargetType string

+ TenantID string

+ type CreateTemplateSourceInput struct

+ AutoSyncOnScan bool

+ CacheTTLMinutes int

+ CredentialID string

+ Description string

+ Enabled bool

+ GitConfig *ts.GitSourceConfig

+ HTTPConfig *ts.HTTPSourceConfig

+ Name string

+ S3Config *ts.S3SourceConfig

+ SourceType string

+ TemplateType string

+ TenantID string

+ UserID string

+ type CreateTenantInput struct

+ Description string

+ Name string

+ Slug string

+ type CreateTenantToolConfigInput struct

+ Config map[string]any

+ IsEnabled bool

+ TenantID string

+ ToolID string

+ UpdatedBy string

+ type CreateToolInput struct

+ Capabilities []string

+ CategoryID string

+ ConfigSchema map[string]any

+ DefaultConfig map[string]any

+ Description string

+ DisplayName string

+ DocsURL string

+ GithubURL string

+ InstallCmd string

+ InstallMethod string

+ LogoURL string

+ Name string

+ OutputFormats []string

+ SupportedTargets []string

+ Tags []string

+ UpdateCmd string

+ VersionCmd string

+ VersionRegex string

+ type CreateVulnerabilityInput struct

+ CVEID string

+ CVSSScore *float64

+ CVSSVector string

+ Description string

+ EPSSPercentile *float64

+ EPSSScore *float64

+ ExploitAvailable bool

+ ExploitMaturity string

+ FixedVersions []string

+ Remediation string

+ Severity string

+ Title string

+ type CreateWebhookInput struct

+ CreatedBy string

+ Description string

+ EventTypes []string

+ MaxRetries int

+ Name string

+ RetryInterval int

+ Secret string

+ SeverityThreshold string

+ TenantID string

+ URL string

+ type CreateWorkflowInput struct

+ Description string

+ Edges []CreateEdgeInput

+ Name string

+ Nodes []CreateNodeInput

+ Tags []string

+ TenantID shared.ID

+ UserID shared.ID

+ type CredentialImportService struct

+ func NewCredentialImportService(exposureRepo exposure.Repository, historyRepo exposure.StateHistoryRepository, ...) *CredentialImportService

+ func (s *CredentialImportService) AcceptCredential(ctx context.Context, tenantID, credentialID, userID, notes string) (*CredentialItem, error)

+ func (s *CredentialImportService) GetByID(ctx context.Context, tenantID, id string) (*CredentialItem, error)

+ func (s *CredentialImportService) GetCredentialStats(ctx context.Context, tenantID string) (map[string]any, error)

+ func (s *CredentialImportService) GetExposuresForIdentity(ctx context.Context, tenantID string, identity string, page, pageSize int) (*CredentialListResult, error)

+ func (s *CredentialImportService) GetRelatedCredentials(ctx context.Context, tenantID string, credentialID string) ([]CredentialItem, error)

+ func (s *CredentialImportService) Import(ctx context.Context, tenantID string, req credential.ImportRequest) (*credential.ImportResult, error)

+ func (s *CredentialImportService) ImportCSV(ctx context.Context, tenantID string, records [][]string, ...) (*credential.ImportResult, error)

+ func (s *CredentialImportService) List(ctx context.Context, tenantID string, opts CredentialListOptions, ...) (*CredentialListResult, error)

+ func (s *CredentialImportService) ListByIdentity(ctx context.Context, tenantID string, opts CredentialListOptions, ...) (*IdentityListResult, error)

+ func (s *CredentialImportService) MarkCredentialFalsePositive(ctx context.Context, tenantID, credentialID, userID, notes string) (*CredentialItem, error)

+ func (s *CredentialImportService) ReactivateCredential(ctx context.Context, tenantID, credentialID string) (*CredentialItem, error)

+ func (s *CredentialImportService) ResolveCredential(ctx context.Context, tenantID, credentialID, userID, notes string) (*CredentialItem, error)

+ type CredentialItem struct

+ CredentialType string

+ Details map[string]any

+ FirstSeenAt time.Time

+ ID string

+ Identifier string

+ IsRevoked bool

+ IsVerified bool

+ LastSeenAt time.Time

+ SecretValue string

+ Severity string

+ Source string

+ State string

+ type CredentialListOptions struct

+ Search string

+ Severities []string

+ SortField string

+ SortOrder string

+ Sources []string

+ States []string

+ type CredentialListResult struct

+ Items []CredentialItem

+ Page int

+ PageSize int

+ Total int64

+ TotalPages int

+ type DashboardService struct

+ func NewDashboardService(repo DashboardStatsRepository, log *logger.Logger) *DashboardService

+ func (s *DashboardService) GetGlobalStats(ctx context.Context) (*DashboardStats, error)

+ func (s *DashboardService) GetStats(ctx context.Context, tenantID shared.ID) (*DashboardStats, error)

+ func (s *DashboardService) GetStatsForTenants(ctx context.Context, tenantIDs []string) (*DashboardStats, error)

+ type DashboardStats struct

+ AssetCount int

+ AssetsByStatus map[string]int

+ AssetsByType map[string]int

+ AverageCVSS float64

+ AverageRiskScore float64

+ FindingCount int

+ FindingsBySeverity map[string]int

+ FindingsByStatus map[string]int

+ OverdueFindings int

+ RecentActivity []ActivityItem

+ RepositoriesWithFindings int

+ RepositoryCount int

+ type DashboardStatsRepository interface

+ GetAssetStats func(ctx context.Context, tenantID shared.ID) (AssetStatsData, error)

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

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

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

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

+ GetFindingStats func(ctx context.Context, tenantID shared.ID) (FindingStatsData, error)

+ GetGlobalAssetStats func(ctx context.Context) (AssetStatsData, error)

+ GetGlobalFindingStats func(ctx context.Context) (FindingStatsData, error)

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

+ GetGlobalRepositoryStats func(ctx context.Context) (RepositoryStatsData, error)

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

+ GetRepositoryStats func(ctx context.Context, tenantID shared.ID) (RepositoryStatsData, error)

+ type DefaultConditionEvaluator struct

+ func (e *DefaultConditionEvaluator) Evaluate(ctx context.Context, expression string, data map[string]any) (bool, error)

+ type DefaultNotificationHandler struct

+ func (h *DefaultNotificationHandler) Send(ctx context.Context, input *NotificationInput) (map[string]any, error)

+ type DeleteCapabilityInput struct

+ AuditContext AuditContext

+ CapabilityID string

+ Force bool

+ TenantID string

+ type EPSSStats struct

+ CriticalRiskCount int

+ HighRiskCount int

+ TotalScores int

+ type EmailCredentials struct

+ FromEmail string

+ FromName string

+ Password string

+ ReplyTo string

+ SMTPHost string

+ SMTPPort int

+ SkipVerify bool

+ ToEmails []string

+ UseSTARTTLS bool

+ UseTLS bool

+ Username string

+ type EmailJobEnqueuer interface

+ EnqueueTeamInvitation func(ctx context.Context, payload TeamInvitationJobPayload) error

+ type EmailMetadata struct

+ FromEmail string

+ FromName string

+ ReplyTo string

+ SMTPHost string

+ SMTPPort int

+ SkipVerify bool

+ ToEmails []string

+ UseSTARTTLS bool

+ UseTLS bool

+ type EmailSensitiveCredentials struct

+ Password string

+ Username string

+ type EmailService struct

+ func NewEmailService(sender email.Sender, cfg config.SMTPConfig, appName string, log *logger.Logger) *EmailService

+ func (s *EmailService) IsConfigured() bool

+ func (s *EmailService) SendPasswordChangedEmail(ctx context.Context, userEmail, userName, ipAddress string) error

+ func (s *EmailService) SendPasswordResetEmail(ctx context.Context, userEmail, userName, token string, ...) error

+ func (s *EmailService) SendTeamInvitationEmail(ctx context.Context, recipientEmail, inviterName, teamName, token string, ...) error

+ func (s *EmailService) SendVerificationEmail(ctx context.Context, userEmail, userName, token string, ...) error

+ func (s *EmailService) SendWelcomeEmail(ctx context.Context, userEmail, userName string) error

+ type EnqueueNotificationParams struct

+ AggregateID *uuid.UUID

+ AggregateType string

+ Body string

+ EventType string

+ Metadata map[string]any

+ Severity string

+ TenantID shared.ID

+ Title string

+ URL string

+ type EvaluateQualityGateInput struct

+ Counts scanprofile.FindingCounts

+ ProfileID string

+ TenantID string

+ type ExchangeTokenInput struct

+ RefreshToken string

+ TenantID string

+ type ExchangeTokenResult struct

+ AccessToken string

+ ExpiresAt time.Time

+ Role string

+ TenantID string

+ TenantSlug string

+ type ExecutionContext struct

+ CompletedNodeKeys map[string]bool

+ Context map[string]any

+ NodeRunsByKey map[string]*workflow.NodeRun

+ Run *workflow.Run

+ TriggerData map[string]any

+ Workflow *workflow.Workflow

+ func (ec *ExecutionContext) GetContextValue(key string) (any, bool)

+ func (ec *ExecutionContext) IsNodeCompleted(nodeKey string) bool

+ func (ec *ExecutionContext) MarkNodeCompleted(nodeKey string)

+ func (ec *ExecutionContext) SetContextValue(key string, value any)

+ type ExposedService struct

+ Criticality string

+ Exposure string

+ FindingCount int

+ ID string

+ LastSeen time.Time

+ Name string

+ Port int

+ Type string

+ type ExposureService struct

+ func NewExposureService(repo exposure.Repository, historyRepo exposure.StateHistoryRepository, ...) *ExposureService

+ func (s *ExposureService) AcceptExposure(ctx context.Context, exposureID, userID, notes string) (*exposure.ExposureEvent, error)

+ func (s *ExposureService) BulkIngestExposures(ctx context.Context, inputs []CreateExposureInput) ([]*exposure.ExposureEvent, error)

+ func (s *ExposureService) CreateExposure(ctx context.Context, input CreateExposureInput) (*exposure.ExposureEvent, error)

+ func (s *ExposureService) DeleteExposure(ctx context.Context, exposureID, tenantID string) error

+ func (s *ExposureService) GetExposure(ctx context.Context, eventID string) (*exposure.ExposureEvent, error)

+ func (s *ExposureService) GetExposureStats(ctx context.Context, tenantID string) (map[string]any, error)

+ func (s *ExposureService) GetStateHistory(ctx context.Context, exposureID string) ([]*exposure.StateHistory, error)

+ func (s *ExposureService) IngestExposure(ctx context.Context, input CreateExposureInput) (*exposure.ExposureEvent, error)

+ func (s *ExposureService) ListExposures(ctx context.Context, input ListExposuresInput) (pagination.Result[*exposure.ExposureEvent], error)

+ func (s *ExposureService) MarkFalsePositive(ctx context.Context, exposureID, userID, notes string) (*exposure.ExposureEvent, error)

+ func (s *ExposureService) ReactivateExposure(ctx context.Context, exposureID, userID string) (*exposure.ExposureEvent, error)

+ func (s *ExposureService) ResolveExposure(ctx context.Context, exposureID, userID, notes string) (*exposure.ExposureEvent, error)

+ func (s *ExposureService) SetNotificationService(db *sql.DB, svc *NotificationService)

+ type FailCommandInput struct

+ CommandID string

+ ErrorMessage string

+ TenantID string

+ type FailToolExecutionInput struct

+ ErrorMessage string

+ ExecutionID string

+ type FindSCMIntegrationInput struct

+ Provider string

+ SCMOrg string

+ TenantID string

+ type FindingActionHandler struct

+ func NewFindingActionHandler(vulnSvc *VulnerabilityService, log *logger.Logger) *FindingActionHandler

+ func (h *FindingActionHandler) Execute(ctx context.Context, input *ActionInput) (map[string]any, error)

+ type FindingActivityService struct

+ func NewFindingActivityService(activityRepo vulnerability.FindingActivityRepository, ...) *FindingActivityService

+ func (s *FindingActivityService) CountActivities(ctx context.Context, tenantID, findingID string, ...) (int64, error)

+ func (s *FindingActivityService) GetActivity(ctx context.Context, activityID string) (*vulnerability.FindingActivity, error)

+ func (s *FindingActivityService) ListActivities(ctx context.Context, input ListActivitiesInput) (pagination.Result[*vulnerability.FindingActivity], error)

+ func (s *FindingActivityService) RecordActivity(ctx context.Context, input RecordActivityInput) (*vulnerability.FindingActivity, error)

+ func (s *FindingActivityService) RecordAssignment(ctx context.Context, tenantID, findingID string, actorID *string, ...) (*vulnerability.FindingActivity, error)

+ func (s *FindingActivityService) RecordCommentAdded(ctx context.Context, tenantID, findingID string, actorID *string, ...) (*vulnerability.FindingActivity, error)

+ func (s *FindingActivityService) RecordCommentDeleted(ctx context.Context, tenantID, findingID string, actorID *string, ...) (*vulnerability.FindingActivity, error)

+ func (s *FindingActivityService) RecordCommentUpdated(ctx context.Context, tenantID, findingID string, actorID *string, ...) (*vulnerability.FindingActivity, error)

+ func (s *FindingActivityService) RecordCreated(ctx context.Context, tenantID, findingID string, source string, ...) (*vulnerability.FindingActivity, error)

+ func (s *FindingActivityService) RecordScanDetected(ctx context.Context, tenantID, findingID string, ...) (*vulnerability.FindingActivity, error)

+ func (s *FindingActivityService) RecordSeverityChange(ctx context.Context, tenantID, findingID string, actorID *string, ...) (*vulnerability.FindingActivity, error)

+ func (s *FindingActivityService) RecordStatusChange(ctx context.Context, tenantID, findingID string, actorID *string, ...) (*vulnerability.FindingActivity, error)

+ func (s *FindingActivityService) RecordUnassignment(ctx context.Context, tenantID, findingID string, actorID *string, ...) (*vulnerability.FindingActivity, error)

+ func (s *FindingActivityService) SetBroadcaster(broadcaster ActivityBroadcaster)

+ func (s *FindingActivityService) SetUserRepo(repo user.Repository)

+ type FindingCommentService struct

+ func NewFindingCommentService(commentRepo vulnerability.FindingCommentRepository, ...) *FindingCommentService

+ func (s *FindingCommentService) AddComment(ctx context.Context, input AddCommentInput) (*vulnerability.FindingComment, error)

+ func (s *FindingCommentService) AddStatusChangeComment(ctx context.Context, input AddStatusChangeCommentInput) (*vulnerability.FindingComment, error)

+ func (s *FindingCommentService) CountFindingComments(ctx context.Context, findingID string) (int, error)

+ func (s *FindingCommentService) DeleteComment(ctx context.Context, commentID, authorID string) error

+ func (s *FindingCommentService) GetComment(ctx context.Context, commentID string) (*vulnerability.FindingComment, error)

+ func (s *FindingCommentService) ListFindingComments(ctx context.Context, findingID string) ([]*vulnerability.FindingComment, error)

+ func (s *FindingCommentService) UpdateComment(ctx context.Context, commentID, authorID string, input UpdateCommentInput) (*vulnerability.FindingComment, error)

+ type FindingEvent struct

+ Changes map[string]any

+ EventType workflow.TriggerType

+ Finding *vulnerability.Finding

+ TenantID shared.ID

+ type FindingLifecycleScheduler struct

+ func NewFindingLifecycleScheduler(findingRepo vulnerability.FindingRepository, tenantLister TenantLister, ...) *FindingLifecycleScheduler

+ func (s *FindingLifecycleScheduler) Start()

+ func (s *FindingLifecycleScheduler) Stop()

+ type FindingLifecycleSchedulerConfig struct

+ CheckInterval time.Duration

+ DefaultExpiryDays int

+ Enabled bool

+ func DefaultFindingLifecycleSchedulerConfig() FindingLifecycleSchedulerConfig

+ type FindingNotifier interface

+ NotifyNewFinding func(tenantID, title, body, severity, url string)

+ type FindingSourceCacheService struct

+ func NewFindingSourceCacheService(redisClient *redis.Client, repo findingsource.Repository, log *logger.Logger) (*FindingSourceCacheService, error)

+ func (s *FindingSourceCacheService) GetAll(ctx context.Context) (*CachedFindingSources, error)

+ func (s *FindingSourceCacheService) GetByCategory(ctx context.Context, categoryCode string) ([]*CachedFindingSource, error)

+ func (s *FindingSourceCacheService) GetByCode(ctx context.Context, code string) (*CachedFindingSource, error)

+ func (s *FindingSourceCacheService) GetCategories(ctx context.Context) ([]*CachedCategory, error)

+ func (s *FindingSourceCacheService) InvalidateAll(ctx context.Context) error

+ func (s *FindingSourceCacheService) IsValidCode(ctx context.Context, code string) (bool, error)

+ func (s *FindingSourceCacheService) Refresh(ctx context.Context) (*CachedFindingSources, error)

+ func (s *FindingSourceCacheService) WarmCache(ctx context.Context) error

+ type FindingSourceService struct

+ func NewFindingSourceService(repo findingsource.Repository, categoryRepo findingsource.CategoryRepository, ...) *FindingSourceService

+ func (s *FindingSourceService) GetCategory(ctx context.Context, categoryID string) (*findingsource.Category, error)

+ func (s *FindingSourceService) GetCategoryByCode(ctx context.Context, code string) (*findingsource.Category, error)

+ func (s *FindingSourceService) GetFindingSource(ctx context.Context, findingSourceID string) (*findingsource.FindingSource, error)

+ func (s *FindingSourceService) GetFindingSourceByCode(ctx context.Context, code string) (*findingsource.FindingSource, error)

+ func (s *FindingSourceService) IsValidSourceCode(ctx context.Context, code string) (bool, error)

+ func (s *FindingSourceService) ListActiveCategories(ctx context.Context) ([]*findingsource.Category, error)

+ func (s *FindingSourceService) ListActiveFindingSources(ctx context.Context) ([]*findingsource.FindingSource, error)

+ func (s *FindingSourceService) ListActiveFindingSourcesByCategory(ctx context.Context, categoryID string) ([]*findingsource.FindingSource, error)

+ func (s *FindingSourceService) ListActiveFindingSourcesWithCategory(ctx context.Context) ([]*findingsource.FindingSourceWithCategory, error)

+ func (s *FindingSourceService) ListCategories(ctx context.Context, filter findingsource.CategoryFilter, ...) (pagination.Result[*findingsource.Category], error)

+ func (s *FindingSourceService) ListFindingSources(ctx context.Context, filter findingsource.Filter, ...) (pagination.Result[*findingsource.FindingSource], error)

+ func (s *FindingSourceService) ListFindingSourcesWithCategory(ctx context.Context, filter findingsource.Filter, ...) (pagination.Result[*findingsource.FindingSourceWithCategory], error)

+ type FindingStatsData struct

+ AverageCVSS float64

+ BySeverity map[string]int

+ ByStatus map[string]int

+ Overdue int

+ Total int

+ type ForgotPasswordInput struct

+ Email string

+ type ForgotPasswordResult struct

+ Token string

+ type GetModuleLimitOutput struct

+ Limit int64

+ Unlimited bool

+ type GetNotificationEventsInput struct

+ IntegrationID string

+ Limit int

+ Offset int

+ TenantID string

+ type GetNotificationEventsResult struct

+ Data []NotificationEventEntry

+ Limit int

+ Offset int

+ Total int64

+ type GetSCMRepositoryInput struct

+ FullName string

+ IntegrationID string

+ TenantID string

+ type GetTenantEnabledModulesOutput struct

+ ModuleIDs []string

+ Modules []*module.Module

+ SubModules map[string][]*module.Module

+ type GroupService struct

+ func NewGroupService(repo group.Repository, log *logger.Logger, opts ...GroupServiceOption) *GroupService

+ func (s *GroupService) AddMember(ctx context.Context, input AddGroupMemberInput, actx AuditContext) (*group.Member, error)

+ func (s *GroupService) AssignAsset(ctx context.Context, input AssignAssetInput, assignedBy shared.ID, ...) error

+ func (s *GroupService) AssignPermissionSet(ctx context.Context, input AssignPermissionSetInput, assignedBy shared.ID, ...) error

+ func (s *GroupService) CanAccessAsset(ctx context.Context, userID shared.ID, assetID string) (bool, error)

+ func (s *GroupService) CreateGroup(ctx context.Context, input CreateGroupInput, creatorUserID shared.ID, ...) (*group.Group, error)

+ func (s *GroupService) DeleteGroup(ctx context.Context, groupID string, actx AuditContext) error

+ func (s *GroupService) GetGroup(ctx context.Context, groupID string) (*group.Group, error)

+ func (s *GroupService) GetGroupBySlug(ctx context.Context, tenantID, slug string) (*group.Group, error)

+ func (s *GroupService) ListAssetOwners(ctx context.Context, assetID string) ([]*accesscontrol.AssetOwner, error)

+ func (s *GroupService) ListGroupAssets(ctx context.Context, groupID string) ([]*accesscontrol.AssetOwner, error)

+ func (s *GroupService) ListGroupMembers(ctx context.Context, groupID string) ([]*group.Member, error)

+ func (s *GroupService) ListGroupMembersWithUserInfo(ctx context.Context, groupID string) ([]*group.MemberWithUser, error)

+ func (s *GroupService) ListGroupPermissionSets(ctx context.Context, groupID string) ([]shared.ID, error)

+ func (s *GroupService) ListGroupPermissionSetsWithDetails(ctx context.Context, groupID string) ([]*permissionset.PermissionSetWithItems, error)

+ func (s *GroupService) ListGroups(ctx context.Context, input ListGroupsInput) (*ListGroupsOutput, error)

+ func (s *GroupService) ListMyAssets(ctx context.Context, tenantID string, userID shared.ID) ([]shared.ID, error)

+ func (s *GroupService) ListUserGroups(ctx context.Context, tenantID string, userID shared.ID) ([]*group.GroupWithRole, error)

+ func (s *GroupService) RemoveMember(ctx context.Context, groupID string, userID shared.ID, actx AuditContext) error

+ func (s *GroupService) UnassignAsset(ctx context.Context, input UnassignAssetInput, actx AuditContext) error

+ func (s *GroupService) UnassignPermissionSet(ctx context.Context, groupID, permissionSetID string, actx AuditContext) error

+ func (s *GroupService) UpdateAssetOwnership(ctx context.Context, input UpdateAssetOwnershipInput, actx AuditContext) error

+ func (s *GroupService) UpdateGroup(ctx context.Context, groupID string, input UpdateGroupInput, actx AuditContext) (*group.Group, error)

+ func (s *GroupService) UpdateMemberRole(ctx context.Context, input UpdateGroupMemberRoleInput, actx AuditContext) (*group.Member, error)

+ type GroupServiceOption func(*GroupService)

+ func WithAccessControlRepository(repo accesscontrol.Repository) GroupServiceOption

+ func WithGroupAuditService(auditService *AuditService) GroupServiceOption

+ func WithPermissionSetRepository(repo permissionset.Repository) GroupServiceOption

+ type HTTPRequestHandler struct

+ func NewHTTPRequestHandler(log *logger.Logger) *HTTPRequestHandler

+ func (h *HTTPRequestHandler) Execute(ctx context.Context, input *ActionInput) (map[string]any, error)

+ type IdentityExposure struct

+ CredentialTypes []string

+ ExposureCount int

+ FirstSeenAt time.Time

+ HighestSeverity string

+ Identity string

+ IdentityType string

+ LastSeenAt time.Time

+ Sources []string

+ States map[string]int

+ type IdentityListResult struct

+ Items []IdentityExposure

+ Page int

+ PageSize int

+ Total int64

+ TotalPages int

+ type IntegrationListReposInput struct

+ IntegrationID string

+ Page int

+ PerPage int

+ Search string

+ TenantID string

+ type IntegrationListReposResult struct

+ HasMore bool

+ NextPage int

+ Repositories []scm.Repository

+ Total int

+ type IntegrationService struct

+ func NewIntegrationService(repo integration.Repository, scmExtRepo integration.SCMExtensionRepository, ...) *IntegrationService

+ func (s *IntegrationService) BroadcastNotification(ctx context.Context, input BroadcastNotificationInput) ([]SendNotificationResult, error)

+ func (s *IntegrationService) CreateIntegration(ctx context.Context, input CreateIntegrationInput) (*integration.IntegrationWithSCM, error)

+ func (s *IntegrationService) CreateNotificationIntegration(ctx context.Context, input CreateNotificationIntegrationInput) (*integration.IntegrationWithNotification, error)

+ func (s *IntegrationService) DeleteIntegration(ctx context.Context, id string, tenantID string) error

+ func (s *IntegrationService) DisableIntegration(ctx context.Context, id string, tenantID string) (*integration.Integration, error)

+ func (s *IntegrationService) EnableIntegration(ctx context.Context, id string, tenantID string) (*integration.IntegrationWithSCM, error)

+ func (s *IntegrationService) FindSCMIntegration(ctx context.Context, input FindSCMIntegrationInput) (*integration.IntegrationWithSCM, error)

+ func (s *IntegrationService) GetIntegration(ctx context.Context, id string) (*integration.Integration, error)

+ func (s *IntegrationService) GetIntegrationWithSCM(ctx context.Context, id string) (*integration.IntegrationWithSCM, error)

+ func (s *IntegrationService) GetNotificationEvents(ctx context.Context, input GetNotificationEventsInput) (*GetNotificationEventsResult, error)

+ func (s *IntegrationService) GetNotificationIntegration(ctx context.Context, id string, tenantID string) (*integration.IntegrationWithNotification, error)

+ func (s *IntegrationService) GetSCMRepository(ctx context.Context, input GetSCMRepositoryInput) (*scm.Repository, error)

+ func (s *IntegrationService) ListIntegrations(ctx context.Context, input ListIntegrationsInput) (integration.ListResult, error)

+ func (s *IntegrationService) ListNotificationIntegrations(ctx context.Context, tenantID string) ([]*integration.IntegrationWithNotification, error)

+ func (s *IntegrationService) ListSCMIntegrations(ctx context.Context, tenantID string) ([]*integration.IntegrationWithSCM, error)

+ func (s *IntegrationService) ListSCMRepositories(ctx context.Context, input IntegrationListReposInput) (*IntegrationListReposResult, error)

+ func (s *IntegrationService) NotifyNewFinding(tenantID, title, body, severity, url string)

+ func (s *IntegrationService) SendNotification(ctx context.Context, input SendNotificationInput) (*SendNotificationResult, error)

+ func (s *IntegrationService) SetNotificationEventRepository(repo notificationdomain.EventRepository)

+ func (s *IntegrationService) SetNotificationExtensionRepository(repo integration.NotificationExtensionRepository)

+ func (s *IntegrationService) SyncIntegration(ctx context.Context, id string, tenantID string) (*integration.IntegrationWithSCM, error)

+ func (s *IntegrationService) TestIntegration(ctx context.Context, id string, tenantID string) (*integration.IntegrationWithSCM, error)

+ func (s *IntegrationService) TestIntegrationCredentials(ctx context.Context, input TestIntegrationCredentialsInput) (*TestIntegrationCredentialsResult, error)

+ func (s *IntegrationService) TestNotificationIntegration(ctx context.Context, id string, tenantID string) (*integration.IntegrationWithNotification, error)

+ func (s *IntegrationService) UpdateIntegration(ctx context.Context, id string, tenantID string, input UpdateIntegrationInput) (*integration.IntegrationWithSCM, error)

+ func (s *IntegrationService) UpdateNotificationIntegration(ctx context.Context, id string, tenantID string, ...) (*integration.IntegrationWithNotification, error)

+ type KEVStats struct

+ PastDueCount int

+ RansomwareRelatedCount int

+ RecentlyAddedLast30Days int

+ TotalEntries int

+ type ListAPIKeysInput struct

+ Page int

+ PerPage int

+ Search string

+ SortBy string

+ SortOrder string

+ Status string

+ TenantID string

+ type ListActivitiesInput struct

+ ActivityTypes []string

+ FindingID string

+ Page int

+ PageSize int

+ TenantID string

+ type ListAgentsInput struct

+ Capabilities []string

+ ExecutionMode string

+ HasCapacity *bool

+ Health string

+ Page int

+ PerPage int

+ Search string

+ Status string

+ TenantID string

+ Tools []string

+ Type string

+ type ListAssetGroupsInput struct

+ BusinessUnit string

+ Criticalities []string

+ Environments []string

+ HasFindings *bool

+ MaxRiskScore *int

+ MinRiskScore *int

+ Owner string

+ Page int

+ PerPage int

+ Search string

+ Sort string

+ Tags []string

+ TenantID string

+ type ListAssetGroupsOutput struct

+ Groups []*assetgroup.AssetGroup

+ Page int

+ Pages int

+ Total int64

+ type ListAssetsInput struct

+ Criticalities []string

+ Exposures []string

+ HasFindings *bool

+ MaxRiskScore *int

+ MinRiskScore *int

+ Name string

+ Page int

+ PerPage int

+ Scopes []string

+ Search string

+ Sort string

+ Statuses []string

+ Tags []string

+ TenantID string

+ Types []string

+ type ListAuditLogsInput struct

+ Actions []string

+ ActorID string

+ ExcludeSystem bool

+ Page int

+ PerPage int

+ RequestID string

+ ResourceID string

+ ResourceTypes []string

+ Results []string

+ SearchTerm string

+ Severities []string

+ Since *time.Time

+ SortBy string

+ SortOrder string

+ TenantID string

+ Until *time.Time

+ type ListAvailableToolsInput struct

+ Capabilities []string

+ Category string

+ IsActive *bool

+ Page int

+ PerPage int

+ Search string

+ Tags []string

+ TenantID string

+ type ListBranchesInput struct

+ BranchTypes []string

+ IsDefault *bool

+ Name string

+ Page int

+ PerPage int

+ RepositoryID string

+ ScanStatus string

+ Sort string

+ type ListBundlesInput struct

+ Status string

+ TenantID string

+ ToolID string

+ type ListCapabilitiesInput struct

+ Category *string

+ IsBuiltin *bool

+ Page int

+ PerPage int

+ Search string

+ TenantID string

+ type ListCategoriesInput struct

+ IsBuiltin *bool

+ Page int

+ PerPage int

+ Search string

+ TenantID string

+ type ListCommandsInput struct

+ AgentID string

+ Page int

+ PerPage int

+ Priority string

+ Status string

+ TenantID string

+ Type string

+ type ListComponentsInput struct

+ AssetID string

+ DependencyTypes []string

+ Ecosystems []string

+ HasVulnerabilities *bool

+ Licenses []string

+ Name string

+ Page int

+ PerPage int

+ Statuses []string

+ TenantID string

+ type ListCredentialsInput struct

+ CredentialType *string

+ Page int

+ PageSize int

+ SortBy string

+ SortOrder string

+ TenantID shared.ID

+ type ListCredentialsOutput struct

+ Items []*secretstore.Credential

+ TotalCount int

+ type ListCustomToolsInput struct

+ Capabilities []string

+ Category string

+ IsActive *bool

+ Page int

+ PerPage int

+ Search string

+ Tags []string

+ TenantID string

+ type ListDeliveriesInput struct

+ Page int

+ PerPage int

+ Status string

+ TenantID string

+ WebhookID string

+ type ListExclusionsInput struct

+ ExclusionTypes []string

+ IsApproved *bool

+ Page int

+ PerPage int

+ Search string

+ Statuses []string

+ TenantID string

+ type ListExposuresInput struct

+ AssetID string

+ EventTypes []string

+ FirstSeenAfter int64

+ FirstSeenBefore int64

+ LastSeenAfter int64

+ LastSeenBefore int64

+ Page int

+ PerPage int

+ Search string

+ Severities []string

+ SortBy string

+ SortOrder string

+ Sources []string

+ States []string

+ TenantID string

+ type ListFindingsInput struct

+ AssetID string

+ BranchID string

+ ComponentID string

+ FilePath string

+ Page int

+ PerPage int

+ RuleID string

+ ScanID string

+ Search string

+ Severities []string

+ Sort string

+ Sources []string

+ Statuses []string

+ TenantID string

+ ToolName string

+ VulnerabilityID string

+ type ListGroupsInput struct

+ GroupType *string

+ IsActive *bool

+ Limit int

+ Offset int

+ Search string

+ TenantID string

+ type ListGroupsOutput struct

+ Groups []*group.Group

+ TotalCount int64

+ type ListIntegrationsInput struct

+ Category string

+ Page int

+ PerPage int

+ Provider string

+ Search string

+ SortBy string

+ SortOrder string

+ Status string

+ TenantID string

+ type ListOverridesInput struct

+ AssetGroupID string

+ Enabled *bool

+ Page int

+ PerPage int

+ ScanProfileID string

+ TenantID string

+ ToolID string

+ type ListPermissionSetsInput struct

+ IncludeSystem bool

+ IsActive *bool

+ Limit int

+ Offset int

+ Search string

+ SetType *string

+ TenantID string

+ type ListPermissionSetsOutput struct

+ PermissionSets []*permissionset.PermissionSet

+ TotalCount int64

+ type ListPlatformToolsInput struct

+ Capabilities []string

+ Category string

+ IsActive *bool

+ Page int

+ PerPage int

+ Search string

+ Tags []string

+ type ListRulesInput struct

+ Category string

+ Page int

+ PerPage int

+ RuleIDs []string

+ Search string

+ Severity string

+ SourceID string

+ Tags []string

+ TenantID string

+ ToolID string

+ type ListScanProfilesInput struct

+ IncludeSystem bool

+ IsDefault *bool

+ IsSystem *bool

+ Page int

+ PerPage int

+ Search string

+ Tags []string

+ TenantID string

+ type ListScanSessionsInput struct

+ AssetType string

+ AssetValue string

+ Branch string

+ ScannerName string

+ Since *time.Time

+ Status string

+ Until *time.Time

+ type ListScannerTemplatesInput struct

+ Page int

+ PerPage int

+ Search string

+ Status *string

+ Tags []string

+ TemplateType *string

+ TenantID string

+ type ListSchedulesInput struct

+ Enabled *bool

+ Page int

+ PerPage int

+ ScanTypes []string

+ ScheduleTypes []string

+ Search string

+ TenantID string

+ type ListSourcesInput struct

+ Enabled *bool

+ IsPlatformDefault *bool

+ Page int

+ PerPage int

+ Search string

+ SourceType string

+ SyncStatus string

+ TenantID string

+ ToolID string

+ type ListTargetsInput struct

+ Page int

+ PerPage int

+ Search string

+ Statuses []string

+ Tags []string

+ TargetTypes []string

+ TenantID string

+ type ListTemplateSourcesInput struct

+ Enabled *bool

+ Page int

+ PageSize int

+ SortBy string

+ SortOrder string

+ SourceType *string

+ TemplateType *string

+ TenantID string

+ type ListTenantToolConfigsInput struct

+ IsEnabled *bool

+ Page int

+ PerPage int

+ TenantID string

+ ToolID string

+ type ListToolExecutionsInput struct

+ AgentID string

+ Page int

+ PerPage int

+ PipelineRunID string

+ Status string

+ TenantID string

+ ToolID string

+ type ListToolsInput struct

+ Capabilities []string

+ Category string

+ IsActive *bool

+ IsBuiltin *bool

+ Page int

+ PerPage int

+ Search string

+ Tags []string

+ type ListToolsWithConfigInput struct

+ Category string

+ IsActive *bool

+ IsBuiltin *bool

+ Page int

+ PerPage int

+ Search string

+ Tags []string

+ TenantID string

+ type ListVulnerabilitiesInput struct

+ CISAKEVOnly *bool

+ CVEIDs []string

+ ExploitAvailable *bool

+ MaxCVSS *float64

+ MinCVSS *float64

+ MinEPSS *float64

+ Page int

+ PerPage int

+ Search string

+ Severities []string

+ Sort string

+ Statuses []string

+ type ListWebhooksInput struct

+ EventType string

+ Page int

+ PerPage int

+ Search string

+ SortBy string

+ SortOrder string

+ Status string

+ TenantID string

+ type ListWorkflowRunsInput struct

+ Page int

+ PerPage int

+ Status *workflow.RunStatus

+ TenantID shared.ID

+ WorkflowID *shared.ID

+ type ListWorkflowsInput struct

+ IsActive *bool

+ Page int

+ PerPage int

+ Search string

+ Tags []string

+ TenantID shared.ID

+ type LoginInput struct

+ Email string

+ IPAddress string

+ Password string

+ UserAgent string

+ type LoginResult struct

+ ExpiresAt time.Time

+ RefreshToken string

+ SessionID string

+ Tenants []TenantMembershipInfo

+ User *user.User

+ type ModuleCacheRepository interface

+ GetEventTypesForModulesBatch func(ctx context.Context, moduleIDs []string) (map[string][]string, error)

+ GetModulesByIDs func(ctx context.Context, ids []string) ([]*module.Module, error)

+ GetPlanModulesByTenantID func(ctx context.Context, tenantID uuid.UUID) ([]string, error)

+ GetSubModulesForParents func(ctx context.Context, parentModuleIDs []string) (map[string][]*module.Module, error)

+ type ModuleCacheService struct

+ func NewModuleCacheService(redisClient *redis.Client, repo ModuleCacheRepository, log *logger.Logger) (*ModuleCacheService, error)

+ func (s *ModuleCacheService) GetTenantModules(ctx context.Context, tenantID string) (*CachedTenantModules, error)

+ func (s *ModuleCacheService) HasModule(ctx context.Context, tenantID, moduleID string) (bool, error)

+ func (s *ModuleCacheService) HasSubModule(ctx context.Context, tenantID, parentModuleID, fullSubModuleID string) (bool, error)

+ func (s *ModuleCacheService) Invalidate(ctx context.Context, tenantID string) error

+ func (s *ModuleCacheService) InvalidateAll(ctx context.Context)

+ func (s *ModuleCacheService) Refresh(ctx context.Context, tenantID string) (*CachedTenantModules, error)

+ type ModuleRepository interface

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

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

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

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

+ type ModuleService struct

+ func NewModuleService(moduleRepo ModuleRepository, log *logger.Logger) *ModuleService

+ func (s *ModuleService) GetModule(ctx context.Context, moduleID string) (*module.Module, error)

+ func (s *ModuleService) GetTenantEnabledModules(ctx context.Context, tenantID string) (*GetTenantEnabledModulesOutput, error)

+ func (s *ModuleService) GetTenantModuleLimit(ctx context.Context, tenantID, moduleID, metric string) (*GetModuleLimitOutput, error)

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

+ func (s *ModuleService) TenantHasModule(ctx context.Context, tenantID, moduleID string) (bool, error)

+ func (s *ModuleService) TenantHasSubModule(ctx context.Context, tenantID, parentModuleID, subModuleID string) (bool, error)

+ type NotificationEventEntry struct

+ AggregateID string

+ AggregateType string

+ Body string

+ CreatedAt time.Time

+ EventType string

+ ID string

+ IntegrationsFailed int

+ IntegrationsMatched int

+ IntegrationsSucceeded int

+ IntegrationsTotal int

+ LastError string

+ ProcessedAt time.Time

+ RetryCount int

+ SendResults []NotificationEventSendResult

+ Severity string

+ Status string

+ Title string

+ URL string

+ type NotificationEventSendResult struct

+ Error string

+ IntegrationID string

+ IntegrationName string

+ MessageID string

+ Provider string

+ SentAt time.Time

+ Status string

+ type NotificationHandler interface

+ Send func(ctx context.Context, input *NotificationInput) (map[string]any, error)

+ type NotificationInput struct

+ Context map[string]any

+ NodeKey string

+ NotificationConfig map[string]any

+ NotificationType workflow.NotificationType

+ RunID shared.ID

+ TenantID shared.ID

+ TriggerData map[string]any

+ WorkflowID shared.ID

+ type NotificationScheduler struct

+ func NewNotificationScheduler(service *NotificationService, config NotificationSchedulerConfig, ...) *NotificationScheduler

+ func (s *NotificationScheduler) Start()

+ func (s *NotificationScheduler) Stop()

+ type NotificationSchedulerConfig struct

+ BatchSize int

+ CleanupInterval time.Duration

+ CompletedRetentionDays int

+ EventRetentionDays int

+ FailedRetentionDays int

+ ProcessInterval time.Duration

+ StaleMinutes int

+ UnlockInterval time.Duration

+ func DefaultNotificationSchedulerConfig() NotificationSchedulerConfig

+ type NotificationService struct

+ func NewNotificationService(outboxRepo notification.OutboxRepository, ...) *NotificationService

+ func (s *NotificationService) CleanupOldEntries(ctx context.Context, completedDays, failedDays int) (deletedCompleted, deletedFailed int64, err error)

+ func (s *NotificationService) CleanupOldEvents(ctx context.Context, retentionDays int) (deleted int64, err error)

+ func (s *NotificationService) EnqueueNotification(ctx context.Context, params EnqueueNotificationParams) error

+ func (s *NotificationService) EnqueueNotificationInTx(ctx context.Context, tx *sql.Tx, params EnqueueNotificationParams) error

+ func (s *NotificationService) ProcessOutboxBatch(ctx context.Context, workerID string, batchSize int) (processed, failed int, err error)

+ func (s *NotificationService) UnlockStaleEntries(ctx context.Context, olderThanMinutes int) (unlocked int64, err error)

+ type OAuthProvider string

+ const OAuthProviderGitHub

+ const OAuthProviderGoogle

+ const OAuthProviderMicrosoft

+ func (p OAuthProvider) IsValid() bool

+ func (p OAuthProvider) ToAuthProvider() user.AuthProvider

+ type OAuthService struct

+ func NewOAuthService(userRepo user.Repository, sessionRepo session.Repository, ...) *OAuthService

+ func (s *OAuthService) GetAuthorizationURL(ctx context.Context, input AuthorizationURLInput) (*AuthorizationURLResult, error)

+ func (s *OAuthService) GetAvailableProviders() []ProviderInfo

+ func (s *OAuthService) HandleCallback(ctx context.Context, input CallbackInput) (*CallbackResult, error)

+ type OAuthUserInfo struct

+ AvatarURL string

+ Email string

+ ID string

+ Name string

+ type PermissionCacheService struct

+ func NewPermissionCacheService(redisClient *redis.Client, roleRepo role.Repository, ...) (*PermissionCacheService, error)

+ func (s *PermissionCacheService) GetPermissions(ctx context.Context, tenantID, userID string) ([]string, error)

+ func (s *PermissionCacheService) GetPermissionsWithFallback(ctx context.Context, tenantID, userID string) ([]string, error)

+ func (s *PermissionCacheService) HasAllPermissions(ctx context.Context, tenantID, userID string, permissions ...string) (bool, error)

+ func (s *PermissionCacheService) HasAnyPermission(ctx context.Context, tenantID, userID string, permissions ...string) (bool, error)

+ func (s *PermissionCacheService) HasPermission(ctx context.Context, tenantID, userID, permission string) (bool, error)

+ func (s *PermissionCacheService) Invalidate(ctx context.Context, tenantID, userID string)

+ func (s *PermissionCacheService) InvalidateForTenant(ctx context.Context, tenantID string)

+ func (s *PermissionCacheService) InvalidateForUsers(ctx context.Context, tenantID string, userIDs []string)

+ func (s *PermissionCacheService) Refresh(ctx context.Context, tenantID, userID string) ([]string, error)

+ type PermissionService struct

+ func NewPermissionService(permissionSetRepo permissionset.Repository, log *logger.Logger, ...) *PermissionService

+ func (s *PermissionService) AddPermissionToSet(ctx context.Context, input AddPermissionToSetInput, actx AuditContext) error

+ func (s *PermissionService) CreateGroupPermission(ctx context.Context, input CreateGroupPermissionInput, createdBy shared.ID, ...) (*accesscontrol.GroupPermission, error)

+ func (s *PermissionService) CreatePermissionSet(ctx context.Context, input CreatePermissionSetInput, actx AuditContext) (*permissionset.PermissionSet, error)

+ func (s *PermissionService) DeleteGroupPermission(ctx context.Context, groupID, permissionID string, actx AuditContext) error

+ func (s *PermissionService) DeletePermissionSet(ctx context.Context, permissionSetID string, actx AuditContext) error

+ func (s *PermissionService) GetPermissionSet(ctx context.Context, permissionSetID string) (*permissionset.PermissionSet, error)

+ func (s *PermissionService) GetPermissionSetWithItems(ctx context.Context, permissionSetID string) (*permissionset.PermissionSetWithItems, error)

+ func (s *PermissionService) HasAllPermissions(ctx context.Context, tenantID string, userID shared.ID, ...) (bool, error)

+ func (s *PermissionService) HasAnyPermission(ctx context.Context, tenantID string, userID shared.ID, ...) (bool, error)

+ func (s *PermissionService) HasPermission(ctx context.Context, tenantID string, userID shared.ID, ...) (bool, error)

+ func (s *PermissionService) ListGroupCustomPermissions(ctx context.Context, groupID string) ([]*accesscontrol.GroupPermission, error)

+ func (s *PermissionService) ListPermissionSets(ctx context.Context, input ListPermissionSetsInput) (*ListPermissionSetsOutput, error)

+ func (s *PermissionService) RemovePermissionFromSet(ctx context.Context, permissionSetID, permissionID string, actx AuditContext) error

+ func (s *PermissionService) ResolveGroupPermissions(ctx context.Context, groupID string) ([]permission.Permission, error)

+ func (s *PermissionService) ResolveUserPermissions(ctx context.Context, tenantID string, userID shared.ID) ([]permission.Permission, error)

+ func (s *PermissionService) ResolveUserPermissionsWithCount(ctx context.Context, tenantID string, userID shared.ID) ([]permission.Permission, int, error)

+ func (s *PermissionService) UpdatePermissionSet(ctx context.Context, permissionSetID string, input UpdatePermissionSetInput, ...) (*permissionset.PermissionSet, error)

+ type PermissionServiceOption func(*PermissionService)

+ func WithPermissionAccessControlRepository(repo accesscontrol.Repository) PermissionServiceOption

+ func WithPermissionAuditService(auditService *AuditService) PermissionServiceOption

+ func WithPermissionGroupRepository(repo group.Repository) PermissionServiceOption

+ type PermissionVersionService struct

+ func NewPermissionVersionService(redisClient *redis.Client, log *logger.Logger) *PermissionVersionService

+ func (s *PermissionVersionService) Delete(ctx context.Context, tenantID, userID string) error

+ func (s *PermissionVersionService) EnsureVersion(ctx context.Context, tenantID, userID string) int

+ func (s *PermissionVersionService) Get(ctx context.Context, tenantID, userID string) int

+ func (s *PermissionVersionService) Increment(ctx context.Context, tenantID, userID string) int

+ func (s *PermissionVersionService) IncrementForUsers(ctx context.Context, tenantID string, userIDs []string)

+ func (s *PermissionVersionService) Set(ctx context.Context, tenantID, userID string, version int) error

+ type PipelineDeactivator interface

+ DeactivatePipelinesByTool func(ctx context.Context, toolName string) (int, []shared.ID, error)

+ GetPipelinesUsingTool func(ctx context.Context, toolName string) ([]shared.ID, error)

+ type PipelineTriggerHandler struct

+ func NewPipelineTriggerHandler(pipelineSvc *pipeline.Service, scanSvc *scansvc.Service, log *logger.Logger) *PipelineTriggerHandler

+ func (h *PipelineTriggerHandler) Execute(ctx context.Context, input *ActionInput) (map[string]any, error)

+ type PollCommandsInput struct

+ AgentID string

+ Limit int

+ TenantID string

+ type PromptSanitizer struct

+ func NewPromptSanitizer() *PromptSanitizer

+ func (s *PromptSanitizer) SanitizeCodeSnippet(code string) string

+ func (s *PromptSanitizer) SanitizeForPrompt(text string) string

+ type ProviderInfo struct

+ Enabled bool

+ ID string

+ Name string

+ type RecordActivityInput struct

+ ActivityType string

+ ActorID *string

+ ActorType string

+ Changes map[string]interface{}

+ FindingID string

+ Source string

+ SourceMetadata map[string]interface{}

+ TenantID string

+ type RecordToolExecutionInput struct

+ AgentID string

+ InputConfig map[string]any

+ PipelineRunID string

+ StepRunID string

+ TargetsCount int

+ TenantID string

+ ToolID string

+ type RecoverStuckJobsInput struct

+ Limit int

+ StuckDuration time.Duration

+ type RecoverStuckJobsOutput struct

+ Errors int

+ Recovered int

+ Skipped int

+ Total int

+ type RefreshTokenInput struct

+ IPAddress string

+ RefreshToken string

+ TenantID string

+ UserAgent string

+ type RefreshTokenResult struct

+ AccessToken string

+ ExpiresAt time.Time

+ RefreshExpiresAt time.Time

+ RefreshToken string

+ Role string

+ TenantID string

+ TenantSlug string

+ type RegisterInput struct

+ Email string

+ Name string

+ Password string

+ type RegisterResult struct

+ EmailExisted bool

+ RequiresVerification bool

+ User *user.User

+ VerificationToken string

+ type RegisterScanInput struct

+ AssetType string

+ AssetValue string

+ Branch string

+ CommitSha string

+ ScannerName string

+ ScannerType string

+ ScannerVersion string

+ type RegisterScanOutput struct

+ BaseCommitSha string

+ ScanID string

+ ScanURL string

+ type RepositoryStatsData struct

+ Total int

+ WithFindings int

+ type ResetPasswordInput struct

+ NewPassword string

+ Token string

+ type RevokeAPIKeyInput struct

+ ID string

+ RevokedBy string

+ TenantID string

+ type RoleService struct

+ func NewRoleService(roleRepo role.Repository, permissionRepo role.PermissionRepository, ...) *RoleService

+ func (s *RoleService) AssignRole(ctx context.Context, input AssignRoleInput, assignedBy string, ...) error

+ func (s *RoleService) BulkAssignRoleToUsers(ctx context.Context, input BulkAssignRoleToUsersInput, assignedBy string, ...) (*BulkAssignRoleToUsersResult, error)

+ func (s *RoleService) CountUsersWithRole(ctx context.Context, roleID string) (int, error)

+ func (s *RoleService) CreateRole(ctx context.Context, input CreateRoleInput, createdBy string, ...) (*role.Role, error)

+ func (s *RoleService) DeleteRole(ctx context.Context, roleID string, actx AuditContext) error

+ func (s *RoleService) GetRole(ctx context.Context, roleID string) (*role.Role, error)

+ func (s *RoleService) GetRoleBySlug(ctx context.Context, tenantID *string, slug string) (*role.Role, error)

+ func (s *RoleService) GetUserPermissions(ctx context.Context, tenantID, userID string) ([]string, error)

+ func (s *RoleService) GetUserRoles(ctx context.Context, tenantID, userID string) ([]*role.Role, error)

+ func (s *RoleService) HasFullDataAccess(ctx context.Context, tenantID, userID string) (bool, error)

+ func (s *RoleService) HasPermission(ctx context.Context, tenantID, userID, permission string) (bool, error)

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

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

+ func (s *RoleService) ListRoleMembers(ctx context.Context, tenantID, roleID string) ([]*role.UserRole, error)

+ func (s *RoleService) ListRolesForTenant(ctx context.Context, tenantID string) ([]*role.Role, error)

+ func (s *RoleService) ListSystemRoles(ctx context.Context) ([]*role.Role, error)

+ func (s *RoleService) RemoveRole(ctx context.Context, tenantID, userID, roleID string, actx AuditContext) error

+ func (s *RoleService) SetUserRoles(ctx context.Context, input SetUserRolesInput, assignedBy string, ...) error

+ func (s *RoleService) UpdateRole(ctx context.Context, roleID string, input UpdateRoleInput, actx AuditContext) (*role.Role, error)

+ type RoleServiceOption func(*RoleService)

+ func WithRoleAuditService(auditService *AuditService) RoleServiceOption

+ func WithRolePermissionCacheService(svc *PermissionCacheService) RoleServiceOption

+ func WithRolePermissionVersionService(svc *PermissionVersionService) RoleServiceOption

+ type RuleService struct

+ func NewRuleService(sourceRepo rule.SourceRepository, ruleRepo rule.RuleRepository, ...) *RuleService

+ func (s *RuleService) CleanupExpiredBundles(ctx context.Context) (int64, error)

+ func (s *RuleService) CompleteBundle(ctx context.Context, input CompleteBundleInput) (*rule.Bundle, error)

+ func (s *RuleService) CountRulesBySource(ctx context.Context, sourceID string) (int, error)

+ func (s *RuleService) CreateBundle(ctx context.Context, input CreateBundleInput) (*rule.Bundle, error)

+ func (s *RuleService) CreateOverride(ctx context.Context, input CreateOverrideInput) (*rule.Override, error)

+ func (s *RuleService) CreateSource(ctx context.Context, input CreateSourceInput) (*rule.Source, error)

+ func (s *RuleService) DeleteBundle(ctx context.Context, bundleID string) error

+ func (s *RuleService) DeleteOverride(ctx context.Context, tenantID, overrideID string) error

+ func (s *RuleService) DeleteSource(ctx context.Context, tenantID, sourceID string) error

+ func (s *RuleService) DisableSource(ctx context.Context, tenantID, sourceID string) (*rule.Source, error)

+ func (s *RuleService) EnableSource(ctx context.Context, tenantID, sourceID string) (*rule.Source, error)

+ func (s *RuleService) FailBundle(ctx context.Context, bundleID, errorMessage string) (*rule.Bundle, error)

+ func (s *RuleService) GetBundleByID(ctx context.Context, bundleID string) (*rule.Bundle, error)

+ func (s *RuleService) GetLatestBundle(ctx context.Context, tenantID, toolID string) (*rule.Bundle, error)

+ func (s *RuleService) GetOverride(ctx context.Context, overrideID string) (*rule.Override, error)

+ func (s *RuleService) GetOverrideByTenantAndID(ctx context.Context, tenantID, overrideID string) (*rule.Override, error)

+ func (s *RuleService) GetRule(ctx context.Context, ruleID string) (*rule.Rule, error)

+ func (s *RuleService) GetSource(ctx context.Context, sourceID string) (*rule.Source, error)

+ func (s *RuleService) GetSourceByTenantAndID(ctx context.Context, tenantID, sourceID string) (*rule.Source, error)

+ func (s *RuleService) GetSyncHistory(ctx context.Context, sourceID string, limit int) ([]*rule.SyncHistory, error)

+ func (s *RuleService) ListActiveOverridesForTool(ctx context.Context, tenantID string, toolID *string) ([]*rule.Override, error)

+ func (s *RuleService) ListBundles(ctx context.Context, input ListBundlesInput) ([]*rule.Bundle, error)

+ func (s *RuleService) ListOverrides(ctx context.Context, input ListOverridesInput) (pagination.Result[*rule.Override], error)

+ func (s *RuleService) ListRules(ctx context.Context, input ListRulesInput) (pagination.Result[*rule.Rule], error)

+ func (s *RuleService) ListRulesBySource(ctx context.Context, sourceID string) ([]*rule.Rule, error)

+ func (s *RuleService) ListSources(ctx context.Context, input ListSourcesInput) (pagination.Result[*rule.Source], error)

+ func (s *RuleService) ListSourcesNeedingSync(ctx context.Context, limit int) ([]*rule.Source, error)

+ func (s *RuleService) RecordSyncResult(ctx context.Context, sourceID string, result *SyncResult) error

+ func (s *RuleService) UpdateOverride(ctx context.Context, input UpdateOverrideInput) (*rule.Override, error)

+ func (s *RuleService) UpdateSource(ctx context.Context, input UpdateSourceInput) (*rule.Source, error)

+ func (s *RuleService) UpsertRulesFromSync(ctx context.Context, rules []*rule.Rule) error

+ type SLAComplianceResult struct

+ DaysRemaining int

+ DeadlineAt time.Time

+ EscalationNeeded bool

+ IsCompliant bool

+ PercentElapsed float64

+ Status string

+ type SLAService struct

+ func NewSLAService(repo sla.Repository, log *logger.Logger) *SLAService

+ func (s *SLAService) CalculateSLADeadline(ctx context.Context, tenantID, assetID string, severity vulnerability.Severity, ...) (time.Time, error)

+ func (s *SLAService) CheckSLACompliance(ctx context.Context, tenantID, assetID string, severity vulnerability.Severity, ...) (*SLAComplianceResult, error)

+ func (s *SLAService) CreateDefaultTenantPolicy(ctx context.Context, tenantID string) (*sla.Policy, error)

+ func (s *SLAService) CreateSLAPolicy(ctx context.Context, input CreateSLAPolicyInput) (*sla.Policy, error)

+ func (s *SLAService) DeleteSLAPolicy(ctx context.Context, policyID, tenantID string) error

+ func (s *SLAService) GetAssetSLAPolicy(ctx context.Context, tenantID, assetID string) (*sla.Policy, error)

+ func (s *SLAService) GetSLAPolicy(ctx context.Context, policyID string) (*sla.Policy, error)

+ func (s *SLAService) GetTenantDefaultPolicy(ctx context.Context, tenantID string) (*sla.Policy, error)

+ func (s *SLAService) ListTenantPolicies(ctx context.Context, tenantID string) ([]*sla.Policy, error)

+ func (s *SLAService) UpdateSLAPolicy(ctx context.Context, policyID, tenantID string, input UpdateSLAPolicyInput) (*sla.Policy, error)

+ type ScanProfileService struct

+ func NewScanProfileService(repo scanprofile.Repository, log *logger.Logger) *ScanProfileService

+ func (s *ScanProfileService) CloneScanProfile(ctx context.Context, input CloneScanProfileInput) (*scanprofile.ScanProfile, error)

+ func (s *ScanProfileService) CreateScanProfile(ctx context.Context, input CreateScanProfileInput) (*scanprofile.ScanProfile, error)

+ func (s *ScanProfileService) DeleteScanProfile(ctx context.Context, tenantID, profileID string) error

+ func (s *ScanProfileService) EvaluateQualityGate(ctx context.Context, input EvaluateQualityGateInput) (*scanprofile.QualityGateResult, error)

+ func (s *ScanProfileService) EvaluateQualityGateByProfile(profile *scanprofile.ScanProfile, counts scanprofile.FindingCounts) *scanprofile.QualityGateResult

+ func (s *ScanProfileService) GetDefaultScanProfile(ctx context.Context, tenantID string) (*scanprofile.ScanProfile, error)

+ func (s *ScanProfileService) GetScanProfile(ctx context.Context, tenantID, profileID string) (*scanprofile.ScanProfile, error)

+ func (s *ScanProfileService) GetScanProfileForUse(ctx context.Context, tenantID, profileID string) (*scanprofile.ScanProfile, error)

+ func (s *ScanProfileService) ListScanProfiles(ctx context.Context, input ListScanProfilesInput) (pagination.Result[*scanprofile.ScanProfile], error)

+ func (s *ScanProfileService) SetDefaultScanProfile(ctx context.Context, tenantID, profileID string) (*scanprofile.ScanProfile, error)

+ func (s *ScanProfileService) UpdateQualityGate(ctx context.Context, input UpdateQualityGateInput) (*scanprofile.ScanProfile, error)

+ func (s *ScanProfileService) UpdateScanProfile(ctx context.Context, input UpdateScanProfileInput) (*scanprofile.ScanProfile, error)

+ type ScanScheduler struct

+ func NewScanScheduler(scanRepo scan.Repository, scanService *scansvc.Service, ...) *ScanScheduler

+ func (s *ScanScheduler) Start()

+ func (s *ScanScheduler) Stop()

+ type ScanSchedulerConfig struct

+ BatchSize int

+ CheckInterval time.Duration

+ type ScanSessionService struct

+ func NewScanSessionService(sessionRepo scansession.Repository, agentRepo agent.Repository, ...) *ScanSessionService

+ func (s *ScanSessionService) DeleteScan(ctx context.Context, tenantID shared.ID, scanID string) error

+ func (s *ScanSessionService) GetScan(ctx context.Context, tenantID shared.ID, scanID string) (*scansession.ScanSession, error)

+ func (s *ScanSessionService) GetStats(ctx context.Context, tenantID shared.ID, since time.Time) (*scansession.Stats, error)

+ func (s *ScanSessionService) ListRunning(ctx context.Context, tenantID shared.ID) ([]*scansession.ScanSession, error)

+ func (s *ScanSessionService) ListScanSessions(ctx context.Context, tenantID shared.ID, input ListScanSessionsInput, ...) (pagination.Result[*scansession.ScanSession], error)

+ func (s *ScanSessionService) RegisterScan(ctx context.Context, agt *agent.Agent, input RegisterScanInput) (*RegisterScanOutput, error)

+ func (s *ScanSessionService) UpdateScanSession(ctx context.Context, agt *agent.Agent, scanID string, ...) error

+ type ScannerTemplateService struct

+ func NewScannerTemplateService(repo scannertemplate.Repository, signingSecret string, log *logger.Logger) *ScannerTemplateService

+ func (s *ScannerTemplateService) CreateTemplate(ctx context.Context, input CreateScannerTemplateInput) (*scannertemplate.ScannerTemplate, error)

+ func (s *ScannerTemplateService) DeleteTemplate(ctx context.Context, tenantID, templateID string) error

+ func (s *ScannerTemplateService) DeprecateTemplate(ctx context.Context, tenantID, templateID string) (*scannertemplate.ScannerTemplate, error)

+ func (s *ScannerTemplateService) DownloadTemplate(ctx context.Context, tenantID, templateID string) ([]byte, string, error)

+ func (s *ScannerTemplateService) GetQuota() scannertemplate.TemplateQuota

+ func (s *ScannerTemplateService) GetTemplate(ctx context.Context, tenantID, templateID string) (*scannertemplate.ScannerTemplate, error)

+ func (s *ScannerTemplateService) GetTemplatesByIDs(ctx context.Context, tenantID string, templateIDs []string) ([]*scannertemplate.ScannerTemplate, error)

+ func (s *ScannerTemplateService) GetUsage(ctx context.Context, tenantID string) (*TemplateUsageResult, error)

+ func (s *ScannerTemplateService) ListTemplates(ctx context.Context, input ListScannerTemplatesInput) (pagination.Result[*scannertemplate.ScannerTemplate], error)

+ func (s *ScannerTemplateService) SetQuota(quota scannertemplate.TemplateQuota)

+ func (s *ScannerTemplateService) UpdateTemplate(ctx context.Context, input UpdateScannerTemplateInput) (*scannertemplate.ScannerTemplate, error)

+ func (s *ScannerTemplateService) ValidateTemplate(ctx context.Context, input ValidateTemplateInput) (*validators.ValidationResult, error)

+ func (s *ScannerTemplateService) VerifyTemplateSignature(template *scannertemplate.ScannerTemplate) bool

+ type ScopeService struct

+ func NewScopeService(targetRepo scope.TargetRepository, exclusionRepo scope.ExclusionRepository, ...) *ScopeService

+ func (s *ScopeService) ActivateExclusion(ctx context.Context, exclusionID string) (*scope.Exclusion, error)

+ func (s *ScopeService) ActivateTarget(ctx context.Context, targetID string) (*scope.Target, error)

+ func (s *ScopeService) ApproveExclusion(ctx context.Context, exclusionID string, approvedBy string) (*scope.Exclusion, error)

+ func (s *ScopeService) CheckScope(ctx context.Context, tenantID string, assetType string, value string) (*scope.MatchResult, error)

+ func (s *ScopeService) CreateExclusion(ctx context.Context, input CreateExclusionInput) (*scope.Exclusion, error)

+ func (s *ScopeService) CreateSchedule(ctx context.Context, input CreateScheduleInput) (*scope.Schedule, error)

+ func (s *ScopeService) CreateTarget(ctx context.Context, input CreateTargetInput) (*scope.Target, error)

+ func (s *ScopeService) DeactivateExclusion(ctx context.Context, exclusionID string) (*scope.Exclusion, error)

+ func (s *ScopeService) DeactivateTarget(ctx context.Context, targetID string) (*scope.Target, error)

+ func (s *ScopeService) DeleteExclusion(ctx context.Context, exclusionID string, tenantID string) error

+ func (s *ScopeService) DeleteSchedule(ctx context.Context, scheduleID string, tenantID string) error

+ func (s *ScopeService) DeleteTarget(ctx context.Context, targetID string, tenantID string) error

+ func (s *ScopeService) DisableSchedule(ctx context.Context, scheduleID string) (*scope.Schedule, error)

+ func (s *ScopeService) EnableSchedule(ctx context.Context, scheduleID string) (*scope.Schedule, error)

+ func (s *ScopeService) ExpireOldExclusions(ctx context.Context) error

+ func (s *ScopeService) GetExclusion(ctx context.Context, exclusionID string) (*scope.Exclusion, error)

+ func (s *ScopeService) GetSchedule(ctx context.Context, scheduleID string) (*scope.Schedule, error)

+ func (s *ScopeService) GetStats(ctx context.Context, tenantID string) (*scope.Stats, error)

+ func (s *ScopeService) GetTarget(ctx context.Context, targetID string) (*scope.Target, error)

+ func (s *ScopeService) ListActiveExclusions(ctx context.Context, tenantID string) ([]*scope.Exclusion, error)

+ func (s *ScopeService) ListActiveTargets(ctx context.Context, tenantID string) ([]*scope.Target, error)

+ func (s *ScopeService) ListDueSchedules(ctx context.Context) ([]*scope.Schedule, error)

+ func (s *ScopeService) ListExclusions(ctx context.Context, input ListExclusionsInput) (pagination.Result[*scope.Exclusion], error)

+ func (s *ScopeService) ListSchedules(ctx context.Context, input ListSchedulesInput) (pagination.Result[*scope.Schedule], error)

+ func (s *ScopeService) ListTargets(ctx context.Context, input ListTargetsInput) (pagination.Result[*scope.Target], error)

+ func (s *ScopeService) RecordScheduleRun(ctx context.Context, scheduleID string, status string, nextRunAt *time.Time) (*scope.Schedule, error)

+ func (s *ScopeService) UpdateExclusion(ctx context.Context, exclusionID string, tenantID string, ...) (*scope.Exclusion, error)

+ func (s *ScopeService) UpdateSchedule(ctx context.Context, scheduleID string, tenantID string, ...) (*scope.Schedule, error)

+ func (s *ScopeService) UpdateTarget(ctx context.Context, targetID string, tenantID string, input UpdateTargetInput) (*scope.Target, error)

+ type ScriptRunnerHandler struct

+ func NewScriptRunnerHandler(log *logger.Logger) *ScriptRunnerHandler

+ func (h *ScriptRunnerHandler) Execute(ctx context.Context, input *ActionInput) (map[string]any, error)

+ type SecretStoreService struct

+ func NewSecretStoreService(repo secretstore.Repository, encryptionKey []byte, auditService *AuditService, ...) (*SecretStoreService, error)

+ func (s *SecretStoreService) CreateCredential(ctx context.Context, input CreateCredentialInput) (*secretstore.Credential, error)

+ func (s *SecretStoreService) DecryptCredentialData(ctx context.Context, tenantID shared.ID, credentialID string) (any, error)

+ func (s *SecretStoreService) DeleteCredential(ctx context.Context, tenantID shared.ID, credentialID string) error

+ func (s *SecretStoreService) GetCredential(ctx context.Context, tenantID shared.ID, credentialID string) (*secretstore.Credential, error)

+ func (s *SecretStoreService) ListCredentials(ctx context.Context, input ListCredentialsInput) (*ListCredentialsOutput, error)

+ func (s *SecretStoreService) RotateCredential(ctx context.Context, tenantID shared.ID, credentialID string, newData any) (*secretstore.Credential, error)

+ func (s *SecretStoreService) UpdateCredential(ctx context.Context, input UpdateCredentialInput) (*secretstore.Credential, error)

+ type SecurityValidator struct

+ func NewSecurityValidator(toolRepo tool.Repository, log *logger.Logger) *SecurityValidator

+ func (v *SecurityValidator) GetAllowedCapabilities() []string

+ func (v *SecurityValidator) ValidateCommandPayload(ctx context.Context, tenantID shared.ID, payload map[string]any) *ValidationResult

+ func (v *SecurityValidator) ValidateCronExpression(expr string) error

+ func (v *SecurityValidator) ValidateIdentifier(name string, maxLen int, fieldName string) *ValidationResult

+ func (v *SecurityValidator) ValidateIdentifiers(names []string, maxLen int, fieldName string) *ValidationResult

+ func (v *SecurityValidator) ValidateScannerConfig(ctx context.Context, tenantID shared.ID, scannerConfig map[string]any) *ValidationResult

+ func (v *SecurityValidator) ValidateStepConfig(ctx context.Context, tenantID shared.ID, toolName string, ...) *ValidationResult

+ func (v *SecurityValidator) ValidateTier(tier string) error

+ func (v *SecurityValidator) ValidateTierWithResult(tier string, fieldName string) *ValidationResult

+ type SelectAgentRequest struct

+ AllowQueue bool

+ Capabilities []string

+ Mode AgentSelectionMode

+ Region string

+ TenantID shared.ID

+ Tool string

+ type SelectAgentResult struct

+ Agent *agent.Agent

+ Message string

+ Queued bool

+ type SendNotificationInput struct

+ Body string

+ Fields map[string]string

+ IntegrationID string

+ Severity string

+ TenantID string

+ Title string

+ URL string

+ type SendNotificationResult struct

+ Error string

+ MessageID string

+ Success bool

+ type SessionInfo struct

+ CreatedAt string

+ ID string

+ IPAddress string

+ IsCurrent bool

+ LastActivityAt string

+ UserAgent string

+ type SessionResult struct

+ AccessToken string

+ RefreshToken string

+ type SessionService struct

+ func NewSessionService(sessionRepo session.Repository, ...) *SessionService

+ func (s *SessionService) CleanupExpiredSessions(ctx context.Context) (int64, int64, error)

+ func (s *SessionService) CountActiveSessions(ctx context.Context, userID string) (int, error)

+ func (s *SessionService) GetSessionByAccessToken(ctx context.Context, accessToken string) (*session.Session, error)

+ func (s *SessionService) ListUserSessions(ctx context.Context, userID string, currentSessionID string) ([]SessionInfo, error)

+ func (s *SessionService) RevokeAllSessions(ctx context.Context, userID, exceptSessionID string) error

+ func (s *SessionService) RevokeSession(ctx context.Context, userID, sessionID string) error

+ func (s *SessionService) SetPermissionServices(cacheSvc *PermissionCacheService, versionSvc *PermissionVersionService, ...)

+ func (s *SessionService) UpdateSessionActivity(ctx context.Context, sessionID string) error

+ func (s *SessionService) ValidateSession(ctx context.Context, sessionID string) (*session.Session, error)

+ type SetUserRolesInput struct

+ RoleIDs []string

+ TenantID string

+ UserID string

+ type SyncResult struct

+ Duration time.Duration

+ ErrorDetails map[string]any

+ ErrorMessage string

+ NewContentHash string

+ PreviousHash string

+ RulesAdded int

+ RulesRemoved int

+ RulesUpdated int

+ Status rule.SyncStatus

+ type SyncSourceInput struct

+ SourceID string

+ TenantID string

+ type TeamInvitationJobPayload struct

+ ExpiresIn time.Duration

+ InvitationID string

+ InviterName string

+ RecipientEmail string

+ TeamName string

+ TenantID string

+ Token string

+ type TelegramCredentials struct

+ BotToken string

+ ChatID string

+ type TemplateSourceService struct

+ func NewTemplateSourceService(repo ts.Repository, log *logger.Logger) *TemplateSourceService

+ func (s *TemplateSourceService) CreateSource(ctx context.Context, input CreateTemplateSourceInput) (*ts.TemplateSource, error)

+ func (s *TemplateSourceService) DeleteSource(ctx context.Context, tenantID, sourceID string) error

+ func (s *TemplateSourceService) DisableSource(ctx context.Context, tenantID, sourceID string) (*ts.TemplateSource, error)

+ func (s *TemplateSourceService) EnableSource(ctx context.Context, tenantID, sourceID string) (*ts.TemplateSource, error)

+ func (s *TemplateSourceService) ForceSync(ctx context.Context, tenantID, sourceID string) (*TemplateSyncResult, error)

+ func (s *TemplateSourceService) GetSource(ctx context.Context, tenantID, sourceID string) (*ts.TemplateSource, error)

+ func (s *TemplateSourceService) GetSourcesForScan(ctx context.Context, tenantID string, ...) ([]*ts.TemplateSource, error)

+ func (s *TemplateSourceService) GetSourcesNeedingSync(ctx context.Context, tenantID string) ([]*ts.TemplateSource, error)

+ func (s *TemplateSourceService) ListSources(ctx context.Context, input ListTemplateSourcesInput) (*ts.ListOutput, error)

+ func (s *TemplateSourceService) SetTemplateSyncer(syncer *TemplateSyncer)

+ func (s *TemplateSourceService) UpdateSource(ctx context.Context, input UpdateTemplateSourceInput) (*ts.TemplateSource, error)

+ func (s *TemplateSourceService) UpdateSyncStatus(ctx context.Context, source *ts.TemplateSource) error

+ type TemplateSyncResult struct

+ Duration time.Duration

+ Error string

+ Hash string

+ SourceID shared.ID

+ Success bool

+ TemplatesAdded int

+ TemplatesFound int

+ type TemplateSyncer struct

+ func NewTemplateSyncer(sourceRepo templatesource.Repository, templateRepo scannertemplate.Repository, ...) *TemplateSyncer

+ func (s *TemplateSyncer) SyncSource(ctx context.Context, source *templatesource.TemplateSource) (*TemplateSyncResult, error)

+ func (s *TemplateSyncer) SyncSourcesForScan(ctx context.Context, tenantID shared.ID) ([]*TemplateSyncResult, error)

+ type TemplateUsageResult struct

+ Quota scannertemplate.TemplateQuota

+ Usage scannertemplate.TemplateUsage

+ type TenantAvailableCapabilitiesOutput struct

+ Capabilities []string

+ TotalAgents int

+ type TenantLister interface

+ ListActiveTenantIDs func(ctx context.Context) ([]shared.ID, error)

+ type TenantMembershipAdapter struct

+ func NewTenantMembershipAdapter(repo tenant.Repository) *TenantMembershipAdapter

+ func (a *TenantMembershipAdapter) GetUserTenantIDs(ctx context.Context, userID shared.ID) ([]string, error)

+ type TenantMembershipInfo struct

+ Role string

+ TenantID string

+ TenantName string

+ TenantSlug string

+ type TenantMembershipProvider interface

+ GetUserTenantIDs func(ctx context.Context, userID shared.ID) ([]string, error)

+ type TenantService struct

+ func NewTenantService(repo tenant.Repository, log *logger.Logger, opts ...TenantServiceOption) *TenantService

+ func (s *TenantService) AcceptInvitation(ctx context.Context, token string, userID shared.ID, userEmail string, ...) (*tenant.Membership, error)

+ func (s *TenantService) AddMember(ctx context.Context, tenantID string, input AddMemberInput, ...) (*tenant.Membership, error)

+ func (s *TenantService) CleanupExpiredInvitations(ctx context.Context) (int64, error)

+ func (s *TenantService) CreateInvitation(ctx context.Context, tenantID string, input CreateInvitationInput, ...) (*tenant.Invitation, error)

+ func (s *TenantService) CreateTenant(ctx context.Context, input CreateTenantInput, creatorUserID shared.ID, ...) (*tenant.Tenant, error)

+ func (s *TenantService) DeleteInvitation(ctx context.Context, invitationID string) error

+ func (s *TenantService) DeleteTenant(ctx context.Context, tenantID string) error

+ func (s *TenantService) GetInvitationByToken(ctx context.Context, token string) (*tenant.Invitation, error)

+ func (s *TenantService) GetMemberStats(ctx context.Context, tenantID string) (*tenant.MemberStats, error)

+ func (s *TenantService) GetMembership(ctx context.Context, userID shared.ID, tenantID string) (*tenant.Membership, error)

+ func (s *TenantService) GetTenant(ctx context.Context, tenantID string) (*tenant.Tenant, error)

+ func (s *TenantService) GetTenantBySlug(ctx context.Context, slug string) (*tenant.Tenant, error)

+ func (s *TenantService) GetTenantSettings(ctx context.Context, tenantID string) (*tenant.Settings, error)

+ func (s *TenantService) GetUserDisplayName(ctx context.Context, userID shared.ID) string

+ func (s *TenantService) ListMembers(ctx context.Context, tenantID string) ([]*tenant.Membership, error)

+ func (s *TenantService) ListMembersWithUserInfo(ctx context.Context, tenantID string) ([]*tenant.MemberWithUser, error)

+ func (s *TenantService) ListPendingInvitations(ctx context.Context, tenantID string) ([]*tenant.Invitation, error)

+ func (s *TenantService) ListUserTenants(ctx context.Context, userID shared.ID) ([]*tenant.TenantWithRole, error)

+ func (s *TenantService) RemoveMember(ctx context.Context, membershipID string, actx AuditContext) error

+ func (s *TenantService) SearchMembersWithUserInfo(ctx context.Context, tenantID string, filters tenant.MemberSearchFilters) (*tenant.MemberSearchResult, error)

+ func (s *TenantService) SetPermissionServices(cacheSvc *PermissionCacheService, versionSvc *PermissionVersionService)

+ func (s *TenantService) UpdateAPISettings(ctx context.Context, tenantID string, input UpdateAPISettingsInput, ...) (*tenant.Settings, error)

+ func (s *TenantService) UpdateBranchSettings(ctx context.Context, tenantID string, input UpdateBranchSettingsInput, ...) (*tenant.Settings, error)

+ func (s *TenantService) UpdateBrandingSettings(ctx context.Context, tenantID string, input UpdateBrandingSettingsInput, ...) (*tenant.Settings, error)

+ func (s *TenantService) UpdateGeneralSettings(ctx context.Context, tenantID string, input UpdateGeneralSettingsInput, ...) (*tenant.Settings, error)

+ func (s *TenantService) UpdateMemberRole(ctx context.Context, membershipID string, input UpdateMemberRoleInput, ...) (*tenant.Membership, error)

+ func (s *TenantService) UpdateSecuritySettings(ctx context.Context, tenantID string, input UpdateSecuritySettingsInput, ...) (*tenant.Settings, error)

+ func (s *TenantService) UpdateTenant(ctx context.Context, tenantID string, input UpdateTenantInput) (*tenant.Tenant, error)

+ func (s *TenantService) UpdateTenantSettings(ctx context.Context, tenantID string, settings tenant.Settings, ...) (*tenant.Settings, error)

+ type TenantServiceOption func(*TenantService)

+ func WithEmailEnqueuer(enqueuer EmailJobEnqueuer) TenantServiceOption

+ func WithTenantAuditService(auditService *AuditService) TenantServiceOption

+ func WithTenantPermissionCacheService(svc *PermissionCacheService) TenantServiceOption

+ func WithTenantPermissionVersionService(svc *PermissionVersionService) TenantServiceOption

+ func WithUserInfoProvider(provider UserInfoProvider) TenantServiceOption

+ type TestIntegrationCredentialsInput struct

+ AuthType string

+ BaseURL string

+ Category string

+ Credentials string

+ Provider string

+ SCMOrganization string

+ type TestIntegrationCredentialsResult struct

+ Message string

+ Organization string

+ RepoCount int

+ Success bool

+ Username string

+ type ThreatIntelService struct

+ func NewThreatIntelService(repo threatintel.ThreatIntelRepository, log *logger.Logger) *ThreatIntelService

+ func (s *ThreatIntelService) EnrichCVE(ctx context.Context, cveID string) (*threatintel.ThreatIntelEnrichment, error)

+ func (s *ThreatIntelService) EnrichCVEs(ctx context.Context, cveIDs []string) (map[string]*threatintel.ThreatIntelEnrichment, error)

+ func (s *ThreatIntelService) GetEPSSScore(ctx context.Context, cveID string) (*threatintel.EPSSScore, error)

+ func (s *ThreatIntelService) GetEPSSScores(ctx context.Context, cveIDs []string) ([]*threatintel.EPSSScore, error)

+ func (s *ThreatIntelService) GetEPSSStats(ctx context.Context) (*EPSSStats, error)

+ func (s *ThreatIntelService) GetHighRiskEPSS(ctx context.Context, threshold float64, limit int) ([]*threatintel.EPSSScore, error)

+ func (s *ThreatIntelService) GetKEVEntry(ctx context.Context, cveID string) (*threatintel.KEVEntry, error)

+ func (s *ThreatIntelService) GetKEVStats(ctx context.Context) (*KEVStats, error)

+ func (s *ThreatIntelService) GetSyncStatus(ctx context.Context, source string) (*threatintel.SyncStatus, error)

+ func (s *ThreatIntelService) GetSyncStatuses(ctx context.Context) ([]*threatintel.SyncStatus, error)

+ func (s *ThreatIntelService) GetThreatIntelStats(ctx context.Context) (*ThreatIntelStats, error)

+ func (s *ThreatIntelService) IsInKEV(ctx context.Context, cveID string) (bool, error)

+ func (s *ThreatIntelService) SetSyncEnabled(ctx context.Context, source string, enabled bool) error

+ func (s *ThreatIntelService) SyncAll(ctx context.Context) []ThreatIntelSyncResult

+ func (s *ThreatIntelService) SyncEPSS(ctx context.Context) ThreatIntelSyncResult

+ func (s *ThreatIntelService) SyncKEV(ctx context.Context) ThreatIntelSyncResult

+ type ThreatIntelStats struct

+ EPSS *EPSSStats

+ KEV *KEVStats

+ SyncStatuses []*ThreatIntelSyncDTO

+ type ThreatIntelSyncDTO struct

+ Enabled bool

+ LastError *string

+ LastSyncAt *string

+ LastSyncStatus string

+ NextSyncAt *string

+ RecordsSynced int

+ Source string

+ type ThreatIntelSyncResult struct

+ DurationMs int64

+ Error error

+ RecordsSynced int

+ Source string

+ type TicketActionHandler struct

+ func NewTicketActionHandler(intSvc *IntegrationService, log *logger.Logger) *TicketActionHandler

+ func (h *TicketActionHandler) Execute(ctx context.Context, input *ActionInput) (map[string]any, error)

+ type TokenLimitError struct

+ Limit int

+ Used int

+ func (e *TokenLimitError) Error() string

+ type ToolCategoryService struct

+ func NewToolCategoryService(repo toolcategory.Repository, log *logger.Logger) *ToolCategoryService

+ func (s *ToolCategoryService) CreateCategory(ctx context.Context, input CreateCategoryInput) (*toolcategory.ToolCategory, error)

+ func (s *ToolCategoryService) DeleteCategory(ctx context.Context, tenantID, categoryID string) error

+ func (s *ToolCategoryService) GetCategory(ctx context.Context, id string) (*toolcategory.ToolCategory, error)

+ func (s *ToolCategoryService) ListAllCategories(ctx context.Context, tenantID string) ([]*toolcategory.ToolCategory, error)

+ func (s *ToolCategoryService) ListCategories(ctx context.Context, input ListCategoriesInput) (pagination.Result[*toolcategory.ToolCategory], error)

+ func (s *ToolCategoryService) UpdateCategory(ctx context.Context, input UpdateCategoryInput) (*toolcategory.ToolCategory, error)

+ type ToolService struct

+ func NewToolService(toolRepo tool.Repository, configRepo tool.TenantToolConfigRepository, ...) *ToolService

+ func (s *ToolService) ActivateCustomTool(ctx context.Context, tenantID, toolID string) (*tool.Tool, error)

+ func (s *ToolService) ActivateTool(ctx context.Context, toolID string) (*tool.Tool, error)

+ func (s *ToolService) BulkDisableTools(ctx context.Context, input BulkDisableToolsInput) error

+ func (s *ToolService) BulkEnableTools(ctx context.Context, input BulkEnableToolsInput) error

+ func (s *ToolService) CompleteToolExecution(ctx context.Context, input CompleteToolExecutionInput) (*tool.ToolExecution, error)

+ func (s *ToolService) CreateCustomTool(ctx context.Context, input CreateCustomToolInput) (*tool.Tool, error)

+ func (s *ToolService) CreateTenantToolConfig(ctx context.Context, input CreateTenantToolConfigInput) (*tool.TenantToolConfig, error)

+ func (s *ToolService) CreateTool(ctx context.Context, input CreateToolInput) (*tool.Tool, error)

+ func (s *ToolService) DeactivateCustomTool(ctx context.Context, tenantID, toolID string) (*tool.Tool, error)

+ func (s *ToolService) DeactivateTool(ctx context.Context, toolID string) (*tool.Tool, error)

+ func (s *ToolService) DeleteCustomTool(ctx context.Context, tenantID, toolID string) error

+ func (s *ToolService) DeleteTenantToolConfig(ctx context.Context, tenantID, toolID string) error

+ func (s *ToolService) DeleteTool(ctx context.Context, toolID string) error

+ func (s *ToolService) DisableToolForTenant(ctx context.Context, tenantID, toolID string) error

+ func (s *ToolService) EnableToolForTenant(ctx context.Context, tenantID, toolID string) error

+ func (s *ToolService) FailToolExecution(ctx context.Context, input FailToolExecutionInput) (*tool.ToolExecution, error)

+ func (s *ToolService) GetCustomTool(ctx context.Context, tenantID, toolID string) (*tool.Tool, error)

+ func (s *ToolService) GetEffectiveToolConfig(ctx context.Context, tenantID, toolID string) (map[string]any, error)

+ func (s *ToolService) GetTenantToolConfig(ctx context.Context, tenantID, toolID string) (*tool.TenantToolConfig, error)

+ func (s *ToolService) GetTenantToolStats(ctx context.Context, tenantID string, days int) (*tool.TenantToolStats, error)

+ func (s *ToolService) GetTool(ctx context.Context, toolID string) (*tool.Tool, error)

+ func (s *ToolService) GetToolByName(ctx context.Context, name string) (*tool.Tool, error)

+ func (s *ToolService) GetToolStats(ctx context.Context, tenantID, toolID string, days int) (*tool.ToolStats, error)

+ func (s *ToolService) GetToolWithConfig(ctx context.Context, tenantID, toolID string) (*tool.ToolWithConfig, error)

+ func (s *ToolService) ListAvailableTools(ctx context.Context, input ListAvailableToolsInput) (pagination.Result[*tool.Tool], error)

+ func (s *ToolService) ListCustomTools(ctx context.Context, input ListCustomToolsInput) (pagination.Result[*tool.Tool], error)

+ func (s *ToolService) ListEnabledToolsForTenant(ctx context.Context, tenantID string) ([]*tool.TenantToolConfig, error)

+ func (s *ToolService) ListPlatformTools(ctx context.Context, input ListPlatformToolsInput) (pagination.Result[*tool.Tool], error)

+ func (s *ToolService) ListTenantToolConfigs(ctx context.Context, input ListTenantToolConfigsInput) (pagination.Result[*tool.TenantToolConfig], error)

+ func (s *ToolService) ListToolExecutions(ctx context.Context, input ListToolExecutionsInput) (pagination.Result[*tool.ToolExecution], error)

+ func (s *ToolService) ListTools(ctx context.Context, input ListToolsInput) (pagination.Result[*tool.Tool], error)

+ func (s *ToolService) ListToolsByCapability(ctx context.Context, capability string) ([]*tool.Tool, error)

+ func (s *ToolService) ListToolsByCategory(ctx context.Context, category string) ([]*tool.Tool, error)

+ func (s *ToolService) ListToolsWithConfig(ctx context.Context, input ListToolsWithConfigInput) (pagination.Result[*tool.ToolWithConfig], error)

+ func (s *ToolService) RecordToolExecution(ctx context.Context, input RecordToolExecutionInput) (*tool.ToolExecution, error)

+ func (s *ToolService) SetAgentRepo(repo agent.Repository)

+ func (s *ToolService) SetCategoryRepo(repo toolcategory.Repository)

+ func (s *ToolService) SetPipelineDeactivator(deactivator PipelineDeactivator)

+ func (s *ToolService) TimeoutToolExecution(ctx context.Context, executionID string) (*tool.ToolExecution, error)

+ func (s *ToolService) UpdateCustomTool(ctx context.Context, input UpdateCustomToolInput) (*tool.Tool, error)

+ func (s *ToolService) UpdateTenantToolConfig(ctx context.Context, input UpdateTenantToolConfigInput) (*tool.TenantToolConfig, error)

+ func (s *ToolService) UpdateTool(ctx context.Context, input UpdateToolInput) (*tool.Tool, error)

+ func (s *ToolService) UpdateToolVersion(ctx context.Context, input UpdateToolVersionInput) (*tool.Tool, error)

+ type TriageBroadcaster interface

+ BroadcastTriage func(channel string, data any, tenantID string)

+ type TriageOutputValidator struct

+ func NewTriageOutputValidator() *TriageOutputValidator

+ func (v *TriageOutputValidator) ValidateAndSanitize(content string) (*aitriage.TriageAnalysis, error)

+ type TriageRequest struct

+ FindingID string

+ TenantID string

+ TriageType string

+ UserID *string

+ type TriageResponse struct

+ JobID string

+ Status string

+ type TriageResultResponse struct

+ BusinessImpact string

+ CompletedAt *time.Time

+ CreatedAt time.Time

+ ErrorMessage string

+ Exploitability string

+ ExploitabilityDetails string

+ FalsePositiveLikelihood float64

+ FalsePositiveReason string

+ ID string

+ PriorityRank int

+ RiskScore float64

+ SeverityAssessment string

+ SeverityJustification string

+ Status string

+ Summary string

+ type TriggerWorkflowInput struct

+ TenantID shared.ID

+ TriggerData map[string]any

+ TriggerType workflow.TriggerType

+ UserID shared.ID

+ WorkflowID shared.ID

+ type UnassignAssetInput struct

+ AssetID string

+ GroupID string

+ type UpdateAPISettingsInput struct

+ APIKeyEnabled bool

+ WebhookEvents []string

+ WebhookSecret string

+ WebhookURL string

+ type UpdateAgentInput struct

+ AgentID string

+ AuditContext *AuditContext

+ Capabilities []string

+ Description string

+ MaxConcurrentJobs *int

+ Name string

+ Status string

+ TenantID string

+ Tools []string

+ type UpdateAssetGroupInput struct

+ BusinessUnit *string

+ Criticality *string

+ Description *string

+ Environment *string

+ Name *string

+ Owner *string

+ OwnerEmail *string

+ Tags []string

+ type UpdateAssetInput struct

+ Criticality *string

+ Description *string

+ Exposure *string

+ Name *string

+ Scope *string

+ Tags []string

+ type UpdateAssetOwnershipInput struct

+ AssetID string

+ GroupID string

+ OwnershipType string

+ type UpdateBranchInput struct

+ IsProtected *bool

+ KeepWhenInactive *bool

+ LastCommitAuthor *string

+ LastCommitAuthorAvatar *string

+ LastCommitMessage *string

+ LastCommitSHA *string

+ RetentionDays *int

+ ScanOnPR *bool

+ ScanOnPush *bool

+ type UpdateBranchScanStatusInput struct

+ CriticalFindings *int

+ HighFindings *int

+ LowFindings *int

+ MediumFindings *int

+ QualityGate string

+ ScanID string

+ ScanStatus string

+ TotalFindings *int

+ type UpdateBranchSettingsInput struct

+ TypeRules []BranchTypeRuleInput

+ type UpdateBrandingSettingsInput struct

+ LogoDarkURL string

+ LogoData string

+ PrimaryColor string

+ type UpdateCapabilityInput struct

+ AuditContext AuditContext

+ Category string

+ Color string

+ Description string

+ DisplayName string

+ ID string

+ Icon string

+ TenantID string

+ type UpdateCategoryInput struct

+ Color string

+ Description string

+ DisplayName string

+ ID string

+ Icon string

+ TenantID string

+ type UpdateCommentInput struct

+ Content string

+ type UpdateComponentInput struct

+ DependencyType *string

+ License *string

+ ManifestFile *string

+ ManifestPath *string

+ Namespace *string

+ PackageManager *string

+ Status *string

+ Version *string

+ VulnerabilityCount *int

+ type UpdateCredentialInput struct

+ CredentialID string

+ Data any

+ Description string

+ ExpiresAt *time.Time

+ Name string

+ TenantID shared.ID

+ type UpdateCustomToolInput struct

+ Capabilities []string

+ ConfigSchema map[string]any

+ DefaultConfig map[string]any

+ Description string

+ DisplayName string

+ DocsURL string

+ GithubURL string

+ InstallCmd string

+ LogoURL string

+ OutputFormats []string

+ SupportedTargets []string

+ Tags []string

+ TenantID string

+ ToolID string

+ UpdateCmd string

+ VersionCmd string

+ VersionRegex string

+ type UpdateExclusionInput struct

+ ExpiresAt *time.Time

+ Reason *string

+ type UpdateFindingStatusInput struct

+ ActorID string

+ Resolution string

+ Status string

+ type UpdateGeneralSettingsInput struct

+ Industry string

+ Language string

+ Timezone string

+ Website string

+ type UpdateGroupInput struct

+ Description *string

+ IsActive *bool

+ Name *string

+ Settings *group.GroupSettings

+ Slug *string

+ type UpdateGroupMemberRoleInput struct

+ GroupID string

+ Role string

+ UserID shared.ID

+ type UpdateIntegrationInput struct

+ BaseURL *string

+ Credentials *string

+ Description *string

+ Name *string

+ SCMOrganization *string

+ type UpdateMemberRoleInput struct

+ Role string

+ type UpdateNodeInput struct

+ Config *workflow.NodeConfig

+ Description *string

+ Name *string

+ NodeID shared.ID

+ TenantID shared.ID

+ UIPositionX *float64

+ UIPositionY *float64

+ UserID shared.ID

+ WorkflowID shared.ID

+ type UpdateNotificationIntegrationInput struct

+ ChannelID *string

+ ChannelName *string

+ Credentials *string

+ Description *string

+ EnabledEventTypes []string

+ EnabledSeverities []string

+ IncludeDetails *bool

+ MessageTemplate *string

+ MinIntervalMinutes *int

+ Name *string

+ type UpdateOverrideInput struct

+ AssetGroupID string

+ Enabled *bool

+ ExpiresAt *string

+ IsPattern *bool

+ OverrideID string

+ Reason string

+ RulePattern string

+ ScanProfileID string

+ SeverityOverride string

+ TenantID string

+ type UpdatePermissionSetInput struct

+ Description *string

+ IsActive *bool

+ Name *string

+ type UpdateProfileInput struct

+ AvatarURL *string

+ Name *string

+ Phone *string

+ type UpdateQualityGateInput struct

+ ProfileID string

+ QualityGate scanprofile.QualityGate

+ TenantID string

+ type UpdateRelationshipInput struct

+ Confidence *string

+ Description *string

+ ImpactWeight *int

+ MarkVerified bool

+ Tags []string

+ type UpdateRepositoryExtensionInput struct

+ BranchCount *int

+ CloneURL *string

+ ComponentCount *int

+ ContributorsCount *int

+ DefaultBranch *string

+ Forks *int

+ FullName *string

+ Language *string

+ Languages map[string]int64

+ OpenIssues *int

+ ProtectedBranchCount *int

+ RepoID *string

+ SCMOrganization *string

+ SSHURL *string

+ SizeKB *int

+ Stars *int

+ Topics []string

+ Visibility *string

+ Watchers *int

+ WebURL *string

+ type UpdateRoleInput struct

+ Description *string

+ HasFullDataAccess *bool

+ HierarchyLevel *int

+ Name *string

+ Permissions []string

+ type UpdateSLAPolicyInput struct

+ CriticalDays *int

+ Description *string

+ EscalationConfig map[string]any

+ EscalationEnabled *bool

+ HighDays *int

+ InfoDays *int

+ IsActive *bool

+ IsDefault *bool

+ LowDays *int

+ MediumDays *int

+ Name *string

+ WarningThresholdPct *int

+ type UpdateScanProfileInput struct

+ Description string

+ Intensity string

+ MaxConcurrentScans int

+ Name string

+ ProfileID string

+ QualityGate *scanprofile.QualityGate

+ Tags []string

+ TenantID string

+ TimeoutSeconds int

+ ToolsConfig map[string]scanprofile.ToolConfig

+ type UpdateScanSessionInput struct

+ ErrorMessage string

+ FindingsBySeverity map[string]int

+ FindingsFixed int

+ FindingsNew int

+ FindingsTotal int

+ Status string

+ type UpdateScannerTemplateInput struct

+ Content string

+ Description string

+ Name string

+ Tags []string

+ TemplateID string

+ TenantID string

+ type UpdateScheduleInput struct

+ CronExpression *string

+ Description *string

+ IntervalHours *int

+ Name *string

+ NotificationChannels []string

+ NotifyOnCompletion *bool

+ NotifyOnFindings *bool

+ ScannerConfigs map[string]interface{}

+ ScheduleType *string

+ TargetIDs []string

+ TargetScope *string

+ TargetTags []string

+ type UpdateSecuritySettingsInput struct

+ AllowedDomains []string

+ IPWhitelist []string

+ MFARequired bool

+ SSOConfigURL string

+ SSOEnabled bool

+ SSOProvider string

+ SessionTimeoutMin int

+ type UpdateSourceInput struct

+ Config []byte

+ CredentialsID string

+ Description string

+ Enabled *bool

+ Name string

+ Priority int

+ SourceID string

+ SyncEnabled *bool

+ SyncIntervalMinutes int

+ TenantID string

+ type UpdateTargetInput struct

+ Description *string

+ Priority *int

+ Tags []string

+ type UpdateTemplateSourceInput struct

+ AutoSyncOnScan *bool

+ CacheTTLMinutes *int

+ CredentialID *string

+ Description string

+ Enabled *bool

+ GitConfig *ts.GitSourceConfig

+ HTTPConfig *ts.HTTPSourceConfig

+ Name string

+ S3Config *ts.S3SourceConfig

+ SourceID string

+ TenantID string

+ type UpdateTenantInput struct

+ Description *string

+ LogoURL *string

+ Name *string

+ Slug *string

+ type UpdateTenantToolConfigInput struct

+ Config map[string]any

+ IsEnabled bool

+ TenantID string

+ ToolID string

+ UpdatedBy string

+ type UpdateToolInput struct

+ Capabilities []string

+ ConfigSchema map[string]any

+ DefaultConfig map[string]any

+ Description string

+ DisplayName string

+ DocsURL string

+ GithubURL string

+ InstallCmd string

+ LogoURL string

+ OutputFormats []string

+ SupportedTargets []string

+ Tags []string

+ ToolID string

+ UpdateCmd string

+ VersionCmd string

+ VersionRegex string

+ type UpdateToolVersionInput struct

+ CurrentVersion string

+ LatestVersion string

+ ToolID string

+ type UpdateVulnerabilityInput struct

+ CVSSScore *float64

+ CVSSVector *string

+ Description *string

+ EPSSPercentile *float64

+ EPSSScore *float64

+ ExploitAvailable *bool

+ ExploitMaturity *string

+ FixedVersions []string

+ Remediation *string

+ Severity *string

+ Status *string

+ Title *string

+ type UpdateWebhookInput struct

+ Description *string

+ EventTypes []string

+ MaxRetries *int

+ Name *string

+ RetryInterval *int

+ Secret *string

+ SeverityThreshold *string

+ URL *string

+ type UpdateWorkflowGraphInput struct

+ Description *string

+ Edges []CreateEdgeInput

+ Name *string

+ Nodes []CreateNodeInput

+ Tags []string

+ TenantID shared.ID

+ UserID shared.ID

+ WorkflowID shared.ID

+ type UpdateWorkflowInput struct

+ Description *string

+ IsActive *bool

+ Name *string

+ Tags []string

+ TenantID shared.ID

+ UserID shared.ID

+ WorkflowID shared.ID

+ type UserInfoProvider interface

+ GetUserNameByID func(ctx context.Context, id shared.ID) (string, error)

+ type UserService struct

+ func NewUserService(repo user.Repository, log *logger.Logger) *UserService

+ func (s *UserService) ActivateUser(ctx context.Context, userID string) (*user.User, error)

+ func (s *UserService) GetByEmail(ctx context.Context, email string) (*user.User, error)

+ func (s *UserService) GetByIDs(ctx context.Context, ids []shared.ID) ([]*user.User, error)

+ func (s *UserService) GetByKeycloakID(ctx context.Context, keycloakID string) (*user.User, error)

+ func (s *UserService) GetOrCreateFromLocalToken(ctx context.Context, userID, email, name string) (*user.User, error)

+ func (s *UserService) GetProfile(ctx context.Context, userID string) (*user.User, error)

+ func (s *UserService) GetUsersByIDs(ctx context.Context, userIDs []string) ([]*user.User, error)

+ func (s *UserService) SetSessionService(sessionService *SessionService)

+ func (s *UserService) SuspendUser(ctx context.Context, userID string) (*user.User, error)

+ func (s *UserService) SyncFromKeycloak(ctx context.Context, claims *keycloak.Claims) (*user.User, error)

+ func (s *UserService) UpdatePreferences(ctx context.Context, userID string, prefs user.Preferences) (*user.User, error)

+ func (s *UserService) UpdateProfile(ctx context.Context, userID string, input UpdateProfileInput) (*user.User, error)

+ type ValidateTemplateInput struct

+ Content string

+ TemplateType string

+ type ValidationError struct

+ Code string

+ Field string

+ Message string

+ type ValidationResult struct

+ Errors []ValidationError

+ Valid bool

+ type VulnerabilityService struct

+ func NewVulnerabilityService(vulnRepo vulnerability.VulnerabilityRepository, ...) *VulnerabilityService

+ func (s *VulnerabilityService) AddFindingComment(ctx context.Context, tenantID, findingID, authorID, content string) (*vulnerability.FindingComment, error)

+ func (s *VulnerabilityService) AssignFinding(ctx context.Context, findingID, tenantID, userID, assignerID string) (*vulnerability.Finding, error)

+ func (s *VulnerabilityService) BulkAssignFindings(ctx context.Context, tenantID string, input BulkAssignInput) (*BulkUpdateResult, error)

+ func (s *VulnerabilityService) BulkUpdateFindingsStatus(ctx context.Context, tenantID string, input BulkUpdateStatusInput) (*BulkUpdateResult, error)

+ func (s *VulnerabilityService) ClassifyFinding(ctx context.Context, findingID, tenantID string, input ClassifyFindingInput) (*vulnerability.Finding, error)

+ func (s *VulnerabilityService) CountAssetFindings(ctx context.Context, tenantID string, assetID string) (int64, error)

+ func (s *VulnerabilityService) CountOpenAssetFindings(ctx context.Context, tenantID string, assetID string) (int64, error)

+ func (s *VulnerabilityService) CreateFinding(ctx context.Context, input CreateFindingInput) (*vulnerability.Finding, error)

+ func (s *VulnerabilityService) CreateVulnerability(ctx context.Context, input CreateVulnerabilityInput) (*vulnerability.Vulnerability, error)

+ func (s *VulnerabilityService) DeleteAssetFindings(ctx context.Context, tenantID string, assetID string) error

+ func (s *VulnerabilityService) DeleteFinding(ctx context.Context, findingID string, tenantID string) error

+ func (s *VulnerabilityService) DeleteFindingComment(ctx context.Context, tenantID, commentID, authorID string) error

+ func (s *VulnerabilityService) DeleteVulnerability(ctx context.Context, vulnID string) error

+ func (s *VulnerabilityService) GetFinding(ctx context.Context, tenantID, findingID string) (*vulnerability.Finding, error)

+ func (s *VulnerabilityService) GetFindingCountsByScanID(ctx context.Context, tenantID, scanID string) (vulnerability.SeverityCounts, error)

+ func (s *VulnerabilityService) GetFindingStats(ctx context.Context, tenantID string) (*vulnerability.FindingStats, error)

+ func (s *VulnerabilityService) GetVulnerability(ctx context.Context, vulnID string) (*vulnerability.Vulnerability, error)

+ func (s *VulnerabilityService) GetVulnerabilityByCVE(ctx context.Context, cveID string) (*vulnerability.Vulnerability, error)

+ func (s *VulnerabilityService) ListAssetFindings(ctx context.Context, tenantID string, assetID string, sort string, ...) (pagination.Result[*vulnerability.Finding], error)

+ func (s *VulnerabilityService) ListFindingComments(ctx context.Context, findingID string) ([]*vulnerability.FindingComment, error)

+ func (s *VulnerabilityService) ListFindings(ctx context.Context, input ListFindingsInput) (pagination.Result[*vulnerability.Finding], error)

+ func (s *VulnerabilityService) ListVulnerabilities(ctx context.Context, input ListVulnerabilitiesInput) (pagination.Result[*vulnerability.Vulnerability], error)

+ func (s *VulnerabilityService) SetAITriageService(svc *AITriageService)

+ func (s *VulnerabilityService) SetActivityService(svc *FindingActivityService)

+ func (s *VulnerabilityService) SetCommentRepository(repo vulnerability.FindingCommentRepository)

+ func (s *VulnerabilityService) SetDataFlowRepository(repo vulnerability.DataFlowRepository)

+ func (s *VulnerabilityService) SetFindingNotifier(notifier FindingNotifier)

+ func (s *VulnerabilityService) SetFindingTags(ctx context.Context, findingID, tenantID string, tags []string) (*vulnerability.Finding, error)

+ func (s *VulnerabilityService) SetNotificationService(db *sql.DB, svc *NotificationService)

+ func (s *VulnerabilityService) SetUserRepository(repo user.Repository)

+ func (s *VulnerabilityService) TriageFinding(ctx context.Context, findingID, tenantID, userID, reason string) (*vulnerability.Finding, error)

+ func (s *VulnerabilityService) UnassignFinding(ctx context.Context, findingID, tenantID, actorID string) (*vulnerability.Finding, error)

+ func (s *VulnerabilityService) UpdateFindingComment(ctx context.Context, tenantID, commentID, authorID, content string) (*vulnerability.FindingComment, error)

+ func (s *VulnerabilityService) UpdateFindingSeverity(ctx context.Context, findingID, tenantID, severityStr, actorID string) (*vulnerability.Finding, error)

+ func (s *VulnerabilityService) UpdateFindingStatus(ctx context.Context, findingID string, tenantID string, ...) (*vulnerability.Finding, error)

+ func (s *VulnerabilityService) UpdateVulnerability(ctx context.Context, vulnID string, input UpdateVulnerabilityInput) (*vulnerability.Vulnerability, error)

+ func (s *VulnerabilityService) VerifyFinding(ctx context.Context, findingID, tenantID, userID string) (*vulnerability.Finding, error)

+ type WebhookService struct

+ func NewWebhookService(repo webhook.Repository, encryptor crypto.Encryptor, log *logger.Logger) *WebhookService

+ func (s *WebhookService) CreateWebhook(ctx context.Context, input CreateWebhookInput) (*webhook.Webhook, error)

+ func (s *WebhookService) DeleteWebhook(ctx context.Context, id, tenantIDStr string) error

+ func (s *WebhookService) DisableWebhook(ctx context.Context, id, tenantIDStr string) (*webhook.Webhook, error)

+ func (s *WebhookService) EnableWebhook(ctx context.Context, id, tenantIDStr string) (*webhook.Webhook, error)

+ func (s *WebhookService) GetWebhook(ctx context.Context, id, tenantIDStr string) (*webhook.Webhook, error)

+ func (s *WebhookService) ListDeliveries(ctx context.Context, input ListDeliveriesInput) (webhook.DeliveryListResult, error)

+ func (s *WebhookService) ListWebhooks(ctx context.Context, input ListWebhooksInput) (webhook.ListResult, error)

+ func (s *WebhookService) UpdateWebhook(ctx context.Context, id, tenantIDStr string, input UpdateWebhookInput) (*webhook.Webhook, error)

+ type WorkflowEventDispatcher struct

+ func NewWorkflowEventDispatcher(workflowRepo workflow.WorkflowRepository, nodeRepo workflow.NodeRepository, ...) *WorkflowEventDispatcher

+ func (d *WorkflowEventDispatcher) DispatchAITriageCompleted(ctx context.Context, tenantID, findingID, triageID shared.ID, ...)

+ func (d *WorkflowEventDispatcher) DispatchAITriageEvent(ctx context.Context, event AITriageEvent) error

+ func (d *WorkflowEventDispatcher) DispatchAITriageFailed(ctx context.Context, tenantID, findingID, triageID shared.ID, ...)

+ func (d *WorkflowEventDispatcher) DispatchFindingEvent(ctx context.Context, event FindingEvent) error

+ func (d *WorkflowEventDispatcher) DispatchFindingsCreated(ctx context.Context, tenantID shared.ID, findings []*vulnerability.Finding)

+ type WorkflowEventDispatcherInterface interface

+ DispatchAITriageCompleted func(ctx context.Context, tenantID, findingID, triageID shared.ID, ...)

+ DispatchAITriageFailed func(ctx context.Context, tenantID, findingID, triageID shared.ID, ...)

+ type WorkflowExecutor struct

+ func NewWorkflowExecutor(workflowRepo workflow.WorkflowRepository, runRepo workflow.RunRepository, ...) *WorkflowExecutor

+ func (e *WorkflowExecutor) Execute(ctx context.Context, runID shared.ID) error

+ func (e *WorkflowExecutor) ExecuteAsync(runID shared.ID)

+ func (e *WorkflowExecutor) ExecuteAsyncWithTenant(runID shared.ID, tenantID shared.ID)

+ func (e *WorkflowExecutor) ExecuteWithTenant(ctx context.Context, runID shared.ID, expectedTenantID shared.ID) error

+ func (e *WorkflowExecutor) RegisterActionHandler(actionType workflow.ActionType, handler ActionHandler)

+ type WorkflowExecutorConfig struct

+ MaxConcurrentNodes int

+ MaxNodeExecutionTime time.Duration

+ func DefaultWorkflowExecutorConfig() WorkflowExecutorConfig

+ type WorkflowExecutorOption func(*WorkflowExecutor)

+ func WithExecutorAuditService(svc *AuditService) WorkflowExecutorOption

+ func WithExecutorDB(db *sql.DB) WorkflowExecutorOption

+ func WithExecutorIntegrationService(svc *IntegrationService) WorkflowExecutorOption

+ func WithExecutorNotificationService(svc *NotificationService) WorkflowExecutorOption

+ type WorkflowService struct

+ func NewWorkflowService(workflowRepo workflow.WorkflowRepository, nodeRepo workflow.NodeRepository, ...) *WorkflowService

+ func (s *WorkflowService) AddEdge(ctx context.Context, input AddEdgeInput) (*workflow.Edge, error)

+ func (s *WorkflowService) AddNode(ctx context.Context, input AddNodeInput) (*workflow.Node, error)

+ func (s *WorkflowService) CancelRun(ctx context.Context, tenantID, userID, runID shared.ID) error

+ func (s *WorkflowService) CreateWorkflow(ctx context.Context, input CreateWorkflowInput) (*workflow.Workflow, error)

+ func (s *WorkflowService) DeleteEdge(ctx context.Context, tenantID, workflowID, edgeID shared.ID) error

+ func (s *WorkflowService) DeleteNode(ctx context.Context, tenantID, workflowID, nodeID shared.ID) error

+ func (s *WorkflowService) DeleteWorkflow(ctx context.Context, tenantID, userID, workflowID shared.ID) error

+ func (s *WorkflowService) GetRun(ctx context.Context, tenantID, runID shared.ID) (*workflow.Run, error)

+ func (s *WorkflowService) GetWorkflow(ctx context.Context, tenantID, workflowID shared.ID) (*workflow.Workflow, error)

+ func (s *WorkflowService) ListRuns(ctx context.Context, input ListWorkflowRunsInput) (pagination.Result[*workflow.Run], error)

+ func (s *WorkflowService) ListWorkflows(ctx context.Context, input ListWorkflowsInput) (pagination.Result[*workflow.Workflow], error)

+ func (s *WorkflowService) TriggerWorkflow(ctx context.Context, input TriggerWorkflowInput) (*workflow.Run, error)

+ func (s *WorkflowService) UpdateNode(ctx context.Context, input UpdateNodeInput) (*workflow.Node, error)

+ func (s *WorkflowService) UpdateWorkflow(ctx context.Context, input UpdateWorkflowInput) (*workflow.Workflow, error)

+ func (s *WorkflowService) UpdateWorkflowGraph(ctx context.Context, input UpdateWorkflowGraphInput) (*workflow.Workflow, error)

+ type WorkflowServiceOption func(*WorkflowService)

+ func WithWorkflowAuditService(auditService *AuditService) WorkflowServiceOption

+ func WithWorkflowExecutor(executor *WorkflowExecutor) WorkflowServiceOption

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL