Liking cljdoc? Tell your friends :D

kafka-event-processor.processor.protocols


EventHandlercljprotocol

A handler that is called when at certain points in an events lifecycle. The passed processor contains all the configured dependencies.

A handler that is called when at certain points in an events lifecycle. The passed processor contains all the configured dependencies.

extract-payloadclj

(extract-payload this event)

A callback to transform the event into a suitable format for processing

A callback to transform the event into a suitable format for processing

on-completeclj

(on-complete this processor event event-context)

A callback for when an event has finished processing

A callback for when an event has finished processing

on-eventclj

(on-event this processor event event-context)

A callback for processing an event

A callback for processing an event

processable?clj

(processable? this processor event event-context)

A callback to decide if an event should be processed

A callback to decide if an event should be processed
sourceraw docstring

RewindCheckcljprotocol

A handler that is called to define whether the kafka topic needs rewinding

A handler that is called to define whether the kafka topic needs rewinding

rewind-required?clj

(rewind-required? this processor)

A callback to decide if a rewind is required

A callback to decide if a rewind is required
sourceraw docstring

cljdoc is a website building & hosting documentation for Clojure/Script libraries

× close