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

↓ 1 callersFunctionparse_map

(input: &str)

types/src/data_types.rs:694

↓ 1 callersFunctionparse_msg_len

FIXME: this can be replaced with `usize::from_ascii()` when stable https://github.com/rust-lang/rust/issues/134821

src/response.rs:423

↓ 1 callersFunctionparse_nested_meta

Called for each meta-item inside the `#[clickhouse(...)]` attribute.

macros/src/attributes.rs:37

↓ 1 callersFunctionparse_nullable

(input: &str)

types/src/data_types.rs:683

↓ 1 callersFunctionparse_simple_aggregate_function

`SimpleAggregateFunction(func_name, InnerType)` is a transparent wrapper. The wire format is identical to `InnerType`; the function name is metadata f

types/src/data_types.rs:653

↓ 1 callersFunctionparse_time64

(input: &str)

types/src/data_types.rs:622

↓ 1 callersFunctionparse_tuple

(input: &str)

types/src/data_types.rs:748

↓ 1 callersFunctionparse_variant

(input: &str)

types/src/data_types.rs:764

↓ 1 callersMethodpoll_frame

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

src/request_body.rs:42

↓ 1 callersMethodpoll_next

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

ext-arrow/src/lib.rs:392

↓ 1 callersMethodpoll_write

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

src/insert_formatted.rs:715

↓ 1 callersFunctionprepare_chunk

()

benches/mocked_select.rs:58

↓ 1 callersFunctionprepare_data

See https://clickhouse.com/docs/getting-started/example-datasets/nyc-taxi

benches/select_nyc_taxi_data.rs:79

↓ 1 callersFunctionprepare_data

()

benches/select_market_data.rs:39

↓ 1 callersFunctionprovide

(rows: impl IntoIterator<Item = T>)

src/test/handlers.rs:52

↓ 1 callersFunctionrandom_point

()

examples/data_types_derive_containers.rs:121

↓ 1 callersFunctionrandom_str

()

examples/data_types_derive_containers.rs:113

↓ 1 callersMethodreached

(&self)

src/ticks.rs:48

↓ 1 callersFunctionread

()

types/src/leb128.rs:53

↓ 1 callersMethodread

(mut bytes: &[u8])

src/compression/lz4.rs:92

↓ 1 callersMethodread_data

(&mut self, meta: &Lz4Meta)

src/compression/lz4.rs:137

↓ 1 callersMethodread_meta

(&mut self)

src/compression/lz4.rs:133

↓ 1 callersMethodreal_url

(&self)

src/test/mock.rs:82

↓ 1 callersFunctionrecord

()

src/test/handlers.rs:136

↓ 1 callersFunctionrecord_ddl

()

src/test/handlers.rs:173

↓ 1 callersFunctionremove_json_header

(input: &str)

types/src/data_types.rs:736

↓ 1 callersFunctionsample_serialized

()

src/rowbinary/tests.rs:109

↓ 1 callersFunctionselect

`fetch_arrow()` streams the response as a sequence of Arrow `RecordBatch`es.

examples/arrow.rs:65

↓ 1 callersFunctionselect_merged

Convenience helper: collect the whole response into a single `RecordBatch`. Allocates a fresh batch to concatenate the streamed pieces; use `select()`

examples/arrow.rs:80

↓ 1 callersMethodsender

(&mut self)

src/insert_formatted.rs:83

↓ 1 callersMethodserialize_bytes

(self, value: &[u8])

src/sql/ser.rs:95

↓ 1 callersFunctionserialize_with_validation

Serializes `row` using the `RowBinary` format and writes to `buffer`. Additionally, it will perform validation against the provided `row_metadata`, si

src/rowbinary/ser.rs:30

↓ 1 callersFunctionserver

(listener: TcpListener, shared: Arc<Mutex<Shared>>)

src/test/mock.rs:147

↓ 1 callersMethodset_max_bytes

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

src/inserter.rs:245

↓ 1 callersMethodset_max_rows

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

src/inserter.rs:250

↓ 1 callersMethodset_period

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

src/inserter.rs:255

↓ 1 callersMethodset_period_bias

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

src/inserter.rs:261

↓ 1 callersMethodset_timeouts

( &mut self, send_timeout: Option<Duration>, end_timeout: Option<Duration>, )

src/insert_formatted.rs:267

↓ 1 callersMethodset_timeouts

( &mut self, send_timeout: Option<Duration>, end_timeout: Option<Duration>, )

src/insert.rs:148

↓ 1 callersMethodshould_flush

(&self)

ext-arrow/src/lib.rs:343

↓ 1 callersMethodshutdown

