Class: PgEventstore::SubscriptionsSet

Inherits:
Object
  • Object
show all
Includes:
Extensions::OptionsExtension
Defined in:
lib/pg_eventstore/subscriptions/subscriptions_set.rb

Overview

Defines ruby’s representation of subscriptions_set record.

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Methods included from Extensions::OptionsExtension

included, #initialize, #options_hash, #readonly!, #readonly?

Instance Attribute Details

#created_at ⇒ Time?

Returns:

  • (Time, nil) 


54
 
# File 'lib/pg_eventstore/subscriptions/subscriptions_set.rb', line 54

attribute(:created_at)

#id ⇒ Integer?

Returns It is used to lock the Subscription by updating Subscription#locked_by attribute.

Returns:

  • (Integer, nil) —

    It is used to lock the Subscription by updating Subscription#locked_by attribute



26
 
# File 'lib/pg_eventstore/subscriptions/subscriptions_set.rb', line 26

attribute(:id)

#last_error ⇒ Hash?

Returns the information about last error caused when pulling Subscriptions events.

Returns:

  • (Hash, nil) —

    the information about last error caused when pulling Subscriptions events.



48
 
# File 'lib/pg_eventstore/subscriptions/subscriptions_set.rb', line 48

attribute(:last_error)

#last_error_occurred_at ⇒ Time?

Returns the time when the last error occurred.

Returns:

  • (Time, nil) —

    the time when the last error occurred



51
 
# File 'lib/pg_eventstore/subscriptions/subscriptions_set.rb', line 51

attribute(:last_error_occurred_at)

#last_restarted_at ⇒ Time?

Returns last time the SubscriptionsSet was restarted.

Returns:

  • (Time, nil) —

    last time the SubscriptionsSet was restarted



44
 
# File 'lib/pg_eventstore/subscriptions/subscriptions_set.rb', line 44

attribute(:last_restarted_at)

#max_restarts_number ⇒ Integer?

Returns maximum number of times the SubscriptionsSet can be restarted.

Returns:

  • (Integer, nil) —

    maximum number of times the SubscriptionsSet can be restarted



38
 
# File 'lib/pg_eventstore/subscriptions/subscriptions_set.rb', line 38

attribute(:max_restarts_number)

#name ⇒ String?

Returns name of the set.

Returns:

  • (String, nil) —

    name of the set



29
 
# File 'lib/pg_eventstore/subscriptions/subscriptions_set.rb', line 29

attribute(:name)

#restart_count ⇒ Integer?

Returns the number of SubscriptionsSet’s restarts after its failure.

Returns:

  • (Integer, nil) —

    the number of SubscriptionsSet’s restarts after its failure



35
 
# File 'lib/pg_eventstore/subscriptions/subscriptions_set.rb', line 35

attribute(:restart_count)

#state ⇒ String?

Returns:

  • (String, nil) 


32
 
# File 'lib/pg_eventstore/subscriptions/subscriptions_set.rb', line 32

attribute(:state)

#time_between_restarts ⇒ Integer?

Returns interval in seconds between retries of failed SubscriptionsSet.

Returns:

  • (Integer, nil) —

    interval in seconds between retries of failed SubscriptionsSet



41
 
# File 'lib/pg_eventstore/subscriptions/subscriptions_set.rb', line 41

attribute(:time_between_restarts)

#updated_at ⇒ Time?

Returns:

  • (Time, nil) 


57
 
# File 'lib/pg_eventstore/subscriptions/subscriptions_set.rb', line 57

attribute(:updated_at)

Class Method Details

.create(attrs) ⇒ PgEventstore::SubscriptionsSet

Parameters:

  • attrs (Hash)

Returns:



12
13
14
 
# File 'lib/pg_eventstore/subscriptions/subscriptions_set.rb', line 12

def create(attrs)
  new(**subscriptions_set_queries.create(attrs))
end

Instance Method Details

#==(other) ⇒ Boolean

Parameters:

  • other (Object)

Returns:

  • (Boolean) 


105
106
107
108
109
 
# File 'lib/pg_eventstore/subscriptions/subscriptions_set.rb', line 105

def ==(other)
  return false unless other.is_a?(SubscriptionsSet)

  id == other.id
end

#assign_attributes(attrs) ⇒ Hash

Parameters:

  • attrs (Hash)

Returns:

  • (Hash) 


61
62
63
64
65
 
# File 'lib/pg_eventstore/subscriptions/subscriptions_set.rb', line 61

def assign_attributes(attrs)
  attrs.each do |attr, value|
    public_send("#{attr}=", value)
  end
end

#delete ⇒ void

This method returns an undefined value.



74
75
76
 
# File 'lib/pg_eventstore/subscriptions/subscriptions_set.rb', line 74

def delete
  subscriptions_set_queries.delete(id)
end

#dup ⇒ PgEventstore::SubscriptionsSet

Dup the current object without assigned connection

Returns:



80
81
82
 
# File 'lib/pg_eventstore/subscriptions/subscriptions_set.rb', line 80

def dup
  SubscriptionsSet.new(**Utils.deep_dup(options_hash))
end

#eql?(other) ⇒ Boolean

Parameters:

  • other (Object)

Returns:

  • (Boolean) 


97
98
99
100
101
 
# File 'lib/pg_eventstore/subscriptions/subscriptions_set.rb', line 97

def eql?(other)
  return false unless other.is_a?(SubscriptionsSet)

  hash == other.hash
end

#hash ⇒ Integer

Returns:

  • (Integer) 


91
92
93
 
# File 'lib/pg_eventstore/subscriptions/subscriptions_set.rb', line 91

def hash
  id.hash
end

#reload ⇒ PgEventstore::SubscriptionsSet

Returns:



85
86
87
88
 
# File 'lib/pg_eventstore/subscriptions/subscriptions_set.rb', line 85

def reload
  assign_attributes(subscriptions_set_queries.find!(id))
  self
end

#update(attrs) ⇒ Hash

Parameters:

  • attrs (Hash)

Returns:

  • (Hash) 


69
70
71
 
# File 'lib/pg_eventstore/subscriptions/subscriptions_set.rb', line 69

def update(attrs)
  assign_attributes(subscriptions_set_queries.update(id, attrs))
end