Struct KvEventPublishers 

pub struct KvEventPublishers { /* private fields */ }

Shared KV event publisher bundle used by schedulers and KV managers.

Implementations

impl KvEventPublishers

pub fn new( event_sink: Option<Arc<dyn KvCacheEventSink>>, raw_sink: Option<Arc<dyn RawKvEventSink>>, ) -> Self

pub fn raw_enabled(&self) -> bool

pub fn is_empty(&self) -> bool

pub fn publish( &self, event: KvCacheEvent, block_token_ids: Option<&[Vec<u32>]>, ) -> Result<()>

pub fn publish_with_storage_tier( &self, event: KvCacheEvent, block_token_ids: Option<&[Vec<u32>]>, storage_tier: StorageTier, ) -> Result<()>

Trait Implementations

impl Clone for KvEventPublishers

fn clone(&self) -> KvEventPublishers

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for KvEventPublishers

fn default() -> KvEventPublishers

Returns the “default value” for a type.