datastorage

Documentation

Index

• func CreateAIAnalysisCompletedEvent(correlationID string, payload ogenclient.AIAnalysisAuditPayload) (*repository.AuditEvent, error)
• func CreateGatewaySignalReceivedEvent(correlationID string, payload ogenclient.GatewayAuditPayload) (*repository.AuditEvent, error)
• func CreateOrchestratorLifecycleCreatedEvent(correlationID string, payload ogenclient.RemediationOrchestratorAuditPayload) (*repository.AuditEvent, error)
• func CreateWorkflowExecutionStartedEvent(correlationID string, payload ogenclient.WorkflowExecutionAuditPayload) (*repository.AuditEvent, error)
• func CreateWorkflowSelectionCompletedEvent(correlationID string, payload ogenclient.WorkflowExecutionAuditPayload) (*repository.AuditEvent, error)

Functions

func CreateAIAnalysisCompletedEvent

func CreateAIAnalysisCompletedEvent(
	correlationID string,
	payload ogenclient.AIAnalysisAuditPayload,
) (*repository.AuditEvent, error)

CreateAIAnalysisCompletedEvent creates a typed aianalysis.analysis.completed audit event.

Required fields in payload: - EventType (must be aianalysis.analysis.completed) - AnalysisName - Namespace - Phase - ApprovalRequired - DegradedMode - WarningsCount

func CreateGatewaySignalReceivedEvent

func CreateGatewaySignalReceivedEvent(
	correlationID string,
	payload ogenclient.GatewayAuditPayload,
) (*repository.AuditEvent, error)

CreateGatewaySignalReceivedEvent creates a typed gateway.signal.received audit event.

Required fields in payload: - EventType (must be gateway.signal.received) - SignalName - Namespace - Fingerprint

func CreateOrchestratorLifecycleCreatedEvent

func CreateOrchestratorLifecycleCreatedEvent(
	correlationID string,
	payload ogenclient.RemediationOrchestratorAuditPayload,
) (*repository.AuditEvent, error)

CreateOrchestratorLifecycleCreatedEvent creates a typed orchestrator.lifecycle.created audit event.

Required fields in payload: - EventType (must be orchestrator.lifecycle.created) - RRName - Namespace

func CreateWorkflowExecutionStartedEvent

func CreateWorkflowExecutionStartedEvent(
	correlationID string,
	payload ogenclient.WorkflowExecutionAuditPayload,
) (*repository.AuditEvent, error)

CreateWorkflowExecutionStartedEvent creates a typed workflowexecution.execution.started audit event.

Required fields in payload: - EventType (must be workflowexecution.execution.started) - ExecutionName - Namespace - Phase - WorkflowID - WorkflowVersion - TargetResource - ContainerImage

func CreateWorkflowSelectionCompletedEvent

func CreateWorkflowSelectionCompletedEvent(
	correlationID string,
	payload ogenclient.WorkflowExecutionAuditPayload,
) (*repository.AuditEvent, error)

CreateWorkflowSelectionCompletedEvent creates a typed workflowexecution.selection.completed audit event.

Required fields in payload: - EventType (must be workflowexecution.selection.completed) - ExecutionName - Namespace - Phase - WorkflowID - WorkflowVersion - TargetResource - ContainerImage