MCPcopy Create free account

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

Functions638 in github.com/emmett-framework/granian

Function_schedule
(watcher)
granian/_futures.py:84
Function_serve
(**kwargs)
tests/test_uds.py:19
Function_serve
(**kwargs)
tests/conftest.py:13
Method_serve
(self, spawn_target, target_loader)
granian/server/mt.py:315
Method_serve
(self, spawn_target, target_loader)
granian/server/common.py:576
Method_serve_with_reloader
(self, spawn_target, target_loader)
granian/server/mt.py:322
Method_serve_with_reloader
(self, spawn_target, target_loader)
granian/server/common.py:581
Function_server
( interface, runtime_mode, ws=True, tls=False, task_impl='asyncio', static_mount=False, **server_kwargs )
tests/test_uds.py:25
Function_server
( interface, port, runtime_mode, ws=True, tls=False, tls_proto=None, task_impl='as
tests/conftest.py:19
Method_set_schedule_fn
(&self, val: Py<PyAny>)
src/callbacks.rs:229
Method_spawn
(self, target, args)
granian/server/mt.py:45
Method_spawn
(self, target, args)
granian/server/embed.py:51
Method_spawn
(self, target, args)
granian/server/mp.py:95
Method_spawn_asgi_lifespan_worker
( worker_id: int, shutdown_event: Any, callback: Any, sock: Any, loop:
granian/server/mt.py:122
Method_spawn_asgi_lifespan_worker
( worker_id: int, shutdown_event: Any, callback: Any, sock: Any, loop:
granian/server/embed.py:248
Method_spawn_asgi_lifespan_worker
( worker_id: int, callback: Any, sock: Any, ipc: Any, loop: Any,
granian/server/mp.py:166
Method_spawn_asgi_worker
( worker_id: int, shutdown_event: Any, callback: Any, sock: Any, loop:
granian/server/mt.py:74
Method_spawn_asgi_worker
( worker_id: int, shutdown_event: Any, callback: Any, sock: Any, loop:
granian/server/embed.py:202
Method_spawn_asgi_worker
( worker_id: int, callback: Any, sock: Any, ipc: Any, loop: Any,
granian/server/mp.py:115
Method_spawn_rsgi_worker
( worker_id: int, shutdown_event: Any, callback: Any, sock: Any, loop:
granian/server/mt.py:179
Method_spawn_rsgi_worker
( worker_id: int, shutdown_event: Any, callback: Any, sock: Any, loop:
granian/server/embed.py:303
Method_spawn_rsgi_worker
( worker_id: int, callback: Any, sock: Any, ipc: Any, loop: Any,
granian/server/mp.py:226
Method_spawn_worker
(self, idx, target, callback_loader)
granian/server/mt.py:275
Method_spawn_worker
(self, idx, target, callback_loader)
granian/server/mp.py:401
Method_spawn_wsgi_worker
( worker_id: int, shutdown_event: Any, callback: Any, sock: Any, loop:
granian/server/mt.py:230
Method_spawn_wsgi_worker
( worker_id: int, callback: Any, sock: Any, ipc: Any, loop: Any,
granian/server/mp.py:280
Method_start_ipc
(self)
granian/server/mp.py:342
Method_stop_ipc
(self)
granian/server/mp.py:371
Method_unlink_pidfile
(self)
granian/server/mp.py:338
Method_watcher
(self)
granian/server/mt.py:52
Method_watcher
(self)
granian/server/common.py:51
Method_workers_lifetime_watcher
(self, ttl)
granian/server/common.py:388
Method_workers_rss_watcher
(self)
granian/server/common.py:393
Method_write_pidfile
(self)
granian/server/mp.py:334
Methodaccept
(&self, py: Python<'p>)
src/rsgi/io.rs:351
Methodadd_done_callback
(pyself: PyRef<'_, Self>, cb: Py<PyAny>, context: Option<Py<PyAny>>)
src/callbacks.rs:553
Methodadd_waker
(self: Arc<Self>, py: Python, fut: *mut pyo3::ffi::PyObject, fut_cbm: *mut pyo3::ffi::PyObject)
src/callbacks.rs:275
Functionapp
(scope, protocol)
tests/test_embed.py:10
Functionapp
(environ, protocol)
tests/apps/wsgi.py:38
Functionapp
(scope, protocol)
tests/apps/rsgi.py:132
Functionapp
(scope, receive, send)
benchmarks/app/asgi.py:97
Functionapp
(environ, proto)
benchmarks/app/wsgi.py:66
Functionapp
(scope, proto)
benchmarks/app/rsgi.py:88
Functionapp
(scope, receive, send)
benchmarks/ws/app/asgi.py:9
Functionapp
(scope, protocol)
benchmarks/ws/app/rsgi.py:12
Functionasgi_server
(server_port, **extras)
tests/conftest.py:106
Functionasync_app
(scope, receive, send)
benchmarks/app/asgi.py:102
Functionbuild_asyncio_loop
()
granian/_loops.py:73
Functionbuild_auto_loop
()
granian/_loops.py:101
Functionbuild_rloop
(rloop)
granian/_loops.py:94
Functionbuild_uv_loop
(uvloop)
granian/_loops.py:80
Functionbuild_winloop
(winloop)
granian/_loops.py:87
Methodcall
(self, svc: S, stream: I, permit: tokio::sync::OwnedSemaphorePermit, sig: Arc<tokio::sync::Notify>)
src/workers.rs:914
Functioncall_http
( cb: ArcCBScheduler, rt: RuntimeRef, disconnect_guard: Arc<Notify>, server_addr: SockAddr,
src/asgi/callbacks.rs:146
Functioncall_http
( cb: ArcCBScheduler, rt: RuntimeRef, disconnect_guard: Arc<Notify>, body: hyper::body::Incomi
src/rsgi/callbacks.rs:118
Functioncall_ws
( cb: ArcCBScheduler, rt: RuntimeRef, disconnect_guard: Arc<Notify>, server_addr: SockAddr,
src/asgi/callbacks.rs:171
Functioncall_ws
( cb: ArcCBScheduler, rt: RuntimeRef, disconnect_guard: Arc<Notify>, ws: HyperWebsocket, u
src/rsgi/callbacks.rs:138
Methodcancel
(self, msg=None)
granian/_futures.py:40
Methodcancel
(pyself: PyRef<'_, Self>, msg: Option<Py<PyAny>>)
src/callbacks.rs:579
Methodcancelling
(self)
granian/_futures.py:43
Methodcancelling
(self)
granian/_futures.py:60
Methodclient_disconnect
(self)
granian/rsgi.py:55
Methodclient_disconnect
(&self, py: Python<'p>)
src/rsgi/io.rs:132
Methodclose
(self)
granian/wsgi.py:30
Methodclose
(&self, status: Option<i32>)
src/rsgi/io.rs:338
Functionconcurrency_proc
()
benchmarks/benchmarks.py:204
Functionconcurrency_threads
()
benchmarks/benchmarks.py:219
Methodconvert
(self, value: Any, param: click.Parameter | None, ctx: click.Context | None)
granian/cli.py:69
Methodconvert
(self, value, param, ctx)
granian/cli.py:80
Methoddata
(&self)
src/metrics.rs:191
Methoddone
(&self)
src/callbacks.rs:612
Methoddone
(&self)
src/asgi/callbacks.rs:72
Methoddone
(&self)
src/rsgi/callbacks.rs:67
Methoddrop
(&mut self)
src/net.rs:204
Functionecho
(scope, receive, send)
tests/apps/asgi.py:52
Functionecho
(environ, protocol)
tests/apps/wsgi.py:20
Functionecho
(_, protocol: HTTPProtocol)
tests/apps/rsgi.py:28
Functionecho
(scope, receive, send)
benchmarks/app/asgi.py:39
Functionecho
(environ, proto)
benchmarks/app/wsgi.py:24
Functionecho
(scope, proto)
benchmarks/app/rsgi.py:43
Functionecho_iter
(scope, receive, send)
benchmarks/app/asgi.py:45
Functionecho_iter
(environ, proto)
benchmarks/app/wsgi.py:29
Functionecho_iter
(scope, proto)
benchmarks/app/rsgi.py:47
Functionecho_stream
(_, protocol: HTTPProtocol)
tests/apps/rsgi.py:33
Functionembed_server
(server_port)
tests/test_embed.py:20
Methodempty
(status: u16, headers: Vec<(PyBackedStr, PyBackedStr)>)
src/rsgi/types.rs:240
Functionempty_context
(py: Python<'_>)
src/asyncio.rs:14
Methoderr
(&self, py: Python, err: Bound<PyAny>)
src/rsgi/callbacks.rs:71
Functionerr_app
(scope, receive, send)
tests/apps/asgi.py:158
Functionerr_app
(environ, protocol)
tests/apps/wsgi.py:34
Functionerr_app
(scope: Scope, protocol: HTTPProtocol)
tests/apps/rsgi.py:128
Functionerr_proto_flow
(scope, receive, send)
tests/apps/asgi.py:171
Functionerr_proto_msg
(scope, receive, send)
tests/apps/asgi.py:162
Methodexception
(self)
granian/_futures.py:37
Methodexception
(&self, py: Python)
src/callbacks.rs:641
Functionfile
(scope: Scope, protocol: HTTPProtocol)
tests/apps/rsgi.py:45
Functionfile
(scope, proto)
benchmarks/app/rsgi.py:53
Functionfile_body
(scope, receive, send)
benchmarks/app/asgi.py:54
Functionfile_pathsend
(scope, receive, send)
benchmarks/app/asgi.py:61
Functionfile_range
(scope: Scope, protocol: HTTPProtocol)
tests/apps/rsgi.py:50
← previousnext →301–400 of 638, ranked by callers