audit

type ActorContext struct {
	ProjectID      string
	TeamID         *string
	ActorID        *string
	ActorType      *domain.EventActorType
	ClientID       string
	TokenID        string
	DelegationType string
	DelegationID   string
	Grantor        string
	Fingerprint    string
	SessionID      *string
	FlowID         *string
	RequestID      *string
	Authenticated  bool
}

type BatchInserter func(ctx context.Context, events []*domain.Event) error

type EmitSpec struct {
	Type       domain.EventType
	Category   domain.EventCategory
	ProjectID  string
	EntityType string
	EntityID   string
	Payload    any
	SessionID  *string
	TokenID    string
	// Optional actor overrides when the request ActorContext is empty
	// (anonymous session mint, token issue before AuthGate, etc.).
	ActorID   *string
	ActorType *domain.EventActorType
}

type EventBatchInserter interface {
	InsertEvents(ctx context.Context, events []*domain.Event) error
}

type EventExportSource interface {
	ListClaimedProjectIDs(ctx context.Context) ([]string, error)
	EnsureSink(ctx context.Context, sink *domain.EventSink) error
	GetEventSinkCursor(ctx context.Context, sinkID, projectID string) (*domain.EventSinkCursor, error)
	UpsertEventSinkCursor(ctx context.Context, cursor *domain.EventSinkCursor) error
	ListEventsAfterCursor(ctx context.Context, projectID string, afterCreatedAt time.Time, afterID string, limit int) ([]*domain.Event, error)
}

type EventInserter interface {
	InsertEvent(ctx context.Context, event *domain.Event) error
}

type EventPurger interface {
	DeleteEventsOlderThan(ctx context.Context, createdBefore time.Time) (int64, error)
}

type ExportConfig struct {
	Enabled  bool          `mapstructure:"enabled"`
	Interval time.Duration `mapstructure:"interval"`
	Sinks    []SinkConfig  `mapstructure:"sinks"`
}

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

type RequestBufferConfig struct {
	BatchSize       int
	MaxAge          time.Duration
	Capacity        int
	ShutdownTimeout time.Duration
}

type RetentionConfig struct {
	Retention time.Duration `mapstructure:"window"`
	Interval  time.Duration `mapstructure:"interval"`
	Enabled   bool          `mapstructure:"enabled"`
}

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

type SequentialBatchInserter struct {
	Inner EventInserter
}

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

type SinkConfig struct {
	Type domain.EventSinkType `mapstructure:"type"`
	URL  string               `mapstructure:"url"`
	// Enabled is opt-out: a configured sink (non-empty type) ships unless this
	// is explicitly false.
	Enabled *bool `mapstructure:"enabled"`
}