module AggregateStreams::Controls::MessageData::Metadata

Public Class Methods

causation_message_global_position() click to toggle source
# File lib/aggregate_streams/controls/message_data/metadata.rb, line 115
def self.causation_message_global_position
  Messaging::Controls::Metadata.causation_message_global_position
end
causation_message_position() click to toggle source
# File lib/aggregate_streams/controls/message_data/metadata.rb, line 111
def self.causation_message_position
  Messaging::Controls::Metadata.causation_message_position
end
causation_message_stream_name() click to toggle source
# File lib/aggregate_streams/controls/message_data/metadata.rb, line 107
def self.causation_message_stream_name
  Messaging::Controls::Metadata.causation_message_stream_name
end
correlation_stream_name() click to toggle source
# File lib/aggregate_streams/controls/message_data/metadata.rb, line 119
def self.correlation_stream_name
  Messaging::Controls::Metadata.correlation_stream_name
end
example(category: nil, stream_id: nil, stream_name: nil, position: nil, global_position: nil, causation_message_stream_name: nil, causation_message_position: nil, causation_message_global_position: nil, correlation_stream_name: nil, reply_stream_name: nil, properties: nil, local_properties: nil, schema_version: nil) click to toggle source
# File lib/aggregate_streams/controls/message_data/metadata.rb, line 5
def self.example(category: nil, stream_id: nil, stream_name: nil, position: nil, global_position: nil, causation_message_stream_name: nil, causation_message_position: nil, causation_message_global_position: nil, correlation_stream_name: nil, reply_stream_name: nil, properties: nil, local_properties: nil, schema_version: nil)
  if stream_name == :none
    stream_name = nil
  else
    stream_name ||= stream_name(id: stream_id, category: category)
  end

  if position == :none
    position = nil
  else
    position ||= self.position
  end

  if global_position == :none
    global_position = nil
  else
    global_position ||= self.global_position
  end

  if causation_message_stream_name == :none
    causation_message_stream_name = nil
  else
    causation_message_stream_name ||= self.causation_message_stream_name
  end

  if causation_message_position == :none
    causation_message_position = nil
  else
    causation_message_position ||= self.causation_message_position
  end

  if causation_message_global_position == :none
    causation_message_global_position = nil
  else
    causation_message_global_position ||= self.causation_message_global_position
  end

  if correlation_stream_name == :none
    correlation_stream_name = nil
  else
    correlation_stream_name ||= Metadata.correlation_stream_name
  end

  if reply_stream_name == :none
    reply_stream_name = nil
  else
    reply_stream_name ||= Metadata.reply_stream_name
  end

  if properties == :none
    properties = nil
  else
    properties ||= self.properties
  end

  if local_properties == :none
    local_properties = nil
  else
    local_properties ||= self.local_properties
  end

  if schema_version == :none
    schema_version = nil
  else
    schema_version ||= Metadata.schema_version
  end

  metadata = {
    :stream_name => stream_name,
    :position => position,
    :global_position => global_position,

    :causation_message_stream_name => causation_message_stream_name,
    :causation_message_position => causation_message_position,
    :causation_message_global_position => causation_message_global_position,

    :correlation_stream_name => correlation_stream_name,
    :reply_stream_name => reply_stream_name,

    :properties => properties,
    :local_properties => local_properties,

    :schema_version => schema_version
  }

  metadata.delete_if { |_, v| v.nil? }

  metadata
end
global_position() click to toggle source
# File lib/aggregate_streams/controls/message_data/metadata.rb, line 103
def self.global_position
  Position::Global.example
end
local_properties() click to toggle source
# File lib/aggregate_streams/controls/message_data/metadata.rb, line 131
def self.local_properties
  Messaging::Controls::LocalProperties.example
end
position() click to toggle source
# File lib/aggregate_streams/controls/message_data/metadata.rb, line 99
def self.position
  Position.example
end
properties() click to toggle source
# File lib/aggregate_streams/controls/message_data/metadata.rb, line 127
def self.properties
  Messaging::Controls::Properties.example
end
reply_stream_name() click to toggle source
# File lib/aggregate_streams/controls/message_data/metadata.rb, line 123
def self.reply_stream_name
  Messaging::Controls::Metadata.reply_stream_name
end
schema_version() click to toggle source
# File lib/aggregate_streams/controls/message_data/metadata.rb, line 135
def self.schema_version
  Messaging::Controls::Metadata.schema_version
end
stream_name(**args) click to toggle source
# File lib/aggregate_streams/controls/message_data/metadata.rb, line 95
def self.stream_name(**args)
  StreamName.example(**args)
end