Module akka_projection_rs_grpc::producer

source ·

Structs

  • GrpcEventFlow
    Transform and forward gRPC events given a user-supplied transformation function.
  • GrpcEventProcessor
    Processes events transformed from some unknown event envelope (EI) to then pass on to a gRPC event producer.
  • Transformation
    The result of a transformation function for the purposes of passing data on to a gRPC producer.

Functions

  • task
    Provides an asynchronous task and a kill switch that can run and stop a reliable stream of event envelopes to a consumer. Event envelope transmission requests are sent over a channel and have a reply that is completed on the remote consumer’s acknowledgement of receipt.