List of all items

Structs

• SqlPlan
• error::AddressBindSnafu
• error::AlreadyStartedSnafu
• error::ArrowSnafu
• error::AuthSnafu
• error::BuildHttpResponseSnafu
• error::CatalogSnafu
• error::CheckDatabaseValiditySnafu
• error::CollectRecordbatchSnafu
• error::CompressPromRemoteRequestSnafu
• error::ConvertScalarValueSnafu
• error::ConvertSqlValueSnafu
• error::DataFrameSnafu
• error::DataFusionSnafu
• error::DecodeOtlpRequestSnafu
• error::DecodePromRemoteRequestSnafu
• error::DecompressSnappyPromRemoteRequestSnafu
• error::DecompressZstdPromRemoteRequestSnafu
• error::DescribeStatementSnafu
• error::DumpPprofSnafu
• error::DumpProfileDataSnafu
• error::ExecuteGrpcQuerySnafu
• error::ExecuteGrpcRequestSnafu
• error::ExecutePlanSnafu
• error::ExecuteQuerySnafu
• error::FailedToParseQuerySnafu
• error::FileWatchSnafu
• error::InFlightWriteBytesExceededSnafu
• error::IncompatibleSchemaSnafu
• error::InfluxdbLineProtocolSnafu
• error::InternalIoSnafu
• error::InternalSnafu
• error::InvalidAuthHeaderInvalidUtf8ValueSnafu
• error::InvalidAuthHeaderInvisibleASCIISnafu
• error::InvalidAuthHeaderSnafu
• error::InvalidBase64ValueSnafu
• error::InvalidElasticsearchInputSnafu
• error::InvalidExportMetricsConfigSnafu
• error::InvalidFlightTicketSnafu
• error::InvalidHeaderValueSnafu
• error::InvalidJaegerQuerySnafu
• error::InvalidLokiLabelsSnafu
• error::InvalidLokiPayloadSnafu
• error::InvalidOpentsdbJsonRequestSnafu
• error::InvalidParameterSnafu
• error::InvalidPrepareStatementSnafu
• error::InvalidPromRemoteReadQueryResultSnafu
• error::InvalidPromRemoteRequestSnafu
• error::InvalidQuerySnafu
• error::InvalidTableNameSnafu
• error::InvalidUtf8ValueSnafu
• error::JoinTaskSnafu
• error::MissingQueryContextSnafu
• error::MysqlValueConversionSnafu
• error::NotFoundAuthHeaderSnafu
• error::NotFoundInfluxAuthSnafu
• error::NotSupportedSnafu
• error::OtherSnafu
• error::ParseJsonSnafu
• error::ParsePromQLSnafu
• error::ParseTimestampSnafu
• error::PipelineSnafu
• error::PrepareStatementNotFoundSnafu
• error::PreparedStmtTypeMismatchSnafu
• error::RowWriterSnafu
• error::SendPromRemoteRequestSnafu
• error::StartGrpcSnafu
• error::StartHttpSnafu
• error::TableNotFoundSnafu
• error::TcpBindSnafu
• error::TcpIncomingSnafu
• error::TimePrecisionSnafu
• error::TimestampOverflowSnafu
• error::TlsRequiredSnafu
• error::ToJsonSnafu
• error::TokioIoSnafu
• error::UnexpectedResultSnafu
• error::UnsupportedAuthSchemeSnafu
• error::UnsupportedContentTypeSnafu
• error::UnsupportedDataTypeSnafu
• error::UnsupportedJsonDataTypeForTagSnafu
• error::UpdateJemallocMetricsSnafu
• error::UrlDecodeSnafu
• export_metrics::ExportMetricsOption
• export_metrics::ExportMetricsTask
• export_metrics::RemoteWriteOption
• export_metrics::SelfImportOption
• grpc::GrpcOptions
• grpc::GrpcServer
• grpc::GrpcServerConfig
• grpc::HealthCheckHandler
• grpc::authorize::AuthMiddleware
• grpc::authorize::AuthMiddlewareLayer
• grpc::builder::GrpcServerBuilder
• grpc::database::DatabaseService
• grpc::flight::FlightCraftWrapper
• grpc::flight::FlightRecordBatchStream
• grpc::flight::stream::FlightRecordBatchStream
• grpc::greptime_handler::GreptimeRequestHandler
• grpc::greptime_handler::RequestTimer
• grpc::prom_query_gateway::PrometheusGatewayService
• grpc::region_server::RegionServerRequestHandler
• heartbeat_options::HeartbeatOptions
• http::ApiState
• http::ColumnSchema
• http::GreptimeOptionsConfigState
• http::HttpOptions
• http::HttpRecordsOutput
• http::HttpServer
• http::HttpServerBuilder
• http::OutputSchema
• http::authorize::AuthState
• http::event::JSON_CONTENT_TYPE
• http::event::LogIngestRequest
• http::event::LogIngesterQueryParams
• http::event::LogState
• http::event::NDJSON_CONTENT_TYPE
• http::event::PB_CONTENT_TYPE
• http::event::PipelineContent
• http::event::PipelineDryrunParams
• http::event::TEXT_CONTENT_TYPE
• http::event::TEXT_UTF8_CONTENT_TYPE
• http::extractor::LogTableName
• http::extractor::PipelineInfo
• http::extractor::SelectInfoWrapper
• http::extractor::TraceTableName
• http::handler::HealthQuery
• http::handler::HealthResponse
• http::handler::PromqlQuery
• http::handler::SqlQuery
• http::handler::StatusResponse
• http::header::GreptimeDbName
• http::jaeger::JaegerAPIError
• http::jaeger::JaegerAPIResponse
• http::jaeger::JaegerQueryParams
• http::jaeger::KeyValue
• http::jaeger::Log
• http::jaeger::Operation
• http::jaeger::Process
• http::jaeger::QueryTraceParams
• http::jaeger::Reference
• http::jaeger::Span
• http::jaeger::Trace
• http::loki::LOKI_INIT_SCHEMAS
• http::opentsdb::DataPointRequest
• http::opentsdb::OpentsdbDebuggingResponse
• http::opentsdb::OpentsdbDetailError
• http::otlp::OtlpResponse
• http::pprof::handler::PprofQuery
• http::prom_store::PROM_WRITE_REQUEST_POOL
• http::prom_store::PromStoreState
• http::prom_store::RemoteWriteQuery
• http::prometheus::BuildInfoQuery
• http::prometheus::FormatQuery
• http::prometheus::InstantQuery
• http::prometheus::LabelValueQuery
• http::prometheus::LabelsQuery
• http::prometheus::Matches
• http::prometheus::ParseQuery
• http::prometheus::PromData
• http::prometheus::PromSeriesMatrix
• http::prometheus::PromSeriesVector
• http::prometheus::PrometheusJsonResponse
• http::prometheus::RangeQuery
• http::prometheus::SeriesQuery
• http::result::arrow_result::ArrowResponse
• http::result::csv_result::CsvResponse
• http::result::error_result::ErrorResponse
• http::result::greptime_manage_resp::GreptimedbManageResponse
• http::result::greptime_manage_resp::PipelineOutput
• http::result::greptime_result_v1::GreptimedbV1Response
• http::result::influxdb_result_v1::InfluxdbOutput
• http::result::influxdb_result_v1::InfluxdbRecordsOutput
• http::result::influxdb_result_v1::InfluxdbV1Response
• http::result::influxdb_result_v1::SqlQuery
• http::result::json_result::JsonResponse
• http::result::prometheus_resp::PrometheusJsonResponse
• http::result::table_result::TableResponse
• http::test_helpers::RequestBuilder
• http::test_helpers::TestClient
• http::test_helpers::TestResponse
• http::timeout::DynamicTimeout
• http::timeout::DynamicTimeoutLayer
• http::timeout::ResponseFuture
• influxdb::InfluxdbRequest
• metrics::METRIC_AUTH_FAILURE
• metrics::METRIC_ELASTICSEARCH_LOGS_DOCS_COUNT
• metrics::METRIC_ELASTICSEARCH_LOGS_INGESTION_ELAPSED
• metrics::METRIC_ERROR_COUNTER
• metrics::METRIC_GRPC_REQUESTS_ELAPSED
• metrics::METRIC_GRPC_REQUESTS_TOTAL
• metrics::METRIC_HTTP_INFLUXDB_WRITE_ELAPSED
• metrics::METRIC_HTTP_LOGS_ELAPSED
• metrics::METRIC_HTTP_LOGS_INGESTION_COUNTER
• metrics::METRIC_HTTP_LOGS_INGESTION_ELAPSED
• metrics::METRIC_HTTP_LOGS_TRANSFORM_ELAPSED
• metrics::METRIC_HTTP_OPENTELEMETRY_LOGS_ELAPSED
• metrics::METRIC_HTTP_OPENTELEMETRY_METRICS_ELAPSED
• metrics::METRIC_HTTP_OPENTELEMETRY_TRACES_ELAPSED
• metrics::METRIC_HTTP_PROMETHEUS_PROMQL_ELAPSED
• metrics::METRIC_HTTP_PROMQL_ELAPSED
• metrics::METRIC_HTTP_PROM_STORE_CODEC_ELAPSED
• metrics::METRIC_HTTP_PROM_STORE_CONVERT_ELAPSED
• metrics::METRIC_HTTP_PROM_STORE_DECODE_ELAPSED
• metrics::METRIC_HTTP_PROM_STORE_READ_ELAPSED
• metrics::METRIC_HTTP_PROM_STORE_WRITE_ELAPSED
• metrics::METRIC_HTTP_REQUESTS_ELAPSED
• metrics::METRIC_HTTP_REQUESTS_TOTAL
• metrics::METRIC_HTTP_SQL_ELAPSED
• metrics::METRIC_JAEGER_QUERY_ELAPSED
• metrics::METRIC_LOKI_LOGS_INGESTION_COUNTER
• metrics::METRIC_LOKI_LOGS_INGESTION_ELAPSED
• metrics::METRIC_MYSQL_CONNECTIONS
• metrics::METRIC_MYSQL_PREPARED_COUNT
• metrics::METRIC_MYSQL_QUERY_TIMER
• metrics::METRIC_POSTGRES_CONNECTIONS
• metrics::METRIC_POSTGRES_PREPARED_COUNT
• metrics::METRIC_POSTGRES_QUERY_TIMER
• metrics::METRIC_SERVER_GRPC_DB_REQUEST_TIMER
• metrics::METRIC_SERVER_GRPC_PROM_REQUEST_TIMER
• metrics::MetricsMiddleware
• metrics::MetricsMiddlewareLayer
• metrics::PROM_STORE_REMOTE_WRITE_SAMPLES
• metrics::jemalloc::JemallocCollector
• metrics::jemalloc::SYS_JEMALLOC_ALLOCATED
• metrics::jemalloc::SYS_JEMALLOC_RESIDEN
• metrics_handler::MetricsHandler
• mysql::handler::MysqlInstanceShim
• mysql::server::MysqlServer
• mysql::server::MysqlSpawnConfig
• mysql::server::MysqlSpawnRef
• mysql::writer::MysqlResultWriter
• mysql::writer::QueryResult
• opentsdb::codec::DataPoint
• otlp::logs::ParseContext
• otlp::trace::attributes::Attributes
• otlp::trace::attributes::OtlpAnyValue
• otlp::trace::span::SpanEvent
• otlp::trace::span::SpanEvents
• otlp::trace::span::SpanLink
• otlp::trace::span::SpanLinks
• otlp::trace::span::TraceSpan
• postgres::GreptimeDBStartupParameters
• postgres::MakePostgresServerHandler
• postgres::MakePostgresServerHandlerBuilder
• postgres::PostgresServer
• postgres::PostgresServerHandler
• postgres::PostgresServerHandlerInner
• postgres::auth_handler::LoginInfo
• postgres::auth_handler::PgLoginVerifier
• postgres::handler::DefaultQueryParser
• postgres::server::PostgresServer
• postgres::types::bytea::EscapeOutputBytea
• postgres::types::bytea::HexOutputBytea
• postgres::types::datetime::StylingDate
• postgres::types::datetime::StylingDateTime
• postgres::types::error::Ec00000Snafu
• postgres::types::error::Ec01000Snafu
• postgres::types::error::Ec02000Snafu
• postgres::types::error::Ec03000Snafu
• postgres::types::error::Ec08000Snafu
• postgres::types::error::Ec09000Snafu
• postgres::types::error::Ec0A000Snafu
• postgres::types::error::Ec0B000Snafu
• postgres::types::error::Ec0F000Snafu
• postgres::types::error::Ec0L000Snafu
• postgres::types::error::Ec0P000Snafu
• postgres::types::error::Ec0Z000Snafu
• postgres::types::error::Ec20000Snafu
• postgres::types::error::Ec21000Snafu
• postgres::types::error::Ec22000Snafu
• postgres::types::error::Ec22023Snafu
• postgres::types::error::Ec23000Snafu
• postgres::types::error::Ec24000Snafu
• postgres::types::error::Ec25000Snafu
• postgres::types::error::Ec25006Snafu
• postgres::types::error::Ec26000Snafu
• postgres::types::error::Ec27000Snafu
• postgres::types::error::Ec28000Snafu
• postgres::types::error::Ec28P01Snafu
• postgres::types::error::Ec2B000Snafu
• postgres::types::error::Ec2D000Snafu
• postgres::types::error::Ec2F000Snafu
• postgres::types::error::Ec34000Snafu
• postgres::types::error::Ec38000Snafu
• postgres::types::error::Ec39000Snafu
• postgres::types::error::Ec3B000Snafu
• postgres::types::error::Ec3D000Snafu
• postgres::types::error::Ec3F000Snafu
• postgres::types::error::Ec40000Snafu
• postgres::types::error::Ec42000Snafu
• postgres::types::error::Ec42501Snafu
• postgres::types::error::Ec42601Snafu
• postgres::types::error::Ec42701Snafu
• postgres::types::error::Ec42703Snafu
• postgres::types::error::Ec42704Snafu
• postgres::types::error::Ec42P01Snafu
• postgres::types::error::Ec42P04Snafu
• postgres::types::error::Ec42P07Snafu
• postgres::types::error::Ec42P14Snafu
• postgres::types::error::Ec44000Snafu
• postgres::types::error::Ec53000Snafu
• postgres::types::error::Ec54000Snafu
• postgres::types::error::Ec55000Snafu
• postgres::types::error::Ec57000Snafu
• postgres::types::error::Ec58000Snafu
• postgres::types::error::Ec72000Snafu
• postgres::types::error::EcF0000Snafu
• postgres::types::error::EcHV000Snafu
• postgres::types::error::EcP0000Snafu
• postgres::types::error::EcXX000Snafu
• postgres::types::error::PgErrorCodeIter
• postgres::types::interval::PgInterval
• prom_row_builder::TableBuilder
• prom_row_builder::TablesBuilder
• prom_store::Metrics
• prom_store::TimeSeriesId
• proto::PromLabel
• proto::PromTimeSeries
• proto::PromWriteRequest
• query_handler::PromStoreResponse
• query_handler::grpc::ServerGrpcQueryHandlerAdapter
• query_handler::sql::ServerSqlQueryHandlerAdapter
• repeated_field::RepeatedField
• row_writer::MultiTableData
• row_writer::TableData
• server::AcceptTask
• server::BaseTcpServer
• server::ServerHandlers
• tls::ReloadableTlsServerConfig
• tls::TlsOption

