Functions — github.com/Mooncake-Labs/moonlink

hub / github.com/Mooncake-Labs/moonlink / functions

Functions2,717 in github.com/Mooncake-Labs/moonlink

⨍ Functions 2,717◇ Types & classes 409

↓ 1,980 callersMethodclone

(&self)

src/moonlink/src/storage/mooncake_table/table_snapshot.rs:392

↓ 399 callersMethodpath

(&self)

src/moonlink/src/storage/mooncake_table/test_utils.rs:37

↓ 353 callersMethodlen

(&self)

src/moonlink/src/row/column_array_builder.rs:82

↓ 267 callersMethodmap

( &mut self, _map: &MapType, _key_value: Self::T, _value: Self::T, )

src/moonlink/src/storage/table/iceberg/parquet_utils.rs:138

↓ 234 callersMethodpush

(&mut self, table_event: &TableEvent)

src/moonlink/src/storage/wal.rs:670

↓ 232 callersMethodcommit

(&mut self, lsn: u64)

src/moonlink/src/storage/mooncake_table.rs:1290

↓ 172 callersMethodsend

Send a RecordBatch to the writer. Returns Err if the receiver is closed.

src/moonlink_connectors/src/pg_replicate/initial_copy_writer.rs:54

↓ 169 callersMethodappend

Append the given row into column store buffer and mem index. Return the finalized record batch if the current one's full.

src/moonlink/src/storage/mooncake_table/mem_slice.rs:102

↓ 168 callersMethodpush

(&self, row: MoonlinkRow)

src/moonlink/src/storage/mooncake_table/shared_array.rs:38

↓ 142 callersMethodget

Retrieves the internal field ID

src/moonlink/src/storage/table/iceberg/parquet_utils.rs:62

↓ 135 callersFunctionflush_table_and_sync

( table: &mut MooncakeTable, receiver: &mut Receiver<TableEvent>, lsn: u64, )

src/moonlink/src/storage/mooncake_table/table_operation_test_utils.rs:103

↓ 125 callersMethodfile_path

(&self)

src/moonlink/src/storage/storage_utils.rs:20

↓ 119 callersMethoddelete

Delete the given record from mem slice, and return its location if exists.

src/moonlink/src/storage/mooncake_table/mem_slice.rs:49

↓ 119 callersMethodinsert

