Type Members

1.  final case class Delete(unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[Delete] with Product with Serializable

   Annotations

   @SerialVersionUID()

2.  final case class Key(parts: Seq[KeyPart] = _root_.scala.Seq.empty, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[Key] with Product with Serializable

   deprecated, no longer used, Key fields are now ignored

   deprecated, no longer used, Key fields are now ignored

   Annotations

   @SerialVersionUID()

3.  final case class KeyPart(part: Part = kalix.protocol.view.KeyPart.Part.Empty, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[KeyPart] with Product with Serializable

   Annotations

   @SerialVersionUID()

4.  final case class ReceiveEvent(serviceName: String = "", commandName: String = "", payload: Option[Any] = _root_.scala.None, metadata: Option[Metadata] = _root_.scala.None, bySubjectLookupResult: Option[Row] = _root_.scala.None, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[ReceiveEvent] with Product with Serializable

   event for transform_updates where an incoming event is passed to the SDK for user to transform into a final state that is stored/indexed for queries in the view

   event for transform_updates where an incoming event is passed to the SDK for user to transform into a final state that is stored/indexed for queries in the view

   serviceName

   name of the view service the event is for

   commandName

   method on the view service the event is for

   payload

   incoming event to transform

   metadata

   always contains the ce-subject entry which identifies the view entry for the event

   bySubjectLookupResult

   the existing view entry for the ce-subject if there was one,

   Annotations

   @SerialVersionUID()

5.  final case class Row(value: Option[Any] = _root_.scala.None, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[Row] with Product with Serializable
   value

   view entry May be unset if a lookup found no row.

   Annotations

   @SerialVersionUID()

6.  final case class Upsert(row: Option[Row] = _root_.scala.None, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[Upsert] with Product with Serializable

   to ignore an event and do nothing, use Upsert, but no/empty/null value for row

   to ignore an event and do nothing, use Upsert, but no/empty/null value for row

   Annotations

   @SerialVersionUID()

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

   Input message type for the gRPC stream in.

   Input message type for the gRPC stream in.

   Annotations

   @SerialVersionUID()

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

   Output message type for the gRPC stream out.

   Output message type for the gRPC stream out.

   Annotations

   @SerialVersionUID()

9.  trait Views extends AnyRef

   Service that the SDK (in the user service) implements to make views available to the proxy.

   Service that the SDK (in the user service) implements to make views available to the proxy. TODO: It is currently only implemented to support one request (ReceiveEvent) with two possible responses (Upsert, Delete). The intention, and reason for full-duplex streaming, is that there should be able to have an interaction with two main types of operations, loads, and updates, and with each load there is an associated continuation, which in turn may return more operations, including more loads, and so on recursively.

   Annotations

   @AkkaGrpcGenerated()