shaoaiwan/moonevent/cmd/main

README
U
HandlerFn
U
MiddlewareFn
T
BatchFailureMode
T
BatchHaltReason
- ::newBatchOptions::new
- ::completedBatchReport::completed
- ::continue_withBatchReport::continue_with
- ::failedBatchReport::failed
- ::metricsBatchReport::metrics
- ::processedBatchReport::processed
- ::remaining_countBatchReport::remaining_count
- ::undeliveredBatchReport::undelivered
- ::delivery_percentBusMetrics::delivery_percent
- ::failing_handlersBusMetrics::failing_handlers
- ::handlerBusMetrics::handler
- ::mergeBusMetrics::merge
- ::newBusMetrics::new
- ::recordBusMetrics::record
- ::record_manyBusMetrics::record_many
- ::success_percentBusMetrics::success_percent
- ::summaryBusMetrics::summary
- ::topicBusMetrics::topic
- ::totalDedupBatch::total
- ::checkDedupCache::check
- ::clearDedupCache::clear
- ::filterDedupCache::filter
- ::findDedupCache::find
- ::forgetDedupCache::forget
- ::lengthDedupCache::length
- ::newDedupCache::new
- ::publish_uniqueDedupCache::publish_unique
- ::rememberDedupCache::remember
T
DedupDecision
T
DedupStrategy
T
DeliveryAttempt
- ::failed_runsDeliveryBatch::failed_runs
- ::is_okDeliveryBatch::is_ok
- ::metricsDeliveryBatch::metrics
- ::reportsDeliveryBatch::reports
- ::attempt_countDeliveryRun::attempt_count
- ::failure_reasonsDeliveryRun::failure_reasons
- ::last_reportDeliveryRun::last_report
- ::succeededDeliveryRun::succeeded
- ::was_retriedDeliveryRun::was_retried
T
DeliveryState
T
DispatchControl
- ::from_reportsDispatchReport::from_reports
- ::is_okDispatchReport::is_ok
- ::has_tagEvent::has_tag
- ::matches_topicEvent::matches_topic
- ::newEvent::new
- ::summaryEvent::summary
- ::lengthEventBatch::length
- ::publishEventBatch::publish
- ::active_handler_countEventBus::active_handler_count
- ::handler_countEventBus::handler_count
- ::has_handlerEventBus::has_handler
- ::middleware_countEventBus::middleware_count
- ::newEventBus::new
- ::pauseEventBus::pause
- ::publishEventBus::publish
- ::publish_batchEventBus::publish_batch
- ::publish_manyEventBus::publish_many
- ::publish_many_with_retryEventBus::publish_many_with_retry
- ::publish_with_retryEventBus::publish_with_retry
- ::resume_handlerEventBus::resume_handler
- ::schedule_inEventBus::schedule_in
- ::scheduled_countEventBus::scheduled_count
- ::subscribeEventBus::subscribe
- ::tickEventBus::tick
- ::tick_manyEventBus::tick_many
- ::trace_entriesEventBus::trace_entries
- ::unsubscribeEventBus::unsubscribe
- ::use_middlewareEventBus::use_middleware
- ::with_handlerEventBus::with_handler
T
EventContext
- ::afterEventQuery::after
- ::allEventQuery::all
- ::matchesEventQuery::matches
- ::takeEventQuery::take
- ::with_correlationEventQuery::with_correlation
- ::with_min_priorityEventQuery::with_min_priority
- ::with_nameEventQuery::with_name
- ::with_tagEventQuery::with_tag
- ::with_topicEventQuery::with_topic
- ::drainEventQueue::drain
- ::drain_busEventQueue::drain_bus
- ::filter_tagEventQueue::filter_tag
- ::filter_topicEventQueue::filter_topic
- ::fromEventQueue::from
- ::highest_priorityEventQueue::highest_priority
- ::is_emptyEventQueue::is_empty
- ::lengthEventQueue::length
- ::newEventQueue::new
- ::peekEventQueue::peek
- ::pushEventQueue::push
- ::push_manyEventQueue::push_many
- ::takeEventQueue::take
- ::active_rule_countEventRouter::active_rule_count
- ::add_ruleEventRouter::add_rule
- ::disableEventRouter::disable
- ::enableEventRouter::enable
- ::invalid_rulesEventRouter::invalid_rules
- ::newEventRouter::new
- ::remove_ruleEventRouter::remove_rule
- ::routeEventRouter::route
- ::route_manyEventRouter::route_many
- ::rule_countEventRouter::rule_count
- ::appendEventStore::append
- ::append_manyEventStore::append_many
- ::clearEventStore::clear
- ::correlation_countEventStore::correlation_count
- ::eventsEventStore::events
- ::getEventStore::get
- ::is_emptyEventStore::is_empty
- ::latestEventStore::latest
- ::lengthEventStore::length
- ::newEventStore::new
- ::queryEventStore::query
- ::remove_beforeEventStore::remove_before
- ::replayEventStore::replay
- ::statsEventStore::stats
- ::topic_countEventStore::topic_count
- ::error_countEventValidation::error_count
- ::is_validEventValidation::is_valid
- ::warning_countEventValidation::warning_count
- ::defaultEventValidationPolicy::default
- ::newHandler::new
T
HandlerMetrics
T
HandlerOutcome
- ::failedHandlerReport::failed
- ::ignoredHandlerReport::ignored
- ::okHandlerReport::ok
T
HandlerStatus
- ::newMiddleware::new
T
MiddlewareOutcome
T
QueueTake
T
RetryDecision
- ::decideRetryPolicy::decide
- ::newRetryPolicy::new
T
RouteAction
T
RouteNote
- ::is_validRouteRule::is_valid
- ::matchesRouteRule::matches
- ::newRouteRule::new
- ::firstRoutingResult::first
- ::output_countRoutingResult::output_count
- ::publishRoutingResult::publish
- ::newScheduledEvent::new
T
SeenEvent
T
StoreStats
T
StoredEvent
- ::matchesSubscription::matches
- ::newSubscription::new
T
TopicMetrics
- ::compileTopicPattern::compile
- ::is_catch_allTopicPattern::is_catch_all
- ::is_validTopicPattern::is_valid
- ::matchesTopicPattern::matches
- ::specificityTopicPattern::specificity
T
TopicPatternStatus
- ::newTraceEntry::new
T
TraceKind
- ::newTypedEvent::new
- ::to_eventTypedEvent::to_event
T
UniquePublishResult
T
ValidationBatch
T
ValidationIssue
T
ValidationSeverity
V
active_count
V
append_tag
V
chunk_events
V
collect_failures
V
dead_letter_queue
V
dedup_key
V
dispatch
V
filter_by_topic
V
flatten_batches
V
metrics_from_reports
V
publish_name
V
report_needs_retry
V
topic_matches
V
trace_summary
V
validate_event
V
validate_events
V
validate_topic_pattern
V
validation_middleware