Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/HFQR/xitca-web
/ functions
Functions
3,753 in github.com/HFQR/xitca-web
⨍
Functions
3,753
◇
Types & classes
917
↓ 21 callers
Method
into_response
(self, body: ResB)
web/src/context.rs:133
↓ 21 callers
Method
push_str
(&mut self, str: &str)
postgres/src/transaction/builder.rs:155
↓ 21 callers
Method
query
(&self, stmt: S)
postgres/src/client.rs:265
↓ 21 callers
Method
run
(self)
router/tests/insert.rs:6
↓ 21 callers
Method
split_to
(&mut self, at: usize)
unsafe_collection/src/bytes/limit.rs:23
↓ 20 callers
Method
block_on
Runs a future to completion on the tokio-uring runtime. This is the runtime's entry point. This runs the given future on the current thread, blocking
tokio-uring/src/runtime/mod.rs:111
↓ 20 callers
Method
is_empty
(&self)
io/src/bytes.rs:115
↓ 20 callers
Method
parse
Parse the input stream into a frame.
http-ws/src/frame.rs:91
↓ 20 callers
Method
remaining
(&self)
unsafe_collection/src/bytes/limit.rs:75
↓ 20 callers
Method
req_mut
(&mut self)
web/src/context.rs:96
↓ 20 callers
Method
slice
(self, range: impl ops::RangeBounds<usize>)
tokio-uring/src/buf/slice.rs:149
↓ 19 callers
Function
bind
optimized version of postgres_protocol::frontend::bind
postgres/src/protocol.rs:14
↓ 19 callers
Method
push_back
(&mut self, item: T)
unsafe_collection/src/bound_queue/heap.rs:55
↓ 19 callers
Function
read
(s: &str)
http/src/h1/proto/trasnder_coding.rs:558
↓ 19 callers
Method
recv
(&mut self)
postgres/src/driver/codec.rs:43
↓ 18 callers
Method
call
(&self, arg: Arg)
http/src/util/service/route.rs:123
↓ 18 callers
Method
call
(&self, arg: Arg)
http/src/util/service/router.rs:93
↓ 18 callers
Function
func
(_: Request<RequestExt<()>>)
http/src/util/service/router.rs:516
↓ 18 callers
Method
insert
Insert a new operation
tokio-uring/src/runtime/driver/mod.rs:457
↓ 18 callers
Method
map
Mutate `<<Self::Response as Service<Req>>::Future as Future>::Output` type with given closure.
service/src/service/ext.rs:31
↓ 18 callers
Method
push_back
(&mut self, item: T)
unsafe_collection/src/bound_queue/stack.rs:47
↓ 18 callers
Method
run
(self)
web/src/server.rs:405
↓ 18 callers
Method
serve
(service: S)
web/src/server.rs:34
↓ 18 callers
Method
wait
(&mut self)
http/src/h1/io.rs:73
↓ 17 callers
Function
build_table_with_size
(n_field: usize)
http/src/h3/proto/qpack/tests.rs:17
↓ 17 callers
Method
push_back
(&mut self, buf: &mut FrameBuffer<T>, value: T)
http/src/h2/util.rs:77
↓ 17 callers
Method
set_max_blocked
(&mut self, max: usize)
http/src/h3/proto/qpack/dynamic.rs:266
↓ 17 callers
Method
submit
(&mut self)
tokio-uring/src/runtime/driver/mod.rs:69
↓ 17 callers
Function
tracked_table
(stream_id: u64)
http/src/h3/proto/qpack/dynamic.rs:1090
↓ 16 callers
Method
commit
(&mut self, largest_ref: usize)
http/src/h3/proto/qpack/dynamic.rs:81
↓ 16 callers
Method
contains
(&self, other: u8)
http-ws/src/codec.rs:66
↓ 16 callers
Method
encode
(&self, w: &mut B)
http/src/h3/proto/varint.rs:105
↓ 16 callers
Method
into_owned
(self)
postgres/src/statement.rs:292
↓ 16 callers
Method
is_empty
(&self)
postgres/src/row/types.rs:87
↓ 16 callers
Method
leak
leak the statement and it will lose automatic management DOES NOT** cause memory leak
postgres/src/statement.rs:65
↓ 16 callers
Method
name
(&self)
postgres/src/column.rs:22
↓ 16 callers
Method
send_data
(&mut self, bytes: Bytes, eof: bool)
client/src/h2/body.rs:59
↓ 16 callers
Method
try_next
take in &mut Pin<&mut Self> so Field can borrow it as Pin<&mut Multipart>. this avoid another explicit stack pin when operating on Field type.
http-multipart/src/lib.rs:139
↓ 15 callers
Method
as_web_ctx
(&mut self)
web/src/context.rs:187
↓ 15 callers
Method
bind
(&self, params: P)
postgres/src/statement.rs:144
↓ 15 callers
Method
connect
Connect to database, returning [Client] and [Driver] on success # Examples: ```rust use std::future::IntoFuture; use xitca_postgres::{Execute, Postgr
postgres/src/lib.rs:142
↓ 15 callers
Method
enclosed_fn
Enclose App with function as middleware type. See [middleware](crate::middleware) for more.
web/src/app/mod.rs:511
↓ 15 callers
Method
extensions_mut
(&mut self)
client/src/request.rs:196
↓ 15 callers
Method
insert
(&mut self, other: u8)
http/src/h1/proto/context.rs:36
↓ 15 callers
Method
is_empty
(&self)
http/src/h2/util.rs:73
↓ 15 callers
Method
node
Returns a reference to the current node in the traversal.
router/src/tree.rs:90
↓ 15 callers
Method
put_slice
Copies the given byte slice into the buffer, starting at this view's offset. # Panics If the slice's length exceeds the destination's remaining capa
tokio-uring/src/buf/bounded.rs:170
↓ 15 callers
Method
select
(self, other: Fut)
unsafe_collection/src/futures.rs:24
↓ 15 callers
Method
stream_id
Returns the stream identifier that this frame is associated with. This cannot be a zero stream identifier.
http/src/h2/proto/frame/data.rs:47
↓ 15 callers
Function
tempfile
()
tokio-uring/tests/fs_file.rs:305
↓ 15 callers
Method
write_var
(&mut self, x: u64)
http/src/h3/proto/coding.rs:67
↓ 14 callers
Method
call
(&self, res: Result<S, E>)
service/src/service/ext.rs:78
↓ 14 callers
Method
execute_blocking
(self, cli: &C)
postgres/src/execute/sync_impl.rs:22
↓ 14 callers
Method
get
(self, total_inserted: usize, max_table_size: usize)
http/src/h3/proto/qpack/block.rs:126
↓ 14 callers
Method
into_future
(mut self)
postgres/src/driver.rs:275
↓ 14 callers
Method
node_mut
Returns a mutable reference to the current node in the traversal.
router/src/tree.rs:98
↓ 14 callers
Method
pop_front
(&mut self, buf: &mut FrameBuffer<T>)
http/src/h2/util.rs:91
↓ 14 callers
Method
update_max_size
Queues a max size update. The next call to `encode` will include a dynamic size update frame.
http/src/h2/proto/hpack/encoder.rs:35
↓ 14 callers
Method
with_state
Construct App with a thread safe state that will be shared among all tasks and worker threads. State accessing is based on generic type approach wher
web/src/app/mod.rs:464
↓ 13 callers
Method
borrow
(&self)
http/src/http.rs:326
↓ 13 callers
Method
borrow_cli_ref
(&self)
postgres/src/pool/connection.rs:173
↓ 13 callers
Method
code
The SQLSTATE code for the error.
postgres/src/error.rs:536
↓ 13 callers
Method
grpc
(self)
client/src/grpc.rs:130
↓ 13 callers
Method
into_parts
(self)
client/src/upgrade.rs:86
↓ 13 callers
Method
into_parts
(self)
http/src/h2/proto/frame/headers.rs:199
↓ 13 callers
Method
is_empty
(&self)
http/src/h2/proto/frame/data.rs:190
↓ 13 callers
Method
next
(mut self, mut buf: BytesMut)
http-file/src/runtime.rs:124
↓ 13 callers
Method
next
Resolves to a buffer of requested capacity when it is or becomes available in this pool. This may happen when a [`FixedBuf`] handle owning a buffer of
tokio-uring/src/buf/fixed/pool.rs:254
↓ 13 callers
Function
remove_dir
Removes a directory on the local filesystem. This will only remove empty directories with no children. If you want to destroy the entire contents of
tokio-uring/src/fs/directory.rs:72
↓ 13 callers
Function
test_h2_server
A specialized http/2 server on top of [test_server]
test/src/lib.rs:68
↓ 13 callers
Method
write_str
(&mut self, s: &str)
http/src/date.rs:108
↓ 12 callers
Method
body
(self, body: B)
client/src/request.rs:85
↓ 12 callers
Method
check_out
Returns a buffer identified by the specified index for use by the application, unless the buffer is already in use. The buffer is released to be avai
tokio-uring/src/buf/fixed/registry.rs:166
↓ 12 callers
Method
clone
(&self)
unsafe_collection/src/fake.rs:131
↓ 12 callers
Method
conn_mut
(&mut self)
client/src/h1/body.rs:36
↓ 12 callers
Function
connect
(addr: SocketAddr)
test/tests/h2_rst.rs:21
↓ 12 callers
Method
decode_header
Decode field lines received on Request of Push stream. https://www.rfc-editor.org/rfc/rfc9204.html#name-field-line-representations
http/src/h3/proto/qpack/decoder.rs:113
↓ 12 callers
Method
encode
Encode a SETTINGS ACK if one is pending. Applies the HPACK table size update before the ACK so the encoder is consistent with the wire order. Called a
http/src/h2/proto/flow.rs:859
↓ 12 callers
Function
from_str
()
unsafe_collection/src/small_str.rs:308
↓ 12 callers
Function
make_hello
(name: &str)
test/tests/grpc.rs:115
↓ 12 callers
Function
map
()
service/src/service/ext.rs:113
↓ 12 callers
Method
next
(&mut self)
client/src/connect.rs:142
↓ 12 callers
Method
put
(&mut self, field: HeaderField)
http/src/h3/proto/qpack/dynamic.rs:295
↓ 12 callers
Method
remove
Remove a value by index, returning it and placing the slot on the free list.
http/src/h2/util.rs:57
↓ 12 callers
Method
remove
Remove an operation
tokio-uring/src/runtime/driver/mod.rs:462
↓ 12 callers
Method
slice_off
Slices the route with `start..`.
router/src/escape.rs:171
↓ 11 callers
Method
bind_none
(&self)
postgres/src/statement.rs:171
↓ 11 callers
Method
clone
(&self)
postgres/src/pool/connection.rs:220
↓ 11 callers
Method
get_ref
Gets a reference to the underlying buffer. This method escapes the slice's view. # Examples ``` use tokio_uring_xitca::buf::BoundedBuf; let buf =
tokio-uring/src/buf/slice.rs:84
↓ 11 callers
Method
headers
(&self)
http-multipart/src/field.rs:69
↓ 11 callers
Method
index
(&self)
tokio-uring/src/runtime/driver/op/mod.rs:206
↓ 11 callers
Method
params
(&self)
http/src/http.rs:338
↓ 11 callers
Function
read_err
(s: &str, expected_err: io::ErrorKind)
http/src/h1/proto/trasnder_coding.rs:572
↓ 11 callers
Method
reborrow
(&mut self)
web/src/context.rs:50
↓ 11 callers
Method
remove
(&mut self, other: u8)
http-ws/src/codec.rs:56
↓ 11 callers
Function
test_grpc_server
()
test/tests/grpc.rs:91
↓ 11 callers
Method
with_value
(&self, value: T)
http/src/h3/proto/qpack/field.rs:34
↓ 10 callers
Method
checked_sub
(&mut self, n: RecvWindow)
http/src/h2/proto/window.rs:29
↓ 10 callers
Method
clone
(&self)
postgres/src/statement.rs:373
↓ 10 callers
Method
eq
(&self, other: &Self)
http-rate/src/timer.rs:96
← previous
next →
101–200 of 3,753, ranked by callers