amazonica.aws.kinesisfirehose — com.signal-ai/amazonica 0.3.165-signal-3

*list-delivery-streams-default-limit* clj

->bytes clj

(->bytes data)

client-class clj

create-delivery-stream clj

(create-delivery-stream
  &
  {:keys [amazonopensearchservice-destination-configuration
          delivery-stream-encryption-configuration-input delivery-stream-name
          delivery-stream-type elasticsearch-destination-configuration
          extended-s3-destination-configuration
          http-endpoint-destination-configuration
          kinesis-stream-source-configuration redshift-destination-configuration
          s3-destination-configuration splunk-destination-configuration tags]
   :as create-delivery-stream-request})

delete-delivery-stream clj

(delete-delivery-stream &
                        {:keys [allow-force-delete delivery-stream-name]
                         :as delete-delivery-stream-request})

describe-delivery-stream clj

(describe-delivery-stream &
                          {:keys [delivery-stream-name
                                  exclusive-start-destination-id limit]
                           :as describe-delivery-stream-request})

get-cached-response-metadata clj

(get-cached-response-metadata & [amazon-web-service-request])

list-delivery-streams clj

(list-delivery-streams)

(list-delivery-streams creds)

(list-delivery-streams creds limit)

(list-delivery-streams creds limit exclusive-start-delivery-stream-name)

Lists available firehose streams.

list-tags-for-delivery-stream clj

(list-tags-for-delivery-stream &
                               {:keys [delivery-stream-name
                                       exclusive-start-tag-key limit]
                                :as list-tags-for-delivery-stream-request})

maybe-update-in clj

(maybe-update-in m path func & args)

Like update-in, but returns the original map if the key doesn't exist, or the update func returns nil.

put-record clj

(put-record delivery-stream-name data)

(put-record creds delivery-stream-name data)

Puts a record onto a firehose stream.

put-record-batch clj

(put-record-batch delivery-stream-name batch-data)

(put-record-batch creds delivery-stream-name batch-data)

Puts a batch of records onto a firehose stream.

show-functions clj

shutdown clj

(shutdown)

start-delivery-stream-encryption clj

(start-delivery-stream-encryption
  &
  {:keys [delivery-stream-encryption-configuration-input delivery-stream-name]
   :as start-delivery-stream-encryption-request})

stop-delivery-stream-encryption clj

(stop-delivery-stream-encryption &
                                 {:keys [delivery-stream-name]
                                  :as stop-delivery-stream-encryption-request})

tag-delivery-stream clj

(tag-delivery-stream &
                     {:keys [delivery-stream-name tags]
                      :as tag-delivery-stream-request})

untag-delivery-stream clj

(untag-delivery-stream &
                       {:keys [delivery-stream-name tag-keys]
                        :as untag-delivery-stream-request})

update-destination clj

(update-destination
  &
  {:keys [amazonopensearchservice-destination-update
          current-delivery-stream-version-id delivery-stream-name destination-id
          elasticsearch-destination-update extended-s3-destination-update
          http-endpoint-destination-update redshift-destination-update
          s3-destination-update splunk-destination-update]
   :as update-destination-request})