Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/MegEngine/MegFlow
/ functions
Functions
829 in github.com/MegEngine/MegFlow
⨍
Functions
829
◇
Types & classes
213
↳
Endpoints
5
↓ 109 callers
Method
clone
(&self)
flow-rs/src/channel/inner.rs:221
↓ 102 callers
Method
push
(self, id, msg)
flow-python/examples/application/cat_finder/visualize/visualize.py:42
↓ 86 callers
Method
as_ref
(&self)
flow-message/src/cross/map.rs:26
↓ 76 callers
Method
insert
(&self, id: Q, elem: T)
flow-rs/src/registry.rs:58
↓ 60 callers
Method
send
(&self, msg: T)
flow-rs/src/channel/inner.rs:138
↓ 53 callers
Method
info
(&self)
flow-rs/src/graph/node.rs:50
↓ 50 callers
Method
append
(&mut self, other: &mut StorageInner)
flow-rs/src/resource/storage.rs:49
↓ 48 callers
Method
get
(&self)
flow-rs/src/graph/node.rs:38
↓ 39 callers
Function
range
(n: Data)
flow-rs/src/config/parser.rs:31
↓ 33 callers
Method
clone
(&self)
flow-rs/src/registry.rs:96
↓ 33 callers
Method
recv
(&self)
flow-rs/src/channel/inner.rs:268
↓ 31 callers
Method
to_object
(&self, py: Python)
flow-rs/src/loader/python/port.rs:47
↓ 30 callers
Method
load
(ctx: Context, config: &config::Graph, args: &Table)
flow-rs/src/graph/mod.rs:128
↓ 27 callers
Method
clone
(&self)
flow-message/src/c.rs:43
↓ 26 callers
Method
len
(&self)
flow-rs/src/channel/inner.rs:187
↓ 23 callers
Function
match_last_ty
(ty: &syn::Type, wrapper: &str)
flow-derive/src/utils.rs:45
↓ 22 callers
Method
take
Takes the message out of the envelope, leaving a `None` in its place
flow-rs/src/envelope/envelope.rs:99
↓ 21 callers
Method
filter
(&self, names: &[&str])
flow-rs/src/resource/collection.rs:41
↓ 21 callers
Method
get_mut
(&mut self)
flow-rs/src/graph/node.rs:42
↓ 21 callers
Method
send_any
Sends a any envelope into the channel. see document of `send` for more detail
flow-rs/src/channel/sender.rs:123
↓ 20 callers
Method
get
(&self, id: &Q)
flow-rs/src/registry.rs:49
↓ 17 callers
Method
recv_any
Receives a any envelope from the channel, see document of `recv` for more detail
flow-rs/src/channel/receiver.rs:115
↓ 17 callers
Method
remove
(&self, id: u64)
flow-rs/src/registry.rs:140
↓ 16 callers
Method
get
(self)
flow-python/examples/logical_test/buffer.py:14
↓ 15 callers
Method
pop
(self)
flow-python/examples/application/cat_finder/visualize/visualize.py:80
↓ 13 callers
Method
seal
Convert the `Envelope` to `SealedEnvelope`
flow-rs/src/envelope/envelope.rs:76
↓ 13 callers
Method
xset
(&mut self, key: Idx, value: U)
flow-message/src/cross/mod.rs:96
↓ 12 callers
Function
create
(project_dir: &Path, config: GitConfig)
flow-quickstart/src/git.rs:101
↓ 12 callers
Method
is_empty
(&self)
flow-rs/src/channel/inner.rs:179
↓ 12 callers
Function
list
(#[data] state: State)
flow-plugins/src/video_server.rs:77
↓ 11 callers
Method
notify
(&self)
flow-rs/src/debug/feature.rs:35
↓ 11 callers
Method
template
(mut self, template: String)
flow-rs/src/lib.rs:101
↓ 10 callers
Method
build
(self)
flow-rs/src/lib.rs:111
↓ 10 callers
Method
chain
Chain two ResourceCollections, and `other` will overwrite `self`
flow-rs/src/resource/collection.rs:53
↓ 10 callers
Method
info_mut
(&mut self)
flow-rs/src/graph/node.rs:54
↓ 10 callers
Method
len
(&self)
flow-message/src/cross/data/mod.rs:110
↓ 10 callers
Method
receiver
(&self)
flow-rs/src/channel/storage.rs:83
↓ 10 callers
Method
sender
(&self)
flow-rs/src/channel/storage.rs:66
↓ 10 callers
Method
wait
(&mut self, py: Python)
flow-python/src/lib.rs:39
↓ 9 callers
Method
inference
(self, mat)
flow-python/examples/application/warehouse/reid_alignedreid/model.py:43
↓ 9 callers
Function
unbounded
()
flow-rs/src/channel/inner.rs:96
↓ 8 callers
Function
extract_ports
( data: &syn::Data, ty_name: &str, f: fn(ExtractParams) -> TokenStream, )
flow-derive/src/utils.rs:90
↓ 8 callers
Function
ident
(lit: impl AsRef<str>)
flow-derive/src/lit.rs:20
↓ 8 callers
Method
repack
Repack a message, and return a new envelope with the message
flow-rs/src/envelope/envelope.rs:88
↓ 7 callers
Method
close
(&self)
flow-rs/src/broker.rs:157
↓ 7 callers
Method
for_each
(&self, f: F)
flow-rs/src/registry.rs:66
↓ 7 callers
Method
keys
Get all keys
flow-rs/src/resource/collection.rs:83
↓ 7 callers
Method
listen
listen on 0.0.0.0:`self.port`
flow-rs/src/debug/server.rs:138
↓ 7 callers
Function
parse
(s: &str)
flow-rs/src/loader/python/port.rs:82
↓ 7 callers
Method
start
(mut self)
flow-rs/src/sandbox.rs:146
↓ 7 callers
Method
track
(self, det_boxes, use_smooth=True)
flow-python/examples/application/warehouse/track_iou/track_iou.py:201
↓ 7 callers
Method
update
(self, x, y)
flow-python/examples/application/warehouse/track_iou/track_iou.py:266
↓ 7 callers
Method
width
(&self)
flow-message/src/cross/data/mod.rs:65
↓ 7 callers
Function
with_context
(py: Python, f: F)
flow-rs/src/loader/python/context.rs:20
↓ 6 callers
Method
forward
Returns: global_feat: shape [N, C] local_feat: shape [N, H, c]
flow-python/examples/application/warehouse/reid_alignedreid/model.py:29
↓ 6 callers
Function
from_data
(py: Python, data: impl std::ops::Deref<Target = data::Data>)
flow-message/src/cross/python/mod.rs:99
↓ 6 callers
Method
into_object
(self, py: Python)
flow-rs/src/loader/python/channel.rs:75
↓ 6 callers
Method
is_dyn
(&self)
flow-rs/src/config/interlayer.rs:90
↓ 6 callers
Method
pack
(py: Python, msg: PyObject, info: Option<Py<PyDict>>)
flow-rs/src/loader/python/envelope.rs:37
↓ 6 callers
Method
set_port
(&mut self, _port_name: &str, _tag: Option<u64>, _channel: &ChannelStorage)
flow-rs/src/node/shared.rs:118
↓ 6 callers
Function
sleep
(py: Python, dur: u64)
flow-rs/src/loader/python/utils.rs:32
↓ 6 callers
Method
store
(&mut self)
flow-rs/src/loader/python/context.rs:42
↓ 5 callers
Method
build
(self)
flow-python/setup.py:60
↓ 5 callers
Method
close
(&self)
flow-rs/src/graph/context.rs:27
↓ 5 callers
Function
cvt_idx
(len: usize, idx: isize)
flow-message/src/cross/python/mod.rs:51
↓ 5 callers
Function
fields
(data: &syn::Data)
flow-derive/src/utils.rs:24
↓ 5 callers
Function
get_num
(data: &'a InnerData)
flow-rs/src/config/parser.rs:17
↓ 5 callers
Method
into_py_dict
(self, py: Python)
flow-rs/src/loader/python/envelope.rs:142
↓ 5 callers
Method
is_closed
(&self)
flow-rs/src/node/port.rs:186
↓ 5 callers
Method
is_none
(&self)
flow-rs/src/channel/sender.rs:55
↓ 5 callers
Method
keys
(&self)
flow-rs/src/registry.rs:86
↓ 5 callers
Function
list2map
(list)
flow-debugger/debugger-ui/src/parser.js:1
↓ 5 callers
Function
path_to_module
(root: &Path, path: &Path)
flow-rs/src/loader/python/mod.rs:233
↓ 5 callers
Method
start
( mut self: Box<Self>, ctx: Context, resources: ResourceCollection, )
flow-rs/src/node/shared.rs:136
↓ 5 callers
Function
translate_conn
( p: presentation::Connection, nodes: &mut HashMap<String, interlayer::Node>, shared_nodes: &mut H
flow-rs/src/config/mod.rs:74
↓ 4 callers
Method
_make_layer
(self, block, planes, blocks, stride=1)
flow-python/examples/application/warehouse/reid_alignedreid/resnet.py:131
↓ 4 callers
Function
block_on
(py: Python, task: PyObject)
flow-rs/src/loader/python/utils.rs:18
↓ 4 callers
Method
close
Closes the channel and notifies all blocked operations. Returns `true` if this call has closed the channel and it was not closed already.
flow-rs/src/channel/inner.rs:67
↓ 4 callers
Function
context
(name: String, ty: String, local_key: u64)
flow-rs/src/graph/context.rs:63
↓ 4 callers
Method
copy
(self)
flow-python/setup.py:80
↓ 4 callers
Method
fetch
(&self)
flow-rs/src/node/port.rs:152
↓ 4 callers
Method
first
(&self)
flow-rs/src/graph/node.rs:33
↓ 4 callers
Method
inference
(self, img)
flow-python/examples/application/simple_det_classify/lite.py:62
↓ 4 callers
Method
input
(&self, name: &str)
flow-rs/src/sandbox.rs:138
↓ 4 callers
Function
merge_table
(base: Table, mut patch: Table)
flow-rs/src/config/table.rs:13
↓ 4 callers
Method
output
(&self, name: &str)
flow-rs/src/sandbox.rs:142
↓ 4 callers
Method
output
Get an output port from the graph by name
flow-rs/src/graph/mod.rs:72
↓ 4 callers
Method
restrict
(val, min, max)
flow-python/examples/application/electric_bicycle/det.py:37
↓ 4 callers
Method
restrict
(self, val, min, max)
flow-python/examples/application/warehouse/detection_yolox/lite.py:126
↓ 4 callers
Method
run
(self)
flow-python/setup.py:90
↓ 4 callers
Function
string
(lit: T)
flow-derive/src/lit.rs:16
↓ 4 callers
Method
try_recv
(&self)
flow-rs/src/channel/inner.rs:254
↓ 4 callers
Method
xget
(&self, key: &Idx)
flow-message/src/cross/mod.rs:108
↓ 3 callers
Function
canonicalize_path
(p: &Path)
flow-quickstart/src/git.rs:108
↓ 3 callers
Method
capacity
(&self)
flow-rs/src/channel/inner.rs:191
↓ 3 callers
Method
close
(&mut self)
flow-python/src/lib.rs:70
↓ 3 callers
Method
close
(&self)
flow-rs/src/node/port.rs:245
↓ 3 callers
Function
exec
(commands: &[Node<'static>])
flow-quickstart/src/main.rs:50
↓ 3 callers
Method
fetch
(&self)
flow-rs/src/broker.rs:125
↓ 3 callers
Function
finalize
(id: u64)
flow-rs/src/registry.rs:120
next →
1–100 of 829, ranked by callers