List of all items

Structs

• context::PersistentEventContext
• context::ProcedureEventInput
• error::InsertEventsSnafu
• error::KvBackendSnafu
• error::MismatchedSchemaSnafu
• error::SerializeEventSnafu
• event_table::EventTableColumn
• recorder::EventHandlerOptions
• recorder::EventProcessor
• recorder::EventRecorderImpl
• recorder::EventRecorderOptions

Enums

• context::TriggerReason
• error::Error
• recorder::EventTypeFilter

Traits

• recorder::Event
• recorder::EventHandler
• recorder::EventRecorder
• recorder::Eventable

Functions

• event_table::base_column_schemas
• event_table::column_schemas
• event_table::jsonb_value
• event_table::nullable_json
• event_table::nullable_string
• event_table::nullable_value
• event_table::procedure_event_column_schemas
• recorder::build_row_inserts_request
• recorder::default_events_table_ttl
• recorder::deserialize_event_types
• recorder::event_type_filter_is_all
• recorder::group_events_by_type
• recorder::serialize_event_types
• recorder::validate_events

Type Aliases

• error::Result
• recorder::EventRecorderRef
• recorder::EventTypeFilterRef

Constants

• event_table::ACTOR_COLUMN
• event_table::ADMIN_FUNCTION_NAME_COLUMN
• event_table::ADMIN_FUNCTION_OUTPUT_COLUMN
• event_table::ADMIN_FUNCTION_STATUS_COLUMN
• event_table::CATALOG_NAME_COLUMN
• event_table::EVENT_CONTEXT_COLUMN
• event_table::FLOW_ID_COLUMN
• event_table::FLOW_NAME_COLUMN
• event_table::GC_REPORT_COLUMN
• event_table::LATEST_OFFSET_COLUMN
• event_table::PARENT_PROCEDURE_ID_COLUMN
• event_table::PAYLOAD_COLUMN
• event_table::PHYSICAL_TABLE_ID_COLUMN
• event_table::PROCEDURE_ERROR_COLUMN
• event_table::PROCEDURE_ID_COLUMN
• event_table::PROCEDURE_STATE_COLUMN
• event_table::PROCEDURE_TRIGGER_COLUMN
• event_table::PRUNABLE_ENTRY_ID_COLUMN
• event_table::REGION_ID_COLUMN
• event_table::REGION_MIGRATION_DST_NODE_ID_COLUMN
• event_table::REGION_MIGRATION_DST_PEER_ADDR_COLUMN
• event_table::REGION_MIGRATION_SRC_NODE_ID_COLUMN
• event_table::REGION_MIGRATION_SRC_PEER_ADDR_COLUMN
• event_table::REGION_MIGRATION_TRIGGER_REASON_COLUMN
• event_table::REGION_NUMBER_COLUMN
• event_table::REPARTITION_GROUP_ID_COLUMN
• event_table::SCHEMA_NAME_COLUMN
• event_table::SOURCE_PARTITION_EXPR_COLUMN
• event_table::SOURCE_REGION_ID_COLUMN
• event_table::SOURCE_REGION_NUMBER_COLUMN
• event_table::TABLE_ID_COLUMN
• event_table::TABLE_NAME_COLUMN
• event_table::TARGET_PARTITION_EXPR_COLUMN
• event_table::TARGET_REGION_ID_COLUMN
• event_table::TARGET_REGION_NUMBER_COLUMN
• event_table::TIMESTAMP_COLUMN
• event_table::TOPIC_NAME_COLUMN
• event_table::TYPE_COLUMN
• event_table::VIEW_ID_COLUMN
• event_table::VIEW_NAME_COLUMN
• recorder::DEFAULT_BUFFER_SIZE
• recorder::DEFAULT_CHANNEL_SIZE
• recorder::DEFAULT_COMPACTION_TIME_WINDOW
• recorder::DEFAULT_EVENTS_TABLE_NAME
• recorder::DEFAULT_EVENTS_TABLE_TTL
• recorder::DEFAULT_FLUSH_INTERVAL_SECONDS
• recorder::DEFAULT_MAX_RETRY_TIMES
• recorder::EVENTS_TABLE_PAYLOAD_COLUMN_NAME
• recorder::EVENTS_TABLE_TIMESTAMP_COLUMN_NAME
• recorder::EVENTS_TABLE_TYPE_COLUMN_NAME