MCPcopy Create free account

hub / github.com/MercuryWorkshop/epoxy-tls / functions

Functions459 in github.com/MercuryWorkshop/epoxy-tls

⨍ Functions 459◇ Types & classes 140
↓ 1 callersMethodallowed_tcp_hosts
(&self)
server/src/config.rs:500
↓ 1 callersMethodallowed_udp_hosts
(&self)
server/src/config.rs:510
↓ 1 callersFunctionasync_iterator_transport_read
( init: State, func: Func, )
wisp/src/ws/unfold.rs:16
↓ 1 callersFunctionasync_iterator_transport_write
( init: State, func: Func, close_init: CloseState, close_func: CloseFunc, )
wisp/src/ws/unfold.rs:30
↓ 1 callersFunctionasync_main
()
server/src/main.rs:234
↓ 1 callersMethodblocked_hosts
(&self)
server/src/config.rs:495
↓ 1 callersMethodblocked_ports
(&self)
server/src/config.rs:485
↓ 1 callersFunctionblocked_set
(stream_type: StreamType)
server/src/stream.rs:36
↓ 1 callersMethodblocked_tcp_hosts
(&self)
server/src/config.rs:505
↓ 1 callersMethodblocked_udp_hosts
(&self)
server/src/config.rs:515
↓ 1 callersMethodbox_clone
(&self)
wisp/src/extensions/udp.rs:30
↓ 1 callersMethodbuild_from_bytes
( &mut self, _: Bytes, _: crate::Role, )
wisp/src/extensions/udp.rs:43
↓ 1 callersMethodbuild_to_extension
(&mut self, _: crate::Role)
wisp/src/extensions/udp.rs:51
↓ 1 callersFunctionchain
(first: T, second: U)
server/src/util_chain.rs:24
↓ 1 callersMethodclear_cache
(&self)
server/src/main.rs:69
↓ 1 callersMethodclose_with_reason
Close all streams and send a close reason on stream ID 0. Also terminates the multiplexor future.
wisp/src/mux/mod.rs:236
↓ 1 callersMethodconnect
(self, req: hyper::Uri)
client/src/stream_provider.rs:314
↓ 1 callersMethodconnect
( client: &EpoxyClient, handlers: EpoxyHandlers, url: EpoxyUrlInput, protocols: Vec<String>, headers
client/src/websocket.rs:44
↓ 1 callersMethodconnect
(packet: ConnectPacket)
server/src/stream.rs:227
↓ 1 callersMethodconnect_tls
(&self, url: EpoxyUrlInput)
client/src/lib.rs:500
↓ 1 callersMethodconnect_udp
(&self, url: EpoxyUrlInput)
client/src/lib.rs:514
↓ 1 callersMethodconnect_websocket
( &self, handlers: EpoxyHandlers, url: EpoxyUrlInput, protocols: Vec<String>, headers: EpoxyWebSocke
client/src/lib.rs:476
↓ 1 callersMethodconsume
(self: Pin<&mut Self>, amt: usize)
server/src/listener.rs:78
↓ 1 callersFunctionconvert_streaming_body
( val: JsValue, )
client/src/utils/js.rs:171
↓ 1 callersFunctioncopy_fast
( mux: MuxStream<WispStreamWrite>, tcp: TcpStream, #[cfg(feature = "speed-limit")] read_limit: async_speed_
server/src/handle/wisp/mod.rs:35
↓ 1 callersFunctioncreateEpoxy
()
client-showcase/src/epoxy.ts:28
↓ 1 callersFunctioncreateRequest
([url, method, headers, body, _wispServer]: string[])
client-showcase/src/demo.tsx:79
↓ 1 callersFunctioncreate_mux
( opts: &Cli, )
simple-wisp-client/src/main.rs:97
↓ 1 callersMethodcreate_stream
(&mut self, ty: StreamType)
wisp/src/mux/inner.rs:353
↓ 1 callersFunctioncreate_wisp_transport
(function: Function)
client/src/lib.rs:327
↓ 1 callersMethodencode
(&self)
server/src/handle/wisp/twisp.rs:50
↓ 1 callersMethodentry
(&mut self)
wisp/src/mux/inner.rs:251
↓ 1 callersFunctionevictEpoxy
()
client-showcase/src/epoxy.ts:15
↓ 1 callersFunctionfetch
(url: string, options?: any)
client-showcase/src/epoxy.ts:46
↓ 1 callersFunctionfetchWithEpoxy
(req: EpoxyRequest)
client-showcase/src/demo.tsx:22
↓ 1 callersMethodflow_add
(&self, amt: u32)
wisp/src/mux/inner.rs:89
↓ 1 callersMethodflow_empty
(&self)
wisp/src/mux/inner.rs:108
↓ 1 callersMethodflow_register
(&self, cx: &mut Context<'_>)
wisp/src/mux/inner.rs:112
↓ 1 callersMethodflow_set
(&self, amt: u32)
wisp/src/mux/inner.rs:86
↓ 1 callersMethodflow_sub
(&self, amt: u32)
wisp/src/mux/inner.rs:97
↓ 1 callersMethodflow_wake
(&self)
wisp/src/mux/inner.rs:118
↓ 1 callersFunctionformat_stream_type
(stream_type: StreamType)
server/src/stats.rs:8
↓ 1 callersFunctionforward_stream
( muxstream: MuxStream<WispStreamWrite>, stream: ClientStream, resolved_stream: ConnectPacket, uuid: Uuid,
server/src/handle/wisp/mod.rs:112
↓ 1 callersFunctionget_cert
(path: PathBuf)
simple-wisp-client/src/main.rs:81
↓ 1 callersFunctionget_certificates_from_paths
(paths: Vec<PathBuf>)
server/src/handle/wisp/utils.rs:7
↓ 1 callersMethodget_congestion_stream_types
Get stream types that should be treated as TCP. Used to decide whether to handle congestion control for that stream type.
wisp/src/extensions/mod.rs:103
↓ 1 callersMethodget_guard
(&mut self)
wisp/src/locked_sink.rs:262
↓ 1 callersMethodget_next
(&mut self)
wisp/src/locked_sink.rs:76
↓ 1 callersMethodget_redirect
(&self, location: &HeaderValue)
client/src/utils/mod.rs:68
↓ 1 callersMethodget_stream_id
(&self)
wisp/src/stream/mod.rs:63
↓ 1 callersMethodget_supported_packets
Get the protocol extension's supported packets. Used to decide whether to call the protocol extension's packet handler.
wisp/src/extensions/mod.rs:97
↓ 1 callersMethodhandle_close_packet
(&mut self, stream_id: u32, close: ClosePacket)
wisp/src/mux/inner.rs:413
↓ 1 callersMethodhandle_connect_packet
( &mut self, stream: MuxStream<W>, pkt: ConnectPacket, )
wisp/src/mux/server.rs:23
↓ 1 callersMethodhandle_continue_packet
( &mut self, _: u32, _: crate::packet::ContinuePacket, _: &mut StreamMap, )
wisp/src/mux/server.rs:47
↓ 1 callersMethodhandle_data_packet
( &mut self, id: u32, pkt: Payload, streams: &mut StreamMap, )
wisp/src/mux/inner.rs:142
↓ 1 callersMethodhandle_error
( &mut self, err: WispError, tx: &mut LockedWebSocketWrite<W>, )
wisp/src/mux/server.rs:140
↓ 1 callersMethodhandle_handshake
Handle the handshake part of a Wisp connection. This should be used to send or receive data before any streams are created.
wisp/src/extensions/mod.rs:113
↓ 1 callersFunctionhandle_stream
(stream: ServerRouteResult, id: String)
server/src/main.rs:327
↓ 1 callersFunctionhandle_twisp
( id: u32, streamrx: &mut MuxStreamAsyncRead<WispStreamWrite>, streamtx: &mut MuxStreamAsyncWrite<WispStrea
server/src/handle/wisp/twisp.rs:130
↓ 1 callersFunctionhandle_wisp
(stream: WispResult, is_v2: bool, id: String)
server/src/handle/wisp/mod.rs:289
↓ 1 callersFunctionhandle_wispnet
(stream: WispResult, id: String)
server/src/handle/wisp/wispnet.rs:214
↓ 1 callersFunctionhandle_wsproxy
( mut ws: WebSocketStreamWrapper, id: String, path: String, udp: bool, )
server/src/handle/wsproxy.rs:22
↓ 1 callersMethodinto_async_read
(self)
wisp/src/stream/mod.rs:71
↓ 1 callersMethodinto_async_write
(self)
wisp/src/stream/mod.rs:196
↓ 1 callersMethodinto_future
(mut self)
wisp/src/mux/inner.rs:232
↓ 1 callersMethodinto_httpbody
(self)
client/src/utils/js.rs:155
↓ 1 callersMethodinto_inner
Consume this wrapper and get the inner type.
client/src/tokioio.rs:38
↓ 1 callersMethodinto_owned
(self)
wisp/src/ws/mod.rs:30
↓ 1 callersMethodinto_read
(self)
client/src/ws_wrapper.rs:70
↓ 1 callersMethodinto_split
(self)
wisp/src/stream/mod.rs:331
↓ 1 callersMethodinto_write
(self)
client/src/ws_wrapper.rs:186
↓ 1 callersFunctioniostream_from_stream
(stream: ProviderUnencryptedStream)
client/src/io_stream.rs:50
↓ 1 callersFunctionipv4_is_global
taken from rust 1.82.0
server/src/stream.rs:57
↓ 1 callersFunctionipv6_is_global
(addr: Ipv6Addr)
server/src/stream.rs:74
↓ 1 callersFunctionis_redirect
(code: u16)
client/src/utils/mod.rs:55
↓ 1 callersMethodis_thread_per_core
(&self)
server/src/config.rs:78
↓ 1 callersFunctionis_upgrade_request
(request: &hyper::Request<B>)
server/src/upgrade.rs:10
↓ 1 callersMethodlock_ws
Get a locked guard to the write half of the websocket.
wisp/src/mux/mod.rs:209
↓ 1 callersFunctionmap_err
(x: tokio_websockets::Error)
wisp/src/ws/tokio_websockets.rs:17
↓ 1 callersFunctionmap_err
(x: tokio_tungstenite::tungstenite::Error)
wisp/src/ws/tokio_tungstenite.rs:17
↓ 1 callersMethodpoll_close
(mut self: Pin<&mut Self>, cx: &mut Context<'_>)
client/src/utils/mod.rs:194
↓ 1 callersMethodpoll_flush
( self: std::pin::Pin<&mut Self>, cx: &mut std::task::Context<'_>, )
wisp/src/ws/tokio_tungstenite.rs:66
↓ 1 callersMethodpoll_flush
(self: Pin<&mut Self>, cx: &mut Context<'_>)
wisp/src/ws/unfold.rs:160
↓ 1 callersFunctionpoll_inner
( select: &mut UnfairSelectProj<'_, St1, St2>, side: PollNext, cx: &mut Context<'_>, )
wisp/src/unfair_select.rs:104
↓ 1 callersMethodpoll_lock
(&mut self, cx: &mut Context<'_>)
wisp/src/locked_sink.rs:196
↓ 1 callersFunctionpoll_read_buf
( io: Pin<&mut T>, cx: &mut Context<'_>, buf: &mut B, )
client/src/utils/mod.rs:117
↓ 1 callersFunctionreadableStream
(buffer)
client/demo.js:83
↓ 1 callersFunctionreal_main
()
simple-wisp-client/src/main.rs:165
↓ 1 callersMethodreplace_client
(&self)
client/src/stream_provider.rs:156
↓ 1 callersMethodreplace_stream_provider
(&self)
client/src/lib.rs:471
↓ 1 callersFunctionrequest
( req: Request<Empty<Bytes>>, client: &EpoxyClient, )
client/src/websocket.rs:215
↓ 1 callersFunctionroute
( stream: ServerStream, stats_endpoint: Option<String>, callback: impl FnOnce(ServerRouteResult, Option<Str
server/src/route.rs:199
↓ 1 callersFunctionroute_stats
(stream: ServerStream)
server/src/route.rs:191
↓ 1 callersFunctionsec_websocket_protocol
(key: &[u8])
server/src/upgrade.rs:54
↓ 1 callersFunctionsendReq
(req: EpoxyRequest)
client-showcase/src/demo.tsx:209
↓ 1 callersMethodsend_req
( &self, req: http::Request<StreamingBody>, should_redirect: bool, )
client/src/lib.rs:554
↓ 1 callersMethodser
(&self)
server/src/config.rs:522
↓ 1 callersMethodset_reason
(&self, reason: CloseReason)
wisp/src/mux/inner.rs:130
↓ 1 callersFunctionset_term_size
(fd: RawFd, size: Size)
server/src/handle/wisp/twisp.rs:109
↓ 1 callersMethodsize_hint
(&self)
client/src/utils/js.rs:129
← previousnext →101–200 of 459, ranked by callers