Functions — github.com/datenlord/datenlord

hub / github.com/datenlord/datenlord / functions

Functions1,395 in github.com/datenlord/datenlord

⨍ Functions 1,395◇ Types & classes 335

↓ 4 callersMethodrun

for `tokio::select!`

src/common/task_manager/gc.rs:112

↓ 4 callersFunctionrun_grpc_servers

Raised by `tokio::select`

src/csi/mod.rs:154

↓ 4 callersMethodset_result

(self, status: Result<(), RpcError>)

src/distribute_kv_cache/rpc/packet.rs:430

↓ 4 callersMethodshutdown

(&self)

src/common/task_manager/manager.rs:181

↓ 4 callersMethodsleep

If `self.latency` is not zero, sleep for the time of it.

src/storage/mock.rs:40

↓ 4 callersMethodtruncate

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

src/new_storage/storage_manager/manager.rs:139

↓ 4 callersMethodtruncate

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

src/storage/mock.rs:114

↓ 4 callersFunctionu32_to_usize

(x: u32)

src/async_fuse/util.rs:126

↓ 4 callersFunctionunlink

()

src/async_fuse/fuse/fuse_request.rs:1179

↓ 4 callersMethodunlock

Distribute lock - unlock

src/fs/kv_engine/etcd_impl.rs:445

↓ 4 callersMethodupdate_existing_kv

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

src/common/etcd_delegate.rs:396

↓ 4 callersMethodupdate_mtime_ctime_to_now

Update mtime and ctime to now

src/fs/datenlordfs/s3_node.rs:148

↓ 4 callersMethodwrite_block_into_cache

Write a block into the cache without writing through. A block may be evicted to the backend.

src/storage/memory_cache/cache.rs:207

↓ 4 callersMethodwrite_to_etcd

Write a key value pair to etcd - `expire`: auto delete after expire

src/common/etcd_delegate.rs:189

↓ 3 callersMethodadd_volume_meta_data

Add new volume meta data

src/csi/meta_data.rs:791

↓ 3 callersMethodbatch_remove

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

src/distribute_kv_cache/cluster/ring.rs:443

↓ 3 callersFunctionbuild_meta_data

Build meta data

src/csi/mod.rs:32

↓ 3 callersMethodcache_hit_count_inc

Increase the hit count with `name`.

src/metrics/cache.rs:52

↓ 3 callersMethodcache_miss_count_inc

Increase the miss count with `name`.

src/metrics/cache.rs:57

↓ 3 callersFunctioncheck_data

(data: &[u8], user_index: u64)

src/new_storage/storage_manager/tests.rs:72

↓ 3 callersFunctioncheck_name_length

Check the name length is valid or not

src/async_fuse/memfs/mod.rs:144

↓ 3 callersFunctionclean_up_etcd

()

src/distribute_kv_cache/cluster/cluster_manager.rs:998

↓ 3 callersMethodclose

(&self)

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

↓ 3 callersMethodcommit

(&mut self)

src/fs/kv_engine/etcd_impl.rs:768

↓ 3 callersFunctioncreate_storage_with_latency

(write_through: bool)

src/storage/storage_manager/test/latency.rs:24

↓ 3 callersMethoddisable_read

(&self)

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

↓ 3 callersMethoddisable_write

(&self)

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

↓ 3 callersMethodevict

(&self)

src/distribute_kv_cache/server_cache/policy.rs:75

↓ 3 callersFunctionfile_attr_to_serial

(attr: &FileAttr)

src/fs/datenlordfs/serial.rs:122

↓ 3 callersMethodflush

(&self)

src/new_storage/storage_manager/handle.rs:328

↓ 3 callersFunctiongenerate_proto_timestamp

Convert `SystemTime` to proto timestamp

src/csi/util.rs:73

↓ 3 callersMethodget_access_mode

(&self, uid: u32, gid: u32)

src/fs/fs_util.rs:362

↓ 3 callersMethodget_block_from_cache

Get a block from the in-memory cache without fetch it from backend. Notice that this method will also not change the position of the block in the pol

src/storage/memory_cache/cache.rs:100

↓ 3 callersFunctionget_lease_id_from_key

Utils function to get the lease id from etcd by key

src/fs/kv_engine/etcd_impl.rs:1089

↓ 3 callersMethodget_meta_data

Get the block meta data of the Block

src/distribute_kv_cache/server_cache/block.rs:127

