List of all items

Structs

• BadEvent
• Envelope
• EventEnvelope
• NoMessage
• NotAnEventEnvelope
• consumer::GrpcSourceProvider
• producer::GrpcEventFlow
• producer::GrpcEventProcessor
• producer::Transformation
• proto::ConsumeEventIn
• proto::ConsumeEventOut
• proto::ConsumerEventAck
• proto::ConsumerEventInit
• proto::ConsumerEventStart
• proto::EntityIdOffset
• proto::Event
• proto::EventTimestampRequest
• proto::EventTimestampResponse
• proto::ExcludeEntityIds
• proto::ExcludeRegexEntityIds
• proto::ExcludeTags
• proto::FilterCriteria
• proto::FilterReq
• proto::FilteredEvent
• proto::IncludeEntityIds
• proto::IncludeRegexEntityIds
• proto::IncludeTags
• proto::IncludeTopics
• proto::InitReq
• proto::KeepAlive
• proto::LoadEventRequest
• proto::LoadEventResponse
• proto::Offset
• proto::PersistenceIdSeqNr
• proto::RemoveExcludeEntityIds
• proto::RemoveExcludeRegexEntityIds
• proto::RemoveExcludeTags
• proto::RemoveIncludeEntityIds
• proto::RemoveIncludeRegexEntityIds
• proto::RemoveIncludeTags
• proto::RemoveIncludeTopics
• proto::ReplayReq
• proto::ReplicaInfo
• proto::StreamIn
• proto::StreamOut
• proto::event_consumer_service_client::EventConsumerServiceClient
• proto::event_consumer_service_server::EventConsumerServiceServer
• proto::event_producer_service_client::EventProducerServiceClient
• proto::event_producer_service_server::EventProducerServiceServer

Enums

• proto::consume_event_in::Message
• proto::consume_event_out::Message
• proto::filter_criteria::Message
• proto::load_event_response::Message
• proto::stream_in::Message
• proto::stream_out::Message

Traits

• proto::event_consumer_service_server::EventConsumerService
• proto::event_producer_service_server::EventProducerService

Functions

• producer::task

Type Aliases

• OriginId
• StreamId