Open Sidebar
Close Sidebar
Movie
0.1.0
MainMessage
Movie
AbstractActorContext
AbstractActorSystem
AbstractBehavior
ActorContext
State
ActorPath
ActorRef
ActorRefBase
ActorRegistry
ActorSystem
ActorSystemConfig
ActorSystemShuttingDownError
ActorUnavailableError
Address
Ask
Cancelled
Failure
LocalResponseRef
LocalResponseRefBase
Response
Success
TargetTerminated
Behaviors
Cluster
AllocationPlanner
AllocationPlanResult
AllocationSnapshot
BehaviorEntityProvider
BootstrapCoordinator
BootstrapDecision
BootstrapDecisionKind
BootstrapSettings
BroadcastClusterRoutingPolicy
ClusterCompatibility
ClusterConfigurationError
ClusterDaemon
ClusterEvent
Kind
ClusterEventBus
ClusterExtension
ClusterRouterConfigurationError
ClusterRouterLimits
ClusterRouterListingObserver
ClusterRouterPool
ClusterRouterPoolBase
ClusterRouterRef
ClusterRouterRefBase
ClusterRouterRouteeLifecycle
ClusterRouterSettings
ClusterRouterStats
ClusterRouterStoppedError
ClusterRouterTelemetry
ClusterRouterUnavailableError
ClusterRoutingPolicy
ClusterRoutingPolicyFactory
ClusterRoutingStrategy
ClusterSafetyView
ClusterSettings
ClusterShardingConfigurationError
ClusterSingletonConfigurationError
ClusterSingletonRef
ClusterSnapshot
ClusterSplitBrainExtension
ClusterStats
ClusterTelemetry
ClusterTransport
DiscoveryError
DiscoveryHttpResponse
DnsSeedDiscovery
EntityPartitioner
KeepMajorityCoordinator
KeepMajoritySettings
KubernetesSeedDiscovery
LeaseMajorityCoordinator
LeaseMajoritySettings
LeastLoadedAllocation
Member
MembershipCapacityError
MembershipCoordinator
MembershipState
MemberStatus
NoRebalance
NoShardOwnerError
PendingShardingDelivery
PersistentEntityProvider
PlanBootstrapCandidate
PostgresSplitBrainLease
ProtocolMessage
Kind
RandomClusterRoutingPolicy
RateLimitedRebalance
ReachabilityState
RebalancePolicy
ReceptionistClusterEventListener
ReceptionistConfigurationError
ReceptionistDaemon
ReceptionistEnvelope
ReceptionistLimits
ReceptionistListing
ReceptionistListingBuilder
ReceptionistNodeState
ReceptionistStats
ReceptionistSubscription
ReceptionistSubscriptionBase
ReceptionistTelemetry
ReceptionistTransport
ReceptionistWatcher
RendezvousAllocation
RendezvousHashClusterRoutingPolicy
RoleAwareAllocation
RoundRobinClusterRoutingPolicy
SeedDiscovery
ServiceKey
ServiceRef
ServiceRegistration
ShardAllocations
ShardAllocationStrategy
ShardAssignment
ShardedEntityProvider
ShardedEntityRef
ShardedEntityType
ShardHandoffInProgressError
ShardingClusterEventListener
ShardingControlAck
ShardingDaemon
ShardingEnvelope
Kind
ShardingMessage
ShardingMessageConverter
ShardingPlanState
ShardingSettings
ShardingStats
ShardingTelemetry
ShardKey
ShardLeaseUnavailableError
SingletonBackingIdentity
SingletonBackingKind
SingletonPartitioner
SingletonRegistration
SingletonRegistrationBase
SingletonSettings
SingletonStats
SingletonTelemetry
SplitBrainCoordinator
SplitBrainLease
SplitBrainLeaseToken
SplitBrainState
SplitBrainStats
SplitBrainStrategy
StableHashPartitioner
UniqueAddress
WeightedLeastLoadedAllocation
ClusterReceptionist
ClusterReceptionistExtension
ClusterRouters
ClusterRoutersExtension
ClusterSharding
ClusterShardingExtension
ClusterSingleton
ClusterSingletonExtension
ConcurrentDispatcher
Config
ConfigBuilder
ConfigError
ConfigValue
Database
DatabaseExtension
DeadLetter
DeadLetters
DeferredBehavior
Dispatcher
DispatcherRegistry
DrainAndStop
DurableAction
DurableEffect
DurableState
DurableStateBehavior
DurableStateExtension
Envelope
EventEffect
EventSourcedBehavior
EventSourcing
EventSourcingExtension
Execution
ExecutorExtension
ExecutorStopped
TaskFailure
TaskReply
TaskSuccess
Extension
ExtensionId
ExtensionRegistry
ExtensionStartError
Failed
Future
FutureAlreadyCompleted
FutureCancelled
FutureResult
FutureStatus
FutureSubscription
FutureTimeout
Mailbox
MailboxManager
MissingConfigError
OutboxEffect
ParallelDispatcher
PathRegistry
Persistence
AbstractTransactionalProjectionRunner
AcknowledgeOutbox
AcquireShardLease
AppendEvents
Backend
BackendConfigurationError
BackendConnection
BackendRegistry
Factory
CircuitOpenError
ClaimOutbox
CommitProjection
ConcurrentWriteError
ConnectionActor
ConnectionMessage
ConnectionPool
ConnectionRequest
ConnectionWorker
Stopped
DbArgs
DbExec
DbExecLastId
DbQueryString
DbQueryStrings
DeleteEventsTo
DeleteProjectionOffset
DeleteSnapshot
DeleteState
DuplicateProjectionHandlerError
DurableStateBackend
DurableStateEnvelope
DurableStatePage
DurableStateProjection
EnsureEventStore
EnsureStateStore
EntityId
EntityProvider
Factory
EntityRegistry
EntityType
EventEnvelope
EventPage
EventProjection
EventStoreActor
EventStoreClient
EventStoreMessage
GetEntity
GetSchemaVersion
HealthSnapshot
HealthStatus
Id
InvalidMigrationHistoryError
JournalBackend
LoadEvents
LoadProjectionOffset
LoadShardLease
LoadSnapshot
LoadState
MaintenanceResult
MetricsSnapshot
MigrationChecksumMismatchError
OperationConflictError
OperationId
OutboxBackend
OutboxDispatcher
OutboxDispatchResult
OutboxEntry
PostgresBackend
PostgresBackendConnection
ProjectionBehindRetentionError
ProjectionCommitResult
ProjectionControl
ProjectionEnvelope
ProjectionFailureDecider
ProjectionFailureDirective
ProjectionHandler
ProjectionId
ProjectionOffsetConflictError
ProjectionOffsetRegressionError
ProjectionProgressHandler
ProjectionRunner
ProjectionRunResult
ProjectionRuntimeState
ProjectionSettings
ProjectionSource
ProjectionStatus
ProjectionTransaction
QueryBackend
QueryDurableStateChanges
QueryEvents
QueryStoreMessage
ReadinessSnapshot
RegistryMessage
ReleaseOutbox
ReleaseShardLease
RenewShardLease
ResiliencePolicy
RetentionBackend
RetentionResult
RetryableConnectionRequest
RunMaintenance
SaveProjectionOffset
SaveSnapshot
SaveState
SchemaBackend
SchemaMigration
SerializedEvent
ShardLeaseKey
ShardLeaseToken
SnapshotBackend
SnapshotRecord
SqlBackendConnection
SQLiteBackend
SQLiteBackendConnection
StaleShardOwnerError
StateRecord
StateStoreActor
StateStoreClient
StateStoreMessage
StoredEvent
StoredOutboxEntry
Telemetry
TransactionalDurableStateProjectionRunner
TransactionalProjectionRunner
TypedConnectionRequest
UnhandledProjectionEventError
UnknownBackendError
UnsafeRetentionError
UnsupportedSchemaVersionError
WriteResult
PersistentEntityExtension
PinnedDispatcher
Pipe
Failure
Message
Success
PoolExecutionContext
PostRestart
PostStart
PostStop
PreRestart
PreStart
PreStop
Projections
ProjectionsExtension
Promise
Queue
QueueNode
ReceiveMessageBehavior
Remote
AnyJsonPayload
AssociationConfirmation
AssociationHandshake
AssociationNegotiator
AssociationProtocolError
AssociationSettings
ClientTransportFactory
Connection
State
ConnectionStats
ControlDeduplicationCapacityError
ControlDeduplicationStats
ControlDeduplicator
ControlObservation
FrameCodec
Decoder
Encoder
FrameTooLargeError
HandshakeReady
HandshakeRejection
InboundConnection
InboundFrameBatchDecoder
InboundFrameReader
JsonPayload
JsonPayloadDecoder
MalformedFrameError
MalformedMessagePayloadError
MessageDeserializer
MessageRegistry
MessageWrapper
OutboundWriter
PendingAskRegistry
PendingControlBuffer
PoolStats
RawJsonPayload
RemoteActorRef
RemoteAskError
RemoteAskFailurePayload
RemoteAskResponseSenderRef
RemoteDeliveryError
RemoteExtension
RemoteFailedSystemPayload
RemotePeerIdentity
RemoteSystemFailureError
RemoteUnsupportedSystemMessageError
Remoting
SerializableJsonPayload
Server
ServerTransportWrapper
StripedConnectionPool
SystemMessageCodec
TypedDeserializer
TypedMessageWrapper
WireEnvelope
Kind
Restart
RestartStrategy
Resume
RootGuardian
RootGuardianMessage
SameBehavior
Scheduler
Stop
StoppedBehavior
Streams
StageState
Typed
BlueprintRuntime
BroadcastHub
SubscriberState
BufferOverflowError
Cancel
CollectSink
CompletionFlow
DeliveryControl
DropFlow
FilterFlow
Flow
Flows
FoldSink
ManualSource
ManualSourceControl
MapFlow
Materialization
MaterializationScope
MaterializedPipeline
MessageBase
NotUsed
OnComplete
OnError
OnNext
OnSubscribe
OverflowStrategy
PassThroughFlow
Produce
QueueOfferResult
QueueOfferStatus
Request
RunnableFoldPipeline
RunnableGraph
RunnablePipeline
Sink
Sinks
Source
Sources
StageChannel
StreamBuilder
StreamCancelledError
StreamClosedError
StreamCompleted
StreamElement
StreamEvent
StreamFailed
StreamRuntimeExtension
Subscribe
Subscription
SubscriptionCancel
SubscriptionRequest
TakeFlow
TapFlow
TestKitAssertionError
TestPublisherProbe
TestSinks
TestSources
TestSubscriberProbe
SupervisionConfig
SupervisionScope
SupervisionStrategy
SystemGuardian
SystemGuardianMessage
SystemMessage
Terminate
Terminated
TimerHandle
Unwatch
UserGuardian
UserGuardianMessage
Watch
WrongTypeConfigError
alias
Movie::
Persistence::
ProjectionProgressHandler
Alias Definition
Movie::Persistence::ProjectionCommitResult
-> Nil
Defined in:
movie/persistence/protocol.cr