Functions — github.com/HFQR/xitca-web

hub / github.com/HFQR/xitca-web / functions

Functions3,753 in github.com/HFQR/xitca-web

⨍ Functions 3,753◇ Types & classes 917

↓ 10 callersMethodfields

(&self)

http/src/h2/proto/frame/headers.rs:207

↓ 10 callersMethodlen

(&self)

web/src/service/file.rs:174

↓ 10 callersMethodmap_ok

(self, func: F)

postgres/src/iter.rs:21

↓ 10 callersMethodnow

(&self)

http-rate/src/timer.rs:104

↓ 10 callersMethodpop

Pop from front of list

tokio-uring/src/runtime/driver/op/slab_list.rs:78

↓ 10 callersMethodquery

(self, cli: &Client)

postgres/src/execute/async_impl.rs:31

↓ 10 callersMethodquery_blocking

(self, cli: &C)

postgres/src/execute/sync_impl.rs:28

↓ 10 callersMethodread

Reads a packet of data from the socket into the buffer. Returns the original buffer and quantity of data read.

tokio-uring/src/net/udp.rs:305

↓ 10 callersMethodready

(&mut self, interest: Interest)

postgres/src/driver/quic.rs:174

↓ 10 callersMethodstable_ptr

(&self)

tokio-uring/src/buf/slice.rs:198

↓ 10 callersFunctiontest_h1_server

A specialized http/1 server on top of [test_server]

test/src/lib.rs:50

↓ 10 callersMethodtimeout

(self, timer: Pin<&mut KeepAlive>)

http/src/util/timer.rs:17

↓ 10 callersMethodtry_get

Like [`Self::get`], but returns a `Result` rather than panicking.

postgres/src/row/types.rs:166

↓ 10 callersMethodunescaped

(&self)

router/src/escape.rs:114

↓ 9 callersMethodcall

(&self, arg: Arg)

web/src/app/mod.rs:583

↓ 9 callersFunctioncheck_codec

(size: u8, flags: u8, value: u64, data: &[u8])

http/src/h3/proto/qpack/prefix_int.rs:95

↓ 9 callersFunctionconflict

