violetcb/eventrail/cmd/main

README
- ::to_wireBatchDecision::to_wire
- ::manifestBatchPublishReport::manifest
- ::summaryBatchPublishReport::summary
- ::route_linesBatchRouteReport::route_lines
- ::summaryBatchRouteReport::summary
- ::to_wireBatchRouteRow::to_wire
- ::decision_linesBatchRuleReport::decision_lines
- ::summaryBatchRuleReport::summary
- ::to_wireBatchTopicCount::to_wire
- ::to_wireBatchValidationIssue::to_wire
- ::issue_linesBatchValidationReport::issue_lines
- ::summaryBatchValidationReport::summary
- ::auditBus::audit
- ::dead_letter_countBus::dead_letter_count
- ::dead_letters_for_subscriptionBus::dead_letters_for_subscription
- ::deliveries_for_subscriptionBus::deliveries_for_subscription
- ::deliveries_for_topicBus::deliveries_for_topic
- ::delivery_countBus::delivery_count
- ::delivery_statsBus::delivery_stats
- ::explainBus::explain
- ::has_subscriptionBus::has_subscription
- ::last_delivery_for_subscriptionBus::last_delivery_for_subscription
- ::publishBus::publish
- ::publish_with_modeBus::publish_with_mode
- ::routeBus::route
- ::route_with_modeBus::route_with_mode
- ::sizeBus::size
- ::subscribeBus::subscribe
- ::subscription_delivery_statsBus::subscription_delivery_stats
- ::topic_delivery_statsBus::topic_delivery_stats
T
BusAudit
- ::addBusPlan::add
- ::buildBusPlan::build
- ::coverageBusPlan::coverage
- ::is_emptyBusPlan::is_empty
- ::lenBusPlan::len
- ::manifestBusPlan::manifest
- ::validateBusPlan::validate
T
DeadLetter
T
Delivery
- ::to_wireDeliveryMode::to_wire
- ::failure_countDeliveryStats::failure_count
- ::is_cleanDeliveryStats::is_clean
- ::recordDeliveryStats::record
- ::to_wireDeliveryStats::to_wire
- ::to_wireDeliveryStatus::to_wire
- ::to_wireDiagnosticEntry::to_wire
- ::addDiagnosticReport::add
- ::codesDiagnosticReport::codes
- ::errorDiagnosticReport::error
- ::has_warningsDiagnosticReport::has_warnings
- ::infoDiagnosticReport::info
- ::linesDiagnosticReport::lines
- ::manifestDiagnosticReport::manifest
- ::manifest_linesDiagnosticReport::manifest_lines
- ::mergeDiagnosticReport::merge
- ::okDiagnosticReport::ok
- ::summaryDiagnosticReport::summary
- ::warningDiagnosticReport::warning
- ::to_wireDiagnosticSeverity::to_wire
- ::add_traceEnvelope::add_trace
- ::fingerprintEnvelope::fingerprint
- ::headerEnvelope::header
- ::next_attemptEnvelope::next_attempt
- ::payload_pathEnvelope::payload_path
- ::summaryEnvelope::summary
- ::with_headerEnvelope::with_header
- ::appendEventBatch::append
- ::append_manyEventBatch::append_many
- ::apply_retentionEventBatch::apply_retention
- ::compact_by_fingerprintEventBatch::compact_by_fingerprint
- ::evaluate_rulesEventBatch::evaluate_rules
- ::filterEventBatch::filter
- ::fingerprintsEventBatch::fingerprints
- ::is_emptyEventBatch::is_empty
- ::lenEventBatch::len
- ::manifestEventBatch::manifest
- ::manifest_linesEventBatch::manifest_lines
- ::projectEventBatch::project
- ::publishEventBatch::publish
- ::queryEventBatch::query
- ::retention_planEventBatch::retention_plan
- ::route_previewEventBatch::route_preview
- ::snapshotEventBatch::snapshot
- ::sort_by_timestampEventBatch::sort_by_timestamp
- ::to_tapeEventBatch::to_tape
- ::topic_countsEventBatch::topic_counts
- ::validateEventBatch::validate
- ::with_nameEventBatch::with_name
- ::next_fromEventCursor::next_from
- ::to_wireEventCursor::to_wire
- ::with_limitEventCursor::with_limit
- ::with_patternEventCursor::with_pattern
- ::to_wireEventDigest::to_wire
- ::addEventPipeline::add
- ::describeEventPipeline::describe
- ::is_emptyEventPipeline::is_empty
- ::lenEventPipeline::len
- ::runEventPipeline::run
- ::evaluateEventPredicate::evaluate
- ::applyEventProjection::apply
- ::findEventProjection::find
- ::is_emptyEventProjection::is_empty
- ::issue_linesEventProjection::issue_lines
- ::lenEventProjection::len
- ::manifestEventProjection::manifest
- ::manifest_linesEventProjection::manifest_lines
- ::summaryEventProjection::summary
- ::applyEventQuery::apply
- ::matchesEventQuery::matches
- ::to_wireEventQuery::to_wire
- ::with_headerEventQuery::with_header
- ::with_pageEventQuery::with_page
- ::with_predicateEventQuery::with_predicate
- ::with_sortEventQuery::with_sort
- ::with_time_rangeEventQuery::with_time_range
- ::with_topicEventQuery::with_topic
- ::without_topicEventQuery::without_topic
- ::is_configuration_errorEventRailError::is_configuration_error
- ::messageEventRailError::message
- ::validateEventSchema::validate
- ::diffEventSnapshot::diff
- ::event_idsEventSnapshot::event_ids
- ::find_eventEventSnapshot::find_event
- ::manifestEventSnapshot::manifest
- ::manifest_linesEventSnapshot::manifest_lines
- ::subscription_stats_forEventSnapshot::subscription_stats_for
- ::summaryEventSnapshot::summary
- ::topic_countEventSnapshot::topic_count
- ::appendEventTape::append
- ::append_manyEventTape::append_many
- ::apply_retentionEventTape::apply_retention
- ::compact_by_fingerprintEventTape::compact_by_fingerprint
- ::is_emptyEventTape::is_empty
- ::lenEventTape::len
- ::manifestEventTape::manifest
- ::page_countEventTape::page_count
- ::projectEventTape::project
- ::queryEventTape::query
- ::replayEventTape::replay
- ::retention_planEventTape::retention_plan
- ::selectEventTape::select
- ::snapshotEventTape::snapshot
- ::to_manifest_linesEventTape::to_manifest_lines
- ::topic_countsEventTape::topic_counts
- ::windowEventTape::window
- ::as_boolEventValue::as_bool
- ::as_intEventValue::as_int
- ::as_textEventValue::as_text
- ::field_countEventValue::field_count
- ::getEventValue::get
- ::get_pathEventValue::get_path
- ::is_scalarEventValue::is_scalar
- ::list_countEventValue::list_count
- ::require_pathEventValue::require_path
- ::to_wireEventValue::to_wire
T
FieldSpec
T
HandlerResult
- ::to_wireHeaderFilter::to_wire
T
MatchReport
- ::drain_dueOutbox::drain_due
- ::drop_subscriptionOutbox::drop_subscription
- ::dueOutbox::due
- ::from_reportOutbox::from_report
- ::is_emptyOutbox::is_empty
- ::lenOutbox::len
- ::manifestOutbox::manifest
- ::pushOutbox::push
- ::reschedule_allOutbox::reschedule_all
- ::summaryOutboxDrain::summary
T
Pair
- ::to_wirePipelineAction::to_wire
- ::failed_stagesPipelineRun::failed_stages
- ::manifestPipelineRun::manifest
- ::manifest_linesPipelineRun::manifest_lines
- ::okPipelineRun::ok
- ::summaryPipelineRun::summary
- ::warning_stagesPipelineRun::warning_stages
- ::to_wirePipelineStage::to_wire
- ::to_wirePipelineStageStatus::to_wire
- ::issue_linesPlanBuildReport::issue_lines
- ::summaryPlanBuildReport::summary
- ::coverage_linesPlanCoverageReport::coverage_lines
- ::summaryPlanCoverageReport::summary
- ::to_wirePlanCoverageRow::to_wire
- ::to_wirePlanIssue::to_wire
- ::to_wirePlanSeverity::to_wire
- ::to_wireProjectionIssue::to_wire
- ::fieldProjectionRow::field
- ::to_wireProjectionRow::to_wire
- ::emptyProjectionSpec::empty
- ::project_eventsProjectionSpec::project_events
- ::delivery_statsPublishReport::delivery_stats
- ::status_linePublishReport::status_line
- ::eventsQueryResult::events
- ::is_emptyQueryResult::is_empty
- ::manifestQueryResult::manifest
- ::manifest_linesQueryResult::manifest_lines
- ::skip_linesQueryResult::skip_lines
- ::summaryQueryResult::summary
- ::to_wireQueryRow::to_wire
- ::to_wireQuerySkip::to_wire
- ::to_wireQuerySort::to_wire
- ::summaryReplayReport::summary
T
RetentionCandidate
T
RetentionCounter
- ::to_wireRetentionDecision::to_wire
- ::boundedRetentionPolicy::bounded
- ::to_wireRetentionPolicy::to_wire
- ::with_compactionRetentionPolicy::with_compaction
- ::with_limitsRetentionPolicy::with_limits
- ::with_time_rangeRetentionPolicy::with_time_range
- ::with_topicRetentionPolicy::with_topic
- ::without_topicRetentionPolicy::without_topic
- ::decision_linesRetentionReport::decision_lines
- ::drop_linesRetentionReport::drop_lines
- ::dropped_event_idsRetentionReport::dropped_event_ids
- ::dropped_indicesRetentionReport::dropped_indices
- ::dropped_sequencesRetentionReport::dropped_sequences
- ::keep_linesRetentionReport::keep_lines
- ::kept_event_idsRetentionReport::kept_event_ids
- ::kept_indicesRetentionReport::kept_indices
- ::kept_sequencesRetentionReport::kept_sequences
- ::manifestRetentionReport::manifest
- ::manifest_linesRetentionReport::manifest_lines
- ::okRetentionReport::ok
- ::summaryRetentionReport::summary
- ::topic_linesRetentionReport::topic_lines
- ::to_wireRetentionTopicSummary::to_wire
- ::next_delayRetryPolicy::next_delay
T
RouteExplanation
T
RouteProbe
- ::to_handler_resultRuleDecision::to_handler_result
- ::to_wireRuleDecision::to_wire
- ::failRuleResult::fail
- ::okRuleResult::ok
- ::decideRuleSet::decide
- ::evaluateRuleSet::evaluate
- ::to_manifest_lineScheduledEvent::to_manifest_line
- ::to_wireSchemaIssue::to_wire
- ::issue_linesSchemaReport::issue_lines
- ::summarySchemaReport::summary
- ::to_handler_resultSchemaReport::to_handler_result
- ::to_wireSnapshotChange::to_wire
- ::to_wireSnapshotChangeKind::to_wire
- ::to_wireSnapshotDeliveryRow::to_wire
- ::change_linesSnapshotDiff::change_lines
- ::summarySnapshotDiff::summary
- ::first_guard_failureSubscription::first_guard_failure
- ::guards_passSubscription::guards_pass
- ::matchesSubscription::matches
- ::to_wireSubscriptionBlueprint::to_wire
- ::to_wireSubscriptionDeliveryStats::to_wire
- ::to_manifest_lineTapeEntry::to_manifest_line
- ::to_wireTapeState::to_wire
- ::eventsTapeWindow::events
- ::is_emptyTapeWindow::is_empty
- ::lenTapeWindow::len
- ::manifestTapeWindow::manifest
- ::manifest_linesTapeWindow::manifest_lines
- ::summaryTapeWindow::summary
- ::to_tapeTapeWindow::to_tape
T
TopicCount
- ::to_wireTopicDeliveryStats::to_wire
- ::is_catch_allTopicPattern::is_catch_all
- ::matches_topicTopicPattern::matches_topic
- ::prefixTopicPattern::prefix
- ::reportTopicPattern::report
T
TopicToken
- ::to_wireValueKind::to_wire
V
bool_value
V
bus
V
bus_plan
V
compare_pattern_priority
V
delivery_stats
V
diagnose_batch
V
diagnose_batch_rules
V
diagnose_batch_schema
V
diagnose_bus
V
diagnose_pipeline_run
V
diagnose_retention
V
diagnose_snapshot
V
diagnostic_report
V
envelope
V
escape_wire_text
V
event_batch
V
event_cursor
V
event_pipeline
V
event_projection
V
event_query
V
event_schema
V
event_snapshot
V
event_tape
V
field
V
field_spec
V
header_filter
V
int_value
V
list_value
V
null_value
V
outbox
V
package_name
V
package_version
V
pair
V
pairs_to_wire
V
projection_spec
V
record_value
V
retention_policy
V
retry_policy
V
rule_set
V
scheduled_event
V
stable_event_id
V
subscription
V
subscription_blueprint
V
text_value
V
topic_pattern
V
topic_segments