Functions — github.com/datenlord/datenlord

hub / github.com/datenlord/datenlord / functions

Functions1,395 in github.com/datenlord/datenlord

⨍ Functions 1,395◇ Types & classes 335

↓ 128 callersMethodwith_context

(self, context_func: F)

src/common/error.rs:300

↓ 102 callersMethodload

Load data from storage.

src/storage/storage_manager/manager.rs:158

↓ 73 callersMethodadd_context

(self, ctx: C)

src/common/error.rs:292

↓ 71 callersMethodlen

(&self)

src/new_storage/memory_cache.rs:177

↓ 52 callersMethodget

(&self)

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

↓ 50 callersMethodnodeid

(&self)

src/async_fuse/fuse/fuse_request.rs:766

↓ 48 callersMethodlock

(&self, name: &[u8], timeout_sec: u64)

src/common/etcd_delegate.rs:68

↓ 48 callersMethodoperation

(&self)

src/async_fuse/fuse/fuse_request.rs:813

↓ 46 callersFunctioncheck_header

(req: &Request<'_>)

src/async_fuse/fuse/fuse_request.rs:919

↓ 45 callersMethodis_empty

(&self)

src/async_fuse/fuse/fuse_request.rs:806

↓ 45 callersMethodsend

Send response to FUSE kernel

src/async_fuse/fuse/fuse_reply.rs:211

↓ 40 callersMethodstart_storage_operation_timer

Starts a timer to measure the FUSE operations' duration.

src/metrics/file_system.rs:57

↓ 38 callersMethodfetch_ref

Fetch some bytes and transmute to `&T`

src/async_fuse/fuse/de.rs:132

↓ 37 callersMethodstore

(&self, ino: INum, block_id: usize, input: Block)

src/storage/memory_cache/cache.rs:292

↓ 36 callersMethodas_ref

(&self)

src/new_storage/block.rs:51

↓ 36 callersMethodunique

(&self)

src/async_fuse/fuse/fuse_request.rs:759

↓ 35 callersMethodspawn

(&self, f: F)

src/common/task_manager/gc.rs:62

↓ 33 callersFunctionusize_to_u64

(x: usize)

src/async_fuse/util.rs:143

↓ 31 callersMethodinsert

(&mut self, kv_cache_meta: KVCacheMeta<K>, data: &[u8])

src/distribute_kv_cache/kvclient.rs:125

↓ 30 callersMethodstore

(&self, ino: INum, block_id: usize, block: Block)

src/storage/backend/backend_impl.rs:191

↓ 30 callersMethodstore

Store data into storage.

src/storage/storage_manager/manager.rs:215

↓ 29 callersMethodget

Get a block from the cache

src/distribute_kv_cache/server_cache/manager.rs:74

↓ 29 callersMethodgid

(&self)

src/async_fuse/fuse/fuse_request.rs:782

↓ 29 callersMethodok

Reply with empty OK response

src/async_fuse/fuse/fuse_reply.rs:394

↓ 29 callersMethoduid

(&self)

src/async_fuse/fuse/fuse_request.rs:774

↓ 28 callersFunctionspawn_grpc_task

Spawn a task to execute async task and send `gRPC` response

src/csi/util.rs:189

↓ 23 callersMethodwrite

( &self, buf: &[u8], slices: &[BlockSlice], size: u64, version: u64,

src/new_storage/storage_manager/handle.rs:270

↓ 22 callersMethodbuild

Builds a `MemoryCache`.

src/storage/memory_cache/builder.rs:94

↓ 22 callersFunctionwrite

Writes up to `count` bytes from the `buffer` to the file descriptor `fd` at `offset` (from the start of the file). The file offset is not changed. `f

src/async_fuse/proactor/v0.rs:98

↓ 20 callersMethodlen

(&self)

src/async_fuse/fuse/fuse_request.rs:798

↓ 20 callersMethodset

Set the value by the key.

src/fs/kv_engine/etcd_impl.rs:474

↓ 19 callersFunctionbuild_error_result_from_errno

Build error result from `nix` error code # Errors Return the built `Err(anyhow::Error(..))`

src/fs/fs_util.rs:21

↓ 18 callersMethodas_str

(&self)

src/common/logger.rs:50

↓ 18 callersFunctionopen

()

src/async_fuse/fuse/fuse_request.rs:1286

↓ 18 callersMethodread

Reads data from the file starting at the given offset and up to the given length.

src/new_storage/storage_manager/handle.rs:233

↓ 16 callersMethodfetch_str

Fetch some nul-terminated bytes and return an `str` without the nul byte.

src/async_fuse/fuse/de.rs:209

↓ 15 callersMethodaccess

(&self, key: &K)

src/new_storage/policy/lru.rs:33

↓ 15 callersMethodentry

Reply to a request with the given entry

src/async_fuse/fuse/fuse_reply.rs:425

↓ 15 callersMethodlen

(&self)

src/storage/block.rs:255

↓ 15 callersFunctionprepare_backend

Prepare a backend

src/storage/backend/test/mod.rs:15

↓ 15 callersMethodset_dirty

Sets the block to be dirty.

src/storage/block.rs:239

↓ 14 callersMethodget_volume_by_id

Get volume by ID

src/csi/meta_data.rs:617

↓ 14 callersFunctionprepare_empty_storage

()

src/storage/memory_cache/tests.rs:20

↓ 14 callersFunctionu64_to_usize

(x: u64)

src/distribute_kv_cache/rpc/utils.rs:110

↓ 13 callersMethodaccess

(&self, key: &K)

src/distribute_kv_cache/server_cache/policy.rs:55

↓ 13 callersMethodas_slice

(&self)

src/storage/block.rs:180

↓ 13 callersMethodget_attr

(&self)

src/fs/datenlordfs/s3_node.rs:274

↓ 13 callersMethodget_node_id

Get the node ID

src/csi/meta_data.rs:330

↓ 13 callersMethodinsert

Insert a new key-value pair into the index

src/distribute_kv_cache/server_cache/manager.rs:371

↓ 13 callersMethodopen

Increase the open count of the file handle.

src/new_storage/storage_manager/handle.rs:357

↓ 13 callersMethodremove

(&self, ino: INum)

src/storage/memory_cache/cache.rs:347

↓ 12 callersFunctioncreate_storage

()

src/storage/storage_manager/test/common.rs:17

↓ 12 callersMethodset_name

(&mut self, name: &str)

src/fs/datenlordfs/s3_node.rs:259

↓ 11 callersMethodclose

Try to close session

src/fs/kv_engine/etcd_impl.rs:105

↓ 11 callersMethodget

Get the value by the key.

src/fs/kv_engine/etcd_impl.rs:456

↓ 11 callersFunctionget_u64_from_buf

Try to get u64 data from buffer with range

src/distribute_kv_cache/rpc/utils.rs:94

↓ 11 callersMethodlayer

(&self, inner: A)

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

↓ 11 callersMethodwrite

(&self)

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

↓ 10 callersFunctioncleanup

(backend_root: impl AsRef<Path>)

src/storage/backend/test/pessimistic.rs:10

↓ 10 callersMethodcontains

Tests if the storage contains the block of `(ino, block_id)`

src/storage/mock.rs:47

↓ 10 callersFunctionformat_path

(ino: u64, block_id: u64)

src/new_storage/utils.rs:8

↓ 10 callersMethodget_node_from_kv_engine

Get a node from kv engine by inum

src/fs/datenlordfs/s3_metadata.rs:741

↓ 10 callersMethodlen

(&self)

src/new_storage/storage_manager/manager.rs:221

↓ 10 callersMethodnext

(&mut self)

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

↓ 10 callersMethodset_evictable

(&self, key: &K, evictable: bool)

src/new_storage/policy/lru.rs:70

↓ 10 callersMethodset_evictable

(&self, key: &K, evictable: bool)

src/distribute_kv_cache/server_cache/policy.rs:91

↓ 10 callersMethodstore

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

src/distribute_kv_cache/server_cache/backend.rs:80

↓ 10 callersMethodto_string_key

(&self)

src/fs/kv_engine/key_type.rs:91

↓ 9 callersMethodcapacity

(&self)

src/distribute_kv_cache/cluster/ring.rs:195

↓ 9 callersMethodclose

(&self, ino: u64)

src/new_storage/storage_manager/manager.rs:132

↓ 9 callersFunctioncreate_node

Helper function to create a new node with a given IP address

src/distribute_kv_cache/cluster/cluster_manager.rs:991

↓ 9 callersFunctioncreate_volume

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

src/csi/mod.rs:574

↓ 9 callersMethoddelete

Delete the kv pair by the key.

src/fs/kv_engine/etcd_impl.rs:518

↓ 9 callersFunctiondelete_volume

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

src/csi/mod.rs:582

↓ 9 callersMethodget_name

(&self)

src/fs/datenlordfs/s3_node.rs:253

↓ 9 callersFunctionread

Reads up to `count` bytes from file descriptor `fd` at `offset` (from the start of the file) into the `buffer`. The file offset is not changed. `fd`

src/async_fuse/proactor/v0.rs:40

↓ 9 callersMethodremove

(&mut self, key: &K)

src/new_storage/memory_cache.rs:201

↓ 9 callersMethodstore

(&self, ino: INum, block_id: usize, block: Block)

src/storage/mock.rs:81

↓ 9 callersFunctiontest_task

Create a future, that waits for a signal from `token`, then sends a `value` via `tx`.

src/common/task_manager/tests.rs:42

↓ 9 callersMethodversion

(&self)

src/new_storage/block.rs:84

↓ 8 callersMethodclear

Clears the block data and resets metadata. This method marks the block as not dirty, resets the pin count to zero, and resets the version to zero.

src/new_storage/block.rs:135

↓ 8 callersMethodencode

(&self, buf: &mut BytesMut)

src/distribute_kv_cache/rpc/packet.rs:76

↓ 8 callersMethodflush

(&self, ino: INum)

src/storage/memory_cache/cache.rs:373

↓ 8 callersMethodget_current_node_local

(&self)

src/distribute_kv_cache/cluster/cluster_manager.rs:40

↓ 8 callersMethodget_ino

(&self)

src/fs/datenlordfs/s3_node.rs:223

↓ 8 callersMethodnew_block

(&mut self, key: &K, data: &[u8], version: u64)

src/new_storage/memory_cache.rs:96

↓ 8 callersFunctionnot_implement_helper

Replies ENOSYS

src/async_fuse/fuse/session.rs:874

↓ 8 callersMethodparse

( n: u32, data: &mut Deserializer<'a>, #[allow(unused_variables)] proto_version: Proto

src/async_fuse/fuse/fuse_request.rs:297

↓ 8 callersMethodsend_request

Send a request to the server. Try to send data to channel, if the channel is full, return an error. Contains the rezquest header and body. WARN: this

src/distribute_kv_cache/rpc/client.rs:435

↓ 8 callersMethodtruncate

( &self, ino: INum, from_block: usize, to_block: usize, fill_start: us

src/storage/memory_cache/cache.rs:457

↓ 8 callersMethodtruncate

( &self, ino: INum, from_block: usize, to_block: usize, fill_start: us

src/storage/backend/backend_impl.rs:300

↓ 8 callersMethodwrite_new_kv

( &self, key: &str, value: &T, )

src/common/etcd_delegate.rs:417

↓ 7 callersMethodadd

Add a node to a slot We will create a new slot and update slot mapping, then add to the ring If must is true, the ring need to be rebalanced or expand

src/distribute_kv_cache/cluster/ring.rs:231

↓ 7 callersMethodadd_task

Add a task to the packets

src/distribute_kv_cache/rpc/packet.rs:186

↓ 7 callersMethodcancel

(mut self)

src/fs/kv_engine/etcd_impl.rs:277

↓ 7 callersMethoddelete_exact_one_value

( &self, key: &str, )

src/common/etcd_delegate.rs:583

↓ 7 callersMethodendpoint

(&self)

src/distribute_kv_cache/cluster/node.rs:47

↓ 7 callersMethodextend

(&self, old_size: u64, new_size: u64, version: u64)

src/new_storage/storage_manager/handle.rs:346

↓ 7 callersMethodget_at_most_one_value

( &self, key: K, )

src/common/etcd_delegate.rs:352

↓ 7 callersMethodget_handle

Get a file handle with `ino`. # Panic Panics if the file of `ino` is not open.

src/new_storage/storage_manager/manager.rs:229

next →1–100 of 1,395, ranked by callers