class Session::ClusterCoordinator(T)

• Session::ClusterCoordinator(T)
• Reference
• Object

Overview

Main cluster coordinator for managing pub/sub and local caching

Generic Constraint: T must inherit from Session::Base - represents the session type Internally manages LocalCache(T) for caching complete session objects

Defined in:

cluster.cr

Constructors

• .new(redis : Redis, config : ClusterConfig = ClusterConfig.new)

Instance Method Summary

• #config : ClusterConfig
• #local_cache : LocalCache(T)
• #node_id : String
• #publish_cache_clear : Nil

  Publish a cache clear message to all nodes

• #publish_invalidation(session_id : String) : Nil

  Publish a session invalidation message to the cluster

• #publish_session_invalidated(session_id : String) : Nil

  Publish a session updated message (for invalidation on update)

• #running? : Bool

  Check if the coordinator is running

• #start : Nil

  Start the background subscription fiber

• #stop : Nil

  Gracefully stop the coordinator

Constructor Detail

Instance Method Detail