Skip to main content

MasterLogConfig

master_log_client

Struct MasterLogConfig 

Source 
pub struct MasterLogConfig {
Show 14 fields
    pub api_key: Option<String>,
    pub endpoint: Option<String>,
    pub timeout: Duration,
    pub echo: bool,
    pub async_mode: bool,
    pub batch_size: usize,
    pub flush_interval: Duration,
    pub max_queue_size: usize,
    pub drop_when_full: bool,
    pub queue_timeout: Duration,
    pub backpressure: bool,
    pub initial_send_seconds_per_log: f64,
    pub max_enqueue_sleep: Duration,
    pub min_request_interval: Duration,

}

Fields§

§api_key: Option<String>§endpoint: Option<String>§timeout: Duration§echo: bool§async_mode: bool§batch_size: usize§flush_interval: Duration§max_queue_size: usize§drop_when_full: bool§queue_timeout: Duration§backpressure: bool§initial_send_seconds_per_log: f64§max_enqueue_sleep: Duration§min_request_interval: Duration

Implementations§

Source§

impl MasterLogConfig

Source

pub fn from_env() -> Self

Examples found in repository?
examples/simple_usage.rs (line 12)
9fn main() {
10    // You can omit this when MASTER_LOG_API_KEY and MASTER_LOG_ENDPOINT are set.
11    configure(
12        MasterLogConfig::from_env()
13            .api_key("dev-key")
14            .endpoint("http://127.0.0.1:8000")
15            .min_request_interval(Duration::from_millis(20))
16            .batch_size(100),
17    );
18
19    mlog("Telescope array online");
20    mlogf!("Captured frame {} for {}", 42, "M31");
21
22    info("Flat-field calibration completed");
23
24    log_entry(
25        LogEntry::new("Dome slit wind threshold approaching")
26            .severity(Severity::Warn)
27            .tags(["dome", "weather"])
28            .metadata(json!({ "wind_knots": 28, "limit_knots": 32 })),
29    );
30
31    warn("Seeing degraded");
32
33    log_entry(
34        LogEntry::with_title("Camera cooling alert", "CCD cooling loop failed to settle")
35            .severity(Severity::Error)
36            .tags(["ccd", "camera"])
37            .metadata(json!({ "setpoint_celsius": -20, "actual_celsius": -16.8 })),
38    );
39
40    error("Mount tracking watchdog tripped");
41
42    let result = flush(Duration::from_secs(5));
43    if !result.ok {
44        eprintln!(
45            "Master Log flush failed: {}",
46            result.error.unwrap_or_default()
47        );
48    }
49}
Source

pub fn api_key(self, value: impl Into<String>) -> Self

Examples found in repository?
examples/simple_usage.rs (line 13)
9fn main() {
10    // You can omit this when MASTER_LOG_API_KEY and MASTER_LOG_ENDPOINT are set.
11    configure(
12        MasterLogConfig::from_env()
13            .api_key("dev-key")
14            .endpoint("http://127.0.0.1:8000")
15            .min_request_interval(Duration::from_millis(20))
16            .batch_size(100),
17    );
18
19    mlog("Telescope array online");
20    mlogf!("Captured frame {} for {}", 42, "M31");
21
22    info("Flat-field calibration completed");
23
24    log_entry(
25        LogEntry::new("Dome slit wind threshold approaching")
26            .severity(Severity::Warn)
27            .tags(["dome", "weather"])
28            .metadata(json!({ "wind_knots": 28, "limit_knots": 32 })),
29    );
30
31    warn("Seeing degraded");
32
33    log_entry(
34        LogEntry::with_title("Camera cooling alert", "CCD cooling loop failed to settle")
35            .severity(Severity::Error)
36            .tags(["ccd", "camera"])
37            .metadata(json!({ "setpoint_celsius": -20, "actual_celsius": -16.8 })),
38    );
39
40    error("Mount tracking watchdog tripped");
41
42    let result = flush(Duration::from_secs(5));
43    if !result.ok {
44        eprintln!(
45            "Master Log flush failed: {}",
46            result.error.unwrap_or_default()
47        );
48    }
49}
Source

pub fn endpoint(self, value: impl Into<String>) -> Self

Examples found in repository?
examples/simple_usage.rs (line 14)
9fn main() {
10    // You can omit this when MASTER_LOG_API_KEY and MASTER_LOG_ENDPOINT are set.
11    configure(
12        MasterLogConfig::from_env()
13            .api_key("dev-key")
14            .endpoint("http://127.0.0.1:8000")
15            .min_request_interval(Duration::from_millis(20))
16            .batch_size(100),
17    );
18
19    mlog("Telescope array online");
20    mlogf!("Captured frame {} for {}", 42, "M31");
21
22    info("Flat-field calibration completed");
23
24    log_entry(
25        LogEntry::new("Dome slit wind threshold approaching")
26            .severity(Severity::Warn)
27            .tags(["dome", "weather"])
28            .metadata(json!({ "wind_knots": 28, "limit_knots": 32 })),
29    );
30
31    warn("Seeing degraded");
32
33    log_entry(
34        LogEntry::with_title("Camera cooling alert", "CCD cooling loop failed to settle")
35            .severity(Severity::Error)
36            .tags(["ccd", "camera"])
37            .metadata(json!({ "setpoint_celsius": -20, "actual_celsius": -16.8 })),
38    );
39
40    error("Mount tracking watchdog tripped");
41
42    let result = flush(Duration::from_secs(5));
43    if !result.ok {
44        eprintln!(
45            "Master Log flush failed: {}",
46            result.error.unwrap_or_default()
47        );
48    }
49}
Source

