Type Members

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

   Annotations

   @SerialVersionUID()

2.  final case class ReplicatedCounterMapDelta(cleared: Boolean = false, removed: Seq[Any] = _root_.scala.Seq.empty, updated: Seq[ReplicatedCounterMapEntryDelta] = _root_.scala.Seq.empty, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[ReplicatedCounterMapDelta] with Product with Serializable

   Annotations

   @SerialVersionUID()

3.  final case class ReplicatedCounterMapEntryDelta(key: Option[Any] = _root_.scala.None, delta: Option[ReplicatedCounterDelta] = _root_.scala.None, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[ReplicatedCounterMapEntryDelta] with Product with Serializable

   Annotations

   @SerialVersionUID()

4.  trait ReplicatedEntities extends AnyRef

   Replicated Entities Protocol Note that while this protocol provides support for replicated entities, the data types sent across the protocol are not replicated entities themselves.

   Replicated Entities Protocol Note that while this protocol provides support for replicated entities, the data types sent across the protocol are not replicated entities themselves. It is the responsibility of the Kalix proxy to implement the replicated entities, merge functions, vector clocks etc, not the user service. The user service need only hold the current value in memory, and this protocol sends deltas to the user service to update its in memory value as necessary. These deltas have no way of dealing with conflicts, hence it is important that the Kalix proxy always knows what the state of the user service's in memory value is before sending a delta. If the Kalix proxy is not sure what the value is, eg because it has just sent an operation to the user service which may have updated its value as a result, the proxy should wait until it gets the result of the operation back, to ensure its in memory value is in sync with the user service so that it can calculate deltas that won't conflict. The user service is expected to update its value both as the result of receiving deltas from the proxy, as well as when it sends deltas. It must not update its value in any other circumstance, updating the value in response to any other stimuli risks the value becoming out of sync with the Kalix proxy. The user service will not be sent back deltas as a result of its own changes. An invocation of handle is made for each entity being handled. It may be kept alive and used to handle multiple commands, and may subsequently be terminated if that entity becomes idle, or if the entity is deleted. Shutdown is typically done for efficiency reasons, unless the entity is explicitly deleted, and a terminated handle stream does not mean the proxy has stopped tracking the state of the entity in its memory. Special care must be taken when working with maps and sets. The keys/values are google.protobuf.Any, which encodes the value as binary protobuf, however, serialized protobufs are not stable, two semantically equal objects could encode to different bytes. It is the responsibility of the user service to ensure that stable encodings are used.

   Annotations

   @AkkaGrpcGenerated()

5.  sealed abstract class ReplicatedEntityClock extends GeneratedEnum
6.  final case class ReplicatedEntityDelete(unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[ReplicatedEntityDelete] with Product with Serializable

   Annotations

   @SerialVersionUID()

7.  final case class ReplicatedEntityDelta(delta: Delta = kalix.protocol.replicated_entity.ReplicatedEntityDelta.Delta.Empty, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[ReplicatedEntityDelta] with Product with Serializable

   A Replicated Entity delta

   A Replicated Entity delta

   Deltas only carry the change in value to be applied to the current (possibly empty) state.

   Annotations

   @SerialVersionUID()

8.  final case class ReplicatedEntityInit(serviceName: String = "", entityId: String = "", delta: Option[ReplicatedEntityDelta] = _root_.scala.None, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[ReplicatedEntityInit] with Product with Serializable

   Annotations

   @SerialVersionUID()

9.  final case class ReplicatedEntityReply(commandId: Long = 0L, clientAction: Option[ClientAction] = _root_.scala.None, sideEffects: Seq[SideEffect] = _root_.scala.Seq.empty, stateAction: Option[ReplicatedEntityStateAction] = _root_.scala.None, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[ReplicatedEntityReply] with Product with Serializable

   Annotations

   @SerialVersionUID()

10.  final case class ReplicatedEntityStateAction(action: ReplicatedEntityStateAction.Action = kalix.protocol.replicated_entity.ReplicatedEntityStateAction.Action.Empty, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[ReplicatedEntityStateAction] with Product with Serializable

    Annotations

    @SerialVersionUID()

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

    Message for the Replicated Entity handle stream in.

    Message for the Replicated Entity handle stream in.

    Annotations

    @SerialVersionUID()

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

    Message for the Replicated Entity handle stream out.

    Message for the Replicated Entity handle stream out.

    Annotations

    @SerialVersionUID()

13.  final case class ReplicatedMapDelta(cleared: Boolean = false, removed: Seq[Any] = _root_.scala.Seq.empty, updated: Seq[ReplicatedMapEntryDelta] = _root_.scala.Seq.empty, added: Seq[ReplicatedMapEntryDelta] = _root_.scala.Seq.empty, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[ReplicatedMapDelta] with Product with Serializable

    Annotations

    @SerialVersionUID()

14.  final case class ReplicatedMapEntryDelta(key: Option[Any] = _root_.scala.None, delta: Option[ReplicatedEntityDelta] = _root_.scala.None, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[ReplicatedMapEntryDelta] with Product with Serializable
    key

    The entry key.

    Annotations

    @SerialVersionUID()

15.  final case class ReplicatedMultiMapDelta(cleared: Boolean = false, removed: Seq[Any] = _root_.scala.Seq.empty, updated: Seq[ReplicatedMultiMapEntryDelta] = _root_.scala.Seq.empty, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[ReplicatedMultiMapDelta] with Product with Serializable

    Annotations

    @SerialVersionUID()

16.  final case class ReplicatedMultiMapEntryDelta(key: Option[Any] = _root_.scala.None, delta: Option[ReplicatedSetDelta] = _root_.scala.None, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[ReplicatedMultiMapEntryDelta] with Product with Serializable

    Annotations

    @SerialVersionUID()

17.  final case class ReplicatedRegisterDelta(value: Option[Any] = _root_.scala.None, clock: ReplicatedEntityClock = kalix.protocol.replicated_entity.ReplicatedEntityClock.REPLICATED_ENTITY_CLOCK_DEFAULT_UNSPECIFIED, customClockValue: Long = 0L, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[ReplicatedRegisterDelta] with Product with Serializable

    Annotations

    @SerialVersionUID()

18.  final case class ReplicatedRegisterMapDelta(cleared: Boolean = false, removed: Seq[Any] = _root_.scala.Seq.empty, updated: Seq[ReplicatedRegisterMapEntryDelta] = _root_.scala.Seq.empty, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[ReplicatedRegisterMapDelta] with Product with Serializable

    Annotations

    @SerialVersionUID()

19.  final case class ReplicatedRegisterMapEntryDelta(key: Option[Any] = _root_.scala.None, delta: Option[ReplicatedRegisterDelta] = _root_.scala.None, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[ReplicatedRegisterMapEntryDelta] with Product with Serializable

    Annotations

    @SerialVersionUID()

20.  final case class ReplicatedSetDelta(cleared: Boolean = false, removed: Seq[Any] = _root_.scala.Seq.empty, added: Seq[Any] = _root_.scala.Seq.empty, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[ReplicatedSetDelta] with Product with Serializable
    cleared

    If cleared is set, the set must be cleared before added is processed.

    Annotations

    @SerialVersionUID()

21.  final case class VoteDelta(selfVote: Boolean = false, votesFor: Int = 0, totalVoters: Int = 0, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[VoteDelta] with Product with Serializable
    selfVote

    Set by the proxy initially or when the vote has changed. Only set by the user service to change the node's current vote.

    votesFor

    Only set by the proxy initially or when the vote has changed. Ignored by the proxy when set by the user service.

    totalVoters

    Only set by the proxy initially or when the vote has changed. Ignored by the proxy when set by the user service.

    Annotations

    @SerialVersionUID()