@AutoService(value=StatefulFunctionModule.class) public class ExactlyOnceVerificationModule extends java.lang.Object implements StatefulFunctionModule
The application reads ExactlyOnceVerification.WrappedMessage
s from a Kafka ingress which gets routed to FnUnwrapper
functions, which in turn simply forwards the messages to FnCounter
functions
with specified target keys defined in the wrapped message. The counter function keeps count of
the number of times each key as been invoked, and sinks that count to an exactly-once delivery
Kafka egress for verification.
StatefulFunctionModule.Binder
Constructor and Description |
---|
ExactlyOnceVerificationModule() |
Modifier and Type | Method and Description |
---|---|
void |
configure(java.util.Map<java.lang.String,java.lang.String> globalConfiguration,
StatefulFunctionModule.Binder binder)
This method is the entry point for extending a Stateful Functions application by binding
ingresses, egresses, routers, and functions.
|
public void configure(java.util.Map<java.lang.String,java.lang.String> globalConfiguration, StatefulFunctionModule.Binder binder)
StatefulFunctionModule
configure
in interface StatefulFunctionModule
globalConfiguration
- global configuration of the Stateful Functions application.binder
- the binder to be used to bind ingresses, egresses, routers, and functions.Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.