Struct holochain_metrics::cloudwatch::CloudWatchLogger

pub struct CloudWatchLogger {
    pub client: CloudWatchLogsClient,
    pub log_group_name: Option<String>,
    pub log_stream_name: Option<String>,
    pub sequence_token: Option<String>,
    pub metrics_to_publish: Vec<Metric>,
}

A cloud watch logger instance with some configuration and state as needed by various service calls.

Fields

client: CloudWatchLogsClient

The underlying cloudwatch logs client

log_group_name: Option<String>

log_stream_name: Option<String>

sequence_token: Option<String>

Set automatically when publishing log metrics

metrics_to_publish: Vec<Metric>

Methods

impl CloudWatchLogger

pub fn query(&self, query_args: &QueryArgs) -> Vec<Vec<ResultField>>

Query the cloudwatch logger given a start and stop time interval. Produces a raw vector of result field rows (each as a vector). Use CloudWatchLogger::query_metrics or CloudWatchLogger::query_and_aggregate to produce numerical data from this raw data.

pub fn metrics_of_query<'a, I: IntoIterator<Item = Vec<ResultField>> + 'a>(
    query: I
) -> Box<dyn Iterator<Item = Metric> + 'a>

Converts raw result fields to in iterator over metric samples

pub fn query_metrics(
    &self,
    query_args: &QueryArgs
) -> Box<dyn Iterator<Item = Metric>>

Queries cloudwatch logs given a start and end time interval and produces all metric samples observed during the interval

pub fn query_and_aggregate(
    &self,
    query_args: &QueryArgs
) -> StatsByMetric<OnlineStats>

Queries cloudwatch logs given a start and end time interval and produces aggregate statistics of metrics from the results.

pub fn default_log_stream() -> String

pub fn default_log_group() -> String

pub fn default_start_time() -> i64

pub fn default_assume_role_arn() -> String

pub fn default_end_time() -> i64

pub fn with_log_group<P: ProvideAwsCredentials + Sync + Send + 'static>(
    log_group_name: String,
    credentials_provider: P,
    region: &Region
) -> Self where
    P::Future: Send, 

pub fn with_region(region: &Region) -> Self

pub fn ensure_log_group(&self)

pub fn new<P: ProvideAwsCredentials + Sync + Send + 'static>(
    log_stream_name: Option<String>,
    log_group_name: Option<String>,
    credentials_provider: P,
    region: &Region
) -> Self where
    P::Future: Send, 

impl CloudWatchLogger

pub fn get_log_stream_names<S: Into<String>>(
    &self,
    log_stream_name_prefix: S
) -> Box<dyn Iterator<Item = String>>

Trait Implementations

impl Clone for CloudWatchLogger

fn clone(&self) -> CloudWatchLogger

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Default for CloudWatchLogger

fn default() -> Self

Returns the "default value" for a type.

impl Drop for CloudWatchLogger

fn drop(&mut self)

Executes the destructor for this type.

impl MetricPublisher for CloudWatchLogger

fn publish(&mut self, metric: &Metric)

Publish a single metric.