List of all items

Structs

• base::json_schema::BuildJsonSchemaOutput
• base::json_schema::ToJsonSchemaOptions
• base::json_schema::ValueExtractor
• base::schema::CollectorSchema
• base::schema::EnrichedValueType
• base::schema::FieldSchema
• base::schema::FlowSchema
• base::schema::KTableInfo
• base::schema::OpArgSchema
• base::schema::OpScopeSchema
• base::schema::StructSchema
• base::schema::TableSchema
• base::schema::UnionTypeSchema
• base::schema::VectorTypeSchema
• base::spec::AuthEntryReference
• base::spec::CollectOpSpec
• base::spec::ConstantMapping
• base::spec::ExecutionOptions
• base::spec::ExportOpSpec
• base::spec::FieldMapping
• base::spec::FieldPath
• base::spec::FlowInstanceSpec
• base::spec::ForEachOpSpec
• base::spec::FtsIndexDef
• base::spec::ImportOpSpec
• base::spec::IndexOptions
• base::spec::NamedSpec
• base::spec::OpArgBinding
• base::spec::OpArgName
• base::spec::OpSpec
• base::spec::ReactiveOpScope
• base::spec::SourceRefreshOptions
• base::spec::StructMapping
• base::spec::TransformOpSpec
• base::spec::TransientFlowSpec
• base::spec::VectorIndexDef
• base::value::FieldValues
• base::value::KeyValue
• base::value::RangeValue
• base::value::ScopeValue
• base::value::TypedFieldsValue
• base::value::TypedValue
• builder::AnalyzedFlow
• builder::AnalyzedTransientFlow
• builder::analyzer::OpScope
• builder::exec_ctx::AnalyzedSetupState
• builder::exec_ctx::AnalyzedTargetSetupState
• builder::exec_ctx::ExportOpExecutionContext
• builder::exec_ctx::FlowSetupExecutionContext
• builder::exec_ctx::ImportOpExecutionContext
• builder::flow_builder::DataCollector
• builder::flow_builder::DataSlice
• builder::flow_builder::DataType
• builder::flow_builder::Flow
• builder::flow_builder::FlowBuilder
• builder::flow_builder::OpScopeRef
• builder::flow_builder::TransientFlow
• builder::plan::AnalyzedCollectOp
• builder::plan::AnalyzedCollectorReference
• builder::plan::AnalyzedExportOp
• builder::plan::AnalyzedExportTargetOpGroup
• builder::plan::AnalyzedFieldReference
• builder::plan::AnalyzedForEachOp
• builder::plan::AnalyzedFunctionExecInfo
• builder::plan::AnalyzedImportOp
• builder::plan::AnalyzedLocalCollectorReference
• builder::plan::AnalyzedLocalFieldReference
• builder::plan::AnalyzedOpOutput
• builder::plan::AnalyzedOpScope
• builder::plan::AnalyzedStructMapping
• builder::plan::AnalyzedTransformOp
• builder::plan::ExecutionPlan
• builder::plan::FieldDefFingerprint
• builder::plan::TransientExecutionPlan
• execution::FlowLiveUpdater
• execution::FlowLiveUpdaterOptions
• execution::FlowLiveUpdaterUpdates
• execution::dumper::EvaluateAndDumpOptions
• execution::evaluator::EvaluateSourceEntryOutput
• execution::evaluator::ScopeValueBuilder
• execution::evaluator::SourceRowEvaluationContext
• lib_context::DbPools
• lib_context::FlowContext
• lib_context::FlowExecutionContext
• lib_context::LibContext
• lib_context::LibSetupContext
• lib_context::PersistenceContext
• lib_context::QueryHandlerContext
• ops::factory_bases::OpArgResolver
• ops::factory_bases::OpArgsResolver
• ops::factory_bases::ResolvedOpArg
• ops::factory_bases::SimpleFunctionAnalysisOutput
• ops::factory_bases::TypedExportDataCollectionBuildOutput
• ops::factory_bases::TypedExportDataCollectionSpec
• ops::factory_bases::TypedResourceSetupChangeItem
• ops::factory_bases::TypedTargetAttachmentState
• ops::interface::AttachmentSetupKey
• ops::interface::ExportDataCollectionBuildOutput
• ops::interface::ExportDataCollectionSpec
• ops::interface::ExportTargetDeleteEntry
• ops::interface::ExportTargetMutation
• ops::interface::ExportTargetMutationWithContext
• ops::interface::ExportTargetUpsertEntry
• ops::interface::FlowInstanceContext
• ops::interface::Ordinal
• ops::interface::PartialSourceRow
• ops::interface::PartialSourceRowData
• ops::interface::ResourceSetupChangeItem
• ops::interface::SimpleFunctionBuildOutput
• ops::interface::SourceChange
• ops::interface::SourceChangeMessage
• ops::interface::SourceExecutorReadOptions
• ops::interface::TargetAttachmentState
• ops::registry::ExecutorFactoryRegistry
• ops::sdk::EmptySpec
• ops::sdk::SchemaBuilderFieldRef
• ops::sdk::StructSchemaBuilder
• ops::sources::local_file::Factory
• ops::sources::local_file::Spec
• ops::sources::shared::pattern_matcher::PatternMatcher
• prelude::ApiError
• prelude::Arc
• prelude::BTreeMap
• prelude::BTreeSet
• prelude::DateTime
• prelude::HashMap
• prelude::HashSet
• prelude::IndexMap
• prelude::IndexSet
• prelude::LazyLock
• prelude::Mutex
• prelude::OnceLock
• prelude::RwLock
• prelude::Shared
• prelude::Span
• prelude::Utc
• prelude::Weak
• prelude::batching::Batcher
• prelude::batching::BatchingOptions
• prelude::concur_control::CombinedConcurrencyController
• prelude::concur_control::CombinedConcurrencyControllerPermit
• prelude::concur_control::ConcurrencyController
• prelude::concur_control::ConcurrencyControllerPermit
• prelude::concur_control::Options
• prelude::future::AbortHandle
• prelude::future::AbortRegistration
• prelude::future::Abortable
• prelude::future::Aborted
• prelude::future::AlwaysReady
• prelude::future::AndThen
• prelude::future::CatchUnwind
• prelude::future::ErrInto
• prelude::future::Flatten
• prelude::future::FlattenSink
• prelude::future::FlattenStream
• prelude::future::Fuse
• prelude::future::FutureObj
• prelude::future::Inspect
• prelude::future::InspectErr
• prelude::future::InspectOk
• prelude::future::IntoFuture
• prelude::future::IntoStream
• prelude::future::Join
• prelude::future::Join3
• prelude::future::Join4
• prelude::future::Join5
• prelude::future::JoinAll
• prelude::future::Lazy
• prelude::future::LocalFutureObj
• prelude::future::Map
• prelude::future::MapErr
• prelude::future::MapInto
• prelude::future::MapOk
• prelude::future::MapOkOrElse
• prelude::future::NeverError
• prelude::future::OkInto
• prelude::future::OptionFuture
• prelude::future::OrElse
• prelude::future::Pending
• prelude::future::PollFn
• prelude::future::PollImmediate
• prelude::future::Ready
• prelude::future::Remote
• prelude::future::RemoteHandle
• prelude::future::Select
• prelude::future::SelectAll
• prelude::future::SelectOk
• prelude::future::Shared
• prelude::future::Then
• prelude::future::TryFlatten
• prelude::future::TryFlattenStream
• prelude::future::TryJoin
• prelude::future::TryJoin3
• prelude::future::TryJoin4
• prelude::future::TryJoin5
• prelude::future::TryJoinAll
• prelude::future::TrySelect
• prelude::future::UnitError
• prelude::future::UnwrapOrElse
• prelude::future::WeakShared
• prelude::instrument::Instrumented
• prelude::instrument::WithDispatch
• prelude::retryable::Error
• prelude::retryable::RetryOptions
• prelude::sink::Buffer
• prelude::sink::Close
• prelude::sink::Drain
• prelude::sink::Fanout
• prelude::sink::Feed
• prelude::sink::Flush
• prelude::sink::Send
• prelude::sink::SendAll
• prelude::sink::SinkErrInto
• prelude::sink::SinkMapErr
• prelude::sink::Unfold
• prelude::sink::With
• prelude::sink::WithFlatMap
• prelude::stream::AbortHandle
• prelude::stream::AbortRegistration
• prelude::stream::Abortable
• prelude::stream::Aborted
• prelude::stream::All
• prelude::stream::AndThen
• prelude::stream::Any
• prelude::stream::BufferUnordered
• prelude::stream::Buffered
• prelude::stream::CatchUnwind
• prelude::stream::Chain
• prelude::stream::Chunks
• prelude::stream::Collect
• prelude::stream::Concat
• prelude::stream::Count
• prelude::stream::Cycle
• prelude::stream::Empty
• prelude::stream::Enumerate
• prelude::stream::ErrInto
• prelude::stream::Filter
• prelude::stream::FilterMap
• prelude::stream::FlatMap
• prelude::stream::FlatMapUnordered
• prelude::stream::Flatten
• prelude::stream::Fold
• prelude::stream::ForEach
• prelude::stream::ForEachConcurrent
• prelude::stream::Forward
• prelude::stream::Fuse
• prelude::stream::FuturesOrdered
• prelude::stream::FuturesUnordered
• prelude::stream::Inspect
• prelude::stream::InspectErr
• prelude::stream::InspectOk
• prelude::stream::IntoAsyncRead
• prelude::stream::IntoStream
• prelude::stream::Iter
• prelude::stream::Map
• prelude::stream::MapErr
• prelude::stream::MapOk
• prelude::stream::Next
• prelude::stream::NextIf
• prelude::stream::NextIfEq
• prelude::stream::Once
• prelude::stream::OrElse
• prelude::stream::Peek
• prelude::stream::PeekMut
• prelude::stream::Peekable
• prelude::stream::Pending
• prelude::stream::PollFn
• prelude::stream::PollImmediate
• prelude::stream::ReadyChunks
• prelude::stream::Repeat
• prelude::stream::RepeatWith
• prelude::stream::ReuniteError
• prelude::stream::Scan
• prelude::stream::Select
• prelude::stream::SelectAll
• prelude::stream::SelectNextSome
• prelude::stream::SelectWithStrategy
• prelude::stream::Skip
• prelude::stream::SkipWhile
• prelude::stream::SplitSink
• prelude::stream::SplitStream
• prelude::stream::StreamFuture
• prelude::stream::Take
• prelude::stream::TakeUntil
• prelude::stream::TakeWhile
• prelude::stream::Then
• prelude::stream::TryAll
• prelude::stream::TryAny
• prelude::stream::TryBufferUnordered
• prelude::stream::TryBuffered
• prelude::stream::TryChunks
• prelude::stream::TryChunksError
• prelude::stream::TryCollect
• prelude::stream::TryConcat
• prelude::stream::TryFilter
• prelude::stream::TryFilterMap
• prelude::stream::TryFlatten
• prelude::stream::TryFlattenUnordered
• prelude::stream::TryFold
• prelude::stream::TryForEach
• prelude::stream::TryForEachConcurrent
• prelude::stream::TryNext
• prelude::stream::TryReadyChunks
• prelude::stream::TryReadyChunksError
• prelude::stream::TrySkipWhile
• prelude::stream::TryTakeWhile
• prelude::stream::TryUnfold
• prelude::stream::Unfold
• prelude::stream::Unzip
• prelude::stream::Zip
• prelude::stream::futures_unordered::FuturesUnordered
• prelude::stream::futures_unordered::IntoIter
• prelude::stream::futures_unordered::Iter
• prelude::stream::futures_unordered::IterMut
• prelude::stream::futures_unordered::IterPinMut
• prelude::stream::futures_unordered::IterPinRef
• prelude::stream::select_all::IntoIter
• prelude::stream::select_all::Iter
• prelude::stream::select_all::IterMut
• prelude::stream::select_all::SelectAll
• server::ServerSettings
• settings::DatabaseConnectionSpec
• settings::GlobalExecutionOptions
• settings::Settings
• setup::AllSetupStates
• setup::AttachmentsSetupChange
• setup::AuthRegistry
• setup::CombinedState
• setup::DesiredMode
• setup::ExistingMode
• setup::FlowSetupChange
• setup::FlowSetupMetadata
• setup::FlowSetupState
• setup::FormattedFlowSetupChange
• setup::GlobalSetupChange
• setup::ObjectSetupChangeCode
• setup::ResourceIdentifier
• setup::ResourceSetupInfo
• setup::SetupChangeBundle
• setup::SourceSetupState
• setup::TargetSetupChange
• setup::TargetSetupState
• setup::TargetSetupStateCommon
• setup::components::SetupChange

