kinetic.tracker — com.tolitius/kinetic 0.1.5

add-multi-stream-identifier clj

(add-multi-stream-identifier aws-account-number id)

make-initial-position clj

(make-initial-position {:keys [position timestamp] :as at})

make-stream-config clj

(make-stream-config {:keys [identifier start-from] :as opts})

make-stream-id clj

(make-stream-id {:keys [aws-account-number name epoch]})

stream identifier format: <accountId>:<streamName>:<creationEpoch>

source: https://github.com/awslabs/amazon-kinesis-client/blob/7899820cb17eefb1eed4a4d0fbc3b86f2da9f2d3/amazon-kinesis-client/src/main/java/software/amazon/kinesis/common/StreamIdentifier.java#L48-L53

make-stream-tracker clj

(make-stream-tracker {:keys [streams multi-stream?] :as opts})

multi-stream-identifier clj

(multi-stream-identifier stream)

multi-stream-tracker clj

(multi-stream-tracker {:keys [aws-account-number streams]})

{:aws-account-id 42 :streams [{:name "milky-way.solar.pluto" :start-from {:position :trim-horizon} :epoc 1} {:name "milky-way.solar.mars" :start-from {:position :trim-horizon} :delete-leases? true :epoc 42}]}

multi-stream? clj

(multi-stream? scheduler)

single-stream-identifier clj

(single-stream-identifier {:keys [name]})

single-stream-tracker clj

(single-stream-tracker {:keys [name start-from] :as stream})