MCPcopy Create free account

hub / github.com/emmett-framework/granian / functions

Functions638 in github.com/emmett-framework/granian

Functionfiles
()
benchmarks/benchmarks.py:274
Methodfill_buffer
( stream: Arc<AsyncMutex<http_body_util::BodyStream<body::Incoming>>>, buffer: Arc<Mutex<Bytes
src/wsgi/types.rs:38
Methodfmt
(&self, f: &mut std::fmt::Formatter<'_>)
src/metrics.rs:19
Methodfmt
(&self, f: &mut fmt::Formatter<'_>)
src/asgi/errors.rs:19
Methodfrom
(err: std::convert::Infallible)
src/asgi/errors.rs:40
Methodfrom_bytes
(status: u16, headers: Vec<(PyBackedStr, PyBackedStr)>, body: Box<[u8]>)
src/rsgi/types.rs:248
Methodfrom_spec
(spec: &ListenerSpec)
src/net.rs:173
Methodfrom_string
(status: u16, headers: Vec<(PyBackedStr, PyBackedStr)>, body: String)
src/rsgi/types.rs:258
Methodfrom_unix_spec
(spec: &UnixListenerSpec)
src/net.rs:181
Functionfuture_into_py_iter
(rt: R, py: Python, fut: F)
src/runtime.rs:241
Functionfuture_watcher
(watcher)
granian/_futures.py:13
Methodget
(self, key: str)
granian/_loops.py:61
Methodget_block
(&self)
src/callbacks.rs:539
Methodget_loop
(&self, py: Python)
src/callbacks.rs:548
Methodget_sent_response_code
(&self)
src/asgi/io.rs:304
Functionhandle
( rt: RuntimeRef, _disconnect_guard: Arc<Notify>, callback: ArcCBScheduler, server_addr: SockA
src/wsgi/http.rs:22
Functionhandle_404
(scope, receive, send)
benchmarks/app/asgi.py:77
Functionhandle_404
(environ, proto)
benchmarks/app/wsgi.py:49
Functionhandle_404
(scope, proto)
benchmarks/app/rsgi.py:67
Functionhttp2
()
benchmarks/benchmarks.py:261
Functionhttp_client
()
tests/test_uds.py:85
Functioninfo
(scope, receive, send)
tests/apps/asgi.py:21
Functioninfo
(environ, protocol)
tests/apps/wsgi.py:4
Functioninfo
(scope: Scope, protocol: HTTPProtocol)
tests/apps/rsgi.py:8
Functioninit_pymodule
(module: &Bound<PyModule>)
src/workers.rs:1243
Functioninit_pymodule
(module: &Bound<PyModule>)
src/sys.rs:51
Functioninit_pymodule
(module: &Bound<PyModule>)
src/metrics.rs:411
Functioninit_pymodule
(module: &Bound<PyModule>)
src/net.rs:353
Functioninit_pymodule
(module: &Bound<PyModule>)
src/asgi/mod.rs:12
Functioninit_pymodule
(py: Python, module: &Bound<PyModule>)
src/rsgi/mod.rs:11
Functioninit_runtime_mt
( threads: usize, blocking_threads: usize, py_threads: usize, py_threads_idle_timeout: u64,
src/runtime.rs:188
Functioninterfaces
()
benchmarks/benchmarks.py:244
Functionio
(scope, receive, send)
benchmarks/app/asgi.py:69
Functionio
(environ, proto)
benchmarks/app/wsgi.py:41
Functionio
(scope, proto)
benchmarks/app/rsgi.py:60
Methodip
(&self)
src/net.rs:25
Methodis_panic
(&self)
src/runtime.rs:132
Functionis_upgrade_request
(request: &Request<B>)
src/ws.rs:105
Functioniterbody
(environ, protocol)
tests/apps/wsgi.py:25
Functionload_certs
(filename: String)
src/tls.rs:50
Functionload_crls
(filenames: impl Iterator<Item = impl AsRef<std::path::Path>>)
src/tls.rs:57
Functionload_private_key
(filename: String, password: Option<String>)
src/tls.rs:63
Functionload_target
(target: str, wd: Path | None = None, factory: bool = False)
granian/_internal.py:60
Functionloader
(files)
granian/_internal.py:82
Functionlog_request
(rtime, mtime, req, res_code)
granian/log.py:80
Functionloop
()
tests/test_embed.py:15
Functionloops
()
benchmarks/benchmarks.py:284
Functionmain
()
build.rs:1
Functionmatch_static_file
( uri_path: &str, mounts: &Vec<(String, String)>, dir_to_file: Option<&String>, )
src/files.rs:16
Methodnew
(id: usize, fd: RawFd)
src/ipc.rs:50
Methodnew
()
src/workers.rs:26
Methodnew
()
src/sys.rs:20
Methodnew
()
src/metrics.rs:49
Methodnew
(inner: T)
src/blocking.rs:16
Methodnew
( blocking_threads: usize, py_threads: usize, py_threads_idle_timeout: u64, py
src/runtime.rs:55
Methodnew
( py: Python, event_loop: Py<PyAny>, cb: Py<PyAny>, aio_task: Py<PyAny>,
src/callbacks.rs:195
Methodnew
(response_builder: Builder, response_tx: mpsc::Sender<HTTPResponse>)
src/ws.rs:68
Methodnew
(host: String, port: u16, backlog: i32)
src/net.rs:96
Methodnew
( py: Python, worker_id: i32, sock: Py<SocketHolder>, ipc: Option<Py<crate::ip
src/asgi/serve.rs:45
Methodnew
( rt: RuntimeRef, body: hyper::body::Incoming, tx: oneshot::Sender<HTTPResponse>,
src/asgi/io.rs:54
Methodnew
(py: Python, proto: HTTPProtocol, scope: Bound<PyDict>)
src/asgi/callbacks.rs:58
Methodnew
(rt: RuntimeRef, body: body::Incoming)
src/wsgi/types.rs:29
Methodnew
( py: Python, worker_id: i32, sock: Py<SocketHolder>, ipc: Option<Py<crate::ip
src/wsgi/serve.rs:49
Methodnew
(tx: oneshot::Sender<(u16, HeaderMap, HTTPResponseBody)>)
src/wsgi/io.rs:18
Methodnew
(map: HeaderMap)
src/rsgi/types.rs:27
Methodnew
( py: Python, worker_id: i32, sock: Py<SocketHolder>, ipc: Option<Py<crate::ip
src/rsgi/serve.rs:45
Methodnew
(transport: mpsc::UnboundedSender<body::Bytes>)
src/rsgi/io.rs:30
Methodnew
(py: Python, proto: HTTPProtocol, scope: HTTPScope)
src/rsgi/callbacks.rs:53
Methodnew_with_metrics
(max_threads: usize, idle_timeout: u64, metrics: metrics::ArcWorkerMetrics)
src/blocking.rs:46
Methodon_reload
(self, hook: Callable[[], Any])
granian/server/common.py:305
Methodon_shutdown
(self, hook: Callable[[], Any])
granian/server/common.py:309
Methodon_startup
(self, hook: Callable[[], Any])
granian/server/common.py:301
Functionoption
(*param_decls: str, cls: type[click.Option] | None = None, **attrs: Any)
granian/cli.py:102
Functionpathsend
(scope, receive, send)
tests/apps/asgi.py:63
Methodpoll
(&self, aggregator: &Py<MetricsAggregator>)
src/metrics.rs:254
Methodpoll
(self: Pin<&mut Self>, cx: &mut Context)
src/ws.rs:43
Methodport
(&self)
src/net.rs:33
Functionread_msg
(r: &mut R)
src/ipc.rs:204
Methodreadline
(&self, py: Python, _size: Option<usize>)
src/wsgi/types.rs:141
Methodreadlines
(&self, py: Python<'p>, _hint: Option<Py<PyAny>>)
src/wsgi/types.rs:146
Methodreceive
(&self, py: Python<'p>)
src/asgi/io.rs:119
Methodreceive
(&self, py: Python<'p>)
src/rsgi/io.rs:245
Methodregister
(self, key: str)
granian/_loops.py:24
Methodregister
(self, key: str, packages: list[str] | None = None)
granian/_loops.py:44
Methodrelease
(&self, py: Python)
src/workers.rs:48
Methodreload
(self)
granian/server/embed.py:492
Methodremove_done_callback
(&self, cb: Py<PyAny>)
src/callbacks.rs:571
Methodreschedule
(self: Arc<Self>, py: Python, loop_m: *mut pyo3::ffi::PyObject)
src/callbacks.rs:287
Methodresponse_bytes
(&self, status: u16, headers: Vec<(PyBackedStr, PyBackedStr)>, body: Cow<[u8]>)
src/wsgi/io.rs:31
Methodresponse_bytes
(&self, status: u16, headers: Vec<(PyBackedStr, PyBackedStr)>, body: Cow<[u8]>)
src/rsgi/io.rs:154
Methodresponse_empty
(&self, status: u16, headers: Vec<(PyBackedStr, PyBackedStr)>)
src/rsgi/io.rs:147
Methodresponse_file
(&self, status: u16, headers: Vec<(PyBackedStr, PyBackedStr)>, file: String)
src/rsgi/io.rs:172
Methodresponse_file_range
( &self, status: u16, headers: Vec<(PyBackedStr, PyBackedStr)>, file: String,
src/rsgi/io.rs:179
Methodresponse_str
(&self, status: u16, headers: Vec<(PyBackedStr, PyBackedStr)>, body: String)
src/rsgi/io.rs:165
Methodresponse_stream
( &self, py: Python<'p>, status: u16, headers: Vec<(PyBackedStr, PyBackedStr)>
src/rsgi/io.rs:199
Methodresult
(self)
granian/_futures.py:34
Methodresult
(&self, py: Python)
src/callbacks.rs:616
Functionroute
(scope, receive, send)
benchmarks/app/asgi.py:32
Functionroute
(environ, proto)
benchmarks/app/wsgi.py:17
Functionroute
(scope, proto)
benchmarks/app/rsgi.py:28
← previousnext →401–500 of 638, ranked by callers