web

package

Go to main page

Versions in this module

v0

v0.6.1

Jul 14, 2026

v0.6.0

Jul 14, 2026

v0.5.0

Jul 6, 2026

v0.4.2

Jun 25, 2026

v0.4.1

Jun 25, 2026

v0.4.0

Jun 25, 2026

Changes in this version

+ func SweepRuns(ctx context.Context, runStore db.RunStore, dataDir string, enabled bool, ...)

type CreateScheduleRequest

+ AssessmentID string

type Handlers

+ func (h *Handlers) HandleDeleteAssessment(w http.ResponseWriter, r *http.Request)

+ func (h *Handlers) HandleGetAssessment(w http.ResponseWriter, r *http.Request)

+ func (h *Handlers) HandleGetAssessmentByName(w http.ResponseWriter, r *http.Request)

+ func (h *Handlers) HandleListAssessmentRuns(w http.ResponseWriter, r *http.Request)

+ func (h *Handlers) HandleListAssessments(w http.ResponseWriter, r *http.Request)

+ func (h *Handlers) HandleSaveAssessment(w http.ResponseWriter, r *http.Request)

+ func (h *Handlers) HandleUpdateAssessment(w http.ResponseWriter, r *http.Request)

type LintedScenario

+ Expectations int

type RunRequest

+ AssessmentID string

+ type SaveAssessmentRequest struct

+ Name string

+ Type string

+ YAML string

type ScheduleHandlers

+ func (h *ScheduleHandlers) HandleGetScheduleByAssessment(w http.ResponseWriter, r *http.Request)

v0.3.0

Jun 23, 2026

v0.2.1

Jun 23, 2026

v0.2.0

Jun 18, 2026

Changes in this version

+ func SweepAssessments(ctx context.Context, runStore db.RunStore, dataDir string, enabled bool, ...)

+ func SweepRunLogs(dataDir string, enabled bool, days int)

v0.1.0

Jun 17, 2026

Changes in this version

+ const AuthTypeWIF

+ const ScenarioTypeCollect

+ const ScenarioTypeExplore

+ const ScenarioTypeStandard

+ func DeleteRunLog(dataDir, runID string)

+ func ServeWS(hub *Hub, w http.ResponseWriter, r *http.Request)

+ type AzureConnectorConfig struct

+ AuthType string

+ ClientID string

+ SubscriptionID string

+ TenantID string

+ TokenFile string

+ type Client struct

+ type ConnectorHandlers struct

+ func NewConnectorHandlers(connectorStore db.ConnectorStore, secretStore db.SecretStore, ...) *ConnectorHandlers

+ func (h *ConnectorHandlers) HandleCreateConnector(w http.ResponseWriter, r *http.Request)

+ func (h *ConnectorHandlers) HandleDeleteConnector(w http.ResponseWriter, r *http.Request)

+ func (h *ConnectorHandlers) HandleGetConnector(w http.ResponseWriter, r *http.Request)

+ func (h *ConnectorHandlers) HandleGetElasticRule(w http.ResponseWriter, r *http.Request)

+ func (h *ConnectorHandlers) HandleListConnectors(w http.ResponseWriter, r *http.Request)

+ func (h *ConnectorHandlers) HandleListElasticRules(w http.ResponseWriter, r *http.Request)

+ func (h *ConnectorHandlers) HandleListElasticRulesAuto(w http.ResponseWriter, r *http.Request)

+ func (h *ConnectorHandlers) HandleRuleCoverage(w http.ResponseWriter, r *http.Request)

+ func (h *ConnectorHandlers) HandleTestConnector(w http.ResponseWriter, r *http.Request)

+ func (h *ConnectorHandlers) HandleUpdateConnector(w http.ResponseWriter, r *http.Request)

+ type CoverageLastResult struct

+ Passed bool

+ RunID string

+ Timestamp time.Time

+ type CoverageResponse struct

+ Rules []RuleCoverageEntry

+ Summary CoverageSummary

+ type CoverageScenario struct

+ PackName string

+ ScenarioID string

+ ScenarioName string

+ SimulationID string

+ type CoverageSummary struct

+ CoveragePercent float64

+ CoveredRules int

+ TotalRules int

+ type CreateConnectorRequest struct

+ Config map[string]any

+ Description string

+ IsDefault bool

+ Name string

+ SecretGroupID string

+ Type string

+ type CreateScheduleRequest struct

+ CronExpression string

+ Enabled bool

+ Parallelism int

+ ScenarioID string

+ type CreateSecretRequest struct

+ Description string

+ Entries []SecretEntryRequest

+ Name string

+ type ElasticConnectorConfig struct

+ CloudID string

+ ElasticsearchURL string

+ ExportDatastream string

