# WARNING: DO NOT EDIT, AUTO-GENERATED CODE!
# See https://github.com/aws-beam/aws-codegen for more details.

defmodule AWS.KinesisVideoMedia do
  alias AWS.Client
  alias AWS.Request

  @typedoc """

  ## Example:

      client_limit_exceeded_exception() :: %{
        "Message" => String.t() | atom()
      }

  """
  @type client_limit_exceeded_exception() :: %{(String.t() | atom()) => any()}

  @typedoc """

  ## Example:

      connection_limit_exceeded_exception() :: %{
        "Message" => String.t() | atom()
      }

  """
  @type connection_limit_exceeded_exception() :: %{(String.t() | atom()) => any()}

  @typedoc """

  ## Example:

      get_media_input() :: %{
        optional("StreamARN") => String.t() | atom(),
        optional("StreamName") => String.t() | atom(),
        required("StartSelector") => start_selector()
      }

  """
  @type get_media_input() :: %{(String.t() | atom()) => any()}

  @typedoc """

  ## Example:

      get_media_output() :: %{
        "ContentType" => String.t() | atom(),
        "Payload" => binary()
      }

  """
  @type get_media_output() :: %{(String.t() | atom()) => any()}

  @typedoc """

  ## Example:

      invalid_argument_exception() :: %{
        "Message" => String.t() | atom()
      }

  """
  @type invalid_argument_exception() :: %{(String.t() | atom()) => any()}

  @typedoc """

  ## Example:

      invalid_endpoint_exception() :: %{
        "Message" => String.t() | atom()
      }

  """
  @type invalid_endpoint_exception() :: %{(String.t() | atom()) => any()}

  @typedoc """

  ## Example:

      not_authorized_exception() :: %{
        "Message" => String.t() | atom()
      }

  """
  @type not_authorized_exception() :: %{(String.t() | atom()) => any()}

  @typedoc """

  ## Example:

      resource_not_found_exception() :: %{
        "Message" => String.t() | atom()
      }

  """
  @type resource_not_found_exception() :: %{(String.t() | atom()) => any()}

  @typedoc """

  ## Example:

      start_selector() :: %{
        "AfterFragmentNumber" => String.t() | atom(),
        "ContinuationToken" => String.t() | atom(),
        "StartSelectorType" => list(any()),
        "StartTimestamp" => non_neg_integer()
      }

  """
  @type start_selector() :: %{(String.t() | atom()) => any()}

  @type get_media_errors() ::
          resource_not_found_exception()
          | not_authorized_exception()
          | invalid_endpoint_exception()
          | invalid_argument_exception()
          | connection_limit_exceeded_exception()
          | client_limit_exceeded_exception()

  def metadata do
    %{
      api_version: "2017-09-30",
      content_type: "application/x-amz-json-1.1",
      credential_scope: nil,
      endpoint_prefix: "kinesisvideo",
      global?: false,
      hostname: nil,
      protocol: "rest-json",
      service_id: "Kinesis Video Media",
      signature_version: "v4",
      signing_name: "kinesisvideo",
      target_prefix: nil
    }
  end

  @doc """
  Use this API to retrieve media content from a Kinesis video stream.

  In the request,
  you identify the stream name or stream Amazon Resource Name (ARN), and the
  starting chunk.
  Kinesis Video Streams then returns a stream of chunks in order by fragment
  number.

  You must first call the `GetDataEndpoint` API to get an endpoint. Then
  send the `GetMedia` requests to this endpoint using the [--endpoint-url parameter](https://docs.aws.amazon.com/cli/latest/reference/).

  When you put media data (fragments) on a stream, Kinesis Video Streams stores
  each
  incoming fragment and related metadata in what is called a "chunk." For more
  information, see
  [PutMedia](https://docs.aws.amazon.com/kinesisvideostreams/latest/dg/API_dataplane_PutMedia.html). The `GetMedia` API returns a stream of these chunks starting
  from the chunk that you specify in the request.

  The following limits apply when using the `GetMedia` API:

    *
  A client can call `GetMedia` up to five times per second per stream.

    *
  Kinesis Video Streams sends media data at a rate of up to 25 megabytes per
  second
  (or 200 megabits per second) during a `GetMedia` session.

  If an error is thrown after invoking a Kinesis Video Streams media API, in
  addition to
  the HTTP status code and the response body, it includes the following pieces of
  information:

    

  `x-amz-ErrorType` HTTP header – contains a more specific error type in
  addition to what the HTTP status code provides.

    

  `x-amz-RequestId` HTTP header – if you want to report an issue to AWS,
  the support team can better diagnose the problem if given the Request Id.

  Both the HTTP status code and the ErrorType header can be utilized to make
  programmatic
  decisions about whether errors are retry-able and under what conditions, as well
  as provide
  information on what actions the client programmer might need to take in order to
  successfully try again.

  For more information, see the **Errors** section at the
  bottom of this topic, as well as [Common
  Errors](https://docs.aws.amazon.com/kinesisvideostreams/latest/dg/CommonErrors.html).
  """
  @spec get_media(map(), get_media_input(), list()) ::
          {:ok, get_media_output(), any()}
          | {:error, {:unexpected_response, any()}}
          | {:error, term()}
          | {:error, get_media_errors()}
  def get_media(%Client{} = client, input, options \\ []) do
    url_path = "/getMedia"
    headers = []
    custom_headers = []
    query_params = []

    options =
      Keyword.put(
        options,
        :response_header_parameters,
        [{"Content-Type", "ContentType"}]
      )

    meta = metadata()

    Request.request_rest(
      client,
      meta,
      :post,
      url_path,
      query_params,
      custom_headers ++ headers,
      input,
      options,
      200
    )
  end
end