List of all items

Structs

• DefinitionId
• Failure
• Identifier
• MessageError
• Metadata
• StreamField
• __private::BatchDefinition
• __private::MessageError
• __private::PluginGrant
• __private::PluginInventory::Declaration
• __private::PluginInventory::RestartPolicy
• __private::PluginInventory::Section
• __private::PluginInventory::StreamDeclaration
• __private::PluginInventory::contracts::Identity
• __private::PluginInventory::contracts::Manifest
• __private::PluginInventory::contracts::NamedContract
• __private::PluginInventory::contracts::NamedManifest
• __private::PluginInventory::contracts::NamedRequired
• __private::PluginInventory::contracts::Required
• __private::PluginInventory::contributions::Manifest
• __private::PluginInventory::contributions::Section
• __private::PluginInventory::listeners::Manifest
• __private::PluginInventory::listeners::NamedListener
• __private::PluginInventory::listeners::NamedManifest
• __private::PluginInventory::observers::Declaration
• __private::PluginInventory::observers::DemandKey
• __private::PluginInventory::observers::Descriptors
• __private::PluginInventory::observers::Entry
• __private::PluginInventory::observers::Manifest
• __private::PluginInventory::publications::Entry
• __private::PluginInventory::publications::Manifest
• __private::PluginInventory::publications::NamedManifest
• __private::PluginInventory::publications::NamedStream
• __private::PluginRegistrar
• __private::PluginRequirement
• __private::PluginRequirements
• __private::PostcardReader
• __private::SchemaSettings
• builtin::Cancel
• builtin::Cancelling
• builtin::Catalog
• builtin::InstanceState
• builtin::Reporting
• builtin::Status
• builtin::Watch
• builtin::Watching
• catalog::ListenerEntry
• catalog::ObserverEntry
• catalog::OperationEntry
• catalog::PublicationEntry
• catalog::RequirementEntry
• catalog::WireEntry
• config::OperationSettings
• config::SchemaSettings
• config::StorageBudget
• config::StorageRequestSettings
• config::StorageResponseSettings
• config::StorageSettings
• config::StorageStateSettings
• config::StreamSettings
• evidence::Draft
• evidence::Evidence
• evidence::EvidenceRecord
• evidence::Excerpt
• failure::Context
• failure::Diagnostics
• failure::Failure
• failure::Report
• listeners::Declarations
• listeners::Definition
• listeners::Delivery
• listeners::Entry
• message::MessageError
• message::postcard::Reader
• observers::ObserverActivation
• observers::ObserverDefinition
• operations::AuthoredContracts
• operations::AuthoredDeclarations
• operations::Binding
• operations::Bindings
• operations::CacheKey
• operations::CallContext
• operations::CallValue
• operations::Capacity
• operations::Completion
• operations::Context
• operations::ContextMut
• operations::Contract
• operations::Contracts
• operations::Declarations
• operations::Definition
• operations::EncodedInvocation
• operations::Entry
• operations::Grpc
• operations::Implementations
• operations::LaneSet
• operations::OperationGeneration
• operations::OperationInstance
• operations::OperationInstanceId
• operations::OperationManager
• operations::OperationPolicy
• operations::OperationStatus
• operations::Response
• operations::Scope
• operations::Serves
• operations::Session
• operations::SessionInput
• operations::SessionOutput
• operations::Stream
• operations::StreamInput
• operations::StreamItem
• operations::StreamSettings
• operations::WireBinding
• operations::WireChildCall
• operations::WireChildControl
• operations::WireDeclaration
• operations::WireImplementations
• operations::WireStreamLimits
• operations::WireStreams
• operations::WireTable
• operations::authorization::Provider
• operations::authorization::Required
• operations::host::Catalog
• operations::host::CatalogPage
• operations::host::DiscoveredOperation
• operations::instance::Id
• operations::instance::ParseError
• operations::instance::Status
• operations::lifecycle::Cancel
• operations::lifecycle::Descriptor
• operations::lifecycle::Initialize
• operations::lifecycle::InstanceState
• operations::lifecycle::Shutdown
• operations::lifecycle::Status
• operations::lifecycle::Watch
• operations::listing::Listing
• operations::middleware::Invocation
• operations::middleware::Observation
• operations::observers::Control
• operations::resident::Activation
• operations::resident::Key
• operations::resident::ScopeId
• operations::resident::Snapshot
• operations::resident::Staged
• operations::streams::FollowingRow
• operations::streams::Publish
• prelude::Identifier
• prelude::OperationPolicy
• prelude::catalog::ListenerEntry
• prelude::catalog::ObserverEntry
• prelude::catalog::OperationEntry
• prelude::catalog::PublicationEntry
• prelude::catalog::RequirementEntry
• prelude::catalog::WireEntry
• prelude::message::MessageError
• prelude::message::postcard::Reader
• records::Definition
• records::RecordManager
• runtime::BootstrapCleanup
• runtime::Builder
• runtime::Handle
• runtime::Incompatible
• runtime::Inspection
• runtime::Inspector
• runtime::Runtime
• runtime::Startup
• runtime::StopParticipant
• schema::PayloadError
• schema::Validator
• schema::declaration::Definition
• schema::declaration::Name
• schema::declaration::Named
• schema::graph::Field
• schema::graph::Preparation
• schema::graph::Schema
• schema::graph::Seed
• schema::graph::View
• services::Service
• services::ServiceDefinition
• state::At
• state::CaptureLimits
• state::CausationId
• state::CorrelationId
• state::DefinitionId
• state::Entry
• state::Envelope
• state::Focus
• state::ManagedState
• state::Metadata
• state::Origin
• state::Position
• state::Prepared
• state::PrincipalId
• state::Receipt
• state::RecordDefinitions
• state::Records
• state::RequestKey
• state::Reversals
• state::SnapshotPolicy
• state::StateManager
• state::SystemFact
• state::Timestamp
• state::TransactionDefinitions
• storage::BackendSnapshot
• storage::Batch
• storage::ByteRange
• storage::Cursor
• storage::FileBatch
• storage::FileCheckpoint
• storage::FileCompletion
• storage::FileFollower
• storage::FileMetadata
• storage::FileProducer
• storage::FileProgress
• storage::FileReader
• storage::FileReference
• storage::FileSave
• storage::FileSession
• storage::Identifier
• storage::IdentitySelection
• storage::MutationId
• storage::MutationReceipt
• storage::MutationWindow
• storage::ObjectDefinition
• storage::ObjectDefinitions
• storage::ObjectEntry
• storage::ObjectGroup
• storage::ObjectKey
• storage::ObjectPoint
• storage::ObjectRead
• storage::ObjectReader
• storage::ObjectReceipt
• storage::ObjectRevision
• storage::ObjectValue
• storage::ObjectVersionToken
• storage::Payload
• storage::ProjectedRecords
• storage::QueryReader
• storage::ReadLimits
• storage::RecordInput
• storage::RecordRead
• storage::RecordReader
• storage::RecordWrite
• storage::Recovery
• storage::RecoveryPosition
• storage::ScanPage
• storage::SchemaInfo
• storage::SchemaInput
• storage::SchemaKey
• storage::StagedFile
• storage::StorageBackends
• storage::StorageBatch
• storage::StorageBudget
• storage::StorageCursor
• storage::StorageFile
• storage::StorageInfo
• storage::StorageManager
• storage::StorageMetrics
• storage::StorageRequestSettings
• storage::StorageResponseSettings
• storage::StorageSchema
• storage::StorageSettings
• storage::StoreHistory
• storage::StoredRecord
• storage::StoredRow
• storage::StreamInput
• storage::StreamWrite
• storage::Worker
• storage::arrow::ArrowBatch
• storage::arrow::ArrowSchema
• storage::arrow::RetainedMemory
• storage::config::StorageBudget
• storage::config::StorageRequestSettings
• storage::config::StorageResponseSettings
• storage::config::StorageSettings
• storage::execution::Elapsed
• storage::execution::Execution
• storage::files::ByteRange
• storage::files::FileBatch
• storage::files::FileCompletion
• storage::files::FileMetadata
• storage::files::FileProgress
• storage::files::FileReference
• storage::files::FileSession
• storage::files::StagedFile
• storage::files::read::ByteRange
• storage::files::read::FileBatch
• storage::files::read::FileCompletion
• storage::follow::FollowPage
• storage::follow::Follower
• storage::operations::AbandonFile
• storage::operations::AppendFile
• storage::operations::CreateFile
• storage::operations::DeleteFile
• storage::operations::FinishFile
• storage::operations::FollowBoundaries
• storage::operations::FollowFile
• storage::operations::FollowObjects
• storage::operations::FollowRecords
• storage::operations::FollowStream
• storage::operations::Query
• storage::operations::ReadFile
• storage::operations::ResumeFile
• storage::operations::StorageStatus
• storage::operations::WriteFile
• storage::operations::WriteObjects
• storage::operations::WriteRecords
• storage::operations::WriteSchema
• storage::operations::WriteStreams
• storage::query::Accumulator
• storage::query::FileSelection
• storage::query::ObjectRead
• storage::query::ObjectReader
• storage::query::ObjectSelection
• storage::query::QueryCompletion
• storage::query::QueryReader
• storage::query::RecordRead
• storage::query::RecordReader
• storage::query::RecordSelection
• storage::query::RowSlice
• storage::query::SchemaSelection
• storage::query::Scratch
• storage::query::StreamSelection
• storage::query::scalar::ExactNumber
• storage::query::transform::FieldPath
• storage::query::transform::aggregate::Aggregate
• storage::query::transform::aggregate::Groups
• storage::query::transform::aggregate::Measure
• storage::query::transform::downsample::Downsample
• storage::query::transform::filter::Clause
• storage::query::transform::filter::Filter
• storage::query::transform::filter::Term
• storage::query::transform::histogram::Bins
• storage::query::transform::histogram::Histogram
• storage::query::transform::project::Project
• storage::query::transform::project::Projection
• storage::query::transform::sort::Sort
• storage::query::transform::sort::SortKey
• storage::schema::PayloadError
• storage::schema::Validator
• storage::schema::declaration::Definition
• storage::schema::declaration::Name
• storage::schema::declaration::Named
• storage::schema::graph::Field
• storage::schema::graph::Preparation
• storage::schema::graph::Schema
• storage::schema::graph::Seed
• storage::schema::graph::View
• storage::signal::Decibel
• storage::signal::Edge
• storage::signal::Series
• storage::signal::Spectrum
• storage::signal::Summary
• storage::state::Permit
• storage::state::RecoveryEntry
• storage::state::RecoveryPage
• storage::state::RecoveryReader
• storage::state::RecoverySnapshot
• storage::state::StorageStateSettings
• storage::state::config::StorageStateSettings
• storage::state::file::FileBackend
• storage::writes::BatchReceipt
• storage::writes::DataBatch
• storage::writes::DecodedBatch
• storage::writes::StorageSchema
• storage::writes::WriteCompletion
• streams::Aggregated
• streams::BatchDefinition
• streams::Batches
• streams::Bucket
• streams::Definition
• streams::Demand
• streams::ManagedPublication
• streams::Measurement
• streams::PageLimits
• streams::PluginStream
• streams::Point
• streams::PublicationLease
• streams::PublicationRow
• streams::Query
• streams::ReadLimits
• streams::RowPage
• streams::RowReader
• streams::Seal
• streams::StreamFeed
• streams::StreamManager
• streams::Summary
• streams::Survey

