audit

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

type Emitter interface {
	Emit(ctx context.Context, event Event)
}

type Event struct {
	ID             int64     `json:"id"`
	Timestamp      time.Time `json:"timestamp"`
	Category       string    `json:"category"`
	Action         string    `json:"action"`
	Agent          string    `json:"agent"`
	Summary        string    `json:"summary"`
	Detail         string    `json:"detail"`
	Status         string    `json:"status"`
	DurationMs     int64     `json:"duration_ms"`
	Source         string    `json:"source"`
	ConversationID string    `json:"conversation_id"`
}

type ListOpts struct {
	Categories []string
	Agent      string
	Statuses   []string
	Source     string
	// ExcludeSources drops events carrying any of these sources. It is the
	// negative counterpart of Source: filtering *to* a source was always
	// possible, filtering one *out* was not — which matters because dry-run and
	// eval turns emit under the ordinary llm/tool_call categories and would
	// otherwise flood an unfiltered stream.
	ExcludeSources []string
	Search         string
	Since          *time.Time
	Until          *time.Time
	Limit          int
	Offset         int
}

type ListResult struct {
	Events []Event `json:"events"`
	Total  int     `json:"total"`
	Limit  int     `json:"limit"`
	Offset int     `json:"offset"`
}

type NopEmitter struct{}

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

type Stats struct {
	Total          int            `json:"total"`
	ByCategory     map[string]int `json:"by_category"`
	ByStatus       map[string]int `json:"by_status"`
	EventsLastHour int            `json:"events_last_hour"`
}

type StatsOpts struct {
	Since          *time.Time
	ExcludeSources []string
}

type Store interface {
	Insert(ctx context.Context, event Event) error
	InsertBatch(ctx context.Context, events []Event) error
	List(ctx context.Context, opts ListOpts) ([]Event, int, error)
	Stats(ctx context.Context, opts StatsOpts) (*Stats, error)
	PruneBefore(ctx context.Context, before time.Time) (int, error)
	Close() error
}