Package org.apache.pekko.persistence.typed.internal

Class EventSourcedBehaviorImpl$

java.lang.Object

org.apache.pekko.persistence.typed.internal.EventSourcedBehaviorImpl$

All Implemented Interfaces:

Serializable

public class EventSourcedBehaviorImpl$
extends Object
implements Serializable

See Also:

• Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
static final EventSourcedBehaviorImpl$	MODULE$	Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor	Description
EventSourcedBehaviorImpl$()

Method Summary

Modifier and Type	Method	Description
<Command, Event, State> scala.Function1<Event,scala.collection.immutable.Set<String>>	$lessinit$greater$default$10()
<Command, Event, State> <any>	$lessinit$greater$default$11()
<Command, Event, State> SnapshotAdapter<State>	$lessinit$greater$default$12()
<Command, Event, State> scala.Function3<Object,Object,Object,Object>	$lessinit$greater$default$13()
<Command, Event, State> Recovery	$lessinit$greater$default$14()
<Command, Event, State> RetentionCriteria	$lessinit$greater$default$15()
<Command, Event, State> SupervisorStrategy	$lessinit$greater$default$16()
<Command, Event, State> scala.PartialFunction<Object,scala.runtime.Nothing$>	$lessinit$greater$default$17()
<Command, Event, State> scala.Option<org.apache.pekko.persistence.typed.internal.ReplicationSetup>	$lessinit$greater$default$18()
<Command, Event, State> boolean	$lessinit$greater$default$19()
<Command, Event, State> scala.Option<Object>	$lessinit$greater$default$20()
<Command, Event, State> scala.Option<String>	$lessinit$greater$default$6()	Used to start the replication stream at the correct sequence number
<Command, Event, State> scala.Option<String>	$lessinit$greater$default$7()
<Command, Event, State> scala.Option<com.typesafe.config.Config>	$lessinit$greater$default$8()
<Command, Event, State> scala.Option<com.typesafe.config.Config>	$lessinit$greater$default$9()
<Command, Event, State> org.apache.pekko.persistence.typed.internal.EventSourcedBehaviorImpl<Command,Event,State>	apply(PersistenceId persistenceId, State emptyState, scala.Function2<State,Command,Effect<Event,State>> commandHandler, scala.Function2<State,Event,State> eventHandler, Class<?> loggerClass, scala.Option<String> journalPluginId, scala.Option<String> snapshotPluginId, scala.Option<com.typesafe.config.Config> journalPluginConfig, scala.Option<com.typesafe.config.Config> snapshotPluginConfig, scala.Function1<Event,scala.collection.immutable.Set<String>> tagger, EventAdapter<Event,Object> eventAdapter, SnapshotAdapter<State> snapshotAdapter, scala.Function3<State,Event,Object,Object> snapshotWhen, Recovery recovery, RetentionCriteria retention, SupervisorStrategy supervisionStrategy, scala.PartialFunction<scala.Tuple2<State,Signal>,scala.runtime.BoxedUnit> signalHandler, scala.Option<org.apache.pekko.persistence.typed.internal.ReplicationSetup> replication, boolean publishEvents, scala.Option<Object> customStashCapacity)
<Command, Event, State> scala.Function1<Event,scala.collection.immutable.Set<String>>	apply$default$10()
<Command, Event, State> <any>	apply$default$11()
<Command, Event, State> SnapshotAdapter<State>	apply$default$12()
<Command, Event, State> scala.Function3<Object,Object,Object,Object>	apply$default$13()
<Command, Event, State> Recovery	apply$default$14()
<Command, Event, State> RetentionCriteria	apply$default$15()
<Command, Event, State> SupervisorStrategy	apply$default$16()
<Command, Event, State> scala.PartialFunction<Object,scala.runtime.Nothing$>	apply$default$17()
<Command, Event, State> scala.Option<org.apache.pekko.persistence.typed.internal.ReplicationSetup>	apply$default$18()
<Command, Event, State> boolean	apply$default$19()
<Command, Event, State> scala.Option<Object>	apply$default$20()
<Command, Event, State> scala.Option<String>	apply$default$6()
<Command, Event, State> scala.Option<String>	apply$default$7()
<Command, Event, State> scala.Option<com.typesafe.config.Config>	apply$default$8()
<Command, Event, State> scala.Option<com.typesafe.config.Config>	apply$default$9()
<Command, Event, State> scala.Option<scala.Tuple20<PersistenceId,State,scala.Function2<State,Command,Effect<Event,State>>,scala.Function2<State,Event,State>,Class<?>,scala.Option<String>,scala.Option<String>,scala.Option<com.typesafe.config.Config>,scala.Option<com.typesafe.config.Config>,scala.Function1<Event,scala.collection.immutable.Set<String>>,EventAdapter<Event,Object>,SnapshotAdapter<State>,scala.Function3<State,Event,Object,Object>,Recovery,RetentionCriteria,SupervisorStrategy,scala.PartialFunction<scala.Tuple2<State,Signal>,scala.runtime.BoxedUnit>,scala.Option<org.apache.pekko.persistence.typed.internal.ReplicationSetup>,Object,scala.Option<Object>>>	unapply(org.apache.pekko.persistence.typed.internal.EventSourcedBehaviorImpl<Command,Event,State> x$0)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

MODULE$

public static final EventSourcedBehaviorImpl$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Details

EventSourcedBehaviorImpl$

public EventSourcedBehaviorImpl$()

Method Details

$lessinit$greater$default$6

public <Command,
Event,
State> scala.Option<String> $lessinit$greater$default$6()

Used to start the replication stream at the correct sequence number

$lessinit$greater$default$7

