lib/aws-sdk-kinesisanalyticsv2/client.rb in aws-sdk-kinesisanalyticsv2-1.3.0 vs lib/aws-sdk-kinesisanalyticsv2/client.rb in aws-sdk-kinesisanalyticsv2-1.4.0
- old
+ new
@@ -207,10 +207,53 @@
#
# @option options [Boolean] :validate_params (true)
# When `true`, request parameters are validated before
# sending the request.
#
+ # @option options [URI::HTTP,String] :http_proxy A proxy to send
+ # requests through. Formatted like 'http://proxy.com:123'.
+ #
+ # @option options [Float] :http_open_timeout (15) The number of
+ # seconds to wait when opening a HTTP session before rasing a
+ # `Timeout::Error`.
+ #
+ # @option options [Integer] :http_read_timeout (60) The default
+ # number of seconds to wait for response data. This value can
+ # safely be set
+ # per-request on the session yeidled by {#session_for}.
+ #
+ # @option options [Float] :http_idle_timeout (5) The number of
+ # seconds a connection is allowed to sit idble before it is
+ # considered stale. Stale connections are closed and removed
+ # from the pool before making a request.
+ #
+ # @option options [Float] :http_continue_timeout (1) The number of
+ # seconds to wait for a 100-continue response before sending the
+ # request body. This option has no effect unless the request has
+ # "Expect" header set to "100-continue". Defaults to `nil` which
+ # disables this behaviour. This value can safely be set per
+ # request on the session yeidled by {#session_for}.
+ #
+ # @option options [Boolean] :http_wire_trace (false) When `true`,
+ # HTTP debug output will be sent to the `:logger`.
+ #
+ # @option options [Boolean] :ssl_verify_peer (true) When `true`,
+ # SSL peer certificates are verified when establishing a
+ # connection.
+ #
+ # @option options [String] :ssl_ca_bundle Full path to the SSL
+ # certificate authority bundle file that should be used when
+ # verifying peer certificates. If you do not pass
+ # `:ssl_ca_bundle` or `:ssl_ca_directory` the the system default
+ # will be used if available.
+ #
+ # @option options [String] :ssl_ca_directory Full path of the
+ # directory that contains the unbundled SSL certificate
+ # authority files for verifying peer certificates. If you do
+ # not pass `:ssl_ca_bundle` or `:ssl_ca_directory` the the
+ # system default will be used if available.
+ #
def initialize(*args)
super
end
# @!group API Operations
@@ -626,28 +669,23 @@
# Creates an Amazon Kinesis Data Analytics application. For information
# about creating a Kinesis Data Analytics application, see [Creating an
# Application][1].
#
- # <note markdown="1"> SQL is not enabled for this private beta release. Using SQL parameters
- # (such as SqlApplicationConfiguration) will result in an error.
#
- # </note>
#
+ # [1]: https://docs.aws.amazon.com/kinesisanalytics/latest/java/getting-started.html
#
- #
- # [1]: https://docs.aws.amazon.com/kinesisanalytics/latest/Java/creating-app.html
- #
# @option params [required, String] :application_name
# The name of your application (for example, `sample-app`).
#
# @option params [String] :application_description
# A summary description of the application.
#
# @option params [required, String] :runtime_environment
# The runtime environment for the application (`SQL-1.0` or
- # `JAVA-8-FLINK-1.5`).
+ # `FLINK-1_6`).
#
# @option params [required, String] :service_execution_role
# The IAM role used by the application to access Kinesis data streams,
# Kinesis Data Firehose delivery streams, Amazon S3 objects, and other
# external resources.
@@ -657,10 +695,22 @@
#
# @option params [Array<Types::CloudWatchLoggingOption>] :cloud_watch_logging_options
# Use this parameter to configure an Amazon CloudWatch log stream to
# monitor application configuration errors.
#
+ # @option params [Array<Types::Tag>] :tags
+ # A list of one or more tags to assign to the application. A tag is a
+ # key-value pair that identifies an application. Note that the maximum
+ # number of application tags includes system tags. The maximum number of
+ # user-defined application tags is 50. For more information, see [Using
+ # Cost Allocation Tags][1] in the *AWS Billing and Cost Management
+ # Guide*.
+ #
+ #
+ #
+ # [1]: https://docs.aws.amazon.com/awsaccountbilling/latest/aboutv2/cost-alloc-tags.html
+ #
# @return [Types::CreateApplicationResponse] Returns a {Seahorse::Client::Response response} object which responds to the following methods:
#
# * {Types::CreateApplicationResponse#application_detail #application_detail} => Types::ApplicationDetail
#
# @example Request syntax with placeholder values
@@ -810,10 +860,16 @@
# cloud_watch_logging_options: [
# {
# log_stream_arn: "LogStreamARN", # required
# },
# ],
+ # tags: [
+ # {
+ # key: "TagKey", # required
+ # value: "TagValue",
+ # },
+ # ],
# })
#
# @example Response structure
#
# resp.application_detail.application_arn #=> String
@@ -1523,19 +1579,44 @@
def list_applications(params = {}, options = {})
req = build_request(:list_applications, params)
req.send_request(options)
end
+ # Retrieves the list of key-value tags assigned to the application.
+ #
+ # @option params [required, String] :resource_arn
+ # The ARN of the application for which to retrieve tags.
+ #
+ # @return [Types::ListTagsForResourceResponse] Returns a {Seahorse::Client::Response response} object which responds to the following methods:
+ #
+ # * {Types::ListTagsForResourceResponse#tags #tags} => Array<Types::Tag>
+ #
+ # @example Request syntax with placeholder values
+ #
+ # resp = client.list_tags_for_resource({
+ # resource_arn: "KinesisAnalyticsARN", # required
+ # })
+ #
+ # @example Response structure
+ #
+ # resp.tags #=> Array
+ # resp.tags[0].key #=> String
+ # resp.tags[0].value #=> String
+ #
+ # @see http://docs.aws.amazon.com/goto/WebAPI/kinesisanalyticsv2-2018-05-23/ListTagsForResource AWS API Documentation
+ #
+ # @overload list_tags_for_resource(params = {})
+ # @param [Hash] params ({})
+ def list_tags_for_resource(params = {}, options = {})
+ req = build_request(:list_tags_for_resource, params)
+ req.send_request(options)
+ end
+
# Starts the specified Amazon Kinesis Data Analytics application. After
# creating an application, you must exclusively call this operation to
# start your application.
#
- # <note markdown="1"> SQL is not enabled for this private beta. Using SQL parameters (such
- # as RunConfiguration$SqlRunConfigurations) will result in an error.
- #
- # </note>
- #
# @option params [required, String] :application_name
# The name of the application.
#
# @option params [required, Types::RunConfiguration] :run_configuration
# Identifies the run configuration (start parameters) of a Kinesis Data
@@ -1594,22 +1675,77 @@
def stop_application(params = {}, options = {})
req = build_request(:stop_application, params)
req.send_request(options)
end
+ # Adds one or more key-value tags to a Kinesis Analytics application.
+ # Note that the maximum number of application tags includes system tags.
+ # The maximum number of user-defined application tags is 50.
+ #
+ # @option params [required, String] :resource_arn
+ # The ARN of the application to assign the tags.
+ #
+ # @option params [required, Array<Types::Tag>] :tags
+ # The key-value tags to assign to the application.
+ #
+ # @return [Struct] Returns an empty {Seahorse::Client::Response response}.
+ #
+ # @example Request syntax with placeholder values
+ #
+ # resp = client.tag_resource({
+ # resource_arn: "KinesisAnalyticsARN", # required
+ # tags: [ # required
+ # {
+ # key: "TagKey", # required
+ # value: "TagValue",
+ # },
+ # ],
+ # })
+ #
+ # @see http://docs.aws.amazon.com/goto/WebAPI/kinesisanalyticsv2-2018-05-23/TagResource AWS API Documentation
+ #
+ # @overload tag_resource(params = {})
+ # @param [Hash] params ({})
+ def tag_resource(params = {}, options = {})
+ req = build_request(:tag_resource, params)
+ req.send_request(options)
+ end
+
+ # Removes one or more tags from a Kinesis Analytics application.
+ #
+ # @option params [required, String] :resource_arn
+ # The ARN of the Kinesis Analytics application from which to remove the
+ # tags.
+ #
+ # @option params [required, Array<String>] :tag_keys
+ # A list of keys of tags to remove from the specified application.
+ #
+ # @return [Struct] Returns an empty {Seahorse::Client::Response response}.
+ #
+ # @example Request syntax with placeholder values
+ #
+ # resp = client.untag_resource({
+ # resource_arn: "KinesisAnalyticsARN", # required
+ # tag_keys: ["TagKey"], # required
+ # })
+ #
+ # @see http://docs.aws.amazon.com/goto/WebAPI/kinesisanalyticsv2-2018-05-23/UntagResource AWS API Documentation
+ #
+ # @overload untag_resource(params = {})
+ # @param [Hash] params ({})
+ def untag_resource(params = {}, options = {})
+ req = build_request(:untag_resource, params)
+ req.send_request(options)
+ end
+
# Updates an existing Amazon Kinesis Data Analytics application. Using
# this operation, you can update application code, input configuration,
# and output configuration.
#
# Kinesis Data Analytics updates the `ApplicationVersionId` each time
# you update your application.
#
- # <note markdown="1"> SQL is not enabled for this private beta. Using SQL parameters (such
- # as SqlApplicationConfigurationUpdate) will result in an error.
- #
- # </note>
- #
# @option params [required, String] :application_name
# The name of the application to update.
#
# @option params [required, Integer] :current_application_version_id
# The current application version ID. You can retrieve the application
@@ -1904,10 +2040,10 @@
operation: config.api.operation(operation_name),
client: self,
params: params,
config: config)
context[:gem_name] = 'aws-sdk-kinesisanalyticsv2'
- context[:gem_version] = '1.3.0'
+ context[:gem_version] = '1.4.0'
Seahorse::Client::Request.new(handlers, context)
end
# @api private
# @deprecated