Skip to main content

Crate harmos_storage

Crate harmos_storage 

Source

Re-exports§

pub use config::StorageFilesystemSettings;
pub use config::StorageRequestSettings;
pub use config::StorageResponseSettings;
pub use config::StorageSettings;
pub use directory::DirectoryReader;
pub use directory::DirectoryWatcher;
pub use json::JsonStorage;
pub use json::JsonStorageSettings;
pub use query::ObjectRead;
pub use query::ObjectReader;
pub use query::Query;
pub use query::QueryReader;
pub use query::RecordRead;
pub use query::RecordReader;
pub use query::StreamRead;
pub use query::StreamReader;
pub use writes::StorageSchema;

Modules§

aggregate
arrow
config
directory
execution
files
follow
json
query
schema
signal
state
writes

Structs§

BackendSnapshot
ByteRange
FileBatch
FileCapture
FileCheckpoint
FileCompletion
FileFollow
FileFollower
FileHash
FileMetadata
FileProducer
FileProgress
FileRead
FileReadBatch
FileReadSlice
FileReader
FileReference
FileSave
FileSession
FrozenFile
A private immutable copy of an opened file range, retained independently of its source.
Identifier
IdentitySelection
MutationId
MutationReceipt
MutationWindow
ObjectDefinition
ObjectDefinitions
ObjectEntry
ObjectGroup
ObjectKey
ObjectPoint
ObjectReceipt
ObjectRevision
ObjectValue
ObjectVersionToken
OpenedCapture
Retains the original opened source, producer and exact in-flight copy across cancellation.
ProductionFollower
ReadBatch
ReadLimits
RecordInput
RecordWrite
RecoveryPosition
ScanPage
SchemaInfo
SchemaInput
SchemaKey
StagedFile
StorageBackends
StorageBatch
StorageCursor
StorageFile
StorageInfo
StorageManager
StorageMetrics
StoreHistory
StoredRecord
StoredRow
StreamInput
StreamWrite
Worker

Enums§

Aggregate
BackendFailure
CaptureConsistency
ErasedCatalog
Error
FileEvent
FilePhase
FileSource
FollowStart
IdentityKind
MutationValue
ObjectRetention
ObjectVersion
PayloadEncoding
StoredIdentity

Traits§

MemorySize
Message
ObjectCatalog
StorageBackend
StoredObject
WorkerOwner

Functions§

btree_map_memory
encoded_size

Type Aliases§

FileChunk
FileReadEvent
ReadPages
A retained collection of original typed row pages.
Result
StorageFuture