+ ExportEnabled bool

+ KibanaURL string

+ type ErrorResponse struct

+ Error string

+ type GCPConnectorConfig struct

+ AuthType string

+ CredentialsFile string

+ PoolID string

+ ProjectID string

+ ProjectNumber string

+ ProviderID string

+ ServiceAccountEmail string

+ type Handlers struct

+ func NewHandlers(ss *ScenarioService, scenarioStore db.ScenarioStore, runStore db.RunStore, ...) *Handlers

+ func (h *Handlers) HandleDeleteRun(w http.ResponseWriter, r *http.Request)

+ func (h *Handlers) HandleDeleteScenario(w http.ResponseWriter, r *http.Request)

+ func (h *Handlers) HandleDownloadCollectedLogs(w http.ResponseWriter, r *http.Request)

+ func (h *Handlers) HandleGetConfig(w http.ResponseWriter, r *http.Request)

+ func (h *Handlers) HandleGetRun(w http.ResponseWriter, r *http.Request)

+ func (h *Handlers) HandleGetRunLogs(w http.ResponseWriter, r *http.Request)

+ func (h *Handlers) HandleGetScenario(w http.ResponseWriter, r *http.Request)

+ func (h *Handlers) HandleLint(w http.ResponseWriter, r *http.Request)

+ func (h *Handlers) HandleListRuns(w http.ResponseWriter, r *http.Request)

+ func (h *Handlers) HandleListScenarios(w http.ResponseWriter, r *http.Request)

+ func (h *Handlers) HandleRun(w http.ResponseWriter, r *http.Request)

+ func (h *Handlers) HandleSaveScenario(w http.ResponseWriter, r *http.Request)

+ func (h *Handlers) HandleUpdateConfig(w http.ResponseWriter, r *http.Request)

+ func (h *Handlers) HandleUpdateScenario(w http.ResponseWriter, r *http.Request)

+ func (h *Handlers) HandleVersion(w http.ResponseWriter, r *http.Request)

+ type Hub struct

+ func NewHub() *Hub

+ func (h *Hub) BroadcastToRun(runID string, msg WSMessage)

+ func (h *Hub) Run()

+ type InstallPackRequest struct

+ Name string

+ Parameters map[string]any

+ Source string

+ Type string

+ Version string

+ type KubernetesConnectorConfig struct

+ CloudConnector string

+ ClusterName string

+ Project string

+ Region string

+ ResourceGroup string

+ type LintRequest struct

+ YAML string

+ type LintResponse struct

+ Error string

+ Scenarios []LintedScenario

+ Valid bool

+ type LintedScenario struct

+ Assertions int

+ ExecutorName string

+ ExecutorType string

+ Name string

+ type PackHandlers struct

+ func NewPackHandlers(packStore db.PackStore, dataDir string) *PackHandlers

+ func (h *PackHandlers) HandleDeletePack(w http.ResponseWriter, r *http.Request)

+ func (h *PackHandlers) HandleGetManifest(w http.ResponseWriter, r *http.Request)

+ func (h *PackHandlers) HandleGetPackParameters(w http.ResponseWriter, r *http.Request)

+ func (h *PackHandlers) HandleInstallPack(w http.ResponseWriter, r *http.Request)

+ func (h *PackHandlers) HandleListPacks(w http.ResponseWriter, r *http.Request)

+ func (h *PackHandlers) HandleUpdatePackParameters(w http.ResponseWriter, r *http.Request)

+ func (h *PackHandlers) HandleUploadPack(w http.ResponseWriter, r *http.Request)

+ type ResultExporter struct

+ func NewResultExporter(connectorStore db.ConnectorStore, creds *credentials.Resolver) *ResultExporter

+ func (e *ResultExporter) Export(ctx context.Context, runID uuid.UUID, ...)

+ type RuleCoverageEntry struct

+ Covered bool

+ LastResult *CoverageLastResult

+ Name string

+ RiskScore int

+ RuleID string

+ Scenarios []CoverageScenario

+ Severity string

+ Tags []string

+ type RunLogEntry struct

+ Fields map[string]any

+ Level string

+ Message string

+ Timestamp string

+ func ReadRunLog(dataDir, runID string) ([]RunLogEntry, error)

+ type RunLogHook struct

+ func NewRunLogHook(registry *RunLogRegistry, hub *Hub) *RunLogHook

+ func (h *RunLogHook) Fire(entry *logrus.Entry) error

+ func (h *RunLogHook) Levels() []logrus.Level

+ type RunLogRegistry struct

+ func NewRunLogRegistry() *RunLogRegistry

+ func (r *RunLogRegistry) Register(runID string, w *RunLogWriter)

+ func (r *RunLogRegistry) Unregister(runID string)

