Crate akka_projection_rs_grpc

Akka projections with gRPC communication

Sources events over a gRPC connection, using the Akka GRPC protocol.

Modules

• consumer
• producer
• proto

Structs

• BadEvent
  Declares a gRPC event cannot be mapped to an event envelope.
• EventEnvelope
  An envelope wraps a gRPC event associated with a specific entity.
• NoMessage
  Declares that a protobuf criteria is unable to be converted due to there being no message.

Type Definitions

• OriginId
  Identifies an event producer to a consumer
• StreamId
  The logical stream identifier, mapped to a specific internal entity type by the producer settings