metrique-writer-core 0.1.21

Library for wide event metrics - writer-side interface core traits
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52

// Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
// SPDX-License-Identifier: Apache-2.0

use crate::entry::SampleGroupElement;

use super::{Entry, EntryWriter};

/// Merges 2 [Entry] objecs by value. See [Entry::merge].
#[derive(Clone, Debug)]
pub struct Merged<E1, E2>(pub(super) E1, pub(super) E2);

impl<E1: Entry, E2: Entry> Entry for Merged<E1, E2> {
    fn write<'a>(&'a self, writer: &mut impl EntryWriter<'a>) {
        self.0.write(writer);
        self.1.write(writer);
    }

    fn sample_group(&self) -> impl Iterator<Item = SampleGroupElement> {
        self.0.sample_group().chain(self.1.sample_group())
    }

    fn descriptors(&self) -> crate::Descriptors<'_> {
        self.0.descriptors().chain(self.1.descriptors())
    }
}

/// Merges 2 [Entry] objects by reference. See [Entry::merge_by_ref].
#[derive(Debug)]
pub struct MergedRef<'a, E1: ?Sized, E2: ?Sized>(pub(super) &'a E1, pub(super) &'a E2);

impl<E1: Entry + ?Sized, E2: Entry + ?Sized> Entry for MergedRef<'_, E1, E2> {
    fn write<'a>(&'a self, writer: &mut impl EntryWriter<'a>) {
        self.0.write(writer);
        self.1.write(writer);
    }

    fn sample_group(&self) -> impl Iterator<Item = SampleGroupElement> {
        self.0.sample_group().chain(self.1.sample_group())
    }

    fn descriptors(&self) -> crate::Descriptors<'_> {
        self.0.descriptors().chain(self.1.descriptors())
    }
}

impl<E1: ?Sized, E2: ?Sized> Clone for MergedRef<'_, E1, E2> {
    fn clone(&self) -> Self {
        *self
    }
}

impl<E1: ?Sized, E2: ?Sized> Copy for MergedRef<'_, E1, E2> {}