Trait launchdarkly_server_sdk::EventProcessor

pub trait EventProcessor: Send + Sync {
    fn send(&self, event: InputEvent);
    fn flush(&self);
    fn close(&self);
}

Trait for the component that buffers analytics events and sends them to LaunchDarkly. This component can be replaced for testing purposes.

Required Methods

fn send(&self, event: InputEvent)

Records an InputEvent asynchronously. Depending on the feature flag properties and event properties, this may be transmitted to the events service as an individual event, or may only be added into summary data.

fn flush(&self)

Specifies that any buffered events should be sent as soon as possible, rather than waiting for the next flush interval. This method is asynchronous, so events still may not be sent until a later time.

fn close(&self)

Shuts down all event processor activity, after first ensuring that all events have been delivered. Subsequent calls to EventProcessor::send or EventProcessor::flush will be ignored.

Implementors