Type Members

1.  trait EventSourcedEntities extends AnyRef

   Service that the SDK (in the user service) implements to make event-sourced entities available to the proxy

   Service that the SDK (in the user service) implements to make event-sourced entities available to the proxy

   Annotations

   @AkkaGrpcGenerated()

2.  final case class EventSourcedEvent(sequence: Long = 0L, payload: Option[Any] = _root_.scala.None, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[EventSourcedEvent] with Product with Serializable

   An event.

   An event. These will be sent to the entity when the entity starts up.

   sequence

   The sequence number of the event.

   payload

   The event payload.

   Annotations

   @SerialVersionUID()

3.  final case class EventSourcedInit(serviceName: String = "", entityId: String = "", snapshot: Option[EventSourcedSnapshot] = _root_.scala.None, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[EventSourcedInit] with Product with Serializable

   The init message.

   The init message. This will always be the first message sent to the entity when it is loaded.

   serviceName

   The name of the service that this entity is a part of.

   entityId

   The ID of the entity.

   snapshot

   If present the entity should initialise its state using this snapshot.

   Annotations

   @SerialVersionUID()

4.  final case class EventSourcedReply(commandId: Long = 0L, clientAction: Option[ClientAction] = _root_.scala.None, sideEffects: Seq[SideEffect] = _root_.scala.Seq.empty, events: Seq[Any] = _root_.scala.Seq.empty, snapshot: Option[Any] = _root_.scala.None, delete: Option[Duration] = _root_.scala.None, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[EventSourcedReply] with Product with Serializable

   A reply to a command.

   A reply to a command.

   commandId

   The id of the command being replied to. Must match the input command.

   clientAction

   The action to take

   sideEffects

   Any side effects to perform

   events

   A list of events to persist - these will be persisted before the reply is sent.

   snapshot

   An optional snapshot to persist. It is assumed that this snapshot will have the state of any events in the events field applied to it. It is illegal to send a snapshot without sending any events.

   delete

   Mark the entity for deletion. Events and snapshots will be deleted later to give downstream consumers time to process all prior events, including any final deleted event. The EventSourcedReply may optionally also include events and snapshot.

   Annotations

   @SerialVersionUID()

5.  final case class EventSourcedSnapshot(snapshotSequence: Long = 0L, snapshot: Option[Any] = _root_.scala.None, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[EventSourcedSnapshot] with Product with Serializable

   A snapshot

   A snapshot

   snapshotSequence

   The sequence number when the snapshot was taken.

   snapshot

   The snapshot.

   Annotations

   @SerialVersionUID()

6.  final case class EventSourcedSnapshotReply(requestId: Long = 0L, snapshot: Option[Any] = _root_.scala.None, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[EventSourcedSnapshotReply] with Product with Serializable

   The reply to an EventSourcedSnapshotRequest

   The reply to an EventSourcedSnapshotRequest

   requestId

   The ID of this request. Must match the id from the request that this is in reply to.

   snapshot

   The snapshot. The state in this snapshot must not include any applied events that have not been sent in an EventSourcedReply message.

   Annotations

   @SerialVersionUID()

7.  final case class EventSourcedSnapshotRequest(requestId: Long = 0L, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[EventSourcedSnapshotRequest] with Product with Serializable

   A request for a snapshot from the proxy.

   A request for a snapshot from the proxy.

   This can arrive at any time after init, including while a command is being processed.

   requestId

   The ID of this request. The response should include this ID.

   Annotations

   @SerialVersionUID()

8.  final case class EventSourcedStreamIn(message: Message = kalix.protocol.event_sourced_entity.EventSourcedStreamIn.Message.Empty, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[EventSourcedStreamIn] with Product with Serializable

   Input message type for the gRPC stream in.

   Input message type for the gRPC stream in.

   Annotations

   @SerialVersionUID()

9.  final case class EventSourcedStreamOut(message: Message = kalix.protocol.event_sourced_entity.EventSourcedStreamOut.Message.Empty, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[EventSourcedStreamOut] with Product with Serializable

   Output message type for the gRPC stream out.

   Output message type for the gRPC stream out.

   Annotations

   @SerialVersionUID()