Struct RustackLogs 

pub struct RustackLogs { /* private fields */ }

CloudWatch Logs provider with DashMap-based in-memory storage.

Implementations

impl RustackLogs

pub fn new(config: LogsConfig) -> Self

Create a new provider with the given configuration.

pub fn handle_create_log_group( &self, input: &CreateLogGroupInput, ) -> Result<Value, LogsError>

pub fn handle_delete_log_group( &self, input: &DeleteLogGroupInput, ) -> Result<Value, LogsError>

pub fn handle_describe_log_groups( &self, input: &DescribeLogGroupsInput, ) -> Result<DescribeLogGroupsResponse, LogsError>

pub fn handle_create_log_stream( &self, input: &CreateLogStreamInput, ) -> Result<Value, LogsError>

pub fn handle_delete_log_stream( &self, input: &DeleteLogStreamInput, ) -> Result<Value, LogsError>

pub fn handle_describe_log_streams( &self, input: &DescribeLogStreamsInput, ) -> Result<DescribeLogStreamsResponse, LogsError>

pub fn handle_put_log_events( &self, input: &PutLogEventsInput, ) -> Result<PutLogEventsResponse, LogsError>

pub fn handle_get_log_events( &self, input: &GetLogEventsInput, ) -> Result<GetLogEventsResponse, LogsError>

pub fn handle_filter_log_events( &self, input: &FilterLogEventsInput, ) -> Result<FilterLogEventsResponse, LogsError>

pub fn handle_put_retention_policy( &self, input: &PutRetentionPolicyInput, ) -> Result<Value, LogsError>

pub fn handle_delete_retention_policy( &self, input: &DeleteRetentionPolicyInput, ) -> Result<Value, LogsError>

pub fn handle_tag_log_group( &self, input: &TagLogGroupInput, ) -> Result<Value, LogsError>

pub fn handle_untag_log_group( &self, input: &UntagLogGroupInput, ) -> Result<Value, LogsError>

pub fn handle_list_tags_log_group( &self, input: &ListTagsLogGroupInput, ) -> Result<ListTagsLogGroupResponse, LogsError>

pub fn handle_tag_resource( &self, input: &TagResourceInput, ) -> Result<Value, LogsError>

pub fn handle_untag_resource( &self, input: &UntagResourceInput, ) -> Result<Value, LogsError>

pub fn handle_list_tags_for_resource( &self, input: &ListTagsForResourceInput, ) -> Result<ListTagsForResourceResponse, LogsError>

pub fn handle_put_resource_policy( &self, input: &PutResourcePolicyInput, ) -> Result<PutResourcePolicyResponse, LogsError>

pub fn handle_delete_resource_policy( &self, input: &DeleteResourcePolicyInput, ) -> Result<Value, LogsError>

pub fn handle_describe_resource_policies( &self, _input: &DescribeResourcePoliciesInput, ) -> Result<DescribeResourcePoliciesResponse, LogsError>

pub fn handle_put_metric_filter( &self, input: &PutMetricFilterInput, ) -> Result<Value, LogsError>

pub fn handle_delete_metric_filter( &self, input: &DeleteMetricFilterInput, ) -> Result<Value, LogsError>

pub fn handle_describe_metric_filters( &self, input: &DescribeMetricFiltersInput, ) -> Result<DescribeMetricFiltersResponse, LogsError>

pub fn handle_test_metric_filter( &self, input: &TestMetricFilterInput, ) -> Result<TestMetricFilterResponse, LogsError>

pub fn handle_put_subscription_filter( &self, input: &PutSubscriptionFilterInput, ) -> Result<Value, LogsError>

pub fn handle_delete_subscription_filter( &self, input: &DeleteSubscriptionFilterInput, ) -> Result<Value, LogsError>

pub fn handle_describe_subscription_filters( &self, input: &DescribeSubscriptionFiltersInput, ) -> Result<DescribeSubscriptionFiltersResponse, LogsError>

pub fn handle_put_destination( &self, input: &PutDestinationInput, ) -> Result<PutDestinationResponse, LogsError>

pub fn handle_put_destination_policy( &self, input: &PutDestinationPolicyInput, ) -> Result<Value, LogsError>

pub fn handle_delete_destination( &self, input: &DeleteDestinationInput, ) -> Result<Value, LogsError>

pub fn handle_describe_destinations( &self, input: &DescribeDestinationsInput, ) -> Result<DescribeDestinationsResponse, LogsError>

pub fn handle_start_query( &self, _input: &StartQueryInput, ) -> Result<StartQueryResponse, LogsError>

pub fn handle_stop_query( &self, _input: &StopQueryInput, ) -> Result<StopQueryResponse, LogsError>

pub fn handle_get_query_results( &self, _input: &GetQueryResultsInput, ) -> Result<GetQueryResultsResponse, LogsError>

pub fn handle_describe_queries( &self, _input: &DescribeQueriesInput, ) -> Result<DescribeQueriesResponse, LogsError>

pub fn handle_put_query_definition( &self, input: &PutQueryDefinitionInput, ) -> Result<PutQueryDefinitionResponse, LogsError>

pub fn handle_delete_query_definition( &self, input: &DeleteQueryDefinitionInput, ) -> Result<DeleteQueryDefinitionResponse, LogsError>

pub fn handle_describe_query_definitions( &self, input: &DescribeQueryDefinitionsInput, ) -> Result<DescribeQueryDefinitionsResponse, LogsError>

pub fn handle_associate_kms_key( &self, input: &AssociateKmsKeyInput, ) -> Result<Value, LogsError>

pub fn handle_disassociate_kms_key( &self, input: &DisassociateKmsKeyInput, ) -> Result<Value, LogsError>

Trait Implementations

impl Debug for RustackLogs

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

Formats the value using the given formatter.