Sha256: 6595828eb9a79f89afd1f35f72d975edc3f2dd8640cb9978493016bd1922da9d

Contents?: true

Size: 643 Bytes

Versions: 4

Compression:

Stored size: 643 Bytes

Contents

module PgEventstore
  class SubscriptionsLifecycle
    HEARTBEAT_INTERVAL: Integer

    @config_name: Symbol

    @subscriptions_set_lifecycle: PgEventstore::SubscriptionsSetLifecycle

    @subscriptions_pinged_at: Time

    @force_lock: bool

    attr_reader runners: Array[PgEventstore::SubscriptionRunner]

    def initialize: (Symbol config_name, PgEventstore::SubscriptionsSetLifecycle subscriptions_set_lifecycle, ?force_lock: bool)-> void

    def force_locked?: -> bool

    def lock_all: -> void

    def ping_subscriptions: -> void

    def subscriptions: -> Array[PgEventstore::Subscription]

    def force_lock!: -> void
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version Path
pg_eventstore-1.9.0 sig/pg_eventstore/subscriptions/subscriptions_lifecycle.rbs
pg_eventstore-1.8.0 sig/pg_eventstore/subscriptions/subscriptions_lifecycle.rbs
pg_eventstore-1.7.0 sig/pg_eventstore/subscriptions/subscriptions_lifecycle.rbs
pg_eventstore-1.6.0 sig/pg_eventstore/subscriptions/subscriptions_lifecycle.rbs