Enums

• Mode
• error::Error
• http::Epoch
• http::GreptimeQueryOutput
• http::HttpResponse
• http::ResponseFormat
• http::authorize::AuthScheme
• http::jaeger::JaegerData
• http::jaeger::Value
• http::jaeger::ValueType
• http::opentsdb::OneOrMany
• http::opentsdb::OpentsdbPutResponse
• http::pprof::handler::Output
• http::prometheus::PromQueryResult
• http::prometheus::PrometheusResponse
• http::result::greptime_manage_resp::ManageResult
• mysql::handler::Params
• postgres::MakePostgresServerHandlerBuilderError
• postgres::auth_handler::DbResolution
• postgres::types::error::PgErrorCode
• postgres::types::error::PgErrorSeverity
• row_writer::TimestampType
• tls::TlsMode

Traits

• configurator::Configurator
• grpc::flight::FlightCraft
• grpc::region_server::RegionServerHandler
• hint_headers::ToHeaderMap
• http::event::LogValidator
• interceptor::GrpcQueryInterceptor
• interceptor::LineProtocolInterceptor
• interceptor::LogIngestInterceptor
• interceptor::LogQueryInterceptor
• interceptor::OpenTelemetryProtocolInterceptor
• interceptor::PromQueryInterceptor
• interceptor::PromStoreProtocolInterceptor
• interceptor::SqlQueryInterceptor
• prometheus_handler::PrometheusHandler
• query_handler::InfluxdbLineProtocolHandler
• query_handler::JaegerQueryHandler
• query_handler::LogQueryHandler
• query_handler::OpenTelemetryProtocolHandler
• query_handler::OpentsdbProtocolHandler
• query_handler::PipelineHandler
• query_handler::PromStoreProtocolHandler
• query_handler::grpc::GrpcQueryHandler
• query_handler::sql::SqlQueryHandler
• repeated_field::Clear
• server::Server

