Trait ate::sink::EventSink[−][src]

pub trait EventSink {
    fn feed(
        &mut self, 
        _header: &EventHeader, 
        _conversation: Option<&Arc<ConversationSession>>
    ) -> Result<(), SinkError> { ... }
    fn reset(&mut self) { ... }
}

Provided methods

`fn feed( &mut self, _header: &EventHeader, _conversation: Option<&Arc<ConversationSession>> ) -> Result<(), SinkError>`[src]

`fn reset(&mut self)`[src]

Loading content...

Implementors

`impl EventSink for AntiReplayPlugin`[src]

`fn feed( &mut self, header: &EventHeader, _conversation: Option<&Arc<ConversationSession>> ) -> Result<(), SinkError>`[src]

`fn reset(&mut self)`[src]

`impl EventSink for IndecisiveCompactor`[src]

`fn reset(&mut self)`[src]

`impl EventSink for RemoveDuplicatesCompactor`[src]

`fn feed( &mut self, header: &EventHeader, _conversation: Option<&Arc<ConversationSession>> ) -> Result<(), SinkError>`[src]

`fn reset(&mut self)`[src]

`impl EventSink for TombstoneCompactor`[src]

`fn feed( &mut self, header: &EventHeader, _conversation: Option<&Arc<ConversationSession>> ) -> Result<(), SinkError>`[src]

`fn reset(&mut self)`[src]

`impl EventSink for UselessIndexer`[src]

`impl EventSink for SignaturePlugin`[src]

`fn feed( &mut self, header: &EventHeader, conversation: Option<&Arc<ConversationSession>> ) -> Result<(), SinkError>`[src]

`fn reset(&mut self)`[src]

`impl EventSink for TimestampEnforcer`[src]

`fn feed( &mut self, header: &EventHeader, _conversation: Option<&Arc<ConversationSession>> ) -> Result<(), SinkError>`[src]

`fn reset(&mut self)`[src]

`impl EventSink for TreeAuthorityPlugin`[src]

`fn feed( &mut self, header: &EventHeader, conversation: Option<&Arc<ConversationSession>> ) -> Result<(), SinkError>`[src]

`fn reset(&mut self)`[src]

`impl EventSink for TreeCompactor`[src]

`fn feed( &mut self, header: &EventHeader, _conversation: Option<&Arc<ConversationSession>> ) -> Result<(), SinkError>`[src]

Loading content...

Trait ate::sink::EventSink[−][src]

Provided methods

fn feed( &mut self, _header: &EventHeader, _conversation: Option<&Arc<ConversationSession>>) -> Result<(), SinkError>[src]

fn reset(&mut self)[src]

Implementors

impl EventSink for AntiReplayPlugin[src]

fn feed( &mut self, header: &EventHeader, _conversation: Option<&Arc<ConversationSession>>) -> Result<(), SinkError>[src]

fn reset(&mut self)[src]

impl EventSink for IndecisiveCompactor[src]

fn reset(&mut self)[src]

impl EventSink for RemoveDuplicatesCompactor[src]

fn feed( &mut self, header: &EventHeader, _conversation: Option<&Arc<ConversationSession>>) -> Result<(), SinkError>[src]

fn reset(&mut self)[src]

impl EventSink for TombstoneCompactor[src]

fn feed( &mut self, header: &EventHeader, _conversation: Option<&Arc<ConversationSession>>) -> Result<(), SinkError>[src]

fn reset(&mut self)[src]

impl EventSink for UselessIndexer[src]

impl EventSink for SignaturePlugin[src]

fn feed( &mut self, header: &EventHeader, conversation: Option<&Arc<ConversationSession>>) -> Result<(), SinkError>[src]

fn reset(&mut self)[src]

impl EventSink for TimestampEnforcer[src]

fn feed( &mut self, header: &EventHeader, _conversation: Option<&Arc<ConversationSession>>) -> Result<(), SinkError>[src]

fn reset(&mut self)[src]

impl EventSink for TreeAuthorityPlugin[src]

fn feed( &mut self, header: &EventHeader, conversation: Option<&Arc<ConversationSession>>) -> Result<(), SinkError>[src]

fn reset(&mut self)[src]

impl EventSink for TreeCompactor[src]

fn feed( &mut self, header: &EventHeader, _conversation: Option<&Arc<ConversationSession>>) -> Result<(), SinkError>[src]

`fn feed( &mut self, _header: &EventHeader, _conversation: Option<&Arc<ConversationSession>> ) -> Result<(), SinkError>`[src]

`fn reset(&mut self)`[src]

`impl EventSink for AntiReplayPlugin`[src]

`fn feed( &mut self, header: &EventHeader, _conversation: Option<&Arc<ConversationSession>> ) -> Result<(), SinkError>`[src]

`fn reset(&mut self)`[src]

`impl EventSink for IndecisiveCompactor`[src]

`fn reset(&mut self)`[src]

`impl EventSink for RemoveDuplicatesCompactor`[src]

`fn feed( &mut self, header: &EventHeader, _conversation: Option<&Arc<ConversationSession>> ) -> Result<(), SinkError>`[src]

`fn reset(&mut self)`[src]

`impl EventSink for TombstoneCompactor`[src]

`fn feed( &mut self, header: &EventHeader, _conversation: Option<&Arc<ConversationSession>> ) -> Result<(), SinkError>`[src]

`fn reset(&mut self)`[src]

`impl EventSink for UselessIndexer`[src]

`impl EventSink for SignaturePlugin`[src]

`fn feed( &mut self, header: &EventHeader, conversation: Option<&Arc<ConversationSession>> ) -> Result<(), SinkError>`[src]

`fn reset(&mut self)`[src]

`impl EventSink for TimestampEnforcer`[src]

`fn feed( &mut self, header: &EventHeader, _conversation: Option<&Arc<ConversationSession>> ) -> Result<(), SinkError>`[src]

`fn reset(&mut self)`[src]

`impl EventSink for TreeAuthorityPlugin`[src]

`fn feed( &mut self, header: &EventHeader, conversation: Option<&Arc<ConversationSession>> ) -> Result<(), SinkError>`[src]

`fn reset(&mut self)`[src]

`impl EventSink for TreeCompactor`[src]

`fn feed( &mut self, header: &EventHeader, _conversation: Option<&Arc<ConversationSession>> ) -> Result<(), SinkError>`[src]