Liking cljdoc? Tell your friends :D

dvlopt.kstreams.mock

Building a mock Kafka Streams application which do not need a Kafka cluster.

Building a mock Kafka Streams application which do not need a Kafka cluster.
raw docstring

advanceclj

(advance mock-app interval)

Advances the wall-clock time of the mock application.

Advances the wall-clock time of the mock application.
sourceraw docstring

disbandclj

(disband mock-app)

Closes the mock application and releases all associated resources.

Closes the mock application and releases all associated resources.
sourceraw docstring

kv-storeclj

(kv-store mock-app store-name)

Retrieves a writable key-value store used by the mock application.

Retrieves a writable key-value store used by the mock application.
sourceraw docstring

metricsclj

(metrics mock-app)

Cf. dvlopt.kstreams/metrics

Cf. `dvlopt.kstreams/metrics`
sourceraw docstring

mock-appclj

(mock-app application-id topology)
(mock-app application-id topology options)

Given a topology, creates a mock Kafka Streams application which can simulate a cluster. It is very useful for testing and fiddling at the REPL.

It is mainly operated by using pipe-record and read-record.

A map of options may be given :

::wall-clock (defaults to 0) Timestamp for initiating the mock application. Cf. dvlopt.kstreams.ctx/schedule for a description of the difference between :wall-clock-time and :stream-time

:dvlopt.kstreams/configuration Cf. dvlopt.kstreams/app, many properties are ignored but it is useful to supply something realistic.

Given a topology, creates a mock Kafka Streams application which can simulate a cluster. It is
very useful for testing and fiddling at the REPL.

It is mainly operated by using `pipe-record` and `read-record`.


A map of options may be given :

  ::wall-clock (defaults to 0)
   Timestamp for initiating the mock application.
   Cf. `dvlopt.kstreams.ctx/schedule` for a description of the difference between :wall-clock-time
       and :stream-time  

  :dvlopt.kstreams/configuration
   Cf. `dvlopt.kstreams/app`, many properties are ignored but it is useful to supply something
       realistic.
sourceraw docstring

pipe-recordclj

(pipe-record mock-app record)

Processes the given records by the mock application.

Cf. dvlopt.kafka.in/poll for the structure of a record ready to be consumed (headers not supported)

Processes the given records by the mock application. 

Cf. `dvlopt.kafka.in/poll` for the structure of a record ready to be consumed (headers not supported)
sourceraw docstring

read-recordclj

(read-record mock-app topic)
(read-record mock-app topic options)

Records processed after using pipe-record may produce an output depending on the topology of the mock application.

Cf. dvlopt.kafka.out/send for the structure of a record produced by the mock application

Records processed after using `pipe-record` may produce an output depending on the topology
of the mock application.

Cf. `dvlopt.kafka.out/send` for the structure of a record produced by the mock application
sourceraw docstring

session-storeclj

(session-store mock-app store-name)

Retrieves a writable session store used by the application.

Retrieves a writable session store used by the application.
sourceraw docstring

window-storeclj

(window-store mock-app store-name)

Retrieves a read-only window store used by the application.

Retrieves a read-only window store used by the application.
sourceraw docstring

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

× close