Package index

Filesystem construction and configuration

opendal() opendal_uri() credentials_s3() credentials_gcs() credentials_azblob() credentials_gdrive() credentials_gdrive3() credential_schemes() credential_config() credential_summary() runtime_config() layer_concurrent_limit() layer_timeout() fs_info() fs_capabilities() fs_normalize_path() opt() `opt<-`() serial_config() codec_config() serialize_raw() deserialize_raw() fs_read() fs_read_aio() fs_read_bytes() fs_read_bytes_aio() as.raw(<OpendalBytes>) length(<OpendalBytes>) fs_read_iter() read_iter_next() read_iter_collect() fs_tell() fs_seek() fs_write() fs_write_aio() fs_replace() fs_replace_aio() fs_append() fs_append_aio() fs_write_iter() write_iter_write() write_iter_close() fs_stat() fs_stat_aio() fs_stats() fs_stats_aio() fs_exists() fs_exists_aio() fs_ls() fs_ls_aio() fs_ls_iter() fs_walk_iter() ls_iter_next() ls_iter_collect() walk_iter_next() walk_iter_collect() fs_mkdir() fs_mkdir_aio() fs_delete() fs_delete_aio() fs_copy() fs_copy_aio() fs_rename() fs_rename_aio() collect_aio() collect_aio_() call_aio() call_aio_() stop_aio() poll_aio() cv() cv_value() cv_reset() cv_signal() cv_wait() cv_until() aio_monitor() read_monitor() race_aio() unresolved() is_error_value() error_kind() error_message() error_operation() error_path()

Ropendal filesystem API

Filesystem primitives

opendal() opendal_uri() credentials_s3() credentials_gcs() credentials_azblob() credentials_gdrive() credentials_gdrive3() credential_schemes() credential_config() credential_summary() runtime_config() layer_concurrent_limit() layer_timeout() fs_info() fs_capabilities() fs_normalize_path() opt() `opt<-`() serial_config() codec_config() serialize_raw() deserialize_raw() fs_read() fs_read_aio() fs_read_bytes() fs_read_bytes_aio() as.raw(<OpendalBytes>) length(<OpendalBytes>) fs_read_iter() read_iter_next() read_iter_collect() fs_tell() fs_seek() fs_write() fs_write_aio() fs_replace() fs_replace_aio() fs_append() fs_append_aio() fs_write_iter() write_iter_write() write_iter_close() fs_stat() fs_stat_aio() fs_stats() fs_stats_aio() fs_exists() fs_exists_aio() fs_ls() fs_ls_aio() fs_ls_iter() fs_walk_iter() ls_iter_next() ls_iter_collect() walk_iter_next() walk_iter_collect() fs_mkdir() fs_mkdir_aio() fs_delete() fs_delete_aio() fs_copy() fs_copy_aio() fs_rename() fs_rename_aio() collect_aio() collect_aio_() call_aio() call_aio_() stop_aio() poll_aio() cv() cv_value() cv_reset() cv_signal() cv_wait() cv_until() aio_monitor() read_monitor() race_aio() unresolved() is_error_value() error_kind() error_message() error_operation() error_path()

Ropendal filesystem API

Async Aio operations

opendal() opendal_uri() credentials_s3() credentials_gcs() credentials_azblob() credentials_gdrive() credentials_gdrive3() credential_schemes() credential_config() credential_summary() runtime_config() layer_concurrent_limit() layer_timeout() fs_info() fs_capabilities() fs_normalize_path() opt() `opt<-`() serial_config() codec_config() serialize_raw() deserialize_raw() fs_read() fs_read_aio() fs_read_bytes() fs_read_bytes_aio() as.raw(<OpendalBytes>) length(<OpendalBytes>) fs_read_iter() read_iter_next() read_iter_collect() fs_tell() fs_seek() fs_write() fs_write_aio() fs_replace() fs_replace_aio() fs_append() fs_append_aio() fs_write_iter() write_iter_write() write_iter_close() fs_stat() fs_stat_aio() fs_stats() fs_stats_aio() fs_exists() fs_exists_aio() fs_ls() fs_ls_aio() fs_ls_iter() fs_walk_iter() ls_iter_next() ls_iter_collect() walk_iter_next() walk_iter_collect() fs_mkdir() fs_mkdir_aio() fs_delete() fs_delete_aio() fs_copy() fs_copy_aio() fs_rename() fs_rename_aio() collect_aio() collect_aio_() call_aio() call_aio_() stop_aio() poll_aio() cv() cv_value() cv_reset() cv_signal() cv_wait() cv_until() aio_monitor() read_monitor() race_aio() unresolved() is_error_value() error_kind() error_message() error_operation() error_path()

