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
↓ 3 callers
Function
home
home path wrapper
flow-quickstart/src/git.rs:167
↓ 3 callers
Method
inference
(self, mat)
flow-python/examples/application/simple_classification/lite.py:66
↓ 3 callers
Method
inference
(self, mat)
flow-python/examples/application/warehouse/reid_alignedreid/lite.py:39
↓ 3 callers
Function
initialize
(id: u64)
flow-rs/src/registry.rs:116
↓ 3 callers
Method
input
Get an input port from the graph by name
flow-rs/src/graph/mod.rs:68
↓ 3 callers
Function
inputs
(local_key: u64, ty: &str)
flow-rs/src/node/mod.rs:87
↓ 3 callers
Function
isGraph
(config, name)
flow-debugger/debugger-ui/src/parser.js:9
↓ 3 callers
Function
is_overlap_v2
(rect1, rect2, iou_threshold)
flow-python/examples/application/utils.py:83
↓ 3 callers
Function
join
(py: Python, tasks: Vec<PyObject>)
flow-rs/src/loader/python/utils.rs:39
↓ 3 callers
Function
load
(local_key: u64, cfg: &LoaderConfig)
flow-rs/src/loader/mod.rs:49
↓ 3 callers
Function
load_static
( local_key: u64, config: &crate::config::interlayer::Node, )
flow-rs/src/node/mod.rs:59
↓ 3 callers
Method
make
(&self)
flow-rs/src/graph/channel.rs:33
↓ 3 callers
Function
outputs
(local_key: u64, ty: &str)
flow-rs/src/node/mod.rs:97
↓ 3 callers
Method
parse
(input: ParseStream)
flow-derive/src/node.rs:23
↓ 3 callers
Function
range_impl
(start: i64, end: i64, step: i64)
flow-rs/src/config/parser.rs:27
↓ 3 callers
Function
run
(onnx_session, image, class_names, score_thrs, nms_thr=0.6)
flow-python/examples/application/warehouse/detection_memd/onnx_model.py:110
↓ 3 callers
Method
set
(&mut self, storage: ChannelStorage)
flow-rs/src/graph/channel.rs:29
↓ 3 callers
Method
set_port
(&mut self, port_name: &str, tag: Option<u64>, channel: &ChannelStorage)
flow-rs/src/graph/subgraph.rs:16
↓ 3 callers
Function
simple_merge
(rect1, rect2)
flow-python/examples/application/utils.py:142
↓ 3 callers
Method
subscribe
(&mut self, topic: String)
flow-rs/src/broker.rs:51
↓ 3 callers
Method
take_into_arc
(self)
flow-rs/src/resource/collection.rs:32
↓ 3 callers
Function
to_data
(py: Python, object: PyObject)
flow-message/src/cross/python/mod.rs:59
↓ 3 callers
Method
to_vec
(&self)
flow-rs/src/registry.rs:74
↓ 3 callers
Method
ty
(&self)
flow-message/src/cross/data/mod.rs:102
↓ 3 callers
Function
useSealedState
* Keeps the value the same permanently. * Useful over refs especially in instances where the function creation variant is used
flow-debugger/debugger-ui/src/page/topology/VisGraph.js:44
↓ 3 callers
Method
visual
(self, output, img, cls_conf=0.35)
flow-python/examples/application/warehouse/detection_yolox/lite.py:173
↓ 3 callers
Method
wait
(&self)
flow-rs/src/graph/context.rs:39
↓ 3 callers
Method
xpush_back
(&mut self, value: T)
flow-message/src/cross/cow_list.rs:40
↓ 2 callers
Method
__init__
(self, block, layers)
flow-python/examples/application/warehouse/reid_alignedreid/resnet.py:106
↓ 2 callers
Method
abort
Drop self, and closes the channel if there are no senders left.
flow-rs/src/channel/sender.rs:99
↓ 2 callers
Method
area
(mat)
flow-python/examples/application/warehouse/quality_naive/quality.py:21
↓ 2 callers
Method
batch_recv
Receives some envelopes from the channel. If there are less than n envelopes in the channel, this method waits until there is n envelopes or timeout.
flow-rs/src/channel/receiver.rs:145
↓ 2 callers
Function
bcast
( id: &str, src: &mut interlayer::Connection, connections: &mut HashMap<String, interlayer::Connec
flow-rs/src/config/insert.rs:93
↓ 2 callers
Method
boxed
(self)
flow-rs/src/loader/python/mod.rs:49
↓ 2 callers
Method
boxed
(self)
flow-rs/src/node/shared.rs:112
↓ 2 callers
Function
build_test_input2
()
flow-python/examples/application/warehouse/track_iou/track_iou.py:291
↓ 2 callers
Method
clone
(&self)
flow-rs/src/envelope/envelope.rs:127
↓ 2 callers
Function
conv3x3
3x3 convolution with padding
flow-python/examples/application/warehouse/reid_alignedreid/resnet.py:20
↓ 2 callers
Function
copy_dir_all
(src: impl AsRef<Path>, dst: impl AsRef<Path>)
flow-quickstart/src/git.rs:207
↓ 2 callers
Method
create
( &mut self, key: u64, resource: ResourceCollection, args: Table, )
flow-rs/src/node/port.rs:70
↓ 2 callers
Function
create_future
()
flow-rs/src/loader/python/utils.rs:84
↓ 2 callers
Method
create_spec
( &mut self, key: u64, which: &str, resource: ResourceCollection, args
flow-rs/src/node/port.rs:90
↓ 2 callers
Function
determine_repo_kind
determines what kind of repository we got
flow-quickstart/src/git.rs:333
↓ 2 callers
Function
diff
(current, next, field = "id")
flow-debugger/debugger-ui/src/page/topology/VisGraph.js:51
↓ 2 callers
Method
empty_n
(&self)
flow-rs/src/channel/sender.rs:78
↓ 2 callers
Function
envelope_register
(module: &PyModule)
flow-rs/src/loader/python/envelope.rs:158
↓ 2 callers
Function
expand
(ports: &PortSequence, extend_ty: &str)
flow-derive/src/ports.rs:93
↓ 2 callers
Function
expand
(input: DeriveInput)
flow-derive/src/node.rs:46
↓ 2 callers
Method
fetch_with_cache
(&mut self)
flow-rs/src/node/port.rs:171
↓ 2 callers
Function
fill_dict
(py: Python, key: &str, value: &toml::Value, dict: &PyDict)
flow-rs/src/loader/python/node.rs:232
↓ 2 callers
Function
findNodeById
(config, graph_name, id)
flow-debugger/debugger-ui/src/parser.js:334
↓ 2 callers
Method
finish
(&mut self)
flow-plugins/src/utils/multipart.rs:92
↓ 2 callers
Method
get
(&mut self)
flow-rs/src/resource/lazy.rs:27
↓ 2 callers
Method
get
(&mut self, key: &(u64, String))
flow-rs/src/resource/storage.rs:22
↓ 2 callers
Method
get_any
(&self, name: &str)
flow-rs/src/resource/collection.rs:75
↓ 2 callers
Method
get_ref
(&self, key: &str)
flow-message/src/cross/cow_map.rs:20
↓ 2 callers
Function
graph_register
(local_key: u64, ty: &str, port_name: &str)
flow-rs/src/sandbox.rs:164
↓ 2 callers
Method
inference_batch
(self, img)
flow-python/examples/application/simple_det_classify/lite.py:43
↓ 2 callers
Function
init
(project_dir: &Path, branch: &str)
flow-quickstart/src/git.rs:323
↓ 2 callers
Method
input
(&self, key: &str)
flow-python/src/lib.rs:62
↓ 2 callers
Method
into_bgr8
(self)
flow-plugins/src/utils/image.rs:33
↓ 2 callers
Function
isInput
(graph, name)
flow-debugger/debugger-ui/src/parser.js:13
↓ 2 callers
Function
isOutput
(graph, name)
flow-debugger/debugger-ui/src/parser.js:17
↓ 2 callers
Method
is_closed
(&self)
flow-rs/src/channel/storage.rs:33
↓ 2 callers
Method
is_closed
(&self)
flow-rs/src/graph/context.rs:36
↓ 2 callers
Function
is_git_metadata
(entry: &DirEntry)
flow-quickstart/src/lib.rs:27
↓ 2 callers
Method
is_some
(&self)
flow-rs/src/envelope/envelope.rs:142
↓ 2 callers
Method
len
(&self)
flow-rs/src/channel/storage.rs:101
↓ 2 callers
Function
linear_func
(p, x)
flow-python/examples/application/warehouse/track_iou/track_iou.py:253
↓ 2 callers
Method
load_from_scope
(&self, local_key: u64)
flow-rs/src/loader/python/mod.rs:141
↓ 2 callers
Function
load_onnx_model
(onnx_path)
flow-python/examples/application/warehouse/detection_memd/onnx_model.py:18
↓ 2 callers
Function
name_expand
(ports: &PortSequence)
flow-derive/src/ports.rs:118
↓ 2 callers
Method
output
(&self, key: &str)
flow-python/src/lib.rs:66
↓ 2 callers
Function
parseGraph
(config, graph)
flow-debugger/debugger-ui/src/parser.js:21
↓ 2 callers
Function
port_name
(s: &str)
flow-rs/src/loader/python/port.rs:104
↓ 2 callers
Function
ports_expand
( prefix: &str, mut item_struct: ItemStruct, fields: Vec<proc_macro2::TokenStream>, names: Vec
flow-derive/src/lib.rs:104
↓ 2 callers
Function
preprocess
(image, input_size, scale_im, mean, std, swap=(2, 0, 1))
flow-python/examples/application/warehouse/reid_alignedreid/process.py:20
↓ 2 callers
Function
registerValidSW
(swUrl, config)
flow-debugger/debugger-ui/src/serviceWorker.js:57
↓ 2 callers
Function
registry_expand
(input: NodeDefine)
flow-derive/src/node.rs:30
↓ 2 callers
Method
revert
(&mut self)
flow-rs/src/resource/lazy.rs:23
↓ 2 callers
Method
run
(&mut self)
flow-rs/src/broker.rs:70
↓ 2 callers
Function
select_ok
https://users.rust-lang.org/t/usage-of-futures-select-ok/46068/10
flow-rs/src/future.rs:15
↓ 2 callers
Function
send
(seq_id, msg, callback=undefined)
flow-debugger/debugger-ui/src/websocket.js:52
↓ 2 callers
Method
send
Sends a envelope into the channel. If the envelope is empty, sends flush event to channel if the number of the empty envelopes received is equal to t
flow-rs/src/channel/sender.rs:110
↓ 2 callers
Method
sender_count
(&self)
flow-rs/src/channel/inner.rs:199
↓ 2 callers
Method
set
(&mut self, key: String, data: data::Data)
flow-message/src/cross/map.rs:44
↓ 2 callers
Method
set_port_dynamic
(&mut self, _: &str, _: crate::node::DynPortsConfig)
flow-rs/src/node/shared.rs:122
↓ 2 callers
Function
splitGraph
(cfg)
flow-debugger/debugger-ui/src/parser.js:365
↓ 2 callers
Function
splitNode
(cfg)
flow-debugger/debugger-ui/src/parser.js:357
↓ 2 callers
Method
start
( mut self: Box<Self>, _: Context, resources: ResourceCollection, )
flow-plugins/src/video_input.rs:55
↓ 2 callers
Method
start_loop
(&mut self, res: ResourceCollection)
flow-rs/src/loader/python/node.rs:113
↓ 2 callers
Method
stop
Stop the graph, it is equivalent to drop all inputs of the graph
flow-rs/src/graph/mod.rs:84
↓ 2 callers
Method
submit
(&self)
flow-rs/src/loader/python/mod.rs:55
↓ 2 callers
Function
substitute_file_by_placeholder
( dir: &str, filename: &str, from: &str, to: &str, )
flow-quickstart/src/lib.rs:34
↓ 2 callers
Function
table
(value: Value)
flow-rs/src/config/table.rs:51
↓ 2 callers
Method
template_file
(mut self, path: P)
flow-rs/src/lib.rs:91
↓ 2 callers
Function
toml2dict
(py: Python<'a>, args: &toml::value::Table)
flow-rs/src/loader/python/node.rs:208
↓ 2 callers
Method
topic
(&self)
flow-rs/src/broker.rs:149
↓ 2 callers
Function
translate_node
( local_key: u64, is_shared: bool, p: presentation::Node, )
flow-rs/src/config/mod.rs:46
↓ 2 callers
Method
try_fetch
(&self)
flow-rs/src/node/port.rs:140
← previous
next →
101–200 of 829, ranked by callers