correlationuc

package
v0.2.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 27, 2026 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Overview

Package correlationuc orchestrates durable, two-phase event-time correlation.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type IncidentNotifier

type IncidentNotifier interface {
	IncidentsCreated(context.Context, string, shared.ID, []incident.Incident)
}

type IncidentRecorder

type IncidentRecorder interface {
	RecordCorrelation(context.Context, []incident.IncidentEvent) ([]incident.Incident, []incident.Incident, error)
}

type Result

type Result struct {
	Created        []incident.Incident
	Updated        []incident.Incident
	Reassessed     int
	ReassessFailed int
	Evicted        int
	Phase          correlation.Phase
	HasMore        bool
}

type RiskReassessor

type RiskReassessor interface {
	Reassess(context.Context, string, shared.ID) (incident.Incident, error)
}

type Service

type Service struct {
	// contains filtered or unexported fields
}

func (*Service) CorrelateEngagement

func (s *Service) CorrelateEngagement(ctx context.Context, actor string, engagementID shared.ID) (Result, error)

CorrelateEngagement performs exactly one bounded step. Source pages are only materialized; incident output is exclusively produced by the globally event-time ordered consume phase.

func (*Service) SetNotifier

func (s *Service) SetNotifier(n IncidentNotifier)

func (*Service) SetTransactionRunner

func (s *Service) SetTransactionRunner(t ports.TenantTransactionRunner)

Jump to

Keyboard shortcuts

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