abstract class Movie::Extension

• Movie::Extension
• Reference
• Object

Overview

Base class for ActorSystem extensions. Extensions provide additional functionality to the actor system (e.g., remoting, clustering, persistence, metrics).

Extensions are:

• Singletons per ActorSystem (one instance per extension type)
• Lazily initialized on first access
• Automatically stopped when the system shuts down

Example: class MyExtension < Movie::Extension def initialize(@system : Movie::AbstractActorSystem) end

def start
  # Initialize extension
end

def stop
  # Cleanup resources
end

end

Register and use

ext = MyExtension.new(system) system.register_extension(ext) system.extension(MyExtension) # => MyExtension instance

Akka-style access with ExtensionId:

class MyExtId < Movie::ExtensionId(MyExtension) def create(system : Movie::AbstractActorSystem) MyExtension.new(system) end end

MyExtId.get(system) # => MyExtension instance

Direct Known Subclasses

• Movie::Cluster::ClusterExtension
• Movie::ClusterReceptionistExtension
• Movie::ClusterRoutersExtension
• Movie::ClusterShardingExtension
• Movie::ClusterSingletonExtension
• Movie::DatabaseExtension
• Movie::ExecutorExtension
• Movie::PersistentEntityExtension(SM, S)
• Movie::Remote::RemoteExtension
• Movie::Streams::Typed::StreamRuntimeExtension

Defined in:

movie.cr

Instance Method Summary

• #start

  Called when the extension is registered with the system.

• #stop

  Called when the system is shutting down.

Instance Method Detail