public <Command,
Event,
State> scala.Option<String> $lessinit$greater$default$7()

$lessinit$greater$default$8

public <Command,
Event,
State>
scala.Option<com.typesafe.config.Config> $lessinit$greater$default$8()

$lessinit$greater$default$9

public <Command,
Event,
State>
scala.Option<com.typesafe.config.Config> $lessinit$greater$default$9()

$lessinit$greater$default$10

public <Command,
Event,
State>
scala.Function1<Event,scala.collection.immutable.Set<String>> $lessinit$greater$default$10()

$lessinit$greater$default$11

public <Command,
Event,
State> <any> $lessinit$greater$default$11()

$lessinit$greater$default$12

public <Command,
Event,
State> SnapshotAdapter<State> $lessinit$greater$default$12()

$lessinit$greater$default$13

public <Command,
Event,
State>
scala.Function3<Object,Object,Object,Object> $lessinit$greater$default$13()

$lessinit$greater$default$14

public <Command,
Event,
State> Recovery $lessinit$greater$default$14()

$lessinit$greater$default$15

public <Command,
Event,
State> RetentionCriteria $lessinit$greater$default$15()

$lessinit$greater$default$16

public <Command,
Event,
State> SupervisorStrategy $lessinit$greater$default$16()

$lessinit$greater$default$17

public <Command,
Event,
State>
scala.PartialFunction<Object,scala.runtime.Nothing$> $lessinit$greater$default$17()

$lessinit$greater$default$18

public <Command,
Event,
State>
scala.Option<org.apache.pekko.persistence.typed.internal.ReplicationSetup> $lessinit$greater$default$18()

$lessinit$greater$default$19

public <Command,
Event,
State> boolean $lessinit$greater$default$19()

$lessinit$greater$default$20

public <Command,
Event,
State> scala.Option<Object> $lessinit$greater$default$20()

apply

public <Command,
Event,
State>
org.apache.pekko.persistence.typed.internal.EventSourcedBehaviorImpl<Command,Event,State> apply(PersistenceId persistenceId,
 State emptyState,
 scala.Function2<State,Command,Effect<Event,State>> commandHandler,
 scala.Function2<State,Event,State> eventHandler,
 Class<?> loggerClass,
 scala.Option<String> journalPluginId,
 scala.Option<String> snapshotPluginId,
 scala.Option<com.typesafe.config.Config> journalPluginConfig,
 scala.Option<com.typesafe.config.Config> snapshotPluginConfig,
 scala.Function1<Event,scala.collection.immutable.Set<String>> tagger,
 EventAdapter<Event,Object> eventAdapter,
 SnapshotAdapter<State> snapshotAdapter,
 scala.Function3<State,Event,Object,Object> snapshotWhen,
 Recovery recovery,
 RetentionCriteria retention,
 SupervisorStrategy supervisionStrategy,
 scala.PartialFunction<scala.Tuple2<State,Signal>,scala.runtime.BoxedUnit> signalHandler,
 scala.Option<org.apache.pekko.persistence.typed.internal.ReplicationSetup> replication,
 boolean publishEvents,
 scala.Option<Object> customStashCapacity)

apply$default$10

public <Command,
Event,
State>
scala.Function1<Event,scala.collection.immutable.Set<String>> apply$default$10()

apply$default$11

public <Command,
Event,
State> <any> apply$default$11()

apply$default$12

public <Command,
Event,
State> SnapshotAdapter<State> apply$default$12()

apply$default$13

public <Command,
Event,
State>
scala.Function3<Object,Object,Object,Object> apply$default$13()

apply$default$14

public <Command,
Event,
State> Recovery apply$default$14()

apply$default$15

public <Command,
Event,
State> RetentionCriteria apply$default$15()

apply$default$16

public <Command,
Event,
State> SupervisorStrategy apply$default$16()

apply$default$17

public <Command,
Event,
State>
scala.PartialFunction<Object,scala.runtime.Nothing$> apply$default$17()

apply$default$18

public <Command,
Event,
State>
scala.Option<org.apache.pekko.persistence.typed.internal.ReplicationSetup> apply$default$18()

apply$default$19

public <Command,
Event,
State> boolean apply$default$19()

apply$default$20

public <Command,
Event,
State> scala.Option<Object> apply$default$20()

apply$default$6

public <Command,
Event,
State> scala.Option<String> apply$default$6()

apply$default$7

public <Command,
Event,
State> scala.Option<String> apply$default$7()

apply$default$8

public <Command,
Event,
State>
scala.Option<com.typesafe.config.Config> apply$default$8()

apply$default$9

public <Command,
Event,
State>
scala.Option<com.typesafe.config.Config> apply$default$9()

unapply

public <Command,
Event,
State>
scala.Option<scala.Tuple20<PersistenceId,State,scala.Function2<State,Command,Effect<Event,State>>,scala.Function2<State,Event,State>,Class<?>,scala.Option<String>,scala.Option<String>,scala.Option<com.typesafe.config.Config>,scala.Option<com.typesafe.config.Config>,scala.Function1<Event,scala.collection.immutable.Set<String>>,EventAdapter<Event,Object>,SnapshotAdapter<State>,scala.Function3<State,Event,Object,Object>,Recovery,RetentionCriteria,SupervisorStrategy,scala.PartialFunction<scala.Tuple2<State,Signal>,scala.runtime.BoxedUnit>,scala.Option<org.apache.pekko.persistence.typed.internal.ReplicationSetup>,Object,scala.Option<Object>>> unapply(org.apache.pekko.persistence.typed.internal.EventSourcedBehaviorImpl<Command,Event,State> x$0)