Enums

• Aggregate
• BackendFailure
• Error
• IdentifierError
• Refusal
• Value
• ValueError
• __private::PluginInventory::CarrierSection
• __private::PluginInventory::DeclarationError
• __private::PluginInventory::Facility
• __private::PluginInventory::contracts::Error
• __private::PluginInventory::contributions::Error
• __private::PluginInventory::listeners::Error
• __private::PluginInventory::listeners::NamedSource
• __private::PluginInventory::observers::Activation
• __private::PluginInventory::observers::Error
• __private::PluginInventory::operations::Error
• __private::PluginInventory::publications::Error
• __private::PluginRegistrationError
• artifacts::ScanError
• catalog::Node
• config::ConfigError
• evidence::EvidenceError
• failure::CodecError
• failure::Origin
• filesystem::Error
• filesystem::publication::ConfirmError
• listeners::Context
• listeners::ContextError
• listeners::EncodingError
• listeners::Error
• listeners::Source
• listeners::SourceDeclaration
• operations::Backoff
• operations::CacheKeyError
• operations::Codec
• operations::ContextError
• operations::ContractError
• operations::FailureKind
• operations::Jitter
• operations::NoStream
• operations::OperationOutcome
• operations::OperationPhase
• operations::PolicyError
• operations::ReplaySafety
• operations::RestartPolicy
• operations::RetryPolicy
• operations::ServingError
• operations::Visibility
• operations::WireAnswer
• operations::WireChild
• operations::WireChildAction
• operations::WireCodecError
• operations::WireCommand
• operations::authorization::Authorization
• operations::host::CatalogKind
• operations::instance::Outcome
• operations::instance::Phase
• operations::lifecycle::Action
• operations::lifecycle::Error
• operations::resident::Definition
• operations::resident::Kind
• prelude::catalog::Node
• runtime::BootstrapStatus
• runtime::Catalog
• schema::Cardinality
• schema::Error
• schema::Event
• schema::PathElement
• schema::Scalar
• schema::VisitError
• schema::graph::Error
• schema::graph::Kind
• services::Fault
• services::ServiceExit
• services::ServiceStatus
• state::CaptureError
• state::DecodeError
• state::Error
• state::FactSource
• state::Kind
• state::Link
• state::Never
• state::PreparationError
• state::Recorded
• storage::Aggregate
• storage::BackendFailure
• storage::ErasedCatalog
• storage::Error
• storage::FilePhase
• storage::Horizon
• storage::IdentityKind
• storage::MutationValue
• storage::ObjectRetention
• storage::ObjectVersion
• storage::PayloadEncoding
• storage::StorageEntry
• storage::StoragePart
• storage::StoredIdentity
• storage::files::FilePhase
• storage::operations::Followed
• storage::operations::Operations
• storage::query::ObjectVersions
• storage::query::QueryArrow
• storage::query::QueryOutput
• storage::query::Source
• storage::query::scalar::Agg
• storage::query::scalar::ScalarKind
• storage::query::scalar::ScalarValue
• storage::query::transform::Transform
• storage::query::transform::downsample::Algorithm
• storage::query::transform::filter::Compare
• storage::query::transform::filter::Condition
• storage::schema::Cardinality
• storage::schema::Error
• storage::schema::Event
• storage::schema::PathElement
• storage::schema::Scalar
• storage::schema::VisitError
• storage::schema::graph::Error
• storage::schema::graph::Kind
• storage::signal::Band
• storage::signal::Error
• storage::signal::Scale
• storage::signal::Taper
• storage::writes::WriteReceipt
• streams::BatchItem
• streams::BeneathWindow
• streams::Item
• streams::ReadCut
• streams::ReadError
• streams::StreamAdmissionError
• streams::StreamPublicationError

