Class: Hecks::Ports::Projection::Queue

Inherits:

Object

• Object
• Hecks::Ports::Projection::Queue

Defined in:

lib/hecks/ports/projection.rb

Overview

The authoritative append-only journal is the durable projection queue. It is committed before a worker sees it; projection entries are the worker's durable checkpoint, so delivery is at-least-once and safe to replay.

Instance Method Summary

• #entries ⇒ Object
• #initialize(authoritative) ⇒ Queue constructor

  A new instance of Queue.

Constructor Details

#initialize(authoritative) ⇒ Queue

Returns a new instance of Queue.

# File 'lib/hecks/ports/projection.rb', line 91

def initialize(authoritative) = @authoritative = authoritative

Instance Method Details

#entries ⇒ Object

# File 'lib/hecks/ports/projection.rb', line 92

def entries = @authoritative.entries