Events

casty.EventStreamMsg = Subscribe[Any] | Unsubscribe[Any] | Publish

casty.EventStreamSubscribe dataclass

event_type instance-attribute

handler instance-attribute

__init__(event_type, handler)

casty.EventStreamUnsubscribe dataclass

event_type instance-attribute

handler instance-attribute

__init__(event_type, handler)

casty.Publish dataclass

event instance-attribute

__init__(event)

casty.event_stream_actor()

casty.ActorStarted dataclass

ref instance-attribute

__init__(ref)

casty.ActorStopped dataclass

ref instance-attribute

__init__(ref)

casty.ActorRestarted dataclass

ref instance-attribute

exception instance-attribute

__init__(ref, exception)

casty.DeadLetter dataclass

message instance-attribute

intended_ref instance-attribute

__init__(message, intended_ref)

casty.UnhandledMessage dataclass

message instance-attribute

ref instance-attribute

__init__(message, ref)

casty.MemberUp dataclass

Emitted when a cluster member transitions to the up status.

Parameters:

Name	Type	Description	Default
member	Member	The cluster member that came up.	required

Examples:

>>> from casty import MemberUp
>>> event = MemberUp(member=member)

member instance-attribute

__init__(member)

casty.MemberLeft dataclass

Emitted when a cluster member leaves the cluster.

Parameters:

Name	Type	Description	Default
member	Member	The cluster member that left.	required

Examples:

>>> from casty import MemberLeft
>>> event = MemberLeft(member=member)

member instance-attribute

__init__(member)

casty.UnreachableMember dataclass

Emitted when the failure detector marks a member as unreachable.

Parameters:

Name	Type	Description	Default
member	Member	The cluster member that became unreachable.	required

Examples:

>>> from casty import UnreachableMember
>>> event = UnreachableMember(member=member)

member instance-attribute

__init__(member)

casty.ReachableMember dataclass

Emitted when a previously unreachable member becomes reachable again.

Parameters:

Name	Type	Description	Default
member	Member	The cluster member that became reachable.	required

Examples:

>>> from casty import ReachableMember
>>> event = ReachableMember(member=member)

member instance-attribute

__init__(member)

casty.Terminated dataclass

Signal sent when a watched actor is stopped.

Delivered to actors that called ctx.watch() on the terminated actor's reference.

ref instance-attribute

__init__(ref)