List of all items

Structs

• catalog::Catalog
• connector::sink::SinkRecord
• connector::source::SourceBatch
• connector::source::SourceEmitter
• ffi::arena::Arena
• ffi::wrapper::OperatorWrapper
• flow::builder::ChangeBuilder
• operator::builder::ColumnBuilder
• operator::builder::ColumnsBuilder
• operator::builder::CommittedColumn
• operator::change::BorrowedChange
• operator::change::BorrowedColumn
• operator::change::BorrowedColumns
• operator::change::BorrowedDiff
• operator::column::OperatorColumn
• operator::context::OperatorContext
• operator::diff::DiffStart
• operator::diff::InsertDiff
• operator::diff::RemoveDiff
• operator::diff::UpdateDiff
• operator::view_column::BoolIter
• operator::view_column::ColumnView
• operator::view_column::DecimalIter
• operator::view_row::RowView
• procedure::FFIProcedureContext
• procedure::wrapper::ProcedureWrapper
• state::State
• state::cache::StateCache
• state::row::RowNumberProvider
• store::Store
• testing::assertions::ChangeAssertion
• testing::assertions::DiffAssertion
• testing::assertions::RowAssertion
• testing::assertions::StateAssertion
• testing::builders::TestChangeBuilder
• testing::builders::TestLayoutBuilder
• testing::builders::TestRowBuilder
• testing::context::TestContext
• testing::harness::OperatorTestHarness
• testing::harness::TestHarnessBuilder
• testing::harness::TestMetadataHarness
• testing::registry::Active
• testing::registry::Committed
• testing::registry::EmittedDiff
• testing::registry::TestBuilderRegistry
• testing::state::TestStateStore
• testing::stateful::KeyedStatefulTestHelper
• testing::stateful::SingleStatefulTestHelper
• testing::stateful::WindowStatefulTestHelper
• transform::context::FFITransformContext
• transform::wrapper::TransformWrapper

Enums

• connector::sink::SinkDiffType
• connector::source::SourceMode
• error::FFIError

Traits

• connector::sink::FFISink
• connector::sink::FFISinkMetadata
• connector::sink::FFISinkWithMetadata
• connector::source::FFISource
• connector::source::FFISourceMetadata
• connector::source::FFISourceWithMetadata
• operator::FFIOperator
• operator::FFIOperatorMetadata
• operator::FFIOperatorWithMetadata
• procedure::FFIProcedure
• procedure::FFIProcedureMetadata
• procedure::FFIProcedureWithMetadata
• state::FFIRawStatefulOperator
• state::keyed::FFIKeyedStateful
• state::single::FFISingleStateful
• state::window::FFIWindowStateful
• testing::assertions::Assertable
• transform::FFITransform
• transform::FFITransformMetadata
• transform::FFITransformWithMetadata

Functions

• ffi::exports::create_descriptor
• ffi::exports::create_operator_instance
• ffi::exports::operator_magic
• ffi::wrapper::create_vtable
• ffi::wrapper::ffi_apply
• ffi::wrapper::ffi_destroy
• ffi::wrapper::ffi_flush_state
• ffi::wrapper::ffi_pull
• ffi::wrapper::ffi_tick
• marshal::wasm::marshal_columns_to_bytes
• marshal::wasm::unmarshal_columns_from_bytes
• procedure::exports::create_procedure_descriptor
• procedure::exports::create_procedure_instance
• procedure::exports::procedure_magic
• procedure::wrapper::create_procedure_vtable
• procedure::wrapper::ffi_procedure_call
• procedure::wrapper::ffi_procedure_destroy
• state::utils::empty_key
• state::utils::load_or_create_row
• state::utils::save_row
• testing::builders::helpers::batch_insert_change
• testing::builders::helpers::counter_layout
• testing::builders::helpers::empty_change
• testing::builders::helpers::insert_change
• testing::builders::helpers::int_row
• testing::builders::helpers::key_value_layout
• testing::builders::helpers::key_value_row
• testing::builders::helpers::named_key_value_layout
• testing::callbacks::create_test_callbacks
• testing::helpers::encode_key
• testing::helpers::get_values
• testing::registry::into_diffs
• testing::registry::with_registry
• testing::stateful::scenarios::counter_inserts
• testing::stateful::scenarios::grouped_inserts
• testing::stateful::scenarios::state_updates
• testing::stateful::scenarios::windowed_events
• transform::exports::create_transform_descriptor
• transform::exports::create_transform_instance
• transform::exports::transform_magic
• transform::wrapper::create_transform_vtable
• transform::wrapper::ffi_transform
• transform::wrapper::ffi_transform_destroy

Type Aliases

• error::Result
• operator::change::DiffKind