(with: &'static str)

router/tests/insert.rs:15

↓ 9 callersFunctionconnect

(cfg: &mut Config)

postgres/src/driver.rs:53

↓ 9 callersMethodcontains

(&self, other: u8)

http/src/h1/proto/context.rs:44

↓ 9 callersFunctioncreate_dir

Creates a directory on the local filesystem. # Errors This function will return an error in the following situations, but is not limited to just the

tokio-uring/src/fs/directory.rs:33

↓ 9 callersMethoddecode

(self)

http/src/h1/proto/trasnder_coding.rs:99

↓ 9 callersFunctiondrain_write_buf

Drain all ciphertext from `bridge.write_buf` to the network.

tls/src/bridge.rs:95

↓ 9 callersMethodflags

(&mut self, flags: i32)

tokio-uring/src/fs/statx.rs:244

↓ 9 callersMethodframe

(&mut self)

http-body/src/body_ext.rs:11

↓ 9 callersFunctionhandshake

Verify HTTP/1.1 WebSocket handshake request and create handshake response.

http-ws/src/lib.rs:163

↓ 9 callersMethodinto_inner

(self)

http/src/h3/proto/stream.rs:118

↓ 9 callersMethodinto_list

(self, slab: &mut Slab<SlabListEntry<T>>)

tokio-uring/src/runtime/driver/op/slab_list.rs:53

↓ 9 callersMethodinto_parts

(self)

web/src/service/tower_http_compat.rs:111

↓ 9 callersFunctioninvalid_data

(msg: &'static str)

http/src/h3/body_v2.rs:235

↓ 9 callersMethodio_uring

switch to io-uring I/O mode. The stream type is preserved (conversion happens at dispatch).

http/src/builder.rs:128

↓ 9 callersMethodis_empty

Returns `true` if the rate limiter has no keys in it. As with [`len`](#method.len), this method may return imprecise results (indicating that the sta

http-rate/src/state/keyed.rs:166

↓ 9 callersMethodis_escaped

(&self, i: usize)

router/src/escape.rs:50

↓ 9 callersFunctiononce_body

(b: impl Into<Bytes>)

http-multipart/src/lib.rs:271

↓ 9 callersMethodready

(&self)

test/tests/macro.rs:22

↓ 9 callersMethodrun

(self)

router/tests/remove.rs:17

↓ 9 callersMethodsend

Send the request and wait for response asynchronously.

client/src/ws.rs:48

↓ 9 callersMethodslice

(&self, range: impl RangeBounds<usize>)

unsafe_collection/src/bytes/byte_str.rs:34

↓ 9 callersMethodslice_until

Slices the route with `..end`.

router/src/escape.rs:180

↓ 9 callersMethodstring

(self)

client/src/response.rs:99

↓ 9 callersFunctionsync

optimized version of postgres_protocol::frontend::sync

postgres/src/protocol.rs:66

↓ 9 callersMethodtimeout

(mut self, dur: Duration)

client/src/request.rs:252

↓ 9 callersMethodtrack_ref

(&mut self, reference: usize)

http/src/h3/proto/qpack/dynamic.rs:188

↓ 9 callersFunctionuri

(addr: SocketAddr, path: &str)

test/tests/h2_rst.rs:30

↓ 8 callersFunctionB

(e)

examples/file/static/client.626570da.js:1

↓ 8 callersMethodaddr

(&self)

test/src/lib.rs:138

↓ 8 callersMethodborrow

(&self)

http/src/util/middleware/context.rs:84

↓ 8 callersMethodborrow_cli_ref

(&self)

postgres/src/client.rs:93

↓ 8 callersMethodbuild

try convert builder to a connection pool instance.

postgres/src/pool.rs:72

↓ 8 callersMethodbytes_total

(&self)

tokio-uring/src/buf/slice.rs:206

↓ 8 callersFunctioncheck_encode_field_table

( table: &mut DynamicTable, init_fields: &[HeaderField], field: &[HeaderField],

http/src/h3/proto/qpack/encoder.rs:317

↓ 8 callersMethodcheck_key

Allow a single cell through the rate limiter for the given key. If the rate limit is reached, `check_key` returns information about the earliest time

http-rate/src/state/keyed.rs:58

↓ 8 callersMethodclone

(&self)

service/src/pipeline/enum.rs:20

↓ 8 callersFunctioncodec_frame_check

(mut frame: Frame<Bytes>, wire: &[u8], check_frame: Frame<Bytes>)

http/src/h3/proto/frame.rs:563

↓ 8 callersFunctioncstr

(p: &Path)

tokio-uring/src/io/util.rs:5

↓ 8 callersMethodencode

Encode message. Return `EOF` state of encoder

http/src/h1/proto/trasnder_coding.rs:399

↓ 8 callersMethodextensions

(&self)

client/src/request.rs:190

↓ 8 callersFunctionfind

()

http/src/h3/proto/qpack/static_.rs:345

↓ 8 callersMethodget

try to get a connection from pool. when pool is empty it will try to spawn new connection to database and if the process failed the outcome will retur

postgres/src/pool.rs:131

↓ 8 callersMethodget_mut

(&mut self, index: usize)

tokio-uring/src/runtime/driver/mod.rs:451

↓ 8 callersMethodget_var

(&mut self)

http/src/h3/proto/coding.rs:50

↓ 8 callersMethodinto_iter

(self)

http/src/h3/proto/headers.rs:163

↓ 8 callersMethodload

Load and validate a PING frame. Returns `Err(InvalidStreamId)` if the stream ID is non-zero (RFC 7540 §6.7) and `Err(BadFrameSize)` if the payload is

http/src/h2/proto/frame/ping.rs:27

↓ 8 callersMethodmap

(self, res: Self::Response)

http/src/util/service/handler.rs:249

↓ 8 callersMethodon_encoder_recv

The receiving side of encoder stream

http/src/h3/proto/qpack/decoder.rs:139

↓ 8 callersMethodpush

(&mut self, buf: B)

unsafe_collection/src/bytes/buf_list.rs:33

↓ 8 callersFunctionread_buf

read from Io and populate buffer. return byte count on successful read.

unsafe_collection/src/bytes/io.rs:9

↓ 8 callersMethodregister

Registers the buffers with the kernel. This method must be called in the context of a `tokio-uring` runtime. The registration persists for the lifeti

tokio-uring/src/buf/fixed/pool.rs:190

↓ 8 callersMethodsend

(&self, msg: Message)

http-ws/src/stream.rs:224

↓ 8 callersMethodsize_hint

(&self)

postgres/src/iter.rs:94

↓ 8 callersMethodtruncate

Truncates the route to the given length.

router/src/escape.rs:98

↓ 7 callersMethodaccept

Accept [`UdpStream`].

io/src/net/quic.rs:31

↓ 7 callersMethodas_slice

(&self)

http/src/h2/proto/hpack/header.rs:243

↓ 7 callersMethodas_u64

(self)

http-rate/src/nanos.rs:19

↓ 7 callersMethodbegin

Begins the transaction with a borrowned client. The transaction will roll back by default - use [`Transaction::commit`] method to commit it.

postgres/src/transaction/builder.rs:84

↓ 7 callersMethodblocking_recv

(&mut self)

postgres/src/driver/codec.rs:36

↓ 7 callersMethodcall

(&self, res: Result<S, E>)

http/src/util/middleware/context.rs:112

↓ 7 callersMethodcall

(&self, res: Result<S, E>)

web/src/middleware/eraser.rs:100

↓ 7 callersMethodconn_mut

(&mut self)

postgres/src/pool/connection.rs:163

↓ 7 callersMethodconnect

(&self, cfg: Config)

postgres/src/pool/connect.rs:35

↓ 7 callersMethodderef_mut

(&mut self)

postgres/src/transaction.rs:135

↓ 7 callersMethodencode

(&self, buf: &mut W)

http/src/h3/proto/qpack/stream.rs:118

↓ 7 callersMethodencode_eof

Encode eof with optional trailer headers. For chunked encoding, forbidden trailer fields (per RFC 9110) are silently filtered out.

http/src/h1/proto/trasnder_coding.rs:431

↓ 7 callersFunctionexecute

optimized version of postgres_protocol::frontend::execute

postgres/src/protocol.rs:46

↓ 7 callersMethodfinish

finish copy in and return how many rows are affected

postgres/src/copy.rs:91

↓ 7 callersFunctionflush

(stream: &mut S)

client/src/h1/proto/dispatcher.rs:228

↓ 7 callersMethodget

(&self, name: &str)

web/src/handler/types/cookie.rs:108

↓ 7 callersMethodis_empty

(&self)

tokio-uring/src/runtime/driver/op/slab_list.rs:63

↓ 7 callersMethodis_empty

(&self)

router/src/params.rs:61

↓ 7 callersMethodis_sensitive

(&self)

http/src/h2/proto/hpack/header.rs:175

↓ 7 callersMethoditer

(&self)

unsafe_collection/src/bound_queue/heap.rs:86

↓ 7 callersMethodlocal_addr

Returns the local address to which this UDP socket is bound. This can be useful, for example, when binding to port 0 to figure out which port was act

tokio-uring/src/net/udp.rs:131

↓ 7 callersMethodmap_body

(self, func: F)

http/src/http.rs:269

↓ 7 callersMethodmark_destroy

(&mut self)

client/src/pool/service.rs:278

↓ 7 callersMethodmem_size

(&self)

http/src/h3/proto/qpack/field.rs:30

↓ 7 callersMethodpoll_next

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

postgres/src/query/compat.rs:15

↓ 7 callersMethodquery_raw

(&self, stmt: S)

postgres/src/client.rs:273

↓ 7 callersMethodread_fixed_at

Like [`read_at`], but using a pre-mapped buffer registered with [`FixedBufRegistry`]. [`read_at`]: Self::read_at [`FixedBufRegistry`]: crate::buf::fi

tokio-uring/src/fs/file.rs:472

↓ 7 callersMethodreason

(&self)

http/src/h2/proto/error.rs:59

↓ 7 callersMethodreset

(self: Pin<&mut Self>)

http/src/util/timer.rs:71

↓ 7 callersMethodrespond

(self, ctx: WebContext<'r, C, B>)

web/src/handler/impls.rs:151

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