logs

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 LogBackend 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 LogEntry struct {
	// Common fields from jsonPayload
	Message          string
	TraceID          string
	UserID           string
	IPAddress        string
	OutputModule     string
	OutputModuleHash string
	StartBlock       int64
	StopBlock        uint64
	ProductionMode   bool
	Timestamp        string

	// 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
}

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