123456789_123456789_123456789_123456789_123456789_

Class: Redis::KeyspaceNotifications::Manager::Registration

Relationships & Source Files
Super Chains via Extension / Inclusion / Inheritance
Class Chain:
self, Struct
Instance Chain:
self, Struct
Inherits: Struct
  • Object
Defined in: lib/redis/keyspace_notifications/manager.rb

Overview

A fresh object per (re-)subscription, so concurrent operations can tell "the registration I captured" from "the same pattern re-registered meanwhile". #failed marks it dead for good (its subscribe rolled back, or an unsubscribe targeting it completed) so a rollback never resurrects it; a timed-out unsubscribe does NOT mark — that registration legitimately lives on.

Instance Attribute Summary

  • #failed rw

    A fresh object per (re-)subscription, so concurrent operations can tell "the registration I captured" from "the same pattern re-registered meanwhile".

  • #handler rw

    A fresh object per (re-)subscription, so concurrent operations can tell "the registration I captured" from "the same pattern re-registered meanwhile".

Instance Attribute Details

#failed (rw)

A fresh object per (re-)subscription, so concurrent operations can tell "the registration I captured" from "the same pattern re-registered meanwhile". failed marks it dead for good (its subscribe rolled back, or an unsubscribe targeting it completed) so a rollback never resurrects it; a timed-out unsubscribe does NOT mark — that registration legitimately lives on.

[ GitHub ]

  
# File 'lib/redis/keyspace_notifications/manager.rb', line 30

Registration = Struct.new(:handler, :failed)

#handler (rw)

A fresh object per (re-)subscription, so concurrent operations can tell "the registration I captured" from "the same pattern re-registered meanwhile". #failed marks it dead for good (its subscribe rolled back, or an unsubscribe targeting it completed) so a rollback never resurrects it; a timed-out unsubscribe does NOT mark — that registration legitimately lives on.

[ GitHub ]

  
# File 'lib/redis/keyspace_notifications/manager.rb', line 30

Registration = Struct.new(:handler, :failed)