Traits

• Application
• Identified
• MemorySize
• Message
• Plugin
• RowMetadata
• Storable
• StreamSpec
• __private::Answer
• __private::CarrierContext
• __private::Catalogued
• __private::Mutual
• __private::PluginContribution
• __private::PluginDeclared
• __private::PluginInventory::observers::Declared
• __private::PluginInventory::publications::StreamSpec
• __private::PostcardValue
• __private::StreamCatalog
• __private::StreamRow
• catalog::Catalog
• catalog::Contains
• catalog::InertCatalog
• catalog::Member
• catalog::Projection
• catalog::Visitor
• evidence::EvidenceKind
• evidence::Vault
• listeners::Listener
• message::MemorySize
• message::Message
• message::Portable
• message::Storable
• message::postcard::Value
• observers::ObserverBackend
• operations::ContextValue
• operations::Declares
• operations::Direction
• operations::EndpointSet
• operations::Host
• operations::InputEndpoint
• operations::Instance
• operations::Lane
• operations::Operation
• operations::OperationDeclaration
• operations::OutputEndpoint
• operations::WireEndpoints
• operations::authorization::Authorizer
• operations::instance::Instance
• operations::lifecycle::Policy
• operations::lifecycle::SdkOperation
• operations::middleware::Middleware
• prelude::Invert
• prelude::Message
• prelude::OperationDeclaration
• prelude::Transaction
• prelude::catalog::Catalog
• prelude::catalog::Contains
• prelude::catalog::InertCatalog
• prelude::catalog::Member
• prelude::catalog::Projection
• prelude::catalog::Visitor
• prelude::message::MemorySize
• prelude::message::Message
• prelude::message::Portable
• prelude::message::Storable
• prelude::message::postcard::Value
• runtime::Registration
• schema::Described
• services::Resident
• state::CatalogCodec
• state::Catalogued
• state::Invert
• state::JournalCapture
• state::Mutual
• state::Record
• state::RecordCatalog
• state::RecordProjection
• state::Transaction
• state::TransactionCatalog
• state::Undoable
• storage::JournalConsumer
• storage::MemorySize
• storage::Message
• storage::ObjectCatalog
• storage::RecordProjection
• storage::Series
• storage::Source
• storage::StorageBackend
• storage::StoredObject
• storage::StreamConsumer
• storage::WorkerOwner
• storage::follow::Entry
• storage::query::transform::AggregateExecution
• storage::query::transform::DownsampleExecution
• storage::query::transform::FieldPathExecution
• storage::query::transform::FilterExecution
• storage::query::transform::HistogramExecution
• storage::query::transform::ProjectExecution
• storage::query::transform::SortExecution
• storage::query::transform::TransformExecution
• storage::query::transform::aggregate::AggregateExecution
• storage::query::transform::downsample::DownsampleExecution
• storage::query::transform::filter::FilterExecution
• storage::query::transform::histogram::HistogramExecution
• storage::query::transform::project::ProjectExecution
• storage::query::transform::sort::SortExecution
• storage::schema::Described
• storage::signal::Aggregates
• storage::state::StateBackend
• streams::Axial
• streams::Batched
• streams::Prefix
• streams::RowSource
• streams::Stream
• streams::StreamCatalog
• streams::StreamRow
• streams::Track
• streams::Tracked

