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