Macros

• add_service
• http::prometheus::try_call_return_response
• postgres::types::datetime::delegate_to_sql
• unwrap_or_warn_continue

Functions

• addrs::resolve_addr
• elasticsearch::do_handle_bulk_api
• elasticsearch::elasticsearch_headers
• elasticsearch::get_index_from_cmd
• elasticsearch::get_log_value_from_msg_field
• elasticsearch::handle_bulk_api
• elasticsearch::handle_bulk_api_with_index
• elasticsearch::handle_get_license
• elasticsearch::handle_get_version
• elasticsearch::parse_bulk_request
• elasticsearch::write_bulk_response
• error::log_error_if_necessary
• error::status_code_to_http_status
• export_metrics::write_system_metric_by_handler
• export_metrics::write_system_metric_by_network
• grpc::authorize::do_auth
• grpc::cancellation::with_cancellation_handler
• grpc::flight::to_flight_data_stream
• grpc::greptime_handler::auth
• grpc::greptime_handler::create_query_context
• grpc::greptime_handler::get_request_type
• hint_headers::extract_hints
• http::authorize::auth_header
• http::authorize::check_http_auth
• http::authorize::decode_basic
• http::authorize::err_response
• http::authorize::extract_bucket_from_query
• http::authorize::extract_catalog_and_schema
• http::authorize::extract_db_from_query
• http::authorize::extract_influxdb_user_from_query
• http::authorize::extract_param_from_query
• http::authorize::extract_timezone
• http::authorize::extract_username_and_password
• http::authorize::get_influxdb_credentials
• http::authorize::inner_auth
• http::authorize::need_auth
• http::dyn_log::dyn_log_handler
• http::event::add_pipeline
• http::event::add_step_info_for_pipeline_dryrun_error
• http::event::check_data_valid
• http::event::check_pipeline_dryrun_params_valid
• http::event::check_pipeline_name_exists
• http::event::delete_pipeline
• http::event::dryrun_pipeline_inner
• http::event::extract_pipeline_value_by_content_type
• http::event::ingest_logs_inner
• http::event::log_ingester
• http::event::pipeline_dryrun
• http::event::transform_ndjson_array_factory
• http::extractor::string_value_from_header
• http::handler::config
• http::handler::from_output
• http::handler::health
• http::handler::metrics
• http::handler::promql
• http::handler::sql
• http::handler::sql_parse
• http::handler::status
• http::handler::validate_schema
• http::header::collect_into_maps
• http::header::collect_plan_metrics
• http::header::write_cost_header_map
• http::hints::extract_hints
• http::influxdb::influxdb_health
• http::influxdb::influxdb_ping
• http::influxdb::influxdb_write
• http::influxdb::influxdb_write_v1
• http::influxdb::influxdb_write_v2
• http::influxdb::parse_time_precision
• http::jaeger::check_schema
• http::jaeger::convert_string_to_boolean
• http::jaeger::convert_string_to_number
• http::jaeger::covert_to_records
• http::jaeger::error_response
• http::jaeger::handle_find_traces
• http::jaeger::handle_get_operations
• http::jaeger::handle_get_operations_by_service
• http::jaeger::handle_get_services
• http::jaeger::handle_get_trace
• http::jaeger::handle_query_error
• http::jaeger::normalize_span_kind
• http::jaeger::normalize_status_code
• http::jaeger::object_to_tags
• http::jaeger::operations_from_records
• http::jaeger::services_from_records
• http::jaeger::to_keyvalue
• http::jaeger::traces_from_records
• http::jaeger::update_query_context
• http::logs::logs
• http::loki::handle_json_req
• http::loki::handle_pb_req
• http::loki::init_row
• http::loki::loki_ingest
• http::loki::parse_loki_labels
• http::loki::process_labels
• http::loki::prost_ts_to_nano
• http::mem_prof::mem_prof_handler
• http::opentsdb::parse_data_points
• http::opentsdb::put
• http::otlp::logs
• http::otlp::metrics
• http::otlp::traces
• http::pprof::handler::pprof_handler
• http::process_with_limit
• http::prom_store::decode_remote_read_request
• http::prom_store::decode_remote_write_request
• http::prom_store::remote_read
• http::prom_store::remote_write
• http::prom_store::remote_write_impl
• http::prom_store::try_decompress
• http::prometheus::build_info_query
• http::prometheus::do_instant_query
• http::prometheus::do_range_query
• http::prometheus::find_metric_name_and_matchers
• http::prometheus::find_metric_name_not_equal_matchers
• http::prometheus::format_query
• http::prometheus::get_all_column_names
• http::prometheus::get_catalog_schema
• http::prometheus::instant_query
• http::prometheus::label_values_query
• http::prometheus::labels_query
• http::prometheus::parse_query
• http::prometheus::promql_expr_to_metric_name
• http::prometheus::range_query
• http::prometheus::record_batches_to_labels_name
• http::prometheus::record_batches_to_series
• http::prometheus::retrieve_field_names
• http::prometheus::retrieve_labels_name_from_query_result
• http::prometheus::retrieve_metric_name_and_result_type
• http::prometheus::retrieve_metric_name_from_promql
• http::prometheus::retrieve_series_from_query_result
• http::prometheus::series_query
• http::prometheus::take_metric_name
• http::prometheus::try_update_catalog_schema
• http::prometheus::update_metric_name_matcher
• http::read_preference::extract_read_preference
• http::result::arrow_result::compression_type
• http::result::arrow_result::write_arrow_bytes
• influxdb::is_influxdb_request
• influxdb::is_influxdb_v2_request
• influxdb::unwrap_or_default_precision
• install_ring_crypto_provider
• metrics::http_metrics_layer
• mysql::federated::check
• mysql::federated::check_others
• mysql::federated::check_select_variable
• mysql::federated::check_show_variables
• mysql::federated::select_function
• mysql::federated::select_variable
• mysql::federated::show_variables
• mysql::handler::convert_param_value_to_string
• mysql::handler::dummy_params
• mysql::handler::format_duration
• mysql::handler::prepared_params
• mysql::handler::replace_params
• mysql::handler::replace_params_with_exprs
• mysql::handler::replace_params_with_values
• mysql::handler::validate_query
• mysql::helper::convert_expr_to_scalar_value
• mysql::helper::convert_value
• mysql::helper::covert_bytes_to_timestamp
• mysql::helper::fix_placeholder_types
• mysql::helper::format_placeholder
• mysql::helper::replace_placeholders
• mysql::helper::transform_placeholders
• mysql::helper::visit_placeholders
• mysql::writer::create_mysql_column
• mysql::writer::create_mysql_column_def
• mysql::writer::handle_err
• mysql::writer::mysql_error_kind
• mysql::writer::write_output
• opentsdb::data_point_to_grpc_row_insert_requests
• otlp::logs::any_value_to_pipeline_value
• otlp::logs::build_otlp_build_in_row
• otlp::logs::build_otlp_logs_identity_schema
• otlp::logs::decide_column_schema_and_convert_value
• otlp::logs::extract_field_from_attr_and_combine_schema
• otlp::logs::key_value_to_map
• otlp::logs::log_body_to_string
• otlp::logs::log_to_pipeline_value
• otlp::logs::merge_values
• otlp::logs::parse_export_logs_service_request
• otlp::logs::parse_export_logs_service_request_to_rows
• otlp::logs::parse_log
• otlp::logs::parse_resource
• otlp::logs::parse_scope
• otlp::logs::scope_to_jsonb
• otlp::logs::scope_to_pipeline_value
• otlp::logs::to_grpc_insert_requests
• otlp::metrics::encode_exponential_histogram
• otlp::metrics::encode_gauge
• otlp::metrics::encode_histogram
• otlp::metrics::encode_metrics
• otlp::metrics::encode_sum
• otlp::metrics::encode_summary
• otlp::metrics::normalize_otlp_name
• otlp::metrics::to_grpc_insert_requests
• otlp::metrics::write_attributes
• otlp::metrics::write_data_point_value
• otlp::metrics::write_tags_and_timestamp
• otlp::metrics::write_timestamp
• otlp::trace::span::parse
• otlp::trace::span::parse_span
• otlp::trace::span::status_to_string
• otlp::trace::to_grpc_insert_requests
• otlp::trace::v0::v0_to_grpc_insert_requests
• otlp::trace::v0::write_span_to_row
• otlp::trace::v1::v1_to_grpc_insert_requests
• otlp::trace::v1::write_attributes
• otlp::trace::v1::write_span_to_row
• otlp::utils::any_value_to_jsonb
• otlp::utils::bytes_to_hex_string
• otlp::utils::key_value_to_jsonb
• otlp::utils::make_column_data
• otlp::utils::make_string_column_data
• pipeline::get_pipeline
• pipeline::run_custom_pipeline
• pipeline::run_identity_pipeline
• pipeline::run_pipeline
• postgres::auth_handler::resolve_db_info
• postgres::auth_handler::send_error
• postgres::auth_handler::set_client_info
• postgres::fixtures::build_string_data_rows
• postgres::fixtures::matches
• postgres::fixtures::process
• postgres::fixtures::rewrite_sql
• postgres::fixtures::set_transaction_warning
• postgres::handler::output_to_query_response
• postgres::handler::recordbatches_to_query_response
• postgres::handler::send_warning_opt
• postgres::types::datetime::date_format_string
• postgres::types::datetime::datetime_format_string
• postgres::types::encode_array
• postgres::types::encode_value
• postgres::types::invalid_parameter_error
• postgres::types::param_types_to_pg_types
• postgres::types::parameter_to_string
• postgres::types::parameters_to_scalar_values
• postgres::types::schema_to_pg
• postgres::types::to_timestamp_scalar_value
• postgres::types::type_gt_to_pg
• postgres::types::type_pg_to_gt
• prom_store::collect_timeseries_ids
• prom_store::lit_timestamp_millisecond
• prom_store::mock_timeseries
• prom_store::new_label
• prom_store::query_to_plan
• prom_store::recordbatch_to_timeseries
• prom_store::recordbatches_to_timeseries
• prom_store::snappy_compress
• prom_store::snappy_decompress
• prom_store::table_name
• prom_store::to_grpc_row_insert_requests
• prom_store::zstd_decompress
• prometheus::metric_name_matchers_to_plan
• proto::copy_to_bytes
• proto::merge_bytes
• proto::split_to
• row_writer::build_json_column_schema
• row_writer::check_schema
• row_writer::check_schema_number
• row_writer::write_by_schema
• row_writer::write_by_semantic_type
• row_writer::write_f64
• row_writer::write_fields
• row_writer::write_json
• row_writer::write_tag
• row_writer::write_tags
• row_writer::write_ts_to
• row_writer::write_ts_to_millis
• row_writer::write_ts_to_nanos
• tls::maybe_watch_tls_config