(&mut self)

benches/common.rs:36

↓ 1 callersFunctionsparse

Pattern 2: sparse streams ------------------------- This pattern is useful when the stream is sparse, i.e. with pauses between rows. For instance, whe

examples/inserter.rs:48

↓ 1 callersMethodstart

(&mut self, schema: &Schema)

ext-arrow/src/lib.rs:261

↓ 1 callersFunctiontest_fetch

(client: &Client)

tests/it/query_readonly.rs:40

↓ 1 callersFunctiontest_fetch_all

(client: &Client)

tests/it/query_readonly.rs:143

↓ 1 callersFunctiontest_fetch_bytes

(client: &Client)

tests/it/query_readonly.rs:65

↓ 1 callersFunctiontest_fetch_one

(client: &Client)

tests/it/query_readonly.rs:90

↓ 1 callersFunctiontest_fetch_optional

(client: &Client)

tests/it/query_readonly.rs:115

↓ 1 callersMethodtime_left

(&self)

src/ticks.rs:43

↓ 1 callersFunctiontokio_copy_buf

Pattern 1: use the `tokio::io::copy_buf` helper. It shows integration with `tokio::io::AsyncBufWriteExt` trait.

examples/stream_into_file.rs:31

↓ 1 callersMethodtry_send

( &mut self, chunk: Bytes, )

src/request_body.rs:91

↓ 1 callersMethodurl

Returns a test server's URL to provide into [`Client`]. [`Client`]: crate::Client::with_url

src/test/mock.rs:78

↓ 1 callersMethodvalidate_identifier

(&mut self, _value: T)

src/rowbinary/validation.rs:206

↓ 1 callersMethodvisit_newtype_struct

(self, deserializer: D)

src/types/int256.rs:518

↓ 1 callersMethodwith_period_bias

Adds a bias to the period, so actual period is in the following range: ```text [period * (1 - bias), period * (1 + bias)] ``` The `bias` parameter i

src/inserter.rs:163

↓ 1 callersMethodwith_setting

Similar to [`Client::with_setting`], but for this particular query only.

src/query.rs:299

↓ 1 callersMethodwrite

(&self, mut dst: &mut impl fmt::Write)

src/sql/bind.rs:15

↓ 1 callersMethodwrite_checksum

(&self, mut buffer: &mut [u8])

src/compression/lz4.rs:113

↓ 1 callersMethodwrite_header

(&self, mut buffer: &mut [u8])

src/compression/lz4.rs:117

↓ 1 callersFunctionzstd_compress

(uncompressed: &[u8])

src/lib.rs:700

Function_do_render

(input_ugly: &str)

macros/src/tests/mod.rs:19

Method_priv_span

(&self)

src/insert_formatted.rs:588

Functionalias_columns

()

tests/it/rbwnat_smoke.rs:1579

Functionall_floats

()

tests/it/query.rs:209

Functionarrays

()

tests/it/rbwnat_smoke.rs:141

Functionassert_traits

tests/it/fetch_bytes.rs:112

tests/it/rbwnat_smoke.rs:15

Functionbench

(opts: BenchmarkOpts)

benches/select_nyc_taxi_data.rs:158

Functionbig_borrowed_str

()

tests/it/query.rs:171

Methodbind_fields

(&mut self)

src/sql/mod.rs:93

Functionblob_string_with_serde_bytes

()

tests/it/rbwnat_smoke.rs:542

Functionborrowed_data

()

tests/it/rbwnat_smoke.rs:1047

Functionbound_args

()

src/sql/mod.rs:164

Functioncache_row_metadata

()

tests/it/insert.rs:318

src/request_body.rs:31

Functionclear_cached_metadata

()

tests/it/insert.rs:413

Functionclient_with_url

tests/it/fetch_bytes.rs:90

(mut self: Pin<&mut Self>, amt: usize)

src/cursors/bytes.rs:204

Functioncrate_attribute

()

macros/src/tests/cases.rs:124

tests/it/chrono.rs:125

tests/it/chrono.rs:178

Functiondate_and_time

()

tests/it/rbwnat_smoke.rs:679

tests/it/chrono.rs:15

Functiondecimal128_wrong_size

()

tests/it/rbwnat_validation.rs:790

Functiondecimal32_wrong_size

()

tests/it/rbwnat_validation.rs:764

Functiondecimal64_wrong_size

()

tests/it/rbwnat_validation.rs:777

Functiondecimals

()

tests/it/rbwnat_smoke.rs:858

Methoddecoded_bytes

(&self)

src/cursors/bytes.rs:150

← previous next →301–400 of 959, ranked by callers