Macros

• __private::declare
• __private::postcard_product

Attribute Macros

• catalog
• lanes
• listener
• message
• observer
• operation
• plugin
• prelude::catalog
• prelude::message
• prelude::operation
• prelude::record
• prelude::stream
• prelude::transaction
• record
• records
• stream
• streams
• transaction
• transactions

Functions

• __private::PluginInventory::contracts::decode
• __private::PluginInventory::contracts::encode_identity
• __private::PluginInventory::contracts::encode_tree
• __private::PluginInventory::contracts::encoded_tree_len
• __private::PluginInventory::contracts::identity_len
• __private::PluginInventory::contracts::select
• __private::PluginInventory::contracts::validate
• __private::PluginInventory::contributions::encode
• __private::PluginInventory::contributions::encoded_len
• __private::PluginInventory::contributions::namespaced
• __private::PluginInventory::contributions::select
• __private::PluginInventory::contributions::validate
• __private::PluginInventory::listeners::encode
• __private::PluginInventory::listeners::encoded_len
• __private::PluginInventory::listeners::select
• __private::PluginInventory::listeners::validate
• __private::PluginInventory::observers::encode
• __private::PluginInventory::observers::encode_tree
• __private::PluginInventory::observers::encoded_len
• __private::PluginInventory::observers::encoded_tree_len
• __private::PluginInventory::observers::select
• __private::PluginInventory::observers::select_manifest
• __private::PluginInventory::observers::validate
• __private::PluginInventory::operations::validate
• __private::PluginInventory::operations::validate_match
• __private::PluginInventory::publications::encode
• __private::PluginInventory::publications::encoded_len
• __private::PluginInventory::publications::merge
• __private::PluginInventory::publications::require_subset
• __private::PluginInventory::publications::require_tree_subset
• __private::PluginInventory::publications::select
• __private::PluginInventory::publications::validate
• __private::PluginInventory::publications::validate_match
• __private::PluginSchemaMarkers
• __private::decoding_add
• __private::decoding_multiply
• __private::decoding_vector
• __private::stream_definition
• artifacts::fragments
• btree_map_memory
• catalog::count
• catalog::try_for_each
• config::decode_config
• config::encode_config
• config::validate_config
• filesystem::input::read
• filesystem::publication::confirm
• filesystem::publication::confirm_with_checkpoint
• filesystem::publication::create_dir_all
• filesystem::publication::install
• filesystem::publication::move_directory
• filesystem::publication::remove
• filesystem::publication::replace
• filesystem::publication::write
• listeners::encode_borrowed
• listeners::encoding_memory_bytes
• message::btree_map_memory
• operations::item_types
• operations::lifecycle::bind
• operations::listing::register
• operations::observers::contract
• operations::stream
• prelude::catalog::count
• prelude::catalog::try_for_each
• prelude::message::btree_map_memory
• schema::declaration::encode
• schema::declaration::encode_buffer
• schema::declaration::encoded_len
• schema::declaration::markers
• schema::declaration::markers_many
• storage::aggregate::of_series
• storage::aggregate::of_summary
• storage::arrow::decoding_memory
• storage::arrow::encode_payloads
• storage::arrow::validate_schema
• storage::btree_map_memory
• storage::encoded_size
• storage::operations::register
• storage::query::scalar::exact
• storage::query::scalar::ratio_cmp
• storage::schema::declaration::encode
• storage::schema::declaration::encode_buffer
• storage::schema::declaration::encoded_len
• storage::schema::declaration::markers
• storage::schema::declaration::markers_many
• storage::signal::above_floor
• storage::signal::band_energy
• storage::signal::band_rms
• storage::signal::bins
• storage::signal::centroid
• storage::signal::crossing
• storage::signal::decimate
• storage::signal::derivative
• storage::signal::edges
• storage::signal::extrema
• storage::signal::fundamental
• storage::signal::harmonics
• storage::signal::integral
• storage::signal::lttb
• storage::signal::lttb_log
• storage::signal::magnitude
• storage::signal::nearest
• storage::signal::occupied_bandwidth
• storage::signal::papr
• storage::signal::peaks
• storage::signal::phase
• storage::signal::resample
• storage::signal::resample_count
• storage::signal::resample_uniform
• storage::signal::rolloff
• storage::signal::thd
• storage::signal::value_at
• storage::writes::convert::encode_payloads
• storage::writes::convert::objects
• storage::writes::convert::records
• storage::writes::convert::streams

Type Aliases

• Result
• filesystem::Result
• operations::Download
• operations::Exchange
• operations::StreamOutput
• operations::StreamPermit
• operations::Upload
• operations::middleware::Enter
• schema::Field
• schema::Kind
• schema::declaration::Field
• schema::declaration::Kind
• storage::Result
• storage::StorageFuture
• storage::execution::Sleep
• storage::schema::Field
• storage::schema::Kind
• storage::schema::declaration::Field
• storage::schema::declaration::Kind
• storage::signal::Result

Constants

• artifacts::FRAGMENT_LIMIT
• artifacts::KINDS
• artifacts::PREFIX
• operations::CHILD_METHOD
• operations::MAX_CACHE_KEY_BYTES
• operations::PORTABLE_BYTES
• operations::PORTABLE_VALUES
• operations::WIRE_METHOD
• operations::host::POLICY
• operations::lifecycle::POLICY
• operations::observers::POLICY
• schema::MAX_DEPTH
• schema::MAX_NAME_BYTES
• services::POLICY
• storage::operations::EVERY_SCHEMA
• storage::operations::IO_POLICY
• storage::operations::POLICY
• storage::operations::STREAM_POLICY
• storage::schema::MAX_DEPTH
• storage::schema::MAX_NAME_BYTES