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