ExAws v1.1.1 ExAws.Firehose

create_delivery_stream_opts() :: [elasticsearch_destination_configuration: Keyword.t, redshift_destination_configuration: Keyword.t, s3_destination_configuration: Keyword.t]

describe_delivery_stream_opts()

describe_delivery_stream_opts() :: [limit: pos_integer, exclusive_start_destination_id: binary]

list_delivery_stream_opts()

list_delivery_stream_opts() :: [exclusive_start_delivery_stream_name: binary, limit: pos_integer]

put_record_batch_record()

put_record_batch_record() :: [{:data, binary}]

stream_name()

stream_name() :: binary

update_destination_opts()

update_destination_opts() :: [elasticsearch_destination_update: Keyword.t, redshift_destination_update: Keyword.t, s3_destination_update: Keyword.t]

Functions

create_delivery_stream(stream_name, shard_count \\ 1)

create_delivery_stream(stream_name :: stream_name, opts :: create_delivery_stream_opts) :: ExAws.Operation.JSON.t

Creates stream

delete_delivery_stream(stream_name)

delete_delivery_stream(stream_name :: stream_name) :: ExAws.Operation.JSON.t

Deletes stream

describe_delivery_stream(stream_name, opts \\ [])

describe_delivery_stream(stream_name :: stream_name, opts :: describe_delivery_stream_opts) :: ExAws.Operation.JSON.t

Describe Stream

list_delivery_streams(opts \\ [])

list_delivery_streams(opts :: list_delivery_stream_opts) :: ExAws.Operation.JSON.t

Lists streams

put_record(stream_name, data, opts \\ [])

Puts a record on a stream

put_record_batch(stream_name, records)

put_record_batch(stream_name :: stream_name, records :: [put_record_batch_record]) :: ExAws.Operation.JSON.t

Put multiple records on a stream

update_destination(stream_name, version_id, destination_id, opts \\ [])

update_destination(stream_name :: stream_name, version_id :: binary, destination_id :: binary, opts :: update_destination_opts) :: ExAws.Operation.JSON.t

Updates the specified destination of the specified delivery stream.