↓ 3 callersMethodget_shard

Gets a shard of the ino.

src/new_storage/storage_manager/handle.rs:694

↓ 3 callersMethodget_stream_mut

(&self)

src/distribute_kv_cache/rpc/server.rs:198

↓ 3 callersMethodget_volume_by_name

Get volume by name

src/csi/meta_data.rs:638

↓ 3 callersMethodgetattr

Get file attributes.

src/fs/datenlordfs/mod.rs:142

↓ 3 callersMethodinto_inner

Gets the wrapped [`RawFd`]. The raw fd is not closed.

src/async_fuse/proactor/v0.rs:25

↓ 3 callersMethodinto_s3_node

Allow wildcard because there should be only one enum branch matches one specific type. Turn the `ValueType` into `SerialNode` then into `S3Node`. # Pa

src/fs/kv_engine/value_type.rs:33

↓ 3 callersMethodis_empty

(&self)

src/storage/block.rs:259

↓ 3 callersMethodis_ephemeral

Is volume data ephemeral or not

src/csi/meta_data.rs:349

↓ 3 callersFunctionlist_snapshots

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

src/csi/mod.rs:614

↓ 3 callersFunctionmake_gc_task

()

src/common/task_manager/gc.rs:183

↓ 3 callersMethodopen

Open a file. Open flags (with the exception of `O_CREAT`, `O_EXCL`, `O_NOCTTY` and `O_TRUNC`) are available in flags. Filesystem may store an arbitrar

src/async_fuse/memfs/mod.rs:286

↓ 3 callersFunctionparse_metadata

Parse config from command line arguments, and return the created `MetaData`

src/main.rs:99

↓ 3 callersMethodping

Send keep alive message to the server

src/distribute_kv_cache/rpc/client.rs:186

↓ 3 callersMethodpop_bytes_unchecked

pop some bytes without length check

src/async_fuse/fuse/de.rs:104

↓ 3 callersFunctionprepare_data_for_evict

Prepare a backend and cache for test eviction. The backend does not contain any block. The cache contains block `[0, 4)` for file `ino=0`. All the bl

src/storage/memory_cache/tests.rs:124

↓ 3 callersMethodput

Insert a block into the cache

src/distribute_kv_cache/server_cache/manager.rs:46

↓ 3 callersMethodput

Puts a value into the [`SmallBox`]. The previous value in it will be dropped.

src/async_fuse/proactor/small_box.rs:50

↓ 3 callersMethodput_unchecked

(&mut self, value: T)

src/async_fuse/proactor/small_box.rs:62

↓ 3 callersMethodread

Read data. Read should send exactly the number of bytes requested except on EOF or error, otherwise the rest of the data will be substituted with zero

src/async_fuse/fuse/file_system.rs:711

↓ 3 callersMethodread

