Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/emmett-framework/granian
/ functions
Functions
638 in github.com/emmett-framework/granian
⨍
Functions
638
◇
Types & classes
135
↳
Endpoints
34
Function
files
()
benchmarks/benchmarks.py:274
Method
fill_buffer
( stream: Arc<AsyncMutex<http_body_util::BodyStream<body::Incoming>>>, buffer: Arc<Mutex<Bytes
src/wsgi/types.rs:38
Method
fmt
(&self, f: &mut std::fmt::Formatter<'_>)
src/metrics.rs:19
Method
fmt
(&self, f: &mut fmt::Formatter<'_>)
src/asgi/errors.rs:19
Method
from
(err: std::convert::Infallible)
src/asgi/errors.rs:40
Method
from_bytes
(status: u16, headers: Vec<(PyBackedStr, PyBackedStr)>, body: Box<[u8]>)
src/rsgi/types.rs:248
Method
from_spec
(spec: &ListenerSpec)
src/net.rs:173
Method
from_string
(status: u16, headers: Vec<(PyBackedStr, PyBackedStr)>, body: String)
src/rsgi/types.rs:258
Method
from_unix_spec
(spec: &UnixListenerSpec)
src/net.rs:181
Function
future_into_py_iter
(rt: R, py: Python, fut: F)
src/runtime.rs:241
Function
future_watcher
(watcher)
granian/_futures.py:13
Method
get
(self, key: str)
granian/_loops.py:61
Method
get_block
(&self)
src/callbacks.rs:539
Method
get_loop
(&self, py: Python)
src/callbacks.rs:548
Method
get_sent_response_code
(&self)
src/asgi/io.rs:304
Function
handle
( rt: RuntimeRef, _disconnect_guard: Arc<Notify>, callback: ArcCBScheduler, server_addr: SockA
src/wsgi/http.rs:22
Function
handle_404
(scope, receive, send)
benchmarks/app/asgi.py:77
Function
handle_404
(environ, proto)
benchmarks/app/wsgi.py:49
Function
handle_404
(scope, proto)
benchmarks/app/rsgi.py:67
Function
http2
()
benchmarks/benchmarks.py:261
Function
http_client
()
tests/test_uds.py:85
Function
info
(scope, receive, send)
tests/apps/asgi.py:21
Function
info
(environ, protocol)
tests/apps/wsgi.py:4
Function
info
(scope: Scope, protocol: HTTPProtocol)
tests/apps/rsgi.py:8
Function
init_pymodule
(module: &Bound<PyModule>)
src/workers.rs:1243
Function
init_pymodule
(module: &Bound<PyModule>)
src/sys.rs:51
Function
init_pymodule
(module: &Bound<PyModule>)
src/metrics.rs:411
Function
init_pymodule
(module: &Bound<PyModule>)
src/net.rs:353
Function
init_pymodule
(module: &Bound<PyModule>)
src/asgi/mod.rs:12
Function
init_pymodule
(py: Python, module: &Bound<PyModule>)
src/rsgi/mod.rs:11
Function
init_runtime_mt
( threads: usize, blocking_threads: usize, py_threads: usize, py_threads_idle_timeout: u64,
src/runtime.rs:188
Function
interfaces
()
benchmarks/benchmarks.py:244
Function
io
(scope, receive, send)
benchmarks/app/asgi.py:69
Function
io
(environ, proto)
benchmarks/app/wsgi.py:41
Function
io
(scope, proto)
benchmarks/app/rsgi.py:60
Method
ip
(&self)
src/net.rs:25
Method
is_panic
(&self)
src/runtime.rs:132
Function
is_upgrade_request
(request: &Request<B>)
src/ws.rs:105
Function
iterbody
(environ, protocol)
tests/apps/wsgi.py:25
Function
load_certs
(filename: String)
src/tls.rs:50
Function
load_crls
(filenames: impl Iterator<Item = impl AsRef<std::path::Path>>)
src/tls.rs:57
Function
load_private_key
(filename: String, password: Option<String>)
src/tls.rs:63
Function
load_target
(target: str, wd: Path | None = None, factory: bool = False)
granian/_internal.py:60
Function
loader
(files)
granian/_internal.py:82
Function
log_request
(rtime, mtime, req, res_code)
granian/log.py:80
Function
loop
()
tests/test_embed.py:15
Function
loops
()
benchmarks/benchmarks.py:284
Function
main
()
build.rs:1
Function
match_static_file
( uri_path: &str, mounts: &Vec<(String, String)>, dir_to_file: Option<&String>, )
src/files.rs:16
Method
new
(id: usize, fd: RawFd)
src/ipc.rs:50
Method
new
()
src/workers.rs:26
Method
new
()
src/sys.rs:20
Method
new
()
src/metrics.rs:49
Method
new
(inner: T)
src/blocking.rs:16
Method
new
( blocking_threads: usize, py_threads: usize, py_threads_idle_timeout: u64, py
src/runtime.rs:55
Method
new
( py: Python, event_loop: Py<PyAny>, cb: Py<PyAny>, aio_task: Py<PyAny>,
src/callbacks.rs:195
Method
new
(response_builder: Builder, response_tx: mpsc::Sender<HTTPResponse>)
src/ws.rs:68
Method
new
(host: String, port: u16, backlog: i32)
src/net.rs:96
Method
new
( py: Python, worker_id: i32, sock: Py<SocketHolder>, ipc: Option<Py<crate::ip
src/asgi/serve.rs:45
Method
new
( rt: RuntimeRef, body: hyper::body::Incoming, tx: oneshot::Sender<HTTPResponse>,
src/asgi/io.rs:54
Method
new
(py: Python, proto: HTTPProtocol, scope: Bound<PyDict>)
src/asgi/callbacks.rs:58
Method
new
(rt: RuntimeRef, body: body::Incoming)
src/wsgi/types.rs:29
Method
new
( py: Python, worker_id: i32, sock: Py<SocketHolder>, ipc: Option<Py<crate::ip
src/wsgi/serve.rs:49
Method
new
(tx: oneshot::Sender<(u16, HeaderMap, HTTPResponseBody)>)
src/wsgi/io.rs:18
Method
new
(map: HeaderMap)
src/rsgi/types.rs:27
Method
new
( py: Python, worker_id: i32, sock: Py<SocketHolder>, ipc: Option<Py<crate::ip
src/rsgi/serve.rs:45
Method
new
(transport: mpsc::UnboundedSender<body::Bytes>)
src/rsgi/io.rs:30
Method
new
(py: Python, proto: HTTPProtocol, scope: HTTPScope)
src/rsgi/callbacks.rs:53
Method
new_with_metrics
(max_threads: usize, idle_timeout: u64, metrics: metrics::ArcWorkerMetrics)
src/blocking.rs:46
Method
on_reload
(self, hook: Callable[[], Any])
granian/server/common.py:305
Method
on_shutdown
(self, hook: Callable[[], Any])
granian/server/common.py:309
Method
on_startup
(self, hook: Callable[[], Any])
granian/server/common.py:301
Function
option
(*param_decls: str, cls: type[click.Option] | None = None, **attrs: Any)
granian/cli.py:102
Function
pathsend
(scope, receive, send)
tests/apps/asgi.py:63
Method
poll
(&self, aggregator: &Py<MetricsAggregator>)
src/metrics.rs:254
Method
poll
(self: Pin<&mut Self>, cx: &mut Context)
src/ws.rs:43
Method
port
(&self)
src/net.rs:33
Function
read_msg
(r: &mut R)
src/ipc.rs:204
Method
readline
(&self, py: Python, _size: Option<usize>)
src/wsgi/types.rs:141
Method
readlines
(&self, py: Python<'p>, _hint: Option<Py<PyAny>>)
src/wsgi/types.rs:146
Method
receive
(&self, py: Python<'p>)
src/asgi/io.rs:119
Method
receive
(&self, py: Python<'p>)
src/rsgi/io.rs:245
Method
register
(self, key: str)
granian/_loops.py:24
Method
register
(self, key: str, packages: list[str] | None = None)
granian/_loops.py:44
Method
release
(&self, py: Python)
src/workers.rs:48
Method
reload
(self)
granian/server/embed.py:492
Method
remove_done_callback
(&self, cb: Py<PyAny>)
src/callbacks.rs:571
Method
reschedule
(self: Arc<Self>, py: Python, loop_m: *mut pyo3::ffi::PyObject)
src/callbacks.rs:287
Method
response_bytes
(&self, status: u16, headers: Vec<(PyBackedStr, PyBackedStr)>, body: Cow<[u8]>)
src/wsgi/io.rs:31
Method
response_bytes
(&self, status: u16, headers: Vec<(PyBackedStr, PyBackedStr)>, body: Cow<[u8]>)
src/rsgi/io.rs:154
Method
response_empty
(&self, status: u16, headers: Vec<(PyBackedStr, PyBackedStr)>)
src/rsgi/io.rs:147
Method
response_file
(&self, status: u16, headers: Vec<(PyBackedStr, PyBackedStr)>, file: String)
src/rsgi/io.rs:172
Method
response_file_range
( &self, status: u16, headers: Vec<(PyBackedStr, PyBackedStr)>, file: String,
src/rsgi/io.rs:179
Method
response_str
(&self, status: u16, headers: Vec<(PyBackedStr, PyBackedStr)>, body: String)
src/rsgi/io.rs:165
Method
response_stream
( &self, py: Python<'p>, status: u16, headers: Vec<(PyBackedStr, PyBackedStr)>
src/rsgi/io.rs:199
Method
result
(self)
granian/_futures.py:34
Method
result
(&self, py: Python)
src/callbacks.rs:616
Function
route
(scope, receive, send)
benchmarks/app/asgi.py:32
Function
route
(environ, proto)
benchmarks/app/wsgi.py:17
Function
route
(scope, proto)
benchmarks/app/rsgi.py:28
← previous
next →
401–500 of 638, ranked by callers