Enums

• base::schema::BasicValueType
• base::schema::TableKind
• base::schema::ValueType
• base::spec::OutputMode
• base::spec::ReactiveOpSpec
• base::spec::ValueMapping
• base::spec::VectorIndexMethod
• base::spec::VectorSimilarityMetric
• base::value::BasicValue
• base::value::KeyPart
• base::value::Value
• builder::plan::AnalyzedPrimaryKeyDef
• builder::plan::AnalyzedReactiveOp
• builder::plan::AnalyzedValueMapping
• ops::interface::ExecutorFactory
• ops::interface::SetupStateCompatibility
• ops::interface::SourceValue
• prelude::Cow
• prelude::Error
• prelude::future::Either
• prelude::future::MaybeDone
• prelude::future::TryMaybeDone
• prelude::stream::PollNext
• setup::ChangeDescription
• setup::FlowSetupChangeAction
• setup::ObjectStatus
• setup::SetupChangeType
• setup::StateChange

Traits

• base::schema::TypeCore
• base::spec::SpecFormatter
• base::value::EstimatedByteSize
• ops::factory_bases::BatchedFunctionExecutor
• ops::factory_bases::ResolvedOpArgExt
• ops::factory_bases::SimpleFunctionFactoryBase
• ops::factory_bases::SourceFactoryBase
• ops::factory_bases::TargetFactoryBase
• ops::factory_bases::TargetSpecificAttachmentFactoryBase
• ops::interface::AttachmentSetupChange
• ops::interface::SimpleFunctionExecutor
• ops::interface::SimpleFunctionFactory
• ops::interface::SourceExecutor
• ops::interface::SourceFactory
• ops::interface::TargetAttachmentFactory
• ops::interface::TargetFactory
• prelude::Any
• prelude::AsyncBufRead
• prelude::AsyncRead
• prelude::AsyncSeek
• prelude::AsyncWrite
• prelude::ContextExt
• prelude::Debug
• prelude::Deserialize
• prelude::DeserializeOwned
• prelude::Future
• prelude::FutureExt
• prelude::Hash
• prelude::Itertools
• prelude::Serialize
• prelude::Sink
• prelude::Stream
• prelude::StreamExt
• prelude::TryFuture
• prelude::TryStream
• prelude::_
• prelude::batching::Runner
• prelude::future::FusedFuture
• prelude::future::Future
• prelude::future::FutureExt
• prelude::future::TryFuture
• prelude::future::TryFutureExt
• prelude::future::UnsafeFutureObj
• prelude::instrument::Instrument
• prelude::instrument::WithSubscriber
• prelude::retryable::IsRetryable
• prelude::sink::Sink
• prelude::sink::SinkExt
• prelude::stream::FusedStream
• prelude::stream::Stream
• prelude::stream::StreamExt
• prelude::stream::TryStream
• prelude::stream::TryStreamExt
• setup::ObjectSetupChange
• setup::ResourceSetupChange
• setup::StateMode
• setup::components::SetupOperator
• setup::components::State

