Sha256: 086edcb27950d17fdc3c339394c5672dd7e0ef23d5505b7788e66da6a8f1b038

Contents?: true

Size: 976 Bytes

Versions: 4

Compression:

Stored size: 976 Bytes

Contents

# frozen_string_literal: true

module PgEventstore
  module SubscriptionRunnerCommands
    # @!visibility private
    class Base
      include Extensions::OptionsExtension
      include Extensions::BaseCommandExtension

      # @!attribute id
      #   @return [Integer]
      attribute(:id)
      # @!attribute name
      #   @return [String]
      attribute(:name) { self.class.name.split('::').last }
      # @!attribute subscription_id
      #   @return [Integer]
      attribute(:subscription_id)
      # @!attribute subscriptions_set_id
      #   @return [Integer]
      attribute(:subscriptions_set_id)
      # @!attribute data
      #   @return [Hash]
      attribute(:data) { {} }
      # @!attribute created_at
      #   @return [Time]
      attribute(:created_at)

      # @param subscription_runner [PgEventstore::SubscriptionRunner]
      # @return [void]
      def exec_cmd(subscription_runner)
        # Implement it in the subclass
      end
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version Path
pg_eventstore-1.1.3 lib/pg_eventstore/subscriptions/subscription_runner_commands/base.rb
pg_eventstore-1.1.2 lib/pg_eventstore/subscriptions/subscription_runner_commands/base.rb
pg_eventstore-1.1.1 lib/pg_eventstore/subscriptions/subscription_runner_commands/base.rb
pg_eventstore-1.1.0 lib/pg_eventstore/subscriptions/subscription_runner_commands/base.rb