Class: Pgbus::Web::Streamer::StreamEventDispatcher::StreamEnvelope

Inherits:
Data
  • Object
show all
Defined in:
lib/pgbus/web/streamer/stream_event_dispatcher.rb

Overview

An unwrapped stream broadcast. Similar shape to Pgbus::Client::ReadAfter::Envelope (msg_id + payload) so Connection#enqueue can consume either type via duck typing, but adds the ‘visible_to` label carried through from Pgbus::Streams::Stream#broadcast. The Dispatcher uses visible_to to decide per-connection delivery; Connection never sees the field.

Instance Attribute Summary collapse

Instance Attribute Details

#enqueued_at ⇒ Object (readonly)

Returns the value of attribute enqueued_at

Returns:

  • (Object) —

    the current value of enqueued_at



46
47
48
 
# File 'lib/pgbus/web/streamer/stream_event_dispatcher.rb', line 46

def enqueued_at
  @enqueued_at
end

#msg_id ⇒ Object (readonly)

Returns the value of attribute msg_id

Returns:

  • (Object) —

    the current value of msg_id



46
47
48
 
# File 'lib/pgbus/web/streamer/stream_event_dispatcher.rb', line 46

def msg_id
  @msg_id
end

#payload ⇒ Object (readonly)

Returns the value of attribute payload

Returns:

  • (Object) —

    the current value of payload



46
47
48
 
# File 'lib/pgbus/web/streamer/stream_event_dispatcher.rb', line 46

def payload
  @payload
end

#source ⇒ Object (readonly)

Returns the value of attribute source

Returns:

  • (Object) —

    the current value of source



46
47
48
 
# File 'lib/pgbus/web/streamer/stream_event_dispatcher.rb', line 46

def source
  @source
end

#visible_to ⇒ Object (readonly)

Returns the value of attribute visible_to

Returns:

  • (Object) —

    the current value of visible_to



46
47
48
 
# File 'lib/pgbus/web/streamer/stream_event_dispatcher.rb', line 46

def visible_to
  @visible_to
end