agentactivity

type CursorStore interface {
	Since(context.Context, string, int64, int) ([]Event, error)
}

type Event struct {
	ID                 int64           `json:"id"`
	Timestamp          time.Time       `json:"timestamp"`
	EventKind          string          `json:"event_kind,omitempty"`
	ProjectID          string          `json:"project_id,omitempty"`
	TraceID            string          `json:"trace_id,omitempty"`
	RunID              string          `json:"run_id,omitempty"`
	ParentID           string          `json:"parent_id,omitempty"`
	CorrelationKind    string          `json:"correlation_kind,omitempty"`
	Method             string          `json:"method"`
	ToolName           string          `json:"tool_name,omitempty"`
	Status             string          `json:"status"`
	DurationMS         int64           `json:"duration_ms"`
	Error              string          `json:"error,omitempty"`
	FailureCategory    string          `json:"failure_category,omitempty"`
	PolicyCategory     string          `json:"policy_category,omitempty"`
	RelativePath       string          `json:"relative_path,omitempty"`
	RequestID          string          `json:"request_id,omitempty"`
	RemoteAddr         string          `json:"remote_addr,omitempty"`
	UserAgent          string          `json:"user_agent,omitempty"`
	ClientClass        string          `json:"client_class,omitempty"`
	InputSummaryHash   string          `json:"input_summary_hash,omitempty"`
	InputSummaryClass  string          `json:"input_summary_class,omitempty"`
	OutputSummaryHash  string          `json:"output_summary_hash,omitempty"`
	OutputSummaryClass string          `json:"output_summary_class,omitempty"`
	RawRequest         json.RawMessage `json:"raw_request,omitempty"`
	RawParams          json.RawMessage `json:"raw_params,omitempty"`
	RawArgs            json.RawMessage `json:"raw_arguments,omitempty"`
	RawResult          json.RawMessage `json:"raw_result,omitempty"`
}

type IDStore interface {
	MaxID(context.Context) (int64, error)
}

type PolicyEvent struct {
	ProjectID string
	Category  string
	Path      string
}

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

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

type SQLiteStoreOptions struct {
	RetainRawPayloads bool
}

type Store interface {
	Record(context.Context, Event) error
	Recent(context.Context, string, int) ([]Event, error)
}