( &mut self, key: u64, identity_for_key: Option<MoonlinkRow>, location: Record

src/moonlink/src/storage/index/mem_index.rs:99

↓ 113 callersMethodappend_row

( &self, id: i32, name: &str, age: i32, lsn: u64, xact_id: Opt

src/moonlink/src/table_handler/test_utils.rs:223

↓ 110 callersMethodfield

(&mut self, _field: &NestedFieldRef, _value: Self::T)

src/moonlink/src/storage/table/iceberg/parquet_utils.rs:126

↓ 107 callersFunctioncreate_mooncake_and_persist_for_test

Test util function, which updates mooncake table snapshot and create iceberg snapshot in a serial fashion.

src/moonlink/src/storage/mooncake_table/table_operation_test_utils.rs:415

↓ 96 callersMethodbuild

(mut self)

src/moonlink/src/storage/compaction/compactor.rs:388

↓ 90 callersMethodas_any

(&self)

src/moonlink_datafusion/src/table_provider.rs:62

↓ 90 callersFunctioncreate_mooncake_snapshot_for_test

=================================== Composite util functions =================================== Test util function, which creates mooncake snapshot

src/moonlink/src/storage/mooncake_table/table_operation_test_utils.rs:392

↓ 81 callersFunctioncreate_test_object_storage_cache

Creates a new `ObjectStorageCache` for testing, based on the given temporary directory.

src/moonlink/src/storage/mooncake_table/table_creation_test_utils.rs:254

↓ 79 callersFunctiontest_row

(id: i32, name: &str, age: i32)

src/moonlink/src/storage/mooncake_table/test_utils.rs:42

↓ 77 callersMethodload_snapshot_from_table

(&mut self)

src/moonlink/src/storage/table/iceberg/iceberg_table_manager.rs:212

↓ 70 callersMethodappend_value

Append a value to this builder

src/moonlink/src/row/column_array_builder.rs:218

↓ 70 callersMethodfile_id

(&self)

src/moonlink/src/storage/storage_utils.rs:16

↓ 65 callersMethodfinish

(mut self)

src/moonlink/src/row/column_array_builder.rs:55

↓ 62 callersMethodnext

(&mut self)

src/moonlink/src/storage/index/persisted_bucket_hash_map.rs:247

↓ 61 callersMethodrecv

Receive the next RecordBatch from the channel. Returns None if closed.

src/moonlink_connectors/src/pg_replicate/initial_copy_writer.rs:70

↓ 60 callersFunctionget_table_unique_file_id

Test util function to return table unique id, with table id hard-coded to 0.

src/moonlink/src/storage/cache/object_storage/test_utils.rs:20

↓ 59 callersMethodcommit

(&self, lsn: u64)

src/moonlink/src/table_handler/test_utils.rs:266

↓ 56 callersFunctioncreate_table_and_iceberg_manager

Util function to create mooncake table and iceberg table manager; object storage cache will be created internally. Iceberg snapshot will be created w

src/moonlink/src/storage/mooncake_table/table_creation_test_utils.rs:385

↓ 56 callersMethodwrite

(&mut self)

src/moonlink/src/storage/mooncake_table/disk_slice.rs:104

↓ 55 callersMethodwith_source

Sets the source error for this error struct. # Panics Panics if the source error has already been set.

src/moonlink_error/src/error.rs:95

↓ 53 callersMethodremove

(&self, key: &K)

src/moonlink/src/storage/cache/metadata/moka_cache.rs:65

↓ 52 callersFunctioncreate_test_filesystem_accessor

Test util function to create local filesystem accessor from iceberg table config.

src/moonlink/src/storage/mooncake_table/table_creation_test_utils.rs:240

↓ 51 callersFunctioncreate_test_arrow_schema

Test util function to create arrow schema.

src/moonlink/src/storage/mooncake_table/table_creation_test_utils.rs:208

↓ 49 callersMethodregister_table_notify

Register event completion notifier. Notice it should be registered only once, which could be used to notify multiple events.

src/moonlink/src/storage/mooncake_table/snapshot.rs:213

↓ 48 callersMethodappend_in_stream_batch

(&mut self, row: MoonlinkRow, xact_id: u32)

src/moonlink/src/storage/mooncake_table/transaction_stream.rs:171

↓ 48 callersFunctionassert_evictable_cache_size

Test util function to check evictable cache size.

src/moonlink/src/storage/cache/object_storage/test_utils.rs:92

↓ 48 callersFunctionassert_non_evictable_cache_size

Test util function to check non-evictable cache size.

src/moonlink/src/storage/cache/object_storage/test_utils.rs:101

↓ 48 callersFunctionassert_pending_eviction_entries_size

Test util function to check the number of entries pending to delete.

src/moonlink/src/storage/cache/object_storage/test_utils.rs:83

↓ 48 callersFunctionget_database_uri

Util function to get database URI.

src/moonlink_backend/tests/common.rs:628

↓ 46 callersMethodconvert

(&self, json: &Value)

src/moonlink_connectors/src/rest_ingest/json_converter.rs:34

↓ 46 callersFunctiontest_table

( context: &TestContext, table_name: &str, identity: IdentityProp, )

src/moonlink/src/storage/mooncake_table/test_utils.rs:72

↓ 46 callersMethodverify_snapshot

(&self, target_lsn: u64, expected_ids: &[i32])

src/moonlink/src/table_handler/test_utils.rs:402

↓ 44 callersFunctioncreate_data_file

(file_id: u64, file_path: String)

src/moonlink/src/storage/storage_utils.rs:54

↓ 43 callersFunctioncurrent_wal_lsn

Return the current WAL LSN as a simple `u64`.

src/moonlink_backend/tests/common.rs:141

↓ 43 callersMethodscan_table

If the requested database or table doesn't exist, return [`TableNotFound`] error.

src/moonlink_backend/src/lib.rs:386

↓ 41 callersFunctionconnect_to_postgres

(uri: &str)

src/moonlink_backend/tests/common.rs:601

↓ 41 callersFunctioncreate_test_file

Util function to prepare a test file.

src/moonlink/src/storage/cache/object_storage/test_utils.rs:28

↓ 41 callersMethodis_empty

(&self)

src/moonlink/src/storage/mooncake_table.rs:323

↓ 38 callersFunctionconvert_decimal_to_row_value

Based on https://www.postgresql.org/docs/17/datatype-numeric.html, Decimal values fall into 3 categories: 1. scale < 0 Negative scale → requires roun

src/moonlink_connectors/src/rest_ingest/decimal_utils.rs:230

↓ 38 callersFunctionget_iceberg_table_config

Test util function to get iceberg table config for local filesystem.

src/moonlink/src/storage/mooncake_table/table_creation_test_utils.rs:62

↓ 37 callersMethodget_warehouse_uri

(&self)

src/moonlink/src/storage/table/iceberg/iceberg_table_config.rs:97

↓ 37 callersMethodtake_as_read_state

Resolve all remote filepaths and convert into [`ReadState`] for query usage.

src/moonlink/src/storage/mooncake_table/snapshot_read_output.rs:155

↓ 36 callersMethoddo_wal_persistence_update_for_test

Mock function for how this gets called in table handler. We retrieve some data from the wal, asynchronously update the file system, and then call hand

src/moonlink/src/storage/wal/test_utils.rs:27

↓ 36 callersMethodis_empty

Return whether slice is empty.

src/moonlink/src/storage/mooncake_table/mem_slice.rs:44

↓ 35 callersMethodbackend

(&self)

src/moonlink_backend/tests/common.rs:61

↓ 35 callersFunctionprepare_committed_and_flushed_data_files

============================== Test util functions ============================== Test util function to prepare for committed and persisted data file

src/moonlink/src/storage/table/iceberg/state_tests.rs:102

↓ 33 callersFunctioncreate_iceberg_table_config

Test util function to create iceberg table config.

src/moonlink/src/storage/table/iceberg/iceberg_glue_catalog_test.rs:42

↓ 33 callersFunctionget_test_s3_bucket_and_warehouse

()

src/moonlink/src/storage/filesystem/s3/s3_test_utils.rs:46

↓ 33 callersMethodread

( &self, value_and_hashes: &[(u64, u64)], mut bucket_idxs: Vec<u32>, metadata:

src/moonlink/src/storage/index/persisted_bucket_hash_map.rs:173

↓ 33 callersMethodrequest_read

(&mut self)

src/moonlink/src/storage/mooncake_table/snapshot_read.rs:152

↓ 32 callersFunctionadd_new_example_append_event

( lsn: u64, xact_id: Option<u32>, wal: &mut WalManager, expected_events: &mut Vec<TableEvent>,

src/moonlink/src/storage/wal/test_utils.rs:340

↓ 32 callersMethodapply_stream_flush_result

Applies the result of a streaming flush to the stream state. Decrements the pending flush count for this transaction. Handles commit and abort cleanup

src/moonlink/src/storage/mooncake_table/transaction_stream.rs:410

↓ 32 callersFunctionget_moonlink_backend_dir

Moonlink backend directory.

src/moonlink_service/src/test_utils.rs:21

↓ 32 callersFunctionget_read_state_filepath_remap

()

src/moonlink/src/storage/mooncake_table/table_operation_test_utils.rs:739

↓ 32 callersMethodinitiate_snapshot

Initiate an iceberg snapshot event, return the channel for synchronization.

src/moonlink/src/storage/mooncake_table/table_event_manager.rs:50

↓ 31 callersFunctionperform_read_request_for_test

Perform a read request for the given table.

src/moonlink/src/storage/mooncake_table/table_operation_test_utils.rs:699

↓ 31 callersFunctionvalidate_recovered_snapshot

Test util functions to check recovered snapshot only contains remote filepaths and they do exist.

src/moonlink/src/storage/mooncake_table/validation_test_utils.rs:64

↓ 30 callersFunctionappend_rows

(table: &mut MooncakeTable, rows: Vec<MoonlinkRow>)

src/moonlink/src/storage/mooncake_table/test_utils.rs:169

↓ 29 callersFunctioncheck_deletion_vector_consistency_for_snapshot

Test util function to check deletion vector consistency for the given snapshot.

src/moonlink/src/storage/mooncake_table/validation_test_utils.rs:57

↓ 29 callersMethodimport_cache_entry

( &self, file_id: TableUniqueFileId, cache_entry: CacheEntry, )

src/moonlink/src/storage/cache/object_storage/object_storage_cache.rs:395

↓ 29 callersMethodwrite

(&mut self, bits: u32, value: U)

src/moonlink/src/storage/async_bitwriter.rs:131

↓ 28 callersFunctionget_test_row_2

()

src/moonlink/src/storage/table/iceberg/state_tests.rs:67

↓ 27 callersMethodshutdown

--- Lifecycle Helper ---

src/moonlink/src/table_handler/test_utils.rs:412

↓ 27 callersFunctionstart_with_config

(config: ServiceConfig)

src/moonlink_service/src/lib.rs:83

↓ 26 callersMethodcreate_table

Create a table in the database. # Arguments database_id: database id of the table, which must exist. table_id: table id assigned to this table. src_

src/moonlink_backend/src/lib.rs:168

↓ 26 callersFunctionget_test_gcs_bucket_and_warehouse

()

src/moonlink/src/storage/filesystem/gcs/gcs_test_utils.rs:38

↓ 25 callersMethodappend_null

(&mut self)

src/moonlink/src/row/column_array_builder.rs:48

↓ 25 callersFunctionassert_cache_bytes_size

Test util function to check the byte size for cache.

src/moonlink/src/storage/cache/object_storage/test_utils.rs:77

↓ 25 callersMethodclear

(&mut self)

src/moonlink/src/storage/table/iceberg/table_update_proxy.rs:52

↓ 25 callersFunctioncreate_test_table_metadata

Test util function to create mooncake table metadata.

src/moonlink/src/storage/mooncake_table/table_creation_test_utils.rs:247

↓ 25 callersMethoddrop_table

(&self, database: String, table: String)

src/moonlink_backend/src/lib.rs:263

↓ 25 callersMethodflush_table

(&self, lsn: u64)

src/moonlink/src/table_handler/test_utils.rs:332

↓ 25 callersMethodget_cache_entry

( &self, file_id: TableUniqueFileId, remote_filepath: &str, filesystem_accesso

src/moonlink/src/storage/cache/object_storage/object_storage_cache.rs:423

↓ 25 callersFunctionget_service_config

()

src/moonlink_service/src/test_utils.rs:59

↓ 25 callersFunctionwait_for_server_ready

Send request to readiness endpoint and wait until the server is ready.

src/moonlink_service/src/test_utils.rs:75

↓ 24 callersFunctionchaos_test_impl

(mut env: TestEnvironment)

src/moonlink/src/table_handler/chaos_test.rs:1021

↓ 24 callersMethodcollect_deleted_rows

Return deleted row index in ascending order.

src/moonlink/src/storage/mooncake_table/delete_vector.rs:125

↓ 24 callersFunctioncreate_filesystem_accessor

A factory function to create a filesystem accessor based on the given [`config`].

src/moonlink/src/storage/filesystem/accessor/factory.rs:8

↓ 24 callersMethodstream_commit

(&self, lsn: u64, xact_id: u32)

src/moonlink/src/table_handler/test_utils.rs:276

↓ 23 callersMethoddrain

( &mut self, )

src/moonlink/src/storage/mooncake_table/mem_slice.rs:124

↓ 23 callersFunctionget_random_string

()

src/moonlink/src/storage/table/iceberg/rest_catalog_test_utils.rs:13

↓ 23 callersMethodis_empty

(&self)

src/moonlink/src/storage/index/mem_index.rs:135

↓ 22 callersFunctionadd_new_example_commit_event

( lsn: u64, xact_id: Option<u32>, wal: &mut WalManager, expected_events: &mut Vec<TableEvent>,

src/moonlink/src/storage/wal/test_utils.rs:325

↓ 22 callersFunctioncreate_object_storage_cache_with_one_file_size

Test util function to create an object storage cache, with size of only one file.

src/moonlink/src/storage/mooncake_table/cache_test_utils.rs:41

↓ 22 callersFunctiondelete_local_files

Util function to delete local file in parallel. If the file doesn't exists on local filesystem, ignore and proceed.

src/moonlink/src/storage/io_utils.rs:5

↓ 22 callersMethodflush_table_and_sync

Commit the transaction, flush and create mooncake/iceberg snapshot.

src/moonlink/src/table_handler/test_utils.rs:315

↓ 22 callersFunctionget_test_row_3

()

src/moonlink/src/storage/table/iceberg/state_tests.rs:74

next →1–100 of 2,717, ranked by callers