Functions — github.com/ClickHouse/clickhouse-rs

hub / github.com/ClickHouse/clickhouse-rs / functions

Functions959 in github.com/ClickHouse/clickhouse-rs

⨍ Functions 959◇ Types & classes 219

↓ 4 callersFunctionstring

See https://clickhouse.tech/docs/en/sql-reference/syntax/#syntax-string-literal

src/sql/escape.rs:6

↓ 4 callersFunctiont

(arg: &[&str], expected: &str)

src/sql/mod.rs:197

↓ 4 callersFunctionto_u64_saturating

(n: usize)

src/insert_formatted.rs:781

↓ 4 callersMethodwith_period

The time between `INSERT`s. Note that [`Inserter`] doesn't spawn tasks or threads to check the elapsed time, all checks are performed only on [`Inser

src/inserter.rs:148

↓ 3 callersMethodabort

(&mut self)

src/insert_formatted.rs:509

↓ 3 callersFunctionassert_queries_user_agents

(client: &Client, table_name: &str, expected_user_agent: &str)

tests/it/user_agent.rs:39

↓ 3 callersFunctioncheck

(client: Client)

tests/it/compression.rs:5

↓ 3 callersFunctioncreate_user_and_role

Create a test user and role for `test_db_name` with no default grants. Returns a `Client` with the user configured, and the role name.

tests/it/main.rs:344

↓ 3 callersMethoddecoded_bytes

(&self)

src/cursors/row.rs:183

↓ 3 callersMethoddo_execute

(self, default_format: Option<&str>)

src/query.rs:205

↓ 3 callersFunctionerror_msg

(err: impl Display)

src/sql/mod.rs:140

↓ 3 callersFunctionescape

(src: &str, dst: &mut impl fmt::Write)

src/sql/escape.rs:19

↓ 3 callersFunctionextract_exception

(chunk: &[u8], tag: Option<&[u8]>)

src/response.rs:346

↓ 3 callersMethodfetch_one

Executes the query and returns just a single row. Note that `T` must be owned.

src/query.rs:123

↓ 3 callersFunctionget_tracer

()

tests/it/opentelemetry.rs:164

↓ 3 callersMethodinit_request

(&mut self)

src/insert_formatted.rs:452

↓ 3 callersMethodinsert

(&mut self)

src/inserter.rs:356

↓ 3 callersMethodinsert_arrow

(&self, table: &str)

ext-arrow/src/lib.rs:63

↓ 3 callersMethodis_not_started

(&self)

src/insert_formatted.rs:79

↓ 3 callersFunctionlz4_compress

(uncompressed: &[u8])

src/lib.rs:695

↓ 3 callersMethodmake_span

(&self, response_format: Option<&str>)

src/query.rs:175

↓ 3 callersFunctionmax_datetime64

The allowed range for DateTime64(8) and lower is [1900-01-01 00:00:00, 2299-12-31 23:59:59.99999999] UTC See https://clickhouse.com/docs/en/sql-refere

examples/data_types_derive_simple.rs:300

↓ 3 callersFunctionparse_inner_types

Considers the element type parsed once we reach a comma outside of parens AND after an unescaped tick. The most complicated cases are values names in

types/src/data_types.rs:781

↓ 3 callersFunctionparse_rbwnat_columns_header

(mut buffer: impl Buf)

types/src/lib.rs:32

↓ 3 callersMethodpending

Returns statistics about data not yet inserted into ClickHouse.

src/inserter.rs:287

↓ 3 callersMethodpoll_end