pub fn timeout(self, value: Duration) -> Self

Source

pub fn echo(self, value: bool) -> Self

Source

pub fn async_mode(self, value: bool) -> Self

Source

pub fn batch_size(self, value: usize) -> Self

Examples found in repository?
examples/simple_usage.rs (line 16)
9fn main() {
10    // You can omit this when MASTER_LOG_API_KEY and MASTER_LOG_ENDPOINT are set.
11    configure(
12        MasterLogConfig::from_env()
13            .api_key("dev-key")
14            .endpoint("http://127.0.0.1:8000")
15            .min_request_interval(Duration::from_millis(20))
16            .batch_size(100),
17    );
18
19    mlog("Telescope array online");
20    mlogf!("Captured frame {} for {}", 42, "M31");
21
22    info("Flat-field calibration completed");
23
24    log_entry(
25        LogEntry::new("Dome slit wind threshold approaching")
26            .severity(Severity::Warn)
27            .tags(["dome", "weather"])
28            .metadata(json!({ "wind_knots": 28, "limit_knots": 32 })),
29    );
30
31    warn("Seeing degraded");
32
33    log_entry(
34        LogEntry::with_title("Camera cooling alert", "CCD cooling loop failed to settle")
35            .severity(Severity::Error)
36            .tags(["ccd", "camera"])
37            .metadata(json!({ "setpoint_celsius": -20, "actual_celsius": -16.8 })),
38    );
39
40    error("Mount tracking watchdog tripped");
41
42    let result = flush(Duration::from_secs(5));
43    if !result.ok {
44        eprintln!(
45            "Master Log flush failed: {}",
46            result.error.unwrap_or_default()
47        );
48    }
49}
Source

pub fn flush_interval(self, value: Duration) -> Self

Source

pub fn max_queue_size(self, value: usize) -> Self

Source

pub fn drop_when_full(self, value: bool) -> Self

Source

pub fn queue_timeout(self, value: Duration) -> Self

Source

pub fn backpressure(self, value: bool) -> Self

Source

pub fn initial_send_seconds_per_log(self, value: f64) -> Self

Source

pub fn max_enqueue_sleep(self, value: Duration) -> Self

Source

pub fn min_request_interval(self, value: Duration) -> Self

Examples found in repository?
examples/simple_usage.rs (line 15)
9fn main() {
10    // You can omit this when MASTER_LOG_API_KEY and MASTER_LOG_ENDPOINT are set.
11    configure(
12        MasterLogConfig::from_env()
13            .api_key("dev-key")
14            .endpoint("http://127.0.0.1:8000")
15            .min_request_interval(Duration::from_millis(20))
16            .batch_size(100),
17    );
18
19    mlog("Telescope array online");
20    mlogf!("Captured frame {} for {}", 42, "M31");
21
22    info("Flat-field calibration completed");
23
24    log_entry(
25        LogEntry::new("Dome slit wind threshold approaching")
26            .severity(Severity::Warn)
27            .tags(["dome", "weather"])
28            .metadata(json!({ "wind_knots": 28, "limit_knots": 32 })),
29    );
30
31    warn("Seeing degraded");
32
33    log_entry(
34        LogEntry::with_title("Camera cooling alert", "CCD cooling loop failed to settle")
35            .severity(Severity::Error)
36            .tags(["ccd", "camera"])
37            .metadata(json!({ "setpoint_celsius": -20, "actual_celsius": -16.8 })),
38    );
39
40    error("Mount tracking watchdog tripped");
41
42    let result = flush(Duration::from_secs(5));
43    if !result.ok {
44        eprintln!(
45            "Master Log flush failed: {}",
46            result.error.unwrap_or_default()
47        );
48    }
49}

Trait Implementations§

Source§

impl Clone for MasterLogConfig

Source§

fn clone(&self) -> MasterLogConfig

Returns a duplicate of the value. Read more
1.0.0 · Source§

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

Performs copy-assignment from source. Read more
Source§

impl Debug for MasterLogConfig

Source§

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

Formats the value using the given formatter. Read more
Source§

impl Default for MasterLogConfig

Source§

fn default() -> Self

Returns the “default value” for a type. Read more

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> CloneToUninit for T
where T: Clone,

Source§

unsafe fn clone_to_uninit(&self, dest: *mut u8)

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dest. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> PolicyExt for T
where T: ?Sized,

Source§

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow only if self and other return Action::Follow. Read more
Source§

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow if either self or other returns Action::Follow. Read more
Source§

impl<T> ToOwned for T
where T: Clone,

Source§

type Owned = T

The resulting type after obtaining ownership.
Source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
Source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more