List of all items

Structs

• AdminBackendSummary
• AdminCheckpointSummary
• AdminHandlerSummary
• AdminSnapshot
• AdminTopicSummary
• BackendCapabilities
• BackendContext
• ConsoleOpsLog
• Envelope
• Event
• FluvioConfig
• FluvioStoragePort
• FluvioStoragePortBuilder
• GenericPhotonBackend
• GroupOpts
• HandlerCtx
• HandlerDescriptor
• HandlerRegistry
• InProcStoragePort
• JsonActor
• JsonIdentityFactory
• KafkaConfig
• KafkaStoragePort
• KafkaStoragePortBuilder
• NatsConfig
• NatsStoragePort
• NatsStoragePortBuilder
• NoOpsLog
• Photon
• PhotonBuilder
• PhotonRuntimeState
• ShardConfig
• SqliteStoragePort
• SubscribeOpts
• Subscription
• SubscriptionHandle
• TopicDescriptor
• TopicMetadata
• TopicRegistry
• TransportCrypto
• backend::BackendCapabilities
• backend::BackendContext
• backend::GenericPhotonBackend
• backend_instrumentation::InstrumentedPhotonBackend
• backend_instrumentation::PhotonDlqRow
• checkpoint::CheckpointCoalescer
• consumer_group::ConsumerLease
• consumer_group::FleetGroupCoordinator
• consumer_group::GroupMember
• consumer_group::MemoryLeaseStore
• consumer_group::StaticAssignmentConfig
• consumer_group::StaticGroupCoordinator
• delivery::DlqRecord
• delivery::DlqRecordParams
• delivery::DlqSink
• delivery::WorkerPool
• delivery_mode::ShardConfig
• descriptor::TopicDescriptor
• event::TransportCrypto
• handler_ctx::HandlerCtx
• handler_descriptor::HandlerDescriptor
• handler_registry::HandlerRegistry
• host::PhotonRuntimeParts
• instrumentation::InstrumentedPhotonBackend
• instrumentation::PhotonDlqRow
• models::Envelope
• models::Event
• models::GroupOpts
• models::SubscribeOpts
• models::Subscription
• models::SubscriptionHandle
• models::TopicMetadata
• prelude::Event
• prelude::HandlerCtx
• prelude::JsonActor
• prelude::JsonIdentityFactory
• prelude::Photon
• prelude::PhotonBuilder
• prelude::SubscribeOpts
• prelude::SubscriptionHandle
• prelude::TopicDescriptor
• registry::TopicRegistry
• runtime_parts::PhotonRuntimeParts
• storage::InProcStoragePort
• storage::StorageCapabilities

Enums

• DeliveryMode
• FluvioReplayCursor
• IdentityError
• KafkaReplayCursor
• PhotonError
• ReplayCursor
• SubscriptionMode
• backend_instrumentation::FailureReason
• delivery_mode::DeliveryMode
• error::PhotonError
• instrumentation::FailureReason
• models::SubscriptionMode

Traits

• Actor
• IdentityFactory
• OpsLog
• PhotonBackend
• StoragePort
• backend::PhotonBackend
• consumer_group::ConsumerGroupCoordinator
• consumer_group::LeaseStore
• prelude::Actor
• prelude::IdentityFactory
• storage::StoragePort

Macros

• actor_downcast_methods
• prelude::actor_downcast_methods

Attribute Macros

• prelude::subscribe
• prelude::topic
• subscribe
• topic

Functions

• backend_instrumentation::dlq_fields
• backend_instrumentation::log_ops
• backend_instrumentation::ops_log_fields
• backend_instrumentation::record_drain
• backend_instrumentation::record_handler_failure
• backend_instrumentation::record_publish
• backend_instrumentation::record_publish_error
• backend_instrumentation::record_retention_reclaim
• backend_instrumentation::record_retention_safe_seq
• backend_instrumentation::wrap_backend
• collect_admin_snapshot
• configure
• consumer_group::instance_id_from_env
• consumer_group::member_count_from_env
• consumer_group::parse_shard_assignment
• consumer_group::round_robin_shards_for_member
• consumer_group::shard_count_from_env
• consumer_group::static_assigned_shards
• consumer_group_for
• default
• durable_consumer_name
• fluvio_consumer_group_for
• fluvio_durable_consumer_name
• fluvio_endpoint_from_env
• host::build_photon_parts
• install_ops_log
• instrumentation::dlq_fields
• instrumentation::log_ops
• instrumentation::ops_log_fields
• instrumentation::record_drain
• instrumentation::record_handler_failure
• instrumentation::record_publish
• instrumentation::record_publish_error
• instrumentation::wrap_backend
• kafka_brokers_from_env
• ops_log
• prelude::configure
• resolve_photon_remote_base_url
• runtime_parts::build_photon_parts
• shard_router::group_publish_storage_key
• shard_router::is_shard_storage_key
• shard_router::parse_shard_storage_key
• shard_router::routing_key
• shard_router::shard_id
• shard_router::shard_storage_key
• sqlite_path_from_env
• storage::topic_filter_matches

Type Aliases

• EmbeddedBackend
• Result
• backend::EmbeddedBackend
• error::Result
• handler_descriptor::HandlerInvoker
• prelude::Result

Constants

• FLUVIO_ENDPOINT_ENV
• FLUVIO_MAX_INFLIGHT_ENV
• FLUVIO_PREFIX_ENV
• FLUVIO_REPLAY_CURSOR_ENV
• FLUVIO_REPLICAS_ENV
• FLUVIO_RETENTION_ENV
• FLUVIO_SYNC_ACK_ENV
• FLUVIO_TOPIC_SHARDS_ENV
• KAFKA_BROKERS_ENV
• KAFKA_MAX_INFLIGHT_ENV
• KAFKA_PREFIX_ENV
• KAFKA_REPLAY_CURSOR_ENV
• KAFKA_REPLICAS_ENV
• KAFKA_RETENTION_ENV
• KAFKA_SYNC_ACK_ENV
• KAFKA_TOPIC_SHARDS_ENV
• MAX_INFLIGHT_ENV
• NATS_RETENTION_ENV
• NATS_STREAM_ENV
• NATS_STREAM_SHARDS_ENV
• NATS_URL_ENV
• REPLAY_CURSOR_ENV
• SQLITE_PATH_ENV
• SYNC_ACK_ENV
• shard_router::SHARD_KEY_PREFIX