papaline.core — info.sunng/papaline 0.10.3

*post-execution-hook* clj

*pre-execution-hook* clj

abort clj

(abort)

(abort ret)

async-dedicated-thread-pool-pipeline clj

(async-dedicated-thread-pool-pipeline stages
                                      thread-pool
                                      &
                                      {:keys [error-handler]})

cancel-pipeline clj

(cancel-pipeline pipeline)

compound-pipeline clj

(compound-pipeline pipelines)

copy-stage clj

(copy-stage stage-fn & options)

counted-thread-factory clj

(counted-thread-factory name-format daemon)

dedicated-thread-pool-pipeline clj

(dedicated-thread-pool-pipeline stages thread-pool & {:keys [error-handler]})

fork clj

(fork ret)

IPipeline clj protocol

run-pipeline* clj

(run-pipeline* this args)

run-pipeline-timeout* clj

(run-pipeline-timeout* this timeout-interval timeout-val args)

run-pipeline-wait* clj

(run-pipeline-wait* this args)

start! clj

(start! this)

stop! clj

(stop! this)

join clj

(join ret)

make-thread-pool clj

(make-thread-pool threads
                  queue-size
                  &
                  {:keys [overflow-action]
                   :or {overflow-action
                          (ThreadPoolExecutor$DiscardOldestPolicy.)}})

named-stage clj

(named-stage name & args)

pipeline clj

(pipeline stages & {:keys [error-handler]})

pipeline-stage clj

(pipeline-stage pipeline)

pipeline as a stage

run-pipeline clj

(run-pipeline this & args)

run-pipeline-timeout clj

(run-pipeline-timeout this timeout-interval timeout-val & args)

run-pipeline-wait clj

(run-pipeline-wait this & args)

stage clj

(stage stage-fn
       &
       {:keys [in-chan buffer-size buffer-type] :or {buffer-size 100}})

start-stage clj

(start-stage s)