amazonica.aws.kinesis — amazonica 0.3.131

add-tags-to-stream clj

(add-tags-to-stream add-tags-to-stream-request)

client-class clj

create-stream clj

(create-stream create-stream-request)

(create-stream string integer)

decrease-stream-retention-period clj

(decrease-stream-retention-period decrease-stream-retention-period-request)

delete-stream clj

(delete-stream delete-stream-request)

(delete-stream string)

deregister-stream-consumer clj

(deregister-stream-consumer deregister-stream-consumer-request)

describe-limits clj

(describe-limits describe-limits-request)

describe-stream clj

(describe-stream describe-stream-request)

(describe-stream string)

(describe-stream string-1 string-2)

(describe-stream string-1 integer string-2)

describe-stream-consumer clj

(describe-stream-consumer describe-stream-consumer-request)

describe-stream-summary clj

(describe-stream-summary describe-stream-summary-request)

disable-enhanced-monitoring clj

(disable-enhanced-monitoring disable-enhanced-monitoring-request)

enable-enhanced-monitoring clj

(enable-enhanced-monitoring enable-enhanced-monitoring-request)

get-cached-response-metadata clj

(get-cached-response-metadata amazon-web-service-request)

get-records clj

(get-records get-records-request)

get-shard-iterator clj

(get-shard-iterator get-shard-iterator-request)

(get-shard-iterator string-1 string-2 string-3)

(get-shard-iterator string-1 string-2 string-3 string-4)

increase-stream-retention-period clj

(increase-stream-retention-period increase-stream-retention-period-request)

list-shards clj

(list-shards list-shards-request)

list-stream-consumers clj

(list-stream-consumers list-stream-consumers-request)

list-streams clj

(list-streams)

(list-streams list-streams-request)

(list-streams string)

(list-streams integer string)

list-tags-for-stream clj

(list-tags-for-stream list-tags-for-stream-request)

marshall clj

(marshall deserializer record)

merge-shards clj

(merge-shards merge-shards-request)

(merge-shards string-1 string-2 string-3)

put-record clj

(put-record put-record-request)

(put-record string-1 byte-buffer string-2)

(put-record string-1 byte-buffer string-2 string-3)

put-records clj

(put-records put-records-request)

register-stream-consumer clj

(register-stream-consumer register-stream-consumer-request)

remove-tags-from-stream clj

(remove-tags-from-stream remove-tags-from-stream-request)

show-functions clj

shutdown clj

(shutdown)

split-shard clj

(split-shard split-shard-request)

(split-shard string-1 string-2 string-3)

start-stream-encryption clj

(start-stream-encryption start-stream-encryption-request)

stop-stream-encryption clj

(stop-stream-encryption stop-stream-encryption-request)

unwrap clj

(unwrap byte-buffer)

Get the contents of the given buffer as a byte-array, decoding as Nippy bytes if they appear to be Nippy encoded. If the ByteBuffer does not appear to contain Nippy data, the bytes found will be returned unchanged. This technique is inspired by ptaoussanis/faraday.

update-shard-count clj

(update-shard-count update-shard-count-request)

waiters clj

(waiters)

worker clj

(worker & args)

Instantiate a kinesis Worker.

worker! clj

(worker! & args)

Instantiate a new kinesis Worker and invoke its run method in a separate thread. Return the identifier of the Worker.