( &self, req: &Request<'_>, _fh: u64, offset: i64, size: u32,

src/async_fuse/memfs/mod.rs:534

↓ 3 callersMethodread

Read data. Read should send exactly the number of bytes requested except on EOF or error, otherwise the rest of the data will be substituted with zero

src/fs/datenlordfs/mod.rs:465

↓ 3 callersMethodrecv_len

Receive request body from the server.

src/distribute_kv_cache/rpc/client.rs:119

↓ 3 callersMethodregister_to_etcd

src/csi/meta_data.rs:144

↓ 3 callersMethodremove

(&self, ino: u64)

src/new_storage/storage_manager/manager.rs:188

↓ 3 callersMethodremove

Remove a file from the storage.

src/storage/storage_manager/manager.rs:262

↓ 3 callersFunctionremove_socket_file

Remove existing socket file before run CSI `gRPC` server

src/csi/mod.rs:136

↓ 3 callersFunctionrun_test_server

()

src/csi/mod.rs:420

↓ 3 callersMethodsend_block_to_write_back_task

Send a block to the write back task, and it will be stored to the backend later.

src/storage/memory_cache/cache.rs:112

↓ 3 callersMethodsend_data

Send a request to the server. We need to make sure Current send packet need to be in one task, so if we need to send ping and packet we need to make s

src/distribute_kv_cache/rpc/client.rs:150

↓ 3 callersMethodsend_raw_message

( self, error: i32, data: impl AsIoSliceList + Send + Sync + 'static, )

src/async_fuse/fuse/fuse_reply.rs:176

↓ 3 callersMethodset_attr

Set node attribute

src/fs/datenlordfs/s3_node.rs:279

↓ 3 callersMethodset_dirty

Sets the dirty flag of the block.

src/new_storage/block.rs:111

↓ 3 callersMethodset_status

Change the status of the node We export this function to change the status of the node, The state machine is managed by the cluster manager

src/distribute_kv_cache/cluster/node.rs:164

↓ 3 callersMethodsetattr

Set file attributes.

src/fs/datenlordfs/mod.rs:182

↓ 3 callersMethodstart_recv

Start client receiver

src/distribute_kv_cache/rpc/client.rs:423

↓ 3 callersMethodstop

Stop the RPC server.

src/distribute_kv_cache/rpc/server.rs:478

↓ 3 callersFunctionstr2flags

tests/fstest_dir/fstest.c:225

↓ 3 callersMethodtake_task

Get a task from the packets, and update data in the task

src/distribute_kv_cache/rpc/packet.rs:314

↓ 3 callersFunctiontest_backend

(backend: impl Backend)

src/new_storage/backend/mod.rs:30

↓ 3 callersFunctiontime_from_system_time

(system_time: &SystemTime)

src/fs/fs_util.rs:430

↓ 3 callersFunctiontmp_fs_backend

Creates a new `BackendImpl` instance with a temporary file system backend.

src/new_storage/backend/backend_impl.rs:173

↓ 3 callersMethodto_id

(&self)

src/distribute_kv_cache/server_cache/block.rs:77

↓ 3 callersMethodtouch

Update the position of the given key to mark it as recently used.

src/storage/policy/lru.rs:32

↓ 3 callersMethodtry_load

We have checked the index is valid.

src/distribute_kv_cache/kvclient.rs:183

↓ 3 callersFunctionumount_volume_bind_path

Un-mount target path, if fail try force un-mount again

src/csi/util.rs:304

↓ 3 callersMethodunlock

(&self, key: T)

src/common/etcd_delegate.rs:91

↓ 3 callersMethodupdate_node

Update current node

src/distribute_kv_cache/cluster/cluster_manager.rs:950

↓ 3 callersMethodupdate_node_in_cluster

Update node info

src/distribute_kv_cache/cluster/cluster_manager.rs:307

↓ 3 callersMethodwith_prefix

(&mut self)

src/fs/kv_engine/mod.rs:197

↓ 3 callersMethodwrite

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

src/new_storage/backend/backend_impl.rs:144

↓ 3 callersMethodwrite

( &self, req: &Request<'_>, _fh: u64, offset: i64, data: Vec<u8>,

src/async_fuse/memfs/mod.rs:593

↓ 3 callersMethodwrite_through

(mut self, write_through: bool)

src/storage/memory_cache/builder.rs:65

↓ 2 callersFunction_run_bench

(mount_dir_str: &str, is_s3: bool)

src/async_fuse/test/integration_tests.rs:865

↓ 2 callersFunction_run_test

(mount_dir_str: &str, is_s3: bool)

src/async_fuse/test/integration_tests.rs:814

↓ 2 callersMethodactual_size

Get the actual size of the request.

src/distribute_kv_cache/rpc/message.rs:561

↓ 2 callersMethodadd_snapshot_meta_data

Add new snapshot meta data

src/csi/meta_data.rs:667

↓ 2 callersMethodalloc_block_id

(&self)

src/distribute_kv_cache/kvclient.rs:567

↓ 2 callersMethodallocate_fd

Allocate an fd

src/fs/datenlordfs/s3_metadata.rs:735

↓ 2 callersFunctionbuild_create_snapshot_response

Build `CreateSnapshotResponse`

src/csi/util.rs:144

↓ 2 callersFunctionbuild_create_volume_response

Build `CreateVolumeResponse`

src/csi/util.rs:118

↓ 2 callersFunctionbuild_grpc_controller_server

Build controller service

src/csi/mod.rs:104

↓ 2 callersFunctionbuild_grpc_node_server

Build node service

src/csi/mod.rs:79

↓ 2 callersFunctionbuild_grpc_worker_server

Build worker service

src/csi/mod.rs:52

↓ 2 callersMethodcapacity

Return the capacity of the policy.

src/storage/policy/lru.rs:61

↓ 2 callersFunctioncheck_size

(len: usize, need: usize)

src/async_fuse/fuse/de.rs:85

← previous next →201–300 of 1,395, ranked by callers