cddr.kafka.test.transports.rest-proxy — cddr/test-machine 1.0.2-4-gc789324

*http-client* clj

build-record clj

(build-record m)

content-types clj

deliver-ack clj

(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.

destroy-consumer clj

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

handle-proxy-request clj

(handle-proxy-request method url headers body)

ok? clj

proxy-client-info clj

(proxy-client-info client)

rest-proxy-client clj

(rest-proxy-client config)

rest-proxy-consumer clj

(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

rest-proxy-headers clj

(rest-proxy-headers accept)

rest-proxy-poll clj

(rest-proxy-poll consumer)

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

rest-proxy-producer clj

(rest-proxy-producer config topics serializers)

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

rest-proxy-subscription clj

(rest-proxy-subscription config topic-metadata)

RestProxyClient clj

topic-post clj

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

undatafy-record clj

(undatafy-record _topic-metadata m)

uuid clj

(uuid)

with-consumer clj

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

with-subscription clj

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