consumer

type BufferedEvent struct {
	Event        publisher.Event
	Timestamp    time.Time
	Type         publisher.EventType
	AttemptCount int
}

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

type EventClassification string

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

type NATSConsumerConfig struct {
	URL          string
	StreamName   string
	ConsumerName string
	BatchSize    int
	MaxWait      time.Duration
	MaxDeliver   int
	AckWait      time.Duration
	DLQSubject   string

	DeferQueueMaxAttempts int
	DeferQueueTTL         time.Duration
	RetainMessages        bool // Deprecated no-op; legacy raw message retention was removed.
}

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

type ReconciliationConfig struct {
	// Enabled controls whether reconciliation is active
	Enabled bool

	// MaxBufferSize is the maximum number of events to buffer per run
	MaxBufferSize int

	// InactivityTTL is the duration after last event before triggering reconciliation
	InactivityTTL time.Duration

	// MaxPasses is the maximum number of reconciliation passes to attempt
	MaxPasses int

	// PassDelay is the delay between reconciliation passes
	PassDelay time.Duration

	// CleanupInterval is how often to check for inactive buffers
	CleanupInterval time.Duration
}

type ReconciliationStatus string

type RunBuffer struct {
	RunID        string
	Events       []BufferedEvent
	FirstSeen    time.Time
	LastActivity time.Time // Refreshes on ANY event for this runID

	RootSuiteEndReceived bool
	ReconciliationStatus ReconciliationStatus
	// contains filtered or unexported fields
}