+ type RunLogWriter struct

+ func NewRunLogWriter(dataDir, runID string) (*RunLogWriter, error)

+ func (w *RunLogWriter) Close() error

+ func (w *RunLogWriter) Write(entry RunLogEntry)

+ type RunOptions struct

+ CleanupAlerts bool

+ CreatedBy string

+ ExploreMode bool

+ Parallelism int

+ ScheduleID *uuid.UUID

+ ScheduleName *string

+ Timeout time.Duration

+ type RunRequest struct

+ CleanupAlerts bool

+ ExploreMode bool

+ Parallelism int

+ ScenarioID string

+ Timeout string

+ type RunResponse struct

+ RunID string

+ type SSHConnectorConfig struct

+ Host string

+ Port int

+ Username string

+ func (c SSHConnectorConfig) Validate() error

+ type SaveScenarioRequest struct

+ Name string

+ Type string

+ YAML string

+ type ScenarioService struct

+ func NewScenarioService(runStore db.RunStore, scenarioStore db.ScenarioStore, packStore db.PackStore, ...) *ScenarioService

+ func (s *ScenarioService) Lint(yamlContent []byte) (*LintResponse, error)

+ func (s *ScenarioService) Run(ctx context.Context, scenarioID uuid.UUID, opts *RunOptions) (string, error)

+ type ScheduleHandlers struct

+ func NewScheduleHandlers(scheduleStore db.ScheduleStore, scenarioStore db.ScenarioStore, ...) *ScheduleHandlers

+ func (h *ScheduleHandlers) HandleCreateSchedule(w http.ResponseWriter, r *http.Request)

+ func (h *ScheduleHandlers) HandleDeleteSchedule(w http.ResponseWriter, r *http.Request)

+ func (h *ScheduleHandlers) HandleGetSchedule(w http.ResponseWriter, r *http.Request)

+ func (h *ScheduleHandlers) HandleGetScheduleByScenario(w http.ResponseWriter, r *http.Request)

+ func (h *ScheduleHandlers) HandleListSchedules(w http.ResponseWriter, r *http.Request)

+ func (h *ScheduleHandlers) HandleUpdateSchedule(w http.ResponseWriter, r *http.Request)

+ type Scheduler struct

+ func NewScheduler(scheduleStore db.ScheduleStore, scenarioStore db.ScenarioStore, ...) *Scheduler

+ func (s *Scheduler) Reload()

+ func (s *Scheduler) Start() error

+ func (s *Scheduler) Stop()

+ type SecretEntryRequest struct

+ Key string

+ Value *string

+ type SecretGroupResponse struct

+ CreatedAt string

+ CreatedBy string

+ Description string

+ ID string

+ Keys []string

+ Name string

+ UpdatedAt string

+ UpdatedBy string

+ type SecretHandlers struct

+ func NewSecretHandlers(secretStore db.SecretStore, encryptor *crypto.Encryptor) *SecretHandlers

+ func (h *SecretHandlers) HandleDeleteSecret(w http.ResponseWriter, r *http.Request)

+ func (h *SecretHandlers) HandleGetSecret(w http.ResponseWriter, r *http.Request)

+ func (h *SecretHandlers) HandleListSecrets(w http.ResponseWriter, r *http.Request)

+ func (h *SecretHandlers) HandleSaveSecret(w http.ResponseWriter, r *http.Request)

+ func (h *SecretHandlers) HandleUpdateSecret(w http.ResponseWriter, r *http.Request)

+ type Server struct

+ func NewServer(handlers *Handlers, packHandlers *PackHandlers, secretHandlers *SecretHandlers, ...) *Server

+ func (s *Server) ListenAndServe() error

+ func (s *Server) Router() http.Handler

+ type ServerConfig struct

+ DevFrontendURL string

+ DevMode bool

+ Port string

+ type TestConnectorRequest struct

+ Config map[string]any

+ SecretGroupID string

+ Type string

+ type TestConnectorResponse struct

+ Error string

+ Success bool

+ type UpdateConfigRequest struct

+ Key string

+ Value json.RawMessage

+ type UpdateConnectorRequest struct

+ Config map[string]any

+ Description string

+ Enabled bool

+ IsDefault bool

+ Name string

+ SecretGroupID string

+ type UpdatePackParametersRequest struct

+ Parameters map[string]any

+ type UpdateScheduleRequest struct

+ CronExpression string

+ Enabled bool

+ Parallelism int

+ type UpdateSecretRequest struct

+ Description string

+ Entries []SecretEntryRequest

+ Name string

+ type VersionResponse struct

+ BuildDate string

+ Commit string

+ GoVersion string

+ Version string

+ type WSMessage struct

+ Data any

+ Type string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL