Struct relay_metrics::AggregatorService
source · pub struct AggregatorService { /* private fields */ }
Expand description
Service implementing the Aggregator
interface.
Implementations§
source§impl AggregatorService
impl AggregatorService
sourcepub fn new(
config: AggregatorServiceConfig,
receiver: Option<Recipient<FlushBuckets, NoResponse>>
) -> Self
pub fn new( config: AggregatorServiceConfig, receiver: Option<Recipient<FlushBuckets, NoResponse>> ) -> Self
Create a new aggregator service and connect it to receiver
.
The aggregator will flush a list of buckets to the receiver in regular intervals based on
the given config
.
Trait Implementations§
source§impl Drop for AggregatorService
impl Drop for AggregatorService
source§impl Service for AggregatorService
impl Service for AggregatorService
§type Interface = Aggregator
type Interface = Aggregator
The interface of messages this service implements. Read more
source§fn spawn_handler(self, rx: Receiver<Self::Interface>)
fn spawn_handler(self, rx: Receiver<Self::Interface>)
Spawns a task to handle service messages. Read more
§fn start(self) -> Addr<Self::Interface>
fn start(self) -> Addr<Self::Interface>
Starts the service in the current runtime and returns an address for it.
Auto Trait Implementations§
impl !RefUnwindSafe for AggregatorService
impl Send for AggregatorService
impl Sync for AggregatorService
impl Unpin for AggregatorService
impl !UnwindSafe for AggregatorService
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more