Type Aliases

• configurator::ConfiguratorRef
• error::Result
• grpc::TonicResult
• grpc::authorize::BoxFuture
• grpc::cancellation::Result
• grpc::flight::FlightCraftRef
• grpc::flight::TonicStream
• grpc::region_server::RegionServerHandlerRef
• http::authorize::Credential
• http::authorize::Password
• http::authorize::Username
• http::event::LogValidatorRef
• interceptor::GrpcQueryInterceptorRef
• interceptor::LineProtocolInterceptorRef
• interceptor::LogIngestInterceptorRef
• interceptor::LogQueryInterceptorRef
• interceptor::OpenTelemetryProtocolInterceptorRef
• interceptor::PromQueryInterceptorRef
• interceptor::PromStoreProtocolInterceptorRef
• interceptor::SqlQueryInterceptorRef
• otlp::trace::span::TraceSpans
• prometheus_handler::PrometheusHandlerRef
• query_handler::InfluxdbLineProtocolHandlerRef
• query_handler::JaegerQueryHandlerRef
• query_handler::LogQueryHandlerRef
• query_handler::OpenTelemetryProtocolHandlerRef
• query_handler::OpentsdbProtocolHandlerRef
• query_handler::PipelineHandlerRef
• query_handler::PromStoreProtocolHandlerRef
• query_handler::grpc::GrpcQueryHandlerRef
• query_handler::grpc::ServerGrpcQueryHandlerRef
• query_handler::sql::ServerSqlQueryHandlerRef
• query_handler::sql::SqlQueryHandlerRef
• server::AbortableStream
• server::ServerHandler

