Class: JetstreamBridge::Models::Event::Metadata

Inherits:
Struct
  • Object
show all
Defined in:
lib/jetstream_bridge/models/event.rb

Overview

Metadata associated with message delivery.

Contains NATS-level delivery information such as the subject, delivery count, stream name, and sequence number.

Instance Attribute Summary collapse

Instance Method Summary collapse

Instance Attribute Details

#consumer ⇒ String? (readonly)

Returns Consumer name.

Returns:

  • Consumer name



35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
 
# File 'lib/jetstream_bridge/models/event.rb', line 35

Metadata = Struct.new(
  :subject,
  :deliveries,
  :stream,
  :sequence,
  :consumer,
  :timestamp,
  keyword_init: true
) do
  def to_h
    {
      subject: subject,
      deliveries: deliveries,
      stream: stream,
      sequence: sequence,
      consumer: consumer,
      timestamp: timestamp
    }.compact
  end
end

#deliveries ⇒ Integer (readonly)

Returns Number of delivery attempts.

Returns:

  • Number of delivery attempts



35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
 
# File 'lib/jetstream_bridge/models/event.rb', line 35

Metadata = Struct.new(
  :subject,
  :deliveries,
  :stream,
  :sequence,
  :consumer,
  :timestamp,
  keyword_init: true
) do
  def to_h
    {
      subject: subject,
      deliveries: deliveries,
      stream: stream,
      sequence: sequence,
      consumer: consumer,
      timestamp: timestamp
    }.compact
  end
end

#sequence ⇒ Integer? (readonly)

Returns Message sequence number in the stream.

Returns:

  • Message sequence number in the stream



35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
 
# File 'lib/jetstream_bridge/models/event.rb', line 35

Metadata = Struct.new(
  :subject,
  :deliveries,
  :stream,
  :sequence,
  :consumer,
  :timestamp,
  keyword_init: true
) do
  def to_h
    {
      subject: subject,
      deliveries: deliveries,
      stream: stream,
      sequence: sequence,
      consumer: consumer,
      timestamp: timestamp
    }.compact
  end
end

#stream ⇒ String? (readonly)

Returns Stream name.

Returns:

  • Stream name



35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
 
# File 'lib/jetstream_bridge/models/event.rb', line 35

Metadata = Struct.new(
  :subject,
  :deliveries,
  :stream,
  :sequence,
  :consumer,
  :timestamp,
  keyword_init: true
) do
  def to_h
    {
      subject: subject,
      deliveries: deliveries,
      stream: stream,
      sequence: sequence,
      consumer: consumer,
      timestamp: timestamp
    }.compact
  end
end

#subject ⇒ String (readonly)

Returns NATS subject the message was received on.

Returns:

  • NATS subject the message was received on



35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
 
# File 'lib/jetstream_bridge/models/event.rb', line 35

Metadata = Struct.new(
  :subject,
  :deliveries,
  :stream,
  :sequence,
  :consumer,
  :timestamp,
  keyword_init: true
) do
  def to_h
    {
      subject: subject,
      deliveries: deliveries,
      stream: stream,
      sequence: sequence,
      consumer: consumer,
      timestamp: timestamp
    }.compact
  end
end

#timestamp ⇒ Time (readonly)

Returns When the metadata was captured.

Returns:

  • When the metadata was captured



35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
 
# File 'lib/jetstream_bridge/models/event.rb', line 35

Metadata = Struct.new(
  :subject,
  :deliveries,
  :stream,
  :sequence,
  :consumer,
  :timestamp,
  keyword_init: true
) do
  def to_h
    {
      subject: subject,
      deliveries: deliveries,
      stream: stream,
      sequence: sequence,
      consumer: consumer,
      timestamp: timestamp
    }.compact
  end
end

Instance Method Details

#to_h ⇒ Object 



44
45
46
47
48
49
50
51
52
53
 
# File 'lib/jetstream_bridge/models/event.rb', line 44

def to_h
  {
    subject: subject,
    deliveries: deliveries,
    stream: stream,
    sequence: sequence,
    consumer: consumer,
    timestamp: timestamp
  }.compact
end