Liking cljdoc? Tell your friends :D

jackdaw.test.transports.rest-proxy


*http-client*clj

source

build-recordclj

(build-record m)
source

content-typesclj

source

deliver-ackclj

(deliver-ack ack)

Deliver the ack promise with the result of attempting to write to kafka. The default command-handler waits for this before on to the next command so the test response may indicate the success/failure of each write command.

Deliver the `ack` promise with the result of attempting to write to kafka. The
default command-handler waits for this before on to the next command so the
test response may indicate the success/failure of each write command.
sourceraw docstring

destroy-consumerclj

(destroy-consumer {:keys [base-uri]})
source

handle-proxy-requestclj

(handle-proxy-request method url headers body)
source

ok?clj

source

proxy-client-infoclj

(proxy-client-info client)
source

rest-proxy-clientclj

(rest-proxy-client config)
source

rest-proxy-consumerclj

(rest-proxy-consumer config topic-metadata deserializers)

Creates an asynchronous Kafka Consumer of all topics defined in the supplied topic-metadata

Puts all messages on the channel in the returned response. It is the responsibility of the caller to arrange for the read the channel to be read by some other process.

Must be closed with close-consumer when no longer required

Creates an asynchronous Kafka Consumer of all topics defined in the
supplied `topic-metadata`

Puts all messages on the channel in the returned response. It is the
responsibility of the caller to arrange for the read the channel to
be read by some other process.

Must be closed with `close-consumer` when no longer required
sourceraw docstring

rest-proxy-headersclj

(rest-proxy-headers accept)
source

rest-proxy-pollclj

(rest-proxy-poll consumer)

Returns a function that takes a consumer and puts any messages retrieved by polling it onto the supplied messages channel

Returns a function that takes a consumer and puts any messages retrieved
by polling it onto the supplied `messages` channel
sourceraw docstring

rest-proxy-producerclj

(rest-proxy-producer config _topics serializers)

Creates an asynchronous kafka producer to be used by a test-machine for for injecting test messages

Creates an asynchronous kafka producer to be used by a test-machine for for
injecting test messages
sourceraw docstring

rest-proxy-subscriptionclj

(rest-proxy-subscription config topic-metadata)
source

topic-postclj

(topic-post {:keys [bootstrap-uri]} msg callback)
source

undatafy-recordclj

(undatafy-record _topic-metadata m)
source

uuidclj

(uuid)
source

with-consumerclj

(with-consumer {:keys [bootstrap-uri group-id group-config] :as client})
source

with-subscriptionclj

(with-subscription {:keys [base-uri] :as client} topic-metadata)
source

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

× close