org.purefn.sentenza.proto — org.purefn/sentenza 0.2.1

Pipeline clj protocol

cleanup clj

(cleanup this state)

Destroy any transient state created by init for a particular send.

init clj

(init this args)

Initialize any transient state specific to a particular send.

run clj

(run this state source)

Provides the source seq/chan and lets the provider begin processing.

source clj

(source this state)

Return a sequential collection of source records that will be fed into the pipeline.