cauchyQ/moonbit-causalkit/cmd/main

README
- ::append_to_logBatchDelivery::append_to_log
- ::frontierBatchDelivery::frontier
T
BatchError
T
BufferError
- ::appliedCausalBuffer::applied
- ::newCausalBuffer::new
- ::offerCausalBuffer::offer
- ::pendingCausalBuffer::pending
- ::created_atCausalCheckpoint::created_at
- ::frontierCausalCheckpoint::frontier
- ::newCausalCheckpoint::new
- ::operation_countCausalCheckpoint::operation_count
- ::stateCausalCheckpoint::state
T
CausalEdge
T
CausalLayer
- ::compactCausalMap::compact
- ::contains_keyCausalMap::contains_key
- ::contextCausalMap::context
- ::entriesCausalMap::entries
- ::getCausalMap::get
- ::keysCausalMap::keys
- ::mergeCausalMap::merge
- ::newCausalMap::new
- ::putCausalMap::put
- ::removeCausalMap::remove
- ::tombstonesCausalMap::tombstones
T
CausalMapEntry
T
CausalMapError
T
CausalMapTombstone
- ::newCausalOperation::new
T
CausalOrder
T
CausalPath
T
CheckpointError
T
CheckpointPlan
T
ClockDiagnosticError
- ::newClockDiagnosticPolicy::new
- ::anomaliesClockDiagnostics::anomalies
- ::forward_jump_countClockDiagnostics::forward_jump_count
- ::has_anomalyClockDiagnostics::has_anomaly
- ::last_readingClockDiagnostics::last_reading
- ::newClockDiagnostics::new
- ::observeClockDiagnostics::observe
- ::resetClockDiagnostics::reset
- ::rollback_countClockDiagnostics::rollback_count
- ::samplesClockDiagnostics::samples
T
ClockError
T
ClockReadingStatus
T
ClockSample
T
ConcurrentPair
T
CounterComponent
T
CounterError
- ::compareDot::compare
- ::contextDot::context
- ::is_covered_byDot::is_covered_by
- ::newDot::new
T
DotError
- ::addDotSet::add
- ::afterDotSet::after
- ::containsDotSet::contains
- ::coveredDotSet::covered
- ::differenceDotSet::difference
- ::dotsDotSet::dots
- ::from_arrayDotSet::from_array
- ::frontierDotSet::frontier
- ::intersectionDotSet::intersection
- ::is_subset_ofDotSet::is_subset_of
- ::lengthDotSet::length
- ::newDotSet::new
- ::next_counterDotSet::next_counter
- ::removeDotSet::remove
- ::unionDotSet::union
T
EdgeRow
- ::lastHlcClock::last
- ::newHlcClock::new
- ::receiveHlcClock::receive
- ::restoreHlcClock::restore
- ::tickHlcClock::tick
- ::compareHlcTimestamp::compare
- ::newHlcTimestamp::new
- ::precedes_or_equalsHlcTimestamp::precedes_or_equals
- ::to_stringHlcTimestamp::to_string
T
LastWriterWinsError
- ::dominatesLastWriterWinsRegister::dominates
- ::mergeLastWriterWinsRegister::merge
- ::newLastWriterWinsRegister::new
- ::timestampLastWriterWinsRegister::timestamp
- ::valueLastWriterWinsRegister::value
- ::writeLastWriterWinsRegister::write
- ::writerLastWriterWinsRegister::writer
T
LoggedOperation
T
MemberStatus
T
MembershipError
- ::active_replicasMembershipView::active_replicas
- ::from_membersMembershipView::from_members
- ::is_activeMembershipView::is_active
- ::joinMembershipView::join
- ::membersMembershipView::members
- ::mergeMembershipView::merge
- ::newMembershipView::new
- ::reactivateMembershipView::reactivate
- ::recordMembershipView::record
- ::retireMembershipView::retire
- ::retired_replicasMembershipView::retired_replicas
- ::stability_trackerMembershipView::stability_tracker
- ::applyMultiValueRegister::apply
- ::contextMultiValueRegister::context
- ::mergeMultiValueRegister::merge
- ::newMultiValueRegister::new
- ::resolvedMultiValueRegister::resolved
- ::stateMultiValueRegister::state
- ::valuesMultiValueRegister::values
- ::writeMultiValueRegister::write
T
ObservedRemoveError
- ::addObservedRemoveSet::add
- ::compactObservedRemoveSet::compact
- ::containsObservedRemoveSet::contains
- ::contextObservedRemoveSet::context
- ::entriesObservedRemoveSet::entries
- ::mergeObservedRemoveSet::merge
- ::newObservedRemoveSet::new
- ::removalsObservedRemoveSet::removals
- ::removeObservedRemoveSet::remove
- ::valuesObservedRemoveSet::values
T
ObservedValue
- ::appendOperationLog::append
- ::compactOperationLog::compact
- ::entriesOperationLog::entries
- ::lengthOperationLog::length
- ::newOperationLog::new
- ::stable_prefixOperationLog::stable_prefix
T
PendingMessage
- ::componentsPnCounter::components
- ::decrementPnCounter::decrement
- ::decrement_byPnCounter::decrement_by
- ::delta_sincePnCounter::delta_since
- ::from_componentsPnCounter::from_components
- ::incrementPnCounter::increment
- ::increment_byPnCounter::increment_by
- ::is_included_inPnCounter::is_included_in
- ::mergePnCounter::merge
- ::negative_ofPnCounter::negative_of
- ::newPnCounter::new
- ::positive_ofPnCounter::positive_of
- ::valuePnCounter::value
T
RegisterError
T
RegisterState
T
ReplicaAcknowledgement
- ::newReplicaDigest::new
T
ReplicaMember
T
ReplicaState
- ::afterReplicationBatch::after
- ::contains_idReplicationBatch::contains_id
- ::deliverReplicationBatch::deliver
- ::lengthReplicationBatch::length
- ::newReplicationBatch::new
- ::operationsReplicationBatch::operations
- ::advance_toSimulator::advance_to
- ::local_eventSimulator::local_event
- ::newSimulator::new
- ::pendingSimulator::pending
- ::replicasSimulator::replicas
- ::sendSimulator::send
- ::set_onlineSimulator::set_online
- ::timeSimulator::time
- ::traceSimulator::trace
- ::vector_ofSimulator::vector_of
T
SimulatorError
T
StabilityError
- ::acknowledgementsStabilityTracker::acknowledgements
- ::is_stableStabilityTracker::is_stable
- ::newStabilityTracker::new
- ::observeStabilityTracker::observe
- ::stable_frontierStabilityTracker::stable_frontier
T
SyncError
- ::containsSyncRange::contains
- ::lengthSyncRange::length
- ::newSyncRange::new
T
TimestampError
- ::concurrent_pairsTraceAnalysis::concurrent_pairs
- ::direct_edgesTraceAnalysis::direct_edges
- ::direct_predecessorsTraceAnalysis::direct_predecessors
- ::eventsTraceAnalysis::events
- ::layersTraceAnalysis::layers
- ::newTraceAnalysis::new
- ::relationTraceAnalysis::relation
T
TraceError
T
TraceEvent
T
TraceKind
- ::ancestorsTraceQuery::ancestors
- ::between_physical_timesTraceQuery::between_physical_times
- ::by_replicaTraceQuery::by_replica
- ::causal_sliceTraceQuery::causal_slice
- ::concurrent_withTraceQuery::concurrent_with
- ::critical_pathTraceQuery::critical_path
- ::descendantsTraceQuery::descendants
- ::leavesTraceQuery::leaves
- ::longest_path_toTraceQuery::longest_path_to
- ::newTraceQuery::new
- ::rootsTraceQuery::roots
- ::summaryTraceQuery::summary
T
TraceRow
T
TraceSummary
T
VectorDifference
T
VectorEntry
T
VectorError
- ::compareVersionVector::compare
- ::counterVersionVector::counter
- ::entriesVersionVector::entries
- ::from_entriesVersionVector::from_entries
- ::happens_beforeVersionVector::happens_before
- ::incrementVersionVector::increment
- ::mergeVersionVector::merge
- ::newVersionVector::new
T
VersionedValue
V
advance_checkpoint
V
common_frontier
V
concurrency_report_lines
V
edge_rows
V
events_missing_on_right
V
layer_report_lines
V
missing_sync_dots
V
operation_log_frontier
V
plan_checkpoint
V
plan_sync
V
replay_after
V
replicas_ahead
V
same_frontier
V
select_sync_entries
V
sync_batch_frontier
V
sync_operation_count
V
trace_dot_lines
V
trace_kind_detail
V
trace_kind_name
V
trace_mermaid_lines
V
trace_rows
V
validate_checkpoint_against
V
validate_replay
V
vector_differences
V
vector_distance