class Movie::Remote::ControlDeduplicator

• Movie::Remote::ControlDeduplicator
• Reference
• Object

Overview

Tracks one contiguous cursor per node/stream. The global mutex protects only stream lookup; delivery is serialized by the affected stream so a slow actor route does not block unrelated associations.

Defined in:

movie/remote/control_delivery.cr

Constructors

• .new(max_streams : Int32 = 8192)

Instance Method Summary

• #deliver(node_uid : String, stream : String, sequence : Int64, &) : ControlObservation
• #observe(node_uid : String, stream : String, sequence : Int64) : ControlObservation
• #retire_node(node_uid : String) : Int32

  Retires all streams for a process incarnation.

• #stats : ControlDeduplicationStats

Constructor Detail

Instance Method Detail