Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/PersiaML/PERSIA
/ functions
Functions
720 in github.com/PersiaML/PERSIA
⨍
Functions
720
◇
Types & classes
217
↳
Endpoints
1
Function
main
()
rust/persia-embedding-server/src/bin/persia-embedding-worker.rs:40
Method
master_addr
(&self)
rust/persia-core/src/lib.rs:247
Method
minimum_bytes_needed
()
rust/persia-embedding-holder/src/array_linked_list.rs:164
Method
model_manager_status
(&self)
rust/persia-embedding-server/src/embedding_parameter_service/mod.rs:282
Method
monitor_index_batch
(&self, index_batch: &Vec<SingleSignInFeatureBatch>)
rust/persia-embedding-server/src/monitor.rs:98
Method
new
( spec: &PersiaJobSpec, job_name: &str, namespace: &str, kubernetes_client: Cl
k8s/src/lib.rs:20
Method
new
(kubernetes_client: Client)
k8s/src/service.rs:12
Method
new
(client: Client)
k8s/src/bin/operator.rs:45
Method
new
server_addr format should be host:port
rust/others/persia-rpc/src/lib.rs:52
Method
new
()
rust/others/persia-nats-client/src/lib.rs:44
Method
new
(lower: f32, upper: f32)
rust/persia-embedding-config/src/lib.rs:34
Method
new
( job_name: String, instance_name: String, ip_addr: String, push_interval: Dur
rust/persia-metrics/src/lib.rs:70
Method
new
(concurrent_size: usize, replica_index: usize, replica_size: usize)
rust/persia-model-manager/src/lib.rs:101
Method
new
( embedding_holder: PersiaEmbeddingHolder, cur_task: PerisaJobType, num_executors: usi
rust/persia-incremental-update-manager/src/lib.rs:114
Method
new
()
rust/persia-core/src/optim.rs:22
Method
new
(server_addr: &str)
rust/persia-core/src/utils.rs:18
Method
new
( num_coroutines_worker: usize, replica_index: usize, replica_size: usize, dev
rust/persia-core/src/lib.rs:118
Method
new
(master_addr: Option<String>)
rust/persia-core/src/nats.rs:59
Method
new
()
rust/persia-core/src/rpc.rs:20
Method
new
( storage: Storage, shape: Vec<usize>, name: Option<String>, device_id: Option
rust/persia-core/src/tensor.rs:239
Method
new
()
rust/persia-core/src/data.rs:151
Method
new
( backward_ref_id: u64, embedding_worker_addr: &str, embedding_staleness_permit: Optio
rust/persia-core/src/backward.rs:58
Method
new
(world_size: usize, rank_id: usize)
rust/persia-core/src/forward.rs:406
Method
new
(size: usize)
rust/persia-core/src/cuda/pinned_memory_pool.rs:36
Method
new
(_size: usize)
rust/persia-core/src/cuda/cuda_stream_pool.rs:25
Method
new
(size: usize)
rust/persia-core/src/cuda/cuda_memory_pool.rs:38
Method
new
(storage: CPUStorage, shape: Vec<usize>)
rust/persia-core/src/cuda/mod.rs:39
Method
new
()
rust/persia-core/src/cuda/resource_pool.rs:27
Method
new
(_size: usize)
rust/persia-core/src/cuda/cuda_event_pool.rs:39
Method
new
( initialization_method: &InitializationMethod, dim: usize, require_space: usize,
rust/persia-embedding-holder/src/emb_entry.rs:28
Method
new
(prev_index: u32, next_index: u32, data: T)
rust/persia-embedding-holder/src/array_linked_list.rs:104
Method
new
(config: OptimizerConfig)
rust/persia-common/src/optim.rs:49
Method
new
(cap: usize)
rust/persia-common/src/utils.rs:10
Method
new
(feature_name: String, batch: Vec<Vec<u64>>)
rust/persia-common/src/lib.rs:46
Method
new
(server_addr: &str)
rust/persia-common/src/message_queue.rs:34
Method
new
(feature_name: String)
rust/persia-embedding-server/src/monitor.rs:41
Method
new
( embedding: PersiaEmbeddingHolder, server_config: Arc<EmbeddingParameterServerConfig>,
rust/persia-embedding-server/src/embedding_parameter_service/mod.rs:118
Method
new_empty
(dim: usize, require_space: usize, sign: u64)
rust/persia-embedding-holder/src/emb_entry.rs:70
Method
new_initialized
(world_size: Option<usize>)
rust/persia-core/src/nats.rs:156
Method
new_unbounded
()
rust/persia-common/src/utils.rs:15
Method
next_back
(&mut self)
rust/persia-embedding-holder/src/array_linked_list.rs:1023
Function
nn_worker
(filepath: str, nproc_per_node: int, node_rank: int, nnodes: int)
persia/launcher.py:120
Function
on_error
(error: &Error, _context: Context<ContextData>)
k8s/src/bin/operator.rs:119
Function
operator
()
persia/k8s_utils.py:31
Method
opt
(&self)
rust/persia-embedding-holder/src/emb_entry.rs:141
Method
opt_mut
(&mut self)
rust/persia-embedding-holder/src/emb_entry.rs:145
Method
partial_cmp
(&self, other: &Self)
rust/persia-core/src/data.rs:64
Function
persia_core
(py: Python, m: &PyModule)
rust/persia-core/src/lib.rs:462
Method
pod_log
(&self, namespace: &str, pod_name: &str)
k8s/src/service.rs:48
Function
podstatus
(req: web::Json<PodIdentifier>)
k8s/src/bin/server.rs:159
Method
pop_back
Removes the last element from the array and returns it, or `None` if it is empty. This operation should compute in *O*(1) time. # Examples ``` use
rust/persia-embedding-holder/src/array_linked_list.rs:687
Method
postprocess
(self, data)
examples/src/adult-income/serve_handler.py:35
Method
preprocess
(self, data)
examples/src/adult-income/serve_handler.py:21
Function
ptr2vec
(ptr: *mut std::os::raw::c_void, element_num: usize)
rust/persia-core/src/backward.rs:126
Method
push_front
Adds an element at the front of the array and returns its index. The indices are returned in a raising order, starting with zero. See the module descr
rust/persia-embedding-holder/src/array_linked_list.rs:287
Method
read_from
(reader: &mut R)
rust/persia-embedding-holder/src/array_linked_list.rs:143
Method
ready_for_serving
(&self)
rust/persia-embedding-server/src/embedding_parameter_service/mod.rs:264
Function
reconcile
( job: PersiaJob, context: Context<ContextData>, )
k8s/src/bin/operator.rs:56
Method
register_optimizer
(&self, opt: &OptimizerBase)
rust/persia-core/src/nats.rs:386
Method
register_optimizer
( &self, optimizer: OptimizerConfig, )
rust/persia-embedding-server/src/embedding_worker_service/mod.rs:1286
Method
register_optimizer
( &self, optimizer: OptimizerConfig, )
rust/persia-embedding-server/src/embedding_parameter_service/mod.rs:429
Method
remove
(&self)
rust/persia-storage/src/lib.rs:157
Method
replace_back
Adds element at specified index at the front of the list. Useful for updating contents. It basically does the same as `remove` and `push_back`, even
rust/persia-embedding-holder/src/array_linked_list.rs:609
Method
replace_front
Adds element at specified index at the front of the list. Useful for updating contents. It basically does the same as `remove` and `push_back`, even
rust/persia-embedding-holder/src/array_linked_list.rs:551
Method
request_multi
( &self, subject: &str, msg: &[u8], )
rust/others/persia-nats-client/src/lib.rs:81
Method
require_space
(&self, _dim: usize)
rust/persia-common/src/optim.rs:84
Method
send
(&self, content: Vec<u8>)
rust/persia-common/src/message_queue.rs:47
Method
send_data
()
persia/data.py:183
Method
send_id_type_features_to_embedding_worker
( &self, batch: &mut PersiaBatch, )
rust/persia-core/src/nats.rs:250
Method
send_non_id_type_features_to_nn_worker
( &self, batch: &PersiaBatch, )
rust/persia-core/src/nats.rs:314
Function
server
( port: int, )
persia/k8s_utils.py:40
Function
service
(_attr: TokenStream, tokens: TokenStream)
rust/others/persia-nats-marcos/src/lib.rs:216
Function
service
(_attr: TokenStream, tokens: TokenStream)
rust/others/persia-rpc-macro/src/lib.rs:237
Method
set_configures
( file_path: &PathBuf, port: u16, replica_index: usize, replica_size: usize,
rust/persia-embedding-config/src/lib.rs:471
Method
set_embedding
Currently only used for debug
rust/persia-core/src/lib.rs:433
Method
set_embedding
( &self, entries: Vec<HashMapEmbeddingEntry>, )
rust/persia-core/src/rpc.rs:77
Method
set_embedding
( &self, embeddings: Vec<HashMapEmbeddingEntry>, )
rust/persia-embedding-server/src/embedding_parameter_service/mod.rs:287
Function
set_env
Set environment without any sanity check.
persia/env.py:83
Method
shard
(&self, key: &K)
rust/persia-embedding-holder/src/sharded.rs:22
Method
shutdown
(&mut self)
rust/persia-core/src/backward.rs:228
Method
shutdown
(&mut self)
rust/persia-core/src/forward.rs:553
Method
shutdown
(&self, _req: ())
rust/persia-embedding-server/src/embedding_parameter_service/mod.rs:573
Method
shutdown_servers
(&self)
rust/persia-core/src/lib.rs:335
Method
size
(&self)
rust/persia-core/src/cuda/pinned_memory_pool.rs:47
Method
size
(&self)
rust/persia-core/src/cuda/cuda_stream_pool.rs:37
Method
size
(&self)
rust/persia-core/src/cuda/cuda_memory_pool.rs:50
Function
skip_methods
(app, what, name, obj, skip, options)
docs/conf.py:135
Method
spawn_reorder_worker
( world_size: usize, rank_id: usize, channel_r: flume::Receiver<PersiaBatchImpl>,
rust/persia-core/src/forward.rs:415
Method
state_initialization
(&self, _state: &mut [f32], _dim: usize)
rust/persia-common/src/optim.rs:91
Method
subscribe
(&self, subject: &str)
rust/others/persia-nats-client/src/lib.rs:65
Function
test_adagrad
()
rust/persia-common/src/optim.rs:363
Function
test_adagrad_vectorwise_shared
()
rust/persia-common/src/optim.rs:411
Function
test_data_ctx
(use_cuda: bool)
test/test_ctx.py:68
Function
test_data_loader_env
()
test/test_env.py:27
Function
test_evict
()
rust/persia-embedding-holder/src/eviction_map.rs:121
Function
test_get_embedding_worker_services
()
test/test_service.py:6
Function
test_id_type_feature
()
test/embedding/test_data.py:33
Function
test_indices_add_prefix
()
rust/persia-embedding-server/src/embedding_worker_service/mod.rs:1616
Function
test_indices_to_hashstack_indices
()
rust/persia-embedding-server/src/embedding_worker_service/mod.rs:1571
Function
test_ndarray_base_data
()
test/embedding/test_data.py:21
← previous
next →
601–700 of 720, ranked by callers