Functions — github.com/datenlord/datenlord

hub / github.com/datenlord/datenlord / functions

Functions1,395 in github.com/datenlord/datenlord

⨍ Functions 1,395◇ Types & classes 335

↓ 7 callersMethodget_size

Get volume size

src/csi/meta_data.rs:1679

↓ 7 callersMethodget_volume_path

Get volume absolute path by ID

src/csi/meta_data.rs:318

↓ 7 callersMethodis_empty

(&self)

src/distribute_kv_cache/cluster/ring.rs:213

↓ 7 callersMethodlisten

Start the RPC server.

src/distribute_kv_cache/rpc/server.rs:434

↓ 7 callersMethodoffset_to_block_id

Convert offset in byte to block id via the equation: `block_id = offset / block_size`

src/storage/storage_manager/manager.rs:42

↓ 7 callersMethodread

(&self)

src/storage/backend/test/mock.rs:159

↓ 7 callersMethodremove

Remove a block from the cache

src/distribute_kv_cache/server_cache/manager.rs:85

↓ 7 callersMethodremove_all

(&self, dir: &str)

src/new_storage/backend/backend_impl.rs:160

↓ 7 callersMethodset_start

Sets the start offset of valid bytes of the inner block

src/storage/block.rs:169

↓ 7 callersMethodstart

(&self)

src/storage/block.rs:158

↓ 7 callersMethodstart_kv_operation_timer

Starts a timer to measure KV operation latency.

src/metrics/kv.rs:56

↓ 7 callersMethodsubmit_job

Submit a job to the worker pool synchronously, and block until the job is completed. Other process will be blocked until the job is completed. If all

src/distribute_kv_cache/rpc/workerpool.rs:68

↓ 7 callersMethodtruncate

Truncate a file, from size of `from` to size of `to`. Both `from` and `to` are in bytes, and are excluded from the range. After the truncating, the va

src/storage/storage_manager/manager.rs:296

↓ 7 callersMethodtry_put

Attempt to insert `key` into the policy. If the policy is full and does not contain the `key`, return false. If the `key` is inserted successfully or

src/storage/policy/lru.rs:48

↓ 6 callersFunctionarc_atom_true

()

src/storage/backend/test/mock.rs:16

↓ 6 callersMethodattr

Reply to a request with the given attribute

src/async_fuse/fuse/fuse_reply.rs:449

↓ 6 callersFunctionconvert_to_fuse_attr

(attr: FileAttr)

src/fs/fs_util.rs:449

↓ 6 callersMethodencode_large_data

Encode the file block response into a byte buffer.

src/distribute_kv_cache/rpc/message.rs:103

↓ 6 callersMethodend

(&self)

src/storage/block.rs:164

↓ 6 callersMethodget_client

Get a client from the cache manager

src/distribute_kv_cache/kvclient.rs:902

↓ 6 callersMethodget_snapshot_by_id

Get snapshot by ID

src/csi/meta_data.rs:377

↓ 6 callersFunctioninit_logger

(role: LogRole, level: Level)

src/common/logger.rs:69

↓ 6 callersMethodinto_bytes

Convert an item into raw bytes in the specified `endian`.

macro-utils/src/generator.rs:73

↓ 6 callersMethodis_closed

(&self)

src/fs/kv_engine/etcd_impl.rs:100

↓ 6 callersMethodlen

(&self)

src/async_fuse/fuse/fuse_reply.rs:50

↓ 6 callersMethodlock

Distribute lock - lock - `timeout_sec` should be >=1s - `timeout_sec` should be >=1s

src/fs/kv_engine/etcd_impl.rs:421

↓ 6 callersMethodmake_mut_slice

