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

↓ 2 callersFunctionstart_server

(compression: Compression, with_validation: bool)

benches/mocked_select.rs:82

↓ 2 callersMethodterminated

(&mut self, span: &tracing::Span)

src/insert_formatted.rs:113

↓ 2 callersFunctiontest

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

src/compression/zstd.rs:150

↓ 2 callersFunctiontest_env

()

tests/it/main.rs:288

↓ 2 callersFunctiontest_provide

()

tests/it/mock.rs:7

↓ 2 callersMethodtotal_size

(&self)

src/compression/lz4.rs:88

↓ 2 callersMethodtry_send

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

src/insert_formatted.rs:376

↓ 2 callersFunctionwiden_from_le_bytes

(bytes: &[u8])

src/types/int256.rs:554

↓ 2 callersFunctionwith_authentication

(mut builder: Builder, auth: &Authentication)

src/headers.rs:54

↓ 2 callersMethodwith_database

Specifies a database name. Automatically [clears the metadata cache][Self::clear_cached_metadata] for this instance only. # Examples ``` # use click

src/lib.rs:176

↓ 2 callersMethodwith_max_bytes

The maximum number of uncompressed bytes in one `INSERT` statement. This is the soft limit, which can be exceeded if rows between [`Inserter::commit(

src/inserter.rs:104

↓ 2 callersFunctionwith_request_headers

( mut builder: Builder, headers: &HashMap<String, String>, products_info: &[ProductInfo], )

src/headers.rs:26

↓ 2 callersMethodwith_timeouts

Sets timeouts for different operations. `send_timeout` restricts time on sending a data chunk to a socket. `None` disables the timeout, it's a defaul

src/insert.rs:86

↓ 2 callersFunctionwrite_arg

(writer: &mut impl Write, value: &impl Serialize)

src/sql/ser.rs:511

↓ 2 callersMethodwrite_buffered

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

src/insert_formatted.rs:596

↓ 2 callersFunctionwrite_param

(writer: &mut impl Write, value: &impl Serialize)

src/sql/ser.rs:521

↓ 2 callersMethodwriter

(&mut self)

ext-arrow/src/lib.rs:329

↓ 1 callersMethod_priv_span

(&self)

src/cursors/bytes.rs:166

↓ 1 callersMethodabort

(&self)

src/request_body.rs:111

↓ 1 callersFunctionbench

(opts: BenchmarkOpts)

benches/select_numbers.rs:18

↓ 1 callersFunctionbench

(opts: BenchmarkOpts)

benches/select_market_data.rs:97

↓ 1 callersFunctioncalc_checksum

(buffer: &[u8])

src/compression/zstd.rs:20

↓ 1 callersMethodcalc_next_at

(&mut self)

src/ticks.rs:56

↓ 1 callersMethodcapacity

(&self)

src/insert_formatted.rs:557

↓ 1 callersMethodcheck_tuple_fully_validated

(&self)

src/rowbinary/validation.rs:211

↓ 1 callersMethodclear_cached_metadata

Clear table metadata that was previously received and cached. [`Insert`][crate::insert::Insert] uses cached metadata when sending data with validatio

src/lib.rs:566

↓ 1 callersMethodclient_with_sql

(&self)

src/insert_formatted.rs:97

↓ 1 callersFunctioncmp_le

(left: &[u8; 32], right: &[u8; 32])

src/types/int256.rs:571

↓ 1 callersMethodcollect

Collects the whole response into a single [`Bytes`]. # Cancel safety This method is NOT cancellation safe. If cancelled, already collected bytes are

src/cursors/bytes.rs:91

↓ 1 callersMethodcollect

(self)

src/test/handlers.rs:117

↓ 1 callersFunctioncollect_bad_response

( status: StatusCode, exception_code: Option<String>, body: Incoming, compression: Compression

src/response.rs:127

↓ 1 callersFunctioncollect_bytes

(stream: impl Stream<Item = Result<Bytes>>)

src/response.rs:166

↓ 1 callersFunctioncollect_response

( response: HyperResponseFuture, compression: Compression, )

src/response.rs:78

↓ 1 callersFunctioncolumn_names

(data: &DataStruct, cx: &Ctxt, container: &Container)

macros/src/lib.rs:25

↓ 1 callersFunctioncursor_next

Pattern 2: use `BytesCursor::next()`.

examples/stream_into_file.rs:38

↓ 1 callersFunctionddl

(client: &Client)

examples/arrow.rs:16

↓ 1 callersFunctionddl

(client: &Client)

examples/usage.rs:17

↓ 1 callersFunctiondelete

(client: &Client)

examples/usage.rs:106

↓ 1 callersFunctiondense

Pattern 1: dense streams ------------------------ This pattern is useful when the stream is dense, i.e. with no/small pauses between rows. For instanc

examples/inserter.rs:23

↓ 1 callersFunctiondeserialize_row_with_validation

Deserializes a value from `input` using metadata ([`RowMetadata`]) parsed from `RowBinaryWithNamesAndTypes` header to validate the data types. This is

src/rowbinary/de.rs:48

↓ 1 callersFunctiondeserialize_row_without_validation

Deserializes a value from `input` with a row encoded in `RowBinary`, i.e. only when validation is disabled in the client.

src/rowbinary/de.rs:38

↓ 1 callersFunctiondo_handle

( request: Request<Incoming>, shared: &Mutex<Shared>, )

src/test/mock.rs:190

↓ 1 callersMethodend

Ends the current `INSERT` and whole `Inserter` unconditionally. If it isn't called, the current `INSERT` is aborted.

src/inserter.rs:346

↓ 1 callersFunctionensure_size

(buffer: impl Buf, size: usize)

types/src/decoders.rs:17

↓ 1 callersFunctionescape_ascii

(s: &[u8], dst: &mut impl fmt::Write)

src/sql/escape.rs:32

↓ 1 callersFunctionexception

(code: u8)

src/test/handlers.rs:41

↓ 1 callersMethodextend_slow

(&mut self, chunk: Bytes)

src/bytes_ext.rs:54

↓ 1 callersFunctionextract_exception_new

(chunk: &[u8], tag: &[u8])

src/response.rs:382

↓ 1 callersFunctionextract_exception_old

(chunk: &[u8])

src/response.rs:368

↓ 1 callersFunctionfailure

(status: StatusCode)

src/test/handlers.rs:30

↓ 1 callersFunctionfetch

(client: &Client)

examples/usage.rs:58

↓ 1 callersFunctionfetch_all

(client: &Client)

examples/usage.rs:92

↓ 1 callersFunctionfetch_stream

(client: &Client)

examples/usage.rs:74

↓ 1 callersMethodflush

(&mut self)

src/insert_formatted.rs:649

↓ 1 callersMethodforce_commit

Ends the current `INSERT` unconditionally.

src/inserter.rs:337

↓ 1 callersFunctionformat_json_with_hint

( json: &[(String, Box<DataTypeNode>)], f: &mut Formatter<'_>, )

types/src/data_types.rs:312

↓ 1 callersFunctionfutures03_stream

(filename: &str)

examples/stream_into_file.rs:50

↓ 1 callersMethodget_current_column

(&self)

src/rowbinary/validation.rs:71

↓ 1 callersMethodget_insert_metadata

(&self, raw_table_name: &str)

src/lib.rs:607

↓ 1 callersFunctionget_rows

()

examples/data_types_variant.rs:61

↓ 1 callersFunctionget_tracer

()

benches/common_select.rs:201

↓ 1 callersFunctionget_unsigned_leb128

(mut buffer: impl Buf)

src/rowbinary/utils.rs:16

↓ 1 callersFunctionget_user_agent

(products_info: &[ProductInfo])

src/headers.rs:7

↓ 1 callersFunctionhandle

( request: Request<Incoming>, shared: &Mutex<Shared>, )

src/test/mock.rs:171

↓ 1 callersMethodhandle

(&mut self)

src/insert_formatted.rs:90

↓ 1 callersMethodhas_default

(self)

src/row_metadata.rs:195

↓ 1 callersFunctionhex_bytes

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

src/sql/escape.rs:37

↓ 1 callersMethodinit_insert

(&mut self)

src/inserter.rs:375

↓ 1 callersMethodinit_request_if_required

(&mut self)

src/insert_formatted.rs:700

↓ 1 callersMethodinit_request_if_required

(&mut self)

src/insert.rs:240

↓ 1 callersFunctioninsert

`insert_arrow()` writes Arrow `RecordBatch`es to a target table. The Arrow field names are used as the target table's column list for the generated `

examples/arrow.rs:30

↓ 1 callersFunctioninsert

(client: &Client)

examples/usage.rs:31

↓ 1 callersMethodinsert_arrow_with

(&self, sql: &str)

ext-arrow/src/lib.rs:77

↓ 1 callersFunctioninsert_query

Referenced fully qualified here for clarity.

examples/opentelemetry.rs:172

↓ 1 callersMethodinsert_unescaped

Start a new `INSERT` statement using an unescaped table name. See [`Client::insert()`] for details.

src/lib.rs:475

↓ 1 callersFunctioninserter

(client: &Client)

examples/usage.rs:43

↓ 1 callersMethodinto_future

(self)

src/response.rs:55

↓ 1 callersMethodinto_i16

(self)

src/rowbinary/validation.rs:892

↓ 1 callersMethodinto_u8

(self)

src/rowbinary/validation.rs:888

↓ 1 callersMethodis_field_order_wrong

(&self)

src/rowbinary/validation.rs:196

↓ 1 callersMethodis_immutable

(self)

src/row_metadata.rs:191

↓ 1 callersFunctionis_msb_set

(le_bytes: &[u8; 32])

src/types/int256.rs:566

↓ 1 callersFunctionjoin_panic_schema_hint

(col: impl IntoIterator<Item = T>)

src/row_metadata.rs:285

↓ 1 callersMethodlimits_reached

(&self)

src/inserter.rs:350

↓ 1 callersMethodmake

(self)

src/test/handlers.rs:22

↓ 1 callersFunctionmake_create

(client: &Client)

examples/mock.rs:10

↓ 1 callersFunctionmax_execution_time

(mut client: Client, wait_end_of_query: bool)

tests/it/cursor_error.rs:20

↓ 1 callersMethodnext

Emits the next bytes chunk. # Cancel safety This method is cancellation safe.

src/cursors/bytes.rs:59

↓ 1 callersMethodnominal_capacity

(&self)

src/insert_formatted.rs:566

↓ 1 callersFunctionnow

()

examples/async_insert.rs:73

↓ 1 callersMethodnull_encoding

(&self)

src/rowbinary/validation.rs:215

↓ 1 callersFunctionparse_array

(input: &str)

types/src/data_types.rs:523

↓ 1 callersFunctionparse_datetime

(input: &str)

types/src/data_types.rs:554

↓ 1 callersFunctionparse_datetime64

(input: &str)

types/src/data_types.rs:604

↓ 1 callersFunctionparse_decimal

(input: &str)

types/src/data_types.rs:567

↓ 1 callersFunctionparse_enum

(input: &str)

types/src/data_types.rs:534

↓ 1 callersFunctionparse_enum_values_map

(input: &str)

types/src/data_types.rs:860

↓ 1 callersFunctionparse_fixed_string

(input: &str)

types/src/data_types.rs:503

↓ 1 callersFunctionparse_json

(input: &str)

types/src/data_types.rs:713

↓ 1 callersFunctionparse_low_cardinality

(input: &str)

types/src/data_types.rs:637

← previous next →201–300 of 959, ranked by callers