Enum LogClientMessage

pub enum LogClientMessage {
    SetAggregate {
        aggregate_window_sec: Option<u64>,
    },
    StartSyncFlush {
        expected_procs: usize,
        reply: OncePortRef<()>,
        version: OncePortRef<u64>,
    },
}

Messages that can be sent to the LogClient locally.

Variants

SetAggregate

Fields

aggregate_window_sec: Option<u64>

The time window in seconds to aggregate logs. If None, aggregation is disabled.

StartSyncFlush

Synchronously flush all the logs from all the procs. This is for client to call.

Fields

expected_procs: usize

Expect these many procs to ack the flush message.

reply: OncePortRef<()>

Return once we have received the acks from all the procs

version: OncePortRef<u64>

Return to the caller the current flush version

Trait Implementations

impl Clone for LogClientMessage

fn clone(&self) -> LogClientMessage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for LogClientMessage

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for LogClientMessage

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Handler<LogClientMessage> for LogClientActor

fn handle<'life0, 'life1, 'async_trait>( &'life0 mut self, cx: &'life1 Context<'_, Self>, message: LogClientMessage, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Handle the next M-typed message.

impl Named for LogClientMessage

fn typename() -> &'static str

The globally unique type name for the type. This should typically be the fully qualified Rust name of the type.

fn typehash() -> u64

A globally unique hash for this type. TODO: actually enforce perfect hashing

fn arm(&self) -> Option<&'static str>

If the named type is an enum, this returns the name of the arm of the value self.

fn typeid() -> TypeId

The TypeId for this type. TypeIds are unique only within a binary, and should not be used for global identification.

fn port() -> u64

The globally unique port for this type. Typed ports are in the range of 1<<63..1<<64-1.

unsafe fn arm_unchecked(self_: *const ()) -> Option<&'static str>

An unsafe version of ‘arm’, accepting a pointer to the value, for use in type-erased settings.

impl Serialize for LogClientMessage

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl RemoteHandles<LogClientMessage> for LogClientActor