Ropendal filesystem API

Error values

opendal() opendal_uri() credentials_s3() credentials_gcs() credentials_azblob() credentials_gdrive() credentials_gdrive3() credential_schemes() credential_config() credential_summary() runtime_config() layer_concurrent_limit() layer_timeout() fs_info() fs_capabilities() fs_normalize_path() opt() `opt<-`() serial_config() codec_config() serialize_raw() deserialize_raw() fs_read() fs_read_aio() fs_read_bytes() fs_read_bytes_aio() as.raw(<OpendalBytes>) length(<OpendalBytes>) fs_read_iter() read_iter_next() read_iter_collect() fs_tell() fs_seek() fs_write() fs_write_aio() fs_replace() fs_replace_aio() fs_append() fs_append_aio() fs_write_iter() write_iter_write() write_iter_close() fs_stat() fs_stat_aio() fs_stats() fs_stats_aio() fs_exists() fs_exists_aio() fs_ls() fs_ls_aio() fs_ls_iter() fs_walk_iter() ls_iter_next() ls_iter_collect() walk_iter_next() walk_iter_collect() fs_mkdir() fs_mkdir_aio() fs_delete() fs_delete_aio() fs_copy() fs_copy_aio() fs_rename() fs_rename_aio() collect_aio() collect_aio_() call_aio() call_aio_() stop_aio() poll_aio() cv() cv_value() cv_reset() cv_signal() cv_wait() cv_until() aio_monitor() read_monitor() race_aio() unresolved() is_error_value() error_kind() error_message() error_operation() error_path()

Ropendal filesystem API

Serialization and codecs

opendal() opendal_uri() credentials_s3() credentials_gcs() credentials_azblob() credentials_gdrive() credentials_gdrive3() credential_schemes() credential_config() credential_summary() runtime_config() layer_concurrent_limit() layer_timeout() fs_info() fs_capabilities() fs_normalize_path() opt() `opt<-`() serial_config() codec_config() serialize_raw() deserialize_raw() fs_read() fs_read_aio() fs_read_bytes() fs_read_bytes_aio() as.raw(<OpendalBytes>) length(<OpendalBytes>) fs_read_iter() read_iter_next() read_iter_collect() fs_tell() fs_seek() fs_write() fs_write_aio() fs_replace() fs_replace_aio() fs_append() fs_append_aio() fs_write_iter() write_iter_write() write_iter_close() fs_stat() fs_stat_aio() fs_stats() fs_stats_aio() fs_exists() fs_exists_aio() fs_ls() fs_ls_aio() fs_ls_iter() fs_walk_iter() ls_iter_next() ls_iter_collect() walk_iter_next() walk_iter_collect() fs_mkdir() fs_mkdir_aio() fs_delete() fs_delete_aio() fs_copy() fs_copy_aio() fs_rename() fs_rename_aio() collect_aio() collect_aio_() call_aio() call_aio_() stop_aio() poll_aio() cv() cv_value() cv_reset() cv_signal() cv_wait() cv_until() aio_monitor() read_monitor() race_aio() unresolved() is_error_value() error_kind() error_message() error_operation() error_path()

Ropendal filesystem API

Native API

OpendalFs

Filesystem handle backed by Apache OpenDAL.

OpendalAio

Asynchronous operation handle.

OpendalCredentialProvider

Explicit credential provider.

OpendalHttpFixture

Internal HTTP fixture for tests.

OpendalLsIter

Streaming listing iterator over one prefix.

OpendalReadIter

Chunked read iterator over one object.

OpendalWriteIter

Chunked write sink for one object.