metrics

type NilPluginServerMetrics struct{}

type NilTxIndexerMetrics struct{}

type PluginServerMetrics interface {
	// HTTP metrics recording methods
	RecordHTTPRequest(method, path, status string, duration float64)
	RecordHTTPError(method, path, status string)

	// Middleware integration
	HTTPMiddleware() echo.MiddlewareFunc
}

type Registry interface {
	MustRegister(collectors ...prometheus.Collector)
}

type SchedulerMetrics interface {
	// SetActivePolicies sets the total number of active policies
	SetActivePolicies(count float64)

	// SetStuckPolicies sets the number of policies with next_execution < now (stuck policies)
	SetStuckPolicies(count float64)
}

type TxIndexerMetrics interface {
	// RecordTransactionStatus records a transaction status change
	RecordTransactionStatus(chain common.Chain, status string)

	// RecordProcessing records a processed transaction
	RecordProcessing(chain common.Chain)

	// RecordIterationDuration records the time spent in an iteration
	RecordIterationDuration(chain common.Chain, duration float64)

	// SetLastProcessingTimestamp sets the timestamp of the last processing run
	SetLastProcessingTimestamp(timestamp float64)

	// SetActiveTransactions sets the number of active transactions
	SetActiveTransactions(chain common.Chain, status string, count float64)

	// RecordProcessingError records a processing error
	RecordProcessingError(chain common.Chain, errorType string)

	// RecordRPCError records an RPC error
	RecordRPCError(chain common.Chain)

	// SetChainHeight sets the current block height for a chain
	SetChainHeight(chain common.Chain, height float64)
}