Gets a mutable slice of the the valid range, copy them if there are other blocks hold the same data via `Arc`. See also [`Arc::make_mut`](fn@ `std::sy

src/storage/block.rs:192

↓ 6 callersMethodnode_publish_volume

( &mut self, _ctx: RpcContext, req: NodePublishVolumeRequest, sink: UnarySink<

src/csi/node.rs:237

↓ 6 callersMethodremove

Remove a slot If must is true, the ring need to be rebalanced

src/distribute_kv_cache/cluster/ring.rs:373

↓ 6 callersFunctionrename

()

src/async_fuse/fuse/fuse_request.rs:1229

↓ 6 callersFunctionsetup_mock_server

Helper function to setup a mock server

src/distribute_kv_cache/rpc/client.rs:543

↓ 6 callersMethodstatus

(&self)

src/distribute_kv_cache/cluster/node.rs:157

↓ 6 callersFunctionumount

(short_path: &Path)

src/async_fuse/fuse/mount.rs:17

↓ 6 callersMethodupdate

Updates `self` with another block. Contents in `self` that overlaps with the `other` range will be overwritten, if the range of `other` is out of ran

src/storage/block.rs:210

↓ 6 callersMethodvalidate_request_capability

Validate request with controller capabilities

src/csi/controller.rs:84

↓ 6 callersMethodversion

(&self)

src/distribute_kv_cache/cluster/ring.rs:201

↓ 6 callersMethodwrite

(&mut self, block: &Block)

src/distribute_kv_cache/server_cache/manager.rs:204

↓ 5 callersMethodcheck_perm

File permissions in Unix/Linux systems are represented as a 12-bit structure, laid out as follows: ┌───────────────┬─────────┬─────────┬─────────┐ │

src/fs/fs_util.rs:325

↓ 5 callersMethodcmp

(&self, other: &Self)

src/distribute_kv_cache/cluster/ring.rs:93

↓ 5 callersFunctioncreate_a_file

(storage: Arc<StorageManager<S3MetaData>>, ino: u64)

src/new_storage/storage_manager/tests.rs:126

↓ 5 callersMethodcreate_session

Create a lease with keepalive

src/fs/kv_engine/etcd_impl.rs:405

↓ 5 callersFunctioncreate_snapshot

( client: &ControllerClient, req: &CreateSnapshotRequest, )

src/csi/mod.rs:590

↓ 5 callersMethoddata

Reply with byte data response

src/async_fuse/fuse/fuse_reply.rs:408

↓ 5 callersFunctiondecode_from_bytes

(bytes: &[u8])

src/common/util.rs:10

↓ 5 callersMethodfetch_all_bytes

Fetch all remaining bytes

src/async_fuse/fuse/de.rs:116

↓ 5 callersMethodget_file_cache

Get the file-level cache `HashMap`.

src/storage/memory_cache/cache.rs:91

↓ 5 callersMethodget_master_node

Get master node

src/distribute_kv_cache/cluster/cluster_manager.rs:45

↓ 5 callersMethodget_node_by_id

Get node by ID

src/csi/meta_data.rs:359

↓ 5 callersMethodget_ring

Get current hashring

src/distribute_kv_cache/cluster/cluster_manager.rs:50

↓ 5 callersMethodinit

Reply init response

src/async_fuse/fuse/fuse_reply.rs:380

↓ 5 callersMethodnew_meta_txn

(&self)

src/fs/kv_engine/etcd_impl.rs:400

↓ 5 callersMethodnode_unpublish_volume

( &mut self, _ctx: RpcContext, req: NodeUnpublishVolumeRequest, sink: UnarySin

src/csi/node.rs:364

↓ 5 callersFunctionoffset_to_slice

(block_size: u64, offset: u64, len: u64)

src/new_storage/block_slice.rs:49

↓ 5 callersFunctionprepare_empty_storage_with_write_back

()

src/storage/memory_cache/tests.rs:354

↓ 5 callersMethodread

(&self, meta_data: MetaData)

src/distribute_kv_cache/server_cache/manager.rs:133

↓ 5 callersMethodrebalance

Rebalance the ring Try to rebalance the ring

src/distribute_kv_cache/cluster/ring.rs:504

↓ 5 callersMethodrun

Run the cluster manager as state machine We need to perpare current node info, current node list and generate hash ring info

src/distribute_kv_cache/cluster/cluster_manager.rs:92

↓ 5 callersMethodseq

(&self)

src/distribute_kv_cache/rpc/packet.rs:398

↓ 5 callersMethodset_end

Sets the end offset of valid bytes of the inner block

src/storage/block.rs:174

↓ 5 callersMethodunpin

(&mut self, key: &K)

src/new_storage/memory_cache.rs:144

↓ 5 callersMethodwatch

Watch the key, return a receiver to receive the value

src/fs/kv_engine/etcd_impl.rs:559

↓ 4 callersMethodadd

Add an entry to the directory reply buffer. Returns true if the buffer is full. A transparent offset value can be provided for each entry. The kernel

src/async_fuse/fuse/fuse_reply.rs:626

↓ 4 callersMethodbackend

Get the `backend`.

src/storage/memory_cache/cache.rs:81

↓ 4 callersMethodbatch_add

Add a batch of slots If must is true, the ring need to be rebalanced or expanded

src/distribute_kv_cache/cluster/ring.rs:342

↓ 4 callersMethodbuild_response

Build response

src/distribute_kv_cache/manager.rs:566

↓ 4 callersMethodcampaign

Try to campaign the master with simple txn Old(reference to etcd client v3): Create a key with prefix, and compare key (sorted by revision) with the k

src/fs/kv_engine/etcd_impl.rs:661

↓ 4 callersFunctioncheck_name_length

Check the name length is valid or not

src/fs/datenlordfs/mod.rs:52

↓ 4 callersMethodclear

Drops the value in the [`SmallBox`]. After calling [`SmallBox::clear`], the [`SmallBox`] is empty.

src/async_fuse/proactor/small_box.rs:43

↓ 4 callersFunctionconv_u64_sec_2_i64

Convert u64 seceond to i64

src/common/etcd_delegate.rs:25

↓ 4 callersFunctioncreate

()

src/async_fuse/fuse/fuse_request.rs:2017

↓ 4 callersFunctioncreate_lru

Create a `LruPolicy` of `i32`, with keys `1 -> 2 -> 3`.

src/new_storage/policy/lru.rs:106

↓ 4 callersFunctioncreate_lru

Create a `LruPolicy` of `i32`, with keys `1 -> 2 -> 3`.

src/distribute_kv_cache/server_cache/policy.rs:132

↓ 4 callersFunctioncreate_lru

Create a `LruPolicy` of `i32`, with keys `1 -> 2 -> 3`.

src/storage/policy/lru.rs:77

↓ 4 callersFunctioncreate_reader

( storage: Arc<StorageManager<S>>, write_pointer: Arc<AtomicUsize>, mtime: Arc<AtomicCell<SystemTi

src/storage/storage_manager/test/concurrency.rs:44

↓ 4 callersFunctiondelete_snapshot

( client: &ControllerClient, req: &DeleteSnapshotRequest, )

src/csi/mod.rs:606

↓ 4 callersMethoddelete_volume_meta_data

Delete node id from the volume meta data. If the node id is the last one then delete the whole meta data. Delete volume meta data from etcd

src/csi/meta_data.rs:823

↓ 4 callersMethodencode

(&self, buf: &mut BytesMut)

src/distribute_kv_cache/rpc/client.rs:476

↓ 4 callersMethodevict

Remove and return the least recently used item.

src/storage/policy/lru.rs:37

↓ 4 callersMethodfetch

(&self, key: &K, version: u64)

src/new_storage/memory_cache.rs:159

↓ 4 callersFunctionforget

()

src/async_fuse/fuse/fuse_request.rs:958

↓ 4 callersFunctionget_block_path

Get block path by `ino` and `block_id`

src/storage/backend/backend_impl.rs:32

↓ 4 callersMethodget_gc_handle

(&self, name: TaskName)

src/common/task_manager/manager.rs:142

↓ 4 callersMethodget_list

(&self, prefix: &str)

src/common/etcd_delegate.rs:316

↓ 4 callersMethodget_slot

Get the slot of a given key

src/distribute_kv_cache/cluster/ring.rs:474

↓ 4 callersMethodget_volume_bind_mount_path

Get volume bind mount path from etcd

src/csi/meta_data.rs:1130

↓ 4 callersMethodinto_dir_entry

(self)

src/fs/kv_engine/value_type.rs:83

↓ 4 callersMethodinvalidate

(&self, ino: INum)

src/storage/memory_cache/cache.rs:366

↓ 4 callersFunctionlist_volumes

( client: &ControllerClient, req: &ListVolumesRequest, )

src/csi/mod.rs:598

↓ 4 callersMethodnext_seq

Get the next sequence number.

src/distribute_kv_cache/rpc/client.rs:181

↓ 4 callersMethodobserve_storage_operation_throughput

Observes a value of the retry counts of KV transaction.

src/metrics/file_system.rs:64

↓ 4 callersMethodopened

Reply to a request with the given open result

src/async_fuse/fuse/fuse_reply.rs:470

↓ 4 callersFunctionparse_oflag

Parse `OFlag`

src/fs/fs_util.rs:396

↓ 4 callersMethodpin

Increments the pin count of the block.

src/new_storage/block.rs:116

↓ 4 callersMethodprepare

Prepare for the session and other data

src/distribute_kv_cache/cluster/cluster_manager.rs:295

↓ 4 callersFunctionprepare_cache

(capacity: usize)

src/new_storage/memory_cache.rs:237

↓ 4 callersMethodrange

Range get, return all key-value pairs start with prefix

src/fs/kv_engine/etcd_impl.rs:552

↓ 4 callersMethodread

(&self, path: &str, buf: &mut [u8], _version: u64)

src/new_storage/backend/backend_impl.rs:116

↓ 4 callersMethodremove

(&self, ino: INum)

src/storage/mock.rs:93

↓ 4 callersMethodremove

(&self)

src/storage/backend/test/mock.rs:32

↓ 4 callersMethodreset

Resets the [`State`]

src/async_fuse/proactor/global.rs:130

← previous next →101–200 of 1,395, ranked by callers