Module opendal::io_util

Providing IO utils like into_sink, into_stream.

Structs

BottomUpWalker

BottomUpWalker will walk dir in bottom up way:

DecompressDecoder

DecompressDecoder provides blocking decompress support for opendal: decode happen inside a blocking thread (user need to handle the decompress logic)

DecompressReader

DecompressReader provides async decompress support for opendal: decode happen inside poll_read (will block the runtime)

ReadObserver

Observer that created via observe_read.

SeekableReader

SeekableReader implement AsyncRead and AsyncSeek.

TopDownWalker

TopDownWalker will walk dir in top down way:

WriteObserver

Observer that created via observe_write.

Enums

CompressAlgorithm

CompressAlgorithm represents all compress algorithm that OpenDAL supports.

DecompressCodec

DecompressDecoder contains all decoders that opendal supports.

DecompressState

DecompressState is that decode state during decompress.

ReadEvent

Event that sent by ReadObserver, should be handled via FnMut(ReadEvent).

WriteEvent

Event that sent by WriteObserver, should be handled via FnMut(WriteEvent).

Functions

into_reader

Convert BytesStream into BytesRead.

into_sink

Convert BytesWrite into BytesSink.

into_stream

Convert BytesRead into BytesStream.

into_writer

Convert BytesSink into BytesWrite.

observe_read

Create an observer over BytesReader.

observe_write

Create an observer over crate::BytesWrite.

seekable_read

Add seek support for object via internal lazy operation.