Statics

• elasticsearch::ELASTICSEARCH_HEADERS
• http::PUBLIC_APIS
• http::header::CONTENT_ENCODING_SNAPPY
• http::header::CONTENT_TYPE_NDJSON_STR
• http::header::CONTENT_TYPE_PROTOBUF
• http::header::CONTENT_TYPE_PROTOBUF_STR
• http::header::GREPTIME_DB_HEADER_EXECUTION_TIME
• http::header::GREPTIME_DB_HEADER_FORMAT
• http::header::GREPTIME_DB_HEADER_METRICS
• http::header::GREPTIME_DB_HEADER_NAME
• http::header::GREPTIME_DB_HEADER_READ_PREFERENCE
• http::header::GREPTIME_TIMEZONE_HEADER_NAME
• metrics::jemalloc::JEMALLOC_COLLECTOR
• mysql::federated::MYSQL_CONN_JAVA_PATTERN
• mysql::federated::OTHER_NOT_SUPPORTED_STMT
• mysql::federated::SELECT_TIME_DIFF_FUNC_PATTERN
• mysql::federated::SELECT_VAR_PATTERN
• mysql::federated::SHOW_LOWER_CASE_PATTERN
• mysql::federated::SHOW_SQL_MODE_PATTERN
• mysql::federated::SHOW_VARIABLES_LIKE_PATTERN
• mysql::federated::VAR_VALUES
• postgres::fixtures::ABORT_TRANSACTION_PATTERN
• postgres::fixtures::COMMIT_TRANSACTION_PATTERN
• postgres::fixtures::SET_TRANSACTION_PATTERN
• postgres::fixtures::SHOW_PATTERN
• postgres::fixtures::START_TRANSACTION_PATTERN
• postgres::fixtures::VAR_VALUES

Constants

• elasticsearch::ELASTICSEARCH_VERSION
• grpc::DEFAULT_GRPC_ADDR_PORT
• grpc::GRPC_SERVER
• hint_headers::HINTS_KEY
• hint_headers::HINT_KEYS
• http::AUTHORIZATION_HEADER
• http::DEFAULT_BODY_LIMIT
• http::HTTP_API_PREFIX
• http::HTTP_API_VERSION
• http::HTTP_SERVER
• http::event::GREPTIME_INTERNAL_PIPELINE_NAME_PREFIX
• http::header::constants::GREPTIME_DB_HEADER_ERROR_CODE
• http::header::constants::GREPTIME_DB_HEADER_EXECUTION_TIME
• http::header::constants::GREPTIME_DB_HEADER_FORMAT
• http::header::constants::GREPTIME_DB_HEADER_METRICS
• http::header::constants::GREPTIME_DB_HEADER_NAME
• http::header::constants::GREPTIME_DB_HEADER_READ_PREFERENCE
• http::header::constants::GREPTIME_DB_HEADER_TIMEOUT
• http::header::constants::GREPTIME_LOG_EXTRACT_KEYS_HEADER_NAME
• http::header::constants::GREPTIME_LOG_PIPELINE_NAME_HEADER_NAME
• http::header::constants::GREPTIME_LOG_PIPELINE_VERSION_HEADER_NAME
• http::header::constants::GREPTIME_LOG_TABLE_NAME_HEADER_NAME
• http::header::constants::GREPTIME_PIPELINE_NAME_HEADER_NAME
• http::header::constants::GREPTIME_PIPELINE_PARAMS_HEADER
• http::header::constants::GREPTIME_PIPELINE_VERSION_HEADER_NAME
• http::header::constants::GREPTIME_TIMEZONE_HEADER_NAME
• http::header::constants::GREPTIME_TRACE_TABLE_NAME_HEADER_NAME
• http::jaeger::JAEGER_QUERY_TABLE_NAME_KEY
• http::jaeger::REF_TYPE_CHILD_OF
• http::jaeger::SPAN_KIND_TIME_FMTS
• http::loki::LABEL_KEY
• http::loki::LINES_KEY
• http::loki::LOKI_LINE_COLUMN
• http::loki::LOKI_STRUCTURED_METADATA_COLUMN
• http::loki::LOKI_TABLE_NAME
• http::loki::STREAMS_KEY
• http::prom_store::DEFAULT_ENCODING
• http::prom_store::PHYSICAL_TABLE_PARAM
• http::prom_store::VM_ENCODING
• http::prom_store::VM_PROTO_VERSION
• influxdb::DEFAULT_TIME_PRECISION
• influxdb::INFLUXDB_API_PATH_NAME
• influxdb::INFLUXDB_API_V2_PATH_NAME
• influxdb::INFLUXDB_TIMESTAMP_COLUMN_NAME
• metrics::METRIC_CODE_LABEL
• metrics::METRIC_DB_LABEL
• metrics::METRIC_ERROR_COUNTER_LABEL_MYSQL
• metrics::METRIC_FAILURE_VALUE
• metrics::METRIC_METHOD_LABEL
• metrics::METRIC_MYSQL_BINQUERY
• metrics::METRIC_MYSQL_SUBPROTOCOL_LABEL
• metrics::METRIC_MYSQL_TEXTQUERY
• metrics::METRIC_PATH_LABEL
• metrics::METRIC_POSTGRES_EXTENDED_QUERY
• metrics::METRIC_POSTGRES_SIMPLE_QUERY
• metrics::METRIC_POSTGRES_SUBPROTOCOL_LABEL
• metrics::METRIC_PROTOCOL_LABEL
• metrics::METRIC_RESULT_LABEL
• metrics::METRIC_SUCCESS_VALUE
• metrics::METRIC_TYPE_LABEL
• mysql::handler::MYSQL_CLEAR_PASSWORD
• mysql::handler::MYSQL_NATIVE_PASSWORD
• mysql::server::DEFAULT_RESULT_SET_WRITE_BUFFER_SIZE
• mysql::server::MYSQL_SERVER
• otlp::logs::LOG_TABLE_NAME
• otlp::metrics::APPROXIMATE_COLUMN_COUNT
• otlp::metrics::HISTOGRAM_LE_COLUMN
• otlp::trace::DURATION_NANO_COLUMN
• otlp::trace::KEY_OTEL_SCOPE_NAME
• otlp::trace::KEY_OTEL_SCOPE_VERSION
• otlp::trace::KEY_OTEL_STATUS_CODE
• otlp::trace::KEY_SERVICE_NAME
• otlp::trace::KEY_SPAN_KIND
• otlp::trace::PARENT_SPAN_ID_COLUMN
• otlp::trace::RESOURCE_ATTRIBUTES_COLUMN
• otlp::trace::SCOPE_NAME_COLUMN
• otlp::trace::SCOPE_VERSION_COLUMN
• otlp::trace::SERVICE_NAME_COLUMN
• otlp::trace::SPAN_ATTRIBUTES_COLUMN
• otlp::trace::SPAN_EVENTS_COLUMN
• otlp::trace::SPAN_ID_COLUMN
• otlp::trace::SPAN_KIND_COLUMN
• otlp::trace::SPAN_KIND_PREFIX
• otlp::trace::SPAN_NAME_COLUMN
• otlp::trace::SPAN_STATUS_CODE
• otlp::trace::SPAN_STATUS_PREFIX
• otlp::trace::SPAN_STATUS_UNSET
• otlp::trace::TIMESTAMP_COLUMN
• otlp::trace::TRACE_ID_COLUMN
• otlp::trace::TRACE_TABLE_NAME
• otlp::trace::v0::APPROXIMATE_COLUMN_COUNT
• otlp::trace::v1::APPROXIMATE_COLUMN_COUNT
• postgres::METADATA_CATALOG
• postgres::METADATA_DATABASE
• postgres::METADATA_SCHEMA
• postgres::METADATA_USER
• postgres::server::POSTGRES_SERVER
• prom_store::FIELD_NAME_LABEL
• prom_store::METRIC_NAME_LABEL
• prom_store::METRIC_NAME_LABEL_BYTES
• prometheus::MAX_METRICS_NUM
• prometheus_handler::PROMETHEUS_API_VERSION