Trait CompactorStreamEvent

pub trait CompactorStreamEvent:
    Send
    + Sync
    + 'static {
    type EventType: Send + Sync + 'static;

    // Required methods
    fn take_event(self) -> Self::EventType;
    fn create_at(&self) -> u64;
}

Required Associated Types

type EventType: Send + Sync + 'static

Required Methods

fn take_event(self) -> Self::EventType

fn create_at(&self) -> u64

Implementations on Foreign Types

impl CompactorStreamEvent for SubscribeCompactionEventRequest

type EventType = Event

fn take_event(self) -> Self::EventType

fn create_at(&self) -> u64

impl CompactorStreamEvent for SubscribeIcebergCompactionEventRequest

type EventType = Event

fn take_event(self) -> Self::EventType

fn create_at(&self) -> u64

Implementors