Macros

• fields_value
• prelude::api_bail
• prelude::api_error
• prelude::client_bail
• prelude::client_error
• prelude::debug
• prelude::error
• prelude::info
• prelude::info_span
• prelude::internal_bail
• prelude::internal_error
• prelude::stream
• prelude::trace
• prelude::try_stream
• prelude::warn

Attribute Macros

• prelude::async_trait
• prelude::instrument

Derive Macros

• prelude::Debug
• prelude::Deserialize
• prelude::Hash
• prelude::Serialize

Functions

• base::duration::parse_duration
• base::json_schema::build_json_schema
• base::schema::make_output_type
• base::value::test_util::serde_roundtrip
• builder::analyzer::analyze_flow
• builder::analyzer::analyze_transient_flow
• builder::analyzer::build_flow_instance_context
• builder::exec_ctx::build_flow_setup_execution_context
• execution::dumper::evaluate_and_dump
• execution::evaluator::evaluate_source_entry
• execution::evaluator::evaluate_transient_flow
• lib_context::clear_lib_context
• lib_context::create_lib_context
• lib_context::get_auth_registry
• lib_context::get_lib_context
• lib_context::get_runtime
• lib_context::init_lib_context
• lib_context::set_settings_fn
• ops::get_attachment_factory
• ops::get_function_factory
• ops::get_optional_attachment_factory
• ops::get_optional_function_factory
• ops::get_optional_source_factory
• ops::get_optional_target_factory
• ops::get_source_factory
• ops::get_target_factory
• ops::register_factory
• prelude::future::abortable
• prelude::future::always_ready
• prelude::future::err
• prelude::future::join
• prelude::future::join3
• prelude::future::join4
• prelude::future::join5
• prelude::future::join_all
• prelude::future::lazy
• prelude::future::maybe_done
• prelude::future::ok
• prelude::future::pending
• prelude::future::poll_fn
• prelude::future::poll_immediate
• prelude::future::ready
• prelude::future::select
• prelude::future::select_all
• prelude::future::select_ok
• prelude::future::try_join
• prelude::future::try_join3
• prelude::future::try_join4
• prelude::future::try_join5
• prelude::future::try_join_all
• prelude::future::try_maybe_done
• prelude::future::try_select
• prelude::http::request
• prelude::invariance_violation
• prelude::retryable::Ok
• prelude::retryable::run
• prelude::sink::drain
• prelude::sink::unfold
• prelude::stream::abortable
• prelude::stream::empty
• prelude::stream::iter
• prelude::stream::once
• prelude::stream::pending
• prelude::stream::poll_fn
• prelude::stream::poll_immediate
• prelude::stream::repeat
• prelude::stream::repeat_with
• prelude::stream::select
• prelude::stream::select_all
• prelude::stream::select_all::select_all
• prelude::stream::select_with_strategy
• prelude::stream::try_unfold
• prelude::stream::unfold
• server::init_server
• setup::components::apply_component_changes
• setup::diff_flow_setup_states
• setup::flow_features::default_features
• setup::get_existing_setup_state

Type Aliases

• base::spec::FieldName
• base::spec::ScopeName
• prelude::BoxFuture
• prelude::BoxStream
• prelude::Result
• prelude::future::BoxFuture
• prelude::future::LocalBoxFuture
• prelude::retryable::Result
• prelude::stream::BoxStream
• prelude::stream::FlattenUnordered
• prelude::stream::LocalBoxStream

Statics

• base::field_attrs::CHUNK_BASE_TEXT
• base::field_attrs::COCOINDEX_PREFIX
• base::field_attrs::CONTENT_FILENAME
• base::field_attrs::CONTENT_MIME_TYPE
• base::field_attrs::_EMBEDDING_ORIGIN_TEXT
• prelude::concur_control::BYTES_UNKNOWN_YET
• prelude::retryable::HEAVY_LOADED_OPTIONS

Constants

• base::spec::ROOT_SCOPE_NAME
• prelude::retryable::DEFAULT_RETRY_TIMEOUT
• setup::flow_features::FAST_FINGERPRINT
• setup::flow_features::SOURCE_STATE_TABLE