(&mut self, cx: &mut Context<'_>)

src/insert_formatted.rs:413

↓ 3 callersFunctionprint_header

(add: Option<&str>)

benches/common_select.rs:50

↓ 3 callersFunctionprovide

()

tests/it/mock.rs:20

↓ 3 callersFunctionprovide_with_summary

(rows: impl IntoIterator<Item = T>, summary: &str)

src/test/handlers.rs:67

↓ 3 callersFunctionquery

(numbers: u32)

examples/stream_into_file.rs:14

↓ 3 callersFunctionread_env_var

(key: &str)

examples/clickhouse_cloud.rs:73

↓ 3 callersFunctionreason

(status: StatusCode, exception_code: Option<String>)

src/response.rs:179

↓ 3 callersMethodreceived_bytes

(&self)

src/cursors/row.rs:177

↓ 3 callersFunctionrun

(c: &mut Criterion, name: &str, f: impl Fn(Client, u64, Compression, bool) -> F)

benches/mocked_insert.rs:133

↓ 3 callersFunctionsample

()

src/rowbinary/tests.rs:83

↓ 3 callersFunctiontest

(chunks: &[&[u8]], expected: &[u8])

src/compression/lz4.rs:201

↓ 3 callersMethodto_str

(self)

src/row_metadata.rs:199

↓ 3 callersMethodwith_default_roles

Clear any explicitly set [roles] from this `Client` instance. Overrides any roles previously set by [`Client::with_roles`] or [`Client::with_setting`

src/lib.rs:266

↓ 3 callersMethodwith_header

Used to specify a header that will be passed to all queries. # Example ``` # use clickhouse::Client; Client::default().with_header("Cookie", "A=1");

src/lib.rs:348

↓ 3 callersFunctionzstd

()

tests/it/compression.rs:41

↓ 2 callersMethodabort

(&mut self)

src/insert.rs:251

↓ 2 callersMethodadd_product_info

(&mut self, product_name: String, product_version: String)

src/lib.rs:400

↓ 2 callersMethodbuf_len

(&self)

src/insert_formatted.rs:545

↓ 2 callersMethodbuffer_mut

(&mut self)

src/insert_formatted.rs:571

↓ 2 callersMethodbuffered

Wrap this `InsertFormatted` with a buffer of a default size. The returned type also implements [`AsyncWrite`]. To set the capacity, use [`Self::buff

src/insert_formatted.rs:285

↓ 2 callersFunctioncalc_checksum

(buffer: &[u8])

src/compression/lz4.rs:154

↓ 2 callersFunctioncheck

(client: Client, expected_ratio: f64)

tests/it/cursor_stats.rs:5

↓ 2 callersFunctioncompress

(uncompressed: &[u8], level: Option<i32>)

src/compression/zstd.rs:25

↓ 2 callersFunctioncreate_readonly_user

(client: &Client, database: &str)

tests/it/main.rs:305

↓ 2 callersMethoddeserialize_bytes

(self, visitor: V)

src/rowbinary/de.rs:203

↓ 2 callersMethoddeserialize_newtype_struct

( self, name: &str, visitor: V, )

src/rowbinary/de.rs:315

↓ 2 callersMethoddeserialize_tuple

(self, len: usize, visitor: V)

src/rowbinary/de.rs:243

↓ 2 callersMethoddo_write

(&mut self, row: &T::Value<'_>)

src/insert.rs:198

↓ 2 callersFunctionfetch_batches

(client: &Client)

examples/inserter.rs:118

↓ 2 callersFunctionflag_as_str

(flag: bool)

benches/common_select.rs:56

↓ 2 callersMethodflush

Flush the buffered data without ending the request. The buffer is flushed automatically by [`Self::write()`] if it is already full. Manual flushing

ext-arrow/src/lib.rs:218

↓ 2 callersFunctiongenerate_dates

(years: Range<i32>, count: usize)

tests/it/time.rs:222

↓ 2 callersFunctiongenerate_dates

(years: impl RangeBounds<i32>, count: usize)

tests/it/chrono.rs:244

↓ 2 callersMethodget_schema_index

(&self, struct_idx: usize)

src/rowbinary/validation.rs:201

↓ 2 callersMethodget_validation

(&self)

src/lib.rs:573

↓ 2 callersMethodis_negative

(&self)

src/types/int256.rs:361

↓ 2 callersMethodis_started

(&self)

ext-arrow/src/lib.rs:257

↓ 2 callersFunctionmake_insert

(client: &Client, data: &[SomeRow])

examples/mock.rs:21

↓ 2 callersFunctionmake_select

(client: &Client)

examples/mock.rs:14

↓ 2 callersFunctionmax_datetime

()

examples/data_types_derive_simple.rs:293

↓ 2 callersFunctionmax_datetime64_nanos

DateTime64(8)/DateTime(9) allowed range is [1900-01-01 00:00:00, 2262-04-11 23:47:16] UTC See https://clickhouse.com/docs/en/sql-reference/data-types/

examples/data_types_derive_simple.rs:311

↓ 2 callersFunctionnull_encoding_for

Returns the wire-level null encoding of the given type, transparently stripping `LowCardinality(T)` and `SimpleAggregateFunction(_, T)` since those ar

src/rowbinary/validation.rs:230

↓ 2 callersFunctionparse_enum_index

(input_bytes: &[u8], input: &str)

types/src/data_types.rs:844

↓ 2 callersMethodpoll

(&mut self, mut sleep: Pin<&mut Sleep>, cx: &mut Context<'_>)

src/insert_formatted.rs:759

↓ 2 callersMethodpoll_flush_inner

(&mut self, cx: &mut Context<'_>)

src/insert_formatted.rs:654

↓ 2 callersMethodpoll_next

(&mut self, cx: &mut Context<'_>)

src/cursors/raw.rs:38

↓ 2 callersMethodpoll_wait_handle

(&mut self, cx: &mut Context<'_>)

src/insert_formatted.rs:418

↓ 2 callersMethodpoll_write_inner

(&mut self, data: &[u8], cx: &mut Context<'_>)

src/insert_formatted.rs:617

↓ 2 callersFunctionprepare_hyper_rustls_connector

( connector: HttpConnector, provider: rustls::crypto::CryptoProvider, )

src/http_client.rs:80

↓ 2 callersMethodpropagate_server_error

(&self)

src/test/mock.rs:118

↓ 2 callersFunctionrandom_polygon

()

examples/data_types_derive_containers.rs:130

↓ 2 callersFunctionrandom_ring

()

examples/data_types_derive_containers.rs:126

↓ 2 callersFunctionread_string

(mut buffer: impl Buf)

types/src/decoders.rs:6

↓ 2 callersMethodread_vec

(&mut self, size: usize)

src/rowbinary/de.rs:93

↓ 2 callersMethodremove_low_cardinality

LowCardinality(T) -> T

types/src/data_types.rs:181

↓ 2 callersMethodremove_simple_aggregate_function

SimpleAggregateFunction(fn, T) -> T The wire format of a `SimpleAggregateFunction` column is identical to its inner type. This method strips the wrap

types/src/data_types.rs:193

↓ 2 callersMethodrequest

(&self, req: Request<RequestBody>)

src/http_client.rs:31

↓ 2 callersFunctionrow_impl

(input: DeriveInput)

macros/src/lib.rs:52

↓ 2 callersFunctionrow_insert_metadata_query

Also needed by `it::insert::cache_row_metadata()`

src/lib.rs:705

↓ 2 callersFunctionrun_on_st_runtime

(name: &str, f: impl Future + Send + 'static)

benches/common.rs:140

↓ 2 callersMethodschema

(&self)

ext-arrow/src/lib.rs:388

↓ 2 callersFunctionselect_bytes

( client: Client, min_size: u64, compression: Compression, )

benches/mocked_select.rs:129

↓ 2 callersFunctionselect_count

(client: &Client)

examples/usage.rs:118

↓ 2 callersMethodsend_compressed

Send a chunk of pre-compressed data. # Errors In addition to network errors, this will return [`Error::Compression`] if the [`Client`][crate::Client]

src/insert_formatted.rs:857

↓ 2 callersMethodsend_inner

(&mut self, mut data: Bytes, original_size: u64)

src/insert_formatted.rs:322

↓ 2 callersMethodserialize_str

(mut self, value: &str)

src/sql/ser.rs:144

↓ 2 callersFunctionserve

( request: Request<Incoming>, compression: Compression, with_validation: bool, )

benches/mocked_select.rs:21

↓ 2 callersFunctionserve

( request: Request<Incoming>, compression: Compression, with_validation: bool, )

benches/mocked_insert.rs:21

↓ 2 callersMethodset_period_bias

(&mut self, max_bias: f64)

src/ticks.rs:39

↓ 2 callersMethodset_remaining

(&self, n: usize)

src/bytes_ext.rs:31

↓ 2 callersMethodset_timeouts

See [`Inserter::with_timeouts()`].

src/inserter.rs:236

↓ 2 callersFunctionskip_incoming

(request: Request<Incoming>)

benches/common.rs:91

↓ 2 callersFunctionspawn_data_generator

(n: u32, sparse: bool)

examples/inserter.rs:101

↓ 2 callersFunctionstart_runner

()

benches/common.rs:127

↓ 2 callersFunctionstart_server

(addr: SocketAddr, serve: S)

benches/common.rs:52

← previous next →101–200 of 959, ranked by callers