logs

type Backend interface {
	// QueryLogs returns all log entries matching the criteria
	// Returns both incoming requests and stats logs for correlation
	QueryLogs(ctx context.Context, opts QueryOptions) ([]LogEntry, error)

	// Close releases any resources held by the backend
	Close() error
}

type ConnectionLog struct {
	// From incoming request
	TraceID          string
	UserID           string
	IPAddress        string
	OutputModule     string
	OutputModuleHash string
	StartBlock       int64
	StopBlock        uint64
	ProductionMode   bool
	Timestamp        time.Time

	// From resource labels (backend-specific, extracted by backend)
	Namespace   string
	ClusterName string
	PodName     string

	// From stats (nil if not yet received)
	Stats *ConnectionStats

	// IsOrphan indicates this is a stats-only record with no matching incoming request
	IsOrphan bool
}

type ConnectionStats struct {
	TotalBlocksProcessed uint64
	BlockRatePerSec      string
	TimeToFirstData      float64
	ResolvedStartBlock   uint64
	Error                string
	EndTimestamp         time.Time
	Duration             time.Duration // Request duration (from parallel_duration)
}

type ConnectionStatus string

type CorrelationResult struct {
	Connections   []*ConnectionLog
	MaxConcurrent int // Maximum number of connections active at the same time (orphans use range start as start time)
}

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

type LogEntry struct {
	// Common fields from jsonPayload
	Message          string
	TraceID          string
	SessionID        string
	UserID           string
	IPAddress        string
	OutputModule     string
	OutputModuleHash string
	StartBlock       int64
	StopBlock        uint64
	Cursor           string
	ProductionMode   bool
	FinalBlocksOnly  bool
	NoopMode         bool
	Timestamp        string

	// EntryTime is the timestamp of the log entry itself as recorded by the
	// backend, used when the payload carries no `timestamp` field
	EntryTime time.Time

	// Stats-specific fields (only present for "substreams request stats")
	Tier                 string
	TotalBlocksProcessed uint64
	BlockRatePerSec      string
	TimeToFirstData      float64
	ResolvedStartBlock   uint64
	Error                string
	Duration             float64 // Request duration in seconds

	// Resource labels (backend extracts these from envelope)
	Namespace   string
	ClusterName string
	PodName     string

	// Severity of the entry as reported by the backend ("INFO", "ERROR", ...),
	// empty when the backend does not report one
	Severity string

	// Fields holds every jsonPayload field of the entry, used to render raw
	// logs. Nil for entries whose payload was not a JSON object.
	Fields map[string]any
}

type QueryOptions struct {
	UserID    string
	TraceID   string
	Namespace string
	StartTime time.Time
	EndTime   time.Time

	// AllMessages disables the "incoming request"/"request stats" message
	// restriction, returning every log entry matching the subject (trace ID or
	// user ID) instead. Used to display the raw logs of a single request.
	AllMessages bool

	// Limit caps the number of entries returned, keeping the newest ones. Zero
	// means no limit.
	Limit int
}