Type Members

1.  final case class DirectDestination(eventStreamId: String = "", unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[DirectDestination] with Product with Serializable
   eventStreamId

   Identifier for the direct event stream. must be unique inside the same Kalix service.

   Annotations

   @SerialVersionUID()

2.  final case class DirectSource(service: String = "", eventStreamId: String = "", unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[DirectSource] with Product with Serializable

   Direct service-to-service streaming from another Kalix service

   Direct service-to-service streaming from another Kalix service

   service

   The deployed name of the service to consume, can be the deployed name of another Kalix service in the same Kalix Project or a fully qualified public hostname of a Kalix service in a different project. Note: The service name is used as unique identifier for tracking progress in consuming it changing this name will lead to starting over from the beginning of the direct event stream Can be a template referencing an environment variable "${MY_ENV_NAME}" set for the service at deploy

   eventStreamId

   The unique identifier of the stream in the producing service

   Annotations

   @SerialVersionUID()

3.  final case class EventDestination(destination: Destination = kalix.eventing.EventDestination.Destination.Empty, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[EventDestination] with Product with Serializable

   Annotations

   @SerialVersionUID()

4.  final case class EventSource(consumerGroup: String = "", source: Source = kalix.eventing.EventSource.Source.Empty, ignore: Boolean = false, ignoreUnknown: Option[Boolean] = _root_.scala.None, handleDeletes: Option[Boolean] = _root_.scala.None, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[EventSource] with Product with Serializable

   Event source configuration

   Event source configuration

   consumerGroup

   The consumer group id. By default, all rpc methods on a given service with the same source will be part of the same virtual consumer group, messages will be routed to the different methods by type. This can be used to override that. If you want multiple methods to act as independent consumers of the same source (ie, if you want the same event to be published to each consumer) then give each consumer a unique name. Note that this does depend on the event source supporting multiple consumer groups. Queue based event sources may not support this.

   ignore

   If the message is not of interest for consumption the method for that input message type can be marked with ignore: true. Enabling is more efficient than implementing the method. This option can only be used on method level

   ignoreUnknown

   If an incoming event does not have a matching handler, ignore the event and continue processing subsequent events, default is to fail to not accidentally miss events of newly added or unknown event types, as once eventing has continued there is no way to later revisit the ignored event. Enabling is more efficient than implementing a catch-all method. This option can only be used on service level.

   handleDeletes

   Call this method when an entity has been deleted, the method must accept google.protobuf.Empty as input. If the method is in a view the return type should be the view state message type, for other types of components the returned message type can be an arbitrary message, for example for publishing to eventing out on delete. Currently supported only for the value entity streams.

   Annotations

   @SerialVersionUID()

5.  final case class Eventing(in: Option[EventSource] = _root_.scala.None, out: Option[EventDestination] = _root_.scala.None, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[Eventing] with Product with Serializable

   Eventing configuration for a gRPC method.

   Eventing configuration for a gRPC method.

   in

   The event source in configuration.

   out

   The event destination out configuration. Optional, if unset, messages out will not be published anywhere.

   Annotations

   @SerialVersionUID()

6.  final case class ServiceEventing(in: Option[EventSource] = _root_.scala.None, out: Option[ServiceEventingOut] = _root_.scala.None, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[ServiceEventing] with Product with Serializable

   Service level eventing configuration

   Service level eventing configuration

   Annotations

   @SerialVersionUID()

7.  final case class ServiceEventingOut(direct: Option[DirectDestination] = _root_.scala.None, unknownFields: UnknownFieldSet = _root_.scalapb.UnknownFieldSet.empty) extends GeneratedMessage with Updatable[ServiceEventingOut] with Product with Serializable

   Annotations

   @SerialVersionUID()