Skip to content
Permalink
Branch: master
Find file Copy path
Find file Copy path
Fetching contributors…
Cannot retrieve contributors at this time
10276 lines (8805 sloc) 364 KB
// Code generated by private/model/cli/gen-api/main.go. DO NOT EDIT.
package kinesisanalyticsv2
import (
"fmt"
"time"
"github.com/aws/aws-sdk-go/aws"
"github.com/aws/aws-sdk-go/aws/awsutil"
"github.com/aws/aws-sdk-go/aws/request"
"github.com/aws/aws-sdk-go/private/protocol"
"github.com/aws/aws-sdk-go/private/protocol/jsonrpc"
)
const opAddApplicationCloudWatchLoggingOption = "AddApplicationCloudWatchLoggingOption"
// AddApplicationCloudWatchLoggingOptionRequest generates a "aws/request.Request" representing the
// client's request for the AddApplicationCloudWatchLoggingOption operation. The "output" return
// value will be populated with the request's response once the request completes
// successfully.
//
// Use "Send" method on the returned Request to send the API call to the service.
// the "output" return value is not valid until after Send returns without error.
//
// See AddApplicationCloudWatchLoggingOption for more information on using the AddApplicationCloudWatchLoggingOption
// API call, and error handling.
//
// This method is useful when you want to inject custom logic or configuration
// into the SDK's request lifecycle. Such as custom headers, or retry logic.
//
//
// // Example sending a request using the AddApplicationCloudWatchLoggingOptionRequest method.
// req, resp := client.AddApplicationCloudWatchLoggingOptionRequest(params)
//
// err := req.Send()
// if err == nil { // resp is now filled
// fmt.Println(resp)
// }
//
// See also, https://docs.aws.amazon.com/goto/WebAPI/kinesisanalyticsv2-2018-05-23/AddApplicationCloudWatchLoggingOption
func (c *KinesisAnalyticsV2) AddApplicationCloudWatchLoggingOptionRequest(input *AddApplicationCloudWatchLoggingOptionInput) (req *request.Request, output *AddApplicationCloudWatchLoggingOptionOutput) {
op := &request.Operation{
Name: opAddApplicationCloudWatchLoggingOption,
HTTPMethod: "POST",
HTTPPath: "/",
}
if input == nil {
input = &AddApplicationCloudWatchLoggingOptionInput{}
}
output = &AddApplicationCloudWatchLoggingOptionOutput{}
req = c.newRequest(op, input, output)
return
}
// AddApplicationCloudWatchLoggingOption API operation for Amazon Kinesis Analytics.
//
// Adds an Amazon CloudWatch log stream to monitor application configuration
// errors.
//
// Returns awserr.Error for service API and SDK errors. Use runtime type assertions
// with awserr.Error's Code and Message methods to get detailed information about
// the error.
//
// See the AWS API reference guide for Amazon Kinesis Analytics's
// API operation AddApplicationCloudWatchLoggingOption for usage and error information.
//
// Returned Error Codes:
// * ErrCodeResourceNotFoundException "ResourceNotFoundException"
// Specified application can't be found.
//
// * ErrCodeResourceInUseException "ResourceInUseException"
// The application is not available for this operation.
//
// * ErrCodeInvalidArgumentException "InvalidArgumentException"
// The specified input parameter value is not valid.
//
// * ErrCodeConcurrentModificationException "ConcurrentModificationException"
// Exception thrown as a result of concurrent modifications to an application.
// This error can be the result of attempting to modify an application without
// using the current application ID.
//
// * ErrCodeInvalidRequestException "InvalidRequestException"
// The request JSON is not valid for the operation.
//
// * ErrCodeInvalidApplicationConfigurationException "InvalidApplicationConfigurationException"
// The user-provided application configuration is not valid.
//
// See also, https://docs.aws.amazon.com/goto/WebAPI/kinesisanalyticsv2-2018-05-23/AddApplicationCloudWatchLoggingOption
func (c *KinesisAnalyticsV2) AddApplicationCloudWatchLoggingOption(input *AddApplicationCloudWatchLoggingOptionInput) (*AddApplicationCloudWatchLoggingOptionOutput, error) {
req, out := c.AddApplicationCloudWatchLoggingOptionRequest(input)
return out, req.Send()
}
// AddApplicationCloudWatchLoggingOptionWithContext is the same as AddApplicationCloudWatchLoggingOption with the addition of
// the ability to pass a context and additional request options.
//
// See AddApplicationCloudWatchLoggingOption for details on how to use this API operation.
//
// The context must be non-nil and will be used for request cancellation. If
// the context is nil a panic will occur. In the future the SDK may create
// sub-contexts for http.Requests. See https://golang.org/pkg/context/
// for more information on using Contexts.
func (c *KinesisAnalyticsV2) AddApplicationCloudWatchLoggingOptionWithContext(ctx aws.Context, input *AddApplicationCloudWatchLoggingOptionInput, opts ...request.Option) (*AddApplicationCloudWatchLoggingOptionOutput, error) {
req, out := c.AddApplicationCloudWatchLoggingOptionRequest(input)
req.SetContext(ctx)
req.ApplyOptions(opts...)
return out, req.Send()
}
const opAddApplicationInput = "AddApplicationInput"
// AddApplicationInputRequest generates a "aws/request.Request" representing the
// client's request for the AddApplicationInput operation. The "output" return
// value will be populated with the request's response once the request completes
// successfully.
//
// Use "Send" method on the returned Request to send the API call to the service.
// the "output" return value is not valid until after Send returns without error.
//
// See AddApplicationInput for more information on using the AddApplicationInput
// API call, and error handling.
//
// This method is useful when you want to inject custom logic or configuration
// into the SDK's request lifecycle. Such as custom headers, or retry logic.
//
//
// // Example sending a request using the AddApplicationInputRequest method.
// req, resp := client.AddApplicationInputRequest(params)
//
// err := req.Send()
// if err == nil { // resp is now filled
// fmt.Println(resp)
// }
//
// See also, https://docs.aws.amazon.com/goto/WebAPI/kinesisanalyticsv2-2018-05-23/AddApplicationInput
func (c *KinesisAnalyticsV2) AddApplicationInputRequest(input *AddApplicationInputInput) (req *request.Request, output *AddApplicationInputOutput) {
op := &request.Operation{
Name: opAddApplicationInput,
HTTPMethod: "POST",
HTTPPath: "/",
}
if input == nil {
input = &AddApplicationInputInput{}
}
output = &AddApplicationInputOutput{}
req = c.newRequest(op, input, output)
return
}
// AddApplicationInput API operation for Amazon Kinesis Analytics.
//
// Adds a streaming source to your SQL-based Amazon Kinesis Data Analytics application.
//
// You can add a streaming source when you create an application, or you can
// use this operation to add a streaming source after you create an application.
// For more information, see CreateApplication.
//
// Any configuration update, including adding a streaming source using this
// operation, results in a new version of the application. You can use the DescribeApplication
// operation to find the current application version.
//
// Returns awserr.Error for service API and SDK errors. Use runtime type assertions
// with awserr.Error's Code and Message methods to get detailed information about
// the error.
//
// See the AWS API reference guide for Amazon Kinesis Analytics's
// API operation AddApplicationInput for usage and error information.
//
// Returned Error Codes:
// * ErrCodeResourceNotFoundException "ResourceNotFoundException"
// Specified application can't be found.
//
// * ErrCodeResourceInUseException "ResourceInUseException"
// The application is not available for this operation.
//
// * ErrCodeInvalidArgumentException "InvalidArgumentException"
// The specified input parameter value is not valid.
//
// * ErrCodeConcurrentModificationException "ConcurrentModificationException"
// Exception thrown as a result of concurrent modifications to an application.
// This error can be the result of attempting to modify an application without
// using the current application ID.
//
// * ErrCodeCodeValidationException "CodeValidationException"
// The user-provided application code (query) is not valid. This can be a simple
// syntax error.
//
// * ErrCodeInvalidRequestException "InvalidRequestException"
// The request JSON is not valid for the operation.
//
// See also, https://docs.aws.amazon.com/goto/WebAPI/kinesisanalyticsv2-2018-05-23/AddApplicationInput
func (c *KinesisAnalyticsV2) AddApplicationInput(input *AddApplicationInputInput) (*AddApplicationInputOutput, error) {
req, out := c.AddApplicationInputRequest(input)
return out, req.Send()
}
// AddApplicationInputWithContext is the same as AddApplicationInput with the addition of
// the ability to pass a context and additional request options.
//
// See AddApplicationInput for details on how to use this API operation.
//
// The context must be non-nil and will be used for request cancellation. If
// the context is nil a panic will occur. In the future the SDK may create
// sub-contexts for http.Requests. See https://golang.org/pkg/context/
// for more information on using Contexts.
func (c *KinesisAnalyticsV2) AddApplicationInputWithContext(ctx aws.Context, input *AddApplicationInputInput, opts ...request.Option) (*AddApplicationInputOutput, error) {
req, out := c.AddApplicationInputRequest(input)
req.SetContext(ctx)
req.ApplyOptions(opts...)
return out, req.Send()
}
const opAddApplicationInputProcessingConfiguration = "AddApplicationInputProcessingConfiguration"
// AddApplicationInputProcessingConfigurationRequest generates a "aws/request.Request" representing the
// client's request for the AddApplicationInputProcessingConfiguration operation. The "output" return
// value will be populated with the request's response once the request completes
// successfully.
//
// Use "Send" method on the returned Request to send the API call to the service.
// the "output" return value is not valid until after Send returns without error.
//
// See AddApplicationInputProcessingConfiguration for more information on using the AddApplicationInputProcessingConfiguration
// API call, and error handling.
//
// This method is useful when you want to inject custom logic or configuration
// into the SDK's request lifecycle. Such as custom headers, or retry logic.
//
//
// // Example sending a request using the AddApplicationInputProcessingConfigurationRequest method.
// req, resp := client.AddApplicationInputProcessingConfigurationRequest(params)
//
// err := req.Send()
// if err == nil { // resp is now filled
// fmt.Println(resp)
// }
//
// See also, https://docs.aws.amazon.com/goto/WebAPI/kinesisanalyticsv2-2018-05-23/AddApplicationInputProcessingConfiguration
func (c *KinesisAnalyticsV2) AddApplicationInputProcessingConfigurationRequest(input *AddApplicationInputProcessingConfigurationInput) (req *request.Request, output *AddApplicationInputProcessingConfigurationOutput) {
op := &request.Operation{
Name: opAddApplicationInputProcessingConfiguration,
HTTPMethod: "POST",
HTTPPath: "/",
}
if input == nil {
input = &AddApplicationInputProcessingConfigurationInput{}
}
output = &AddApplicationInputProcessingConfigurationOutput{}
req = c.newRequest(op, input, output)
return
}
// AddApplicationInputProcessingConfiguration API operation for Amazon Kinesis Analytics.
//
// Adds an InputProcessingConfiguration to an SQL-based Kinesis Data Analytics
// application. An input processor pre-processes records on the input stream
// before the application's SQL code executes. Currently, the only input processor
// available is AWS Lambda (https://aws.amazon.com/documentation/lambda/).
//
// Returns awserr.Error for service API and SDK errors. Use runtime type assertions
// with awserr.Error's Code and Message methods to get detailed information about
// the error.
//
// See the AWS API reference guide for Amazon Kinesis Analytics's
// API operation AddApplicationInputProcessingConfiguration for usage and error information.
//
// Returned Error Codes:
// * ErrCodeResourceNotFoundException "ResourceNotFoundException"
// Specified application can't be found.
//
// * ErrCodeResourceInUseException "ResourceInUseException"
// The application is not available for this operation.
//
// * ErrCodeInvalidArgumentException "InvalidArgumentException"
// The specified input parameter value is not valid.
//
// * ErrCodeConcurrentModificationException "ConcurrentModificationException"
// Exception thrown as a result of concurrent modifications to an application.
// This error can be the result of attempting to modify an application without
// using the current application ID.
//
// * ErrCodeInvalidRequestException "InvalidRequestException"
// The request JSON is not valid for the operation.
//
// See also, https://docs.aws.amazon.com/goto/WebAPI/kinesisanalyticsv2-2018-05-23/AddApplicationInputProcessingConfiguration
func (c *KinesisAnalyticsV2) AddApplicationInputProcessingConfiguration(input *AddApplicationInputProcessingConfigurationInput) (*AddApplicationInputProcessingConfigurationOutput, error) {
req, out := c.AddApplicationInputProcessingConfigurationRequest(input)
return out, req.Send()
}
// AddApplicationInputProcessingConfigurationWithContext is the same as AddApplicationInputProcessingConfiguration with the addition of
// the ability to pass a context and additional request options.
//
// See AddApplicationInputProcessingConfiguration for details on how to use this API operation.
//
// The context must be non-nil and will be used for request cancellation. If
// the context is nil a panic will occur. In the future the SDK may create
// sub-contexts for http.Requests. See https://golang.org/pkg/context/
// for more information on using Contexts.
func (c *KinesisAnalyticsV2) AddApplicationInputProcessingConfigurationWithContext(ctx aws.Context, input *AddApplicationInputProcessingConfigurationInput, opts ...request.Option) (*AddApplicationInputProcessingConfigurationOutput, error) {
req, out := c.AddApplicationInputProcessingConfigurationRequest(input)
req.SetContext(ctx)
req.ApplyOptions(opts...)
return out, req.Send()
}
const opAddApplicationOutput = "AddApplicationOutput"
// AddApplicationOutputRequest generates a "aws/request.Request" representing the
// client's request for the AddApplicationOutput operation. The "output" return
// value will be populated with the request's response once the request completes
// successfully.
//
// Use "Send" method on the returned Request to send the API call to the service.
// the "output" return value is not valid until after Send returns without error.
//
// See AddApplicationOutput for more information on using the AddApplicationOutput
// API call, and error handling.
//
// This method is useful when you want to inject custom logic or configuration
// into the SDK's request lifecycle. Such as custom headers, or retry logic.
//
//
// // Example sending a request using the AddApplicationOutputRequest method.
// req, resp := client.AddApplicationOutputRequest(params)
//
// err := req.Send()
// if err == nil { // resp is now filled
// fmt.Println(resp)
// }
//
// See also, https://docs.aws.amazon.com/goto/WebAPI/kinesisanalyticsv2-2018-05-23/AddApplicationOutput
func (c *KinesisAnalyticsV2) AddApplicationOutputRequest(input *AddApplicationOutputInput) (req *request.Request, output *AddApplicationOutputOutput) {
op := &request.Operation{
Name: opAddApplicationOutput,
HTTPMethod: "POST",
HTTPPath: "/",
}
if input == nil {
input = &AddApplicationOutputInput{}
}
output = &AddApplicationOutputOutput{}
req = c.newRequest(op, input, output)
return
}
// AddApplicationOutput API operation for Amazon Kinesis Analytics.
//
// Adds an external destination to your SQL-based Amazon Kinesis Data Analytics
// application.
//
// If you want Kinesis Data Analytics to deliver data from an in-application
// stream within your application to an external destination (such as an Kinesis
// data stream, a Kinesis Data Firehose delivery stream, or an AWS Lambda function),
// you add the relevant configuration to your application using this operation.
// You can configure one or more outputs for your application. Each output configuration
// maps an in-application stream and an external destination.
//
// You can use one of the output configurations to deliver data from your in-application
// error stream to an external destination so that you can analyze the errors.
//
// Any configuration update, including adding a streaming source using this
// operation, results in a new version of the application. You can use the DescribeApplication
// operation to find the current application version.
//
// Returns awserr.Error for service API and SDK errors. Use runtime type assertions
// with awserr.Error's Code and Message methods to get detailed information about
// the error.
//
// See the AWS API reference guide for Amazon Kinesis Analytics's
// API operation AddApplicationOutput for usage and error information.
//
// Returned Error Codes:
// * ErrCodeResourceNotFoundException "ResourceNotFoundException"
// Specified application can't be found.
//
// * ErrCodeResourceInUseException "ResourceInUseException"
// The application is not available for this operation.
//
// * ErrCodeInvalidArgumentException "InvalidArgumentException"
// The specified input parameter value is not valid.
//
// * ErrCodeConcurrentModificationException "ConcurrentModificationException"
// Exception thrown as a result of concurrent modifications to an application.
// This error can be the result of attempting to modify an application without
// using the current application ID.
//
// * ErrCodeInvalidRequestException "InvalidRequestException"
// The request JSON is not valid for the operation.
//
// See also, https://docs.aws.amazon.com/goto/WebAPI/kinesisanalyticsv2-2018-05-23/AddApplicationOutput
func (c *KinesisAnalyticsV2) AddApplicationOutput(input *AddApplicationOutputInput) (*AddApplicationOutputOutput, error) {
req, out := c.AddApplicationOutputRequest(input)
return out, req.Send()
}
// AddApplicationOutputWithContext is the same as AddApplicationOutput with the addition of
// the ability to pass a context and additional request options.
//
// See AddApplicationOutput for details on how to use this API operation.
//
// The context must be non-nil and will be used for request cancellation. If
// the context is nil a panic will occur. In the future the SDK may create
// sub-contexts for http.Requests. See https://golang.org/pkg/context/
// for more information on using Contexts.
func (c *KinesisAnalyticsV2) AddApplicationOutputWithContext(ctx aws.Context, input *AddApplicationOutputInput, opts ...request.Option) (*AddApplicationOutputOutput, error) {
req, out := c.AddApplicationOutputRequest(input)
req.SetContext(ctx)
req.ApplyOptions(opts...)
return out, req.Send()
}
const opAddApplicationReferenceDataSource = "AddApplicationReferenceDataSource"
// AddApplicationReferenceDataSourceRequest generates a "aws/request.Request" representing the
// client's request for the AddApplicationReferenceDataSource operation. The "output" return
// value will be populated with the request's response once the request completes
// successfully.
//
// Use "Send" method on the returned Request to send the API call to the service.
// the "output" return value is not valid until after Send returns without error.
//
// See AddApplicationReferenceDataSource for more information on using the AddApplicationReferenceDataSource
// API call, and error handling.
//
// This method is useful when you want to inject custom logic or configuration
// into the SDK's request lifecycle. Such as custom headers, or retry logic.
//
//
// // Example sending a request using the AddApplicationReferenceDataSourceRequest method.
// req, resp := client.AddApplicationReferenceDataSourceRequest(params)
//
// err := req.Send()
// if err == nil { // resp is now filled
// fmt.Println(resp)
// }
//
// See also, https://docs.aws.amazon.com/goto/WebAPI/kinesisanalyticsv2-2018-05-23/AddApplicationReferenceDataSource
func (c *KinesisAnalyticsV2) AddApplicationReferenceDataSourceRequest(input *AddApplicationReferenceDataSourceInput) (req *request.Request, output *AddApplicationReferenceDataSourceOutput) {
op := &request.Operation{
Name: opAddApplicationReferenceDataSource,
HTTPMethod: "POST",
HTTPPath: "/",
}
if input == nil {
input = &AddApplicationReferenceDataSourceInput{}
}
output = &AddApplicationReferenceDataSourceOutput{}
req = c.newRequest(op, input, output)
return
}
// AddApplicationReferenceDataSource API operation for Amazon Kinesis Analytics.
//
// Adds a reference data source to an existing SQL-based Amazon Kinesis Data
// Analytics application.
//
// Kinesis Data Analytics reads reference data (that is, an Amazon S3 object)
// and creates an in-application table within your application. In the request,
// you provide the source (S3 bucket name and object key name), name of the
// in-application table to create, and the necessary mapping information that
// describes how data in an Amazon S3 object maps to columns in the resulting
// in-application table.
//
// Returns awserr.Error for service API and SDK errors. Use runtime type assertions
// with awserr.Error's Code and Message methods to get detailed information about
// the error.
//
// See the AWS API reference guide for Amazon Kinesis Analytics's
// API operation AddApplicationReferenceDataSource for usage and error information.
//
// Returned Error Codes:
// * ErrCodeResourceNotFoundException "ResourceNotFoundException"
// Specified application can't be found.
//
// * ErrCodeResourceInUseException "ResourceInUseException"
// The application is not available for this operation.
//
// * ErrCodeInvalidArgumentException "InvalidArgumentException"
// The specified input parameter value is not valid.
//
// * ErrCodeConcurrentModificationException "ConcurrentModificationException"
// Exception thrown as a result of concurrent modifications to an application.
// This error can be the result of attempting to modify an application without
// using the current application ID.
//
// * ErrCodeInvalidRequestException "InvalidRequestException"
// The request JSON is not valid for the operation.
//
// See also, https://docs.aws.amazon.com/goto/WebAPI/kinesisanalyticsv2-2018-05-23/AddApplicationReferenceDataSource
func (c *KinesisAnalyticsV2) AddApplicationReferenceDataSource(input *AddApplicationReferenceDataSourceInput) (*AddApplicationReferenceDataSourceOutput, error) {
req, out := c.AddApplicationReferenceDataSourceRequest(input)
return out, req.Send()
}
// AddApplicationReferenceDataSourceWithContext is the same as AddApplicationReferenceDataSource with the addition of
// the ability to pass a context and additional request options.
//
// See AddApplicationReferenceDataSource for details on how to use this API operation.
//
// The context must be non-nil and will be used for request cancellation. If
// the context is nil a panic will occur. In the future the SDK may create
// sub-contexts for http.Requests. See https://golang.org/pkg/context/
// for more information on using Contexts.
func (c *KinesisAnalyticsV2) AddApplicationReferenceDataSourceWithContext(ctx aws.Context, input *AddApplicationReferenceDataSourceInput, opts ...request.Option) (*AddApplicationReferenceDataSourceOutput, error) {
req, out := c.AddApplicationReferenceDataSourceRequest(input)
req.SetContext(ctx)
req.ApplyOptions(opts...)
return out, req.Send()
}
const opCreateApplication = "CreateApplication"
// CreateApplicationRequest generates a "aws/request.Request" representing the
// client's request for the CreateApplication operation. The "output" return
// value will be populated with the request's response once the request completes
// successfully.
//
// Use "Send" method on the returned Request to send the API call to the service.
// the "output" return value is not valid until after Send returns without error.
//
// See CreateApplication for more information on using the CreateApplication
// API call, and error handling.
//
// This method is useful when you want to inject custom logic or configuration
// into the SDK's request lifecycle. Such as custom headers, or retry logic.
//
//
// // Example sending a request using the CreateApplicationRequest method.
// req, resp := client.CreateApplicationRequest(params)
//
// err := req.Send()
// if err == nil { // resp is now filled
// fmt.Println(resp)
// }
//
// See also, https://docs.aws.amazon.com/goto/WebAPI/kinesisanalyticsv2-2018-05-23/CreateApplication
func (c *KinesisAnalyticsV2) CreateApplicationRequest(input *CreateApplicationInput) (req *request.Request, output *CreateApplicationOutput) {
op := &request.Operation{
Name: opCreateApplication,
HTTPMethod: "POST",
HTTPPath: "/",
}
if input == nil {
input = &CreateApplicationInput{}
}
output = &CreateApplicationOutput{}
req = c.newRequest(op, input, output)
return
}
// CreateApplication API operation for Amazon Kinesis Analytics.
//
// Creates an Amazon Kinesis Data Analytics application. For information about
// creating a Kinesis Data Analytics application, see Creating an Application
// (https://docs.aws.amazon.com/kinesisanalytics/latest/java/getting-started.html).
//
// Returns awserr.Error for service API and SDK errors. Use runtime type assertions
// with awserr.Error's Code and Message methods to get detailed information about
// the error.
//
// See the AWS API reference guide for Amazon Kinesis Analytics's
// API operation CreateApplication for usage and error information.
//
// Returned Error Codes:
// * ErrCodeCodeValidationException "CodeValidationException"
// The user-provided application code (query) is not valid. This can be a simple
// syntax error.
//
// * ErrCodeResourceInUseException "ResourceInUseException"
// The application is not available for this operation.
//
// * ErrCodeLimitExceededException "LimitExceededException"
// The number of allowed resources has been exceeded.
//
// * ErrCodeInvalidArgumentException "InvalidArgumentException"
// The specified input parameter value is not valid.
//
// * ErrCodeInvalidRequestException "InvalidRequestException"
// The request JSON is not valid for the operation.
//
// * ErrCodeTooManyTagsException "TooManyTagsException"
// Application created with too many tags, or too many tags added to an application.
// Note that the maximum number of application tags includes system tags. The
// maximum number of user-defined application tags is 50.
//
// * ErrCodeConcurrentModificationException "ConcurrentModificationException"
// Exception thrown as a result of concurrent modifications to an application.
// This error can be the result of attempting to modify an application without
// using the current application ID.
//
// See also, https://docs.aws.amazon.com/goto/WebAPI/kinesisanalyticsv2-2018-05-23/CreateApplication
func (c *KinesisAnalyticsV2) CreateApplication(input *CreateApplicationInput) (*CreateApplicationOutput, error) {
req, out := c.CreateApplicationRequest(input)
return out, req.Send()
}
// CreateApplicationWithContext is the same as CreateApplication with the addition of
// the ability to pass a context and additional request options.
//
// See CreateApplication for details on how to use this API operation.
//
// The context must be non-nil and will be used for request cancellation. If
// the context is nil a panic will occur. In the future the SDK may create
// sub-contexts for http.Requests. See https://golang.org/pkg/context/
// for more information on using Contexts.
func (c *KinesisAnalyticsV2) CreateApplicationWithContext(ctx aws.Context, input *CreateApplicationInput, opts ...request.Option) (*CreateApplicationOutput, error) {
req, out := c.CreateApplicationRequest(input)
req.SetContext(ctx)
req.ApplyOptions(opts...)
return out, req.Send()
}
const opCreateApplicationSnapshot = "CreateApplicationSnapshot"
// CreateApplicationSnapshotRequest generates a "aws/request.Request" representing the
// client's request for the CreateApplicationSnapshot operation. The "output" return
// value will be populated with the request's response once the request completes
// successfully.
//
// Use "Send" method on the returned Request to send the API call to the service.
// the "output" return value is not valid until after Send returns without error.
//
// See CreateApplicationSnapshot for more information on using the CreateApplicationSnapshot
// API call, and error handling.
//
// This method is useful when you want to inject custom logic or configuration
// into the SDK's request lifecycle. Such as custom headers, or retry logic.
//
//
// // Example sending a request using the CreateApplicationSnapshotRequest method.
// req, resp := client.CreateApplicationSnapshotRequest(params)
//
// err := req.Send()
// if err == nil { // resp is now filled
// fmt.Println(resp)
// }
//
// See also, https://docs.aws.amazon.com/goto/WebAPI/kinesisanalyticsv2-2018-05-23/CreateApplicationSnapshot
func (c *KinesisAnalyticsV2) CreateApplicationSnapshotRequest(input *CreateApplicationSnapshotInput) (req *request.Request, output *CreateApplicationSnapshotOutput) {
op := &request.Operation{
Name: opCreateApplicationSnapshot,
HTTPMethod: "POST",
HTTPPath: "/",
}
if input == nil {
input = &CreateApplicationSnapshotInput{}
}
output = &CreateApplicationSnapshotOutput{}
req = c.newRequest(op, input, output)
req.Handlers.Unmarshal.Swap(jsonrpc.UnmarshalHandler.Name, protocol.UnmarshalDiscardBodyHandler)
return
}
// CreateApplicationSnapshot API operation for Amazon Kinesis Analytics.
//
// Creates a snapshot of the application's state data.
//
// Returns awserr.Error for service API and SDK errors. Use runtime type assertions
// with awserr.Error's Code and Message methods to get detailed information about
// the error.
//
// See the AWS API reference guide for Amazon Kinesis Analytics's
// API operation CreateApplicationSnapshot for usage and error information.
//
// Returned Error Codes:
// * ErrCodeResourceInUseException "ResourceInUseException"
// The application is not available for this operation.
//
// * ErrCodeResourceNotFoundException "ResourceNotFoundException"
// Specified application can't be found.
//
// * ErrCodeLimitExceededException "LimitExceededException"
// The number of allowed resources has been exceeded.
//
// * ErrCodeInvalidArgumentException "InvalidArgumentException"
// The specified input parameter value is not valid.
//
// * ErrCodeUnsupportedOperationException "UnsupportedOperationException"
// The request was rejected because a specified parameter is not supported or
// a specified resource is not valid for this operation.
//
// * ErrCodeInvalidRequestException "InvalidRequestException"
// The request JSON is not valid for the operation.
//
// See also, https://docs.aws.amazon.com/goto/WebAPI/kinesisanalyticsv2-2018-05-23/CreateApplicationSnapshot
func (c *KinesisAnalyticsV2) CreateApplicationSnapshot(input *CreateApplicationSnapshotInput) (*CreateApplicationSnapshotOutput, error) {
req, out := c.CreateApplicationSnapshotRequest(input)
return out, req.Send()
}
// CreateApplicationSnapshotWithContext is the same as CreateApplicationSnapshot with the addition of
// the ability to pass a context and additional request options.
//
// See CreateApplicationSnapshot for details on how to use this API operation.
//
// The context must be non-nil and will be used for request cancellation. If
// the context is nil a panic will occur. In the future the SDK may create
// sub-contexts for http.Requests. See https://golang.org/pkg/context/
// for more information on using Contexts.
func (c *KinesisAnalyticsV2) CreateApplicationSnapshotWithContext(ctx aws.Context, input *CreateApplicationSnapshotInput, opts ...request.Option) (*CreateApplicationSnapshotOutput, error) {
req, out := c.CreateApplicationSnapshotRequest(input)
req.SetContext(ctx)
req.ApplyOptions(opts...)
return out, req.Send()
}
const opDeleteApplication = "DeleteApplication"
// DeleteApplicationRequest generates a "aws/request.Request" representing the
// client's request for the DeleteApplication operation. The "output" return
// value will be populated with the request's response once the request completes
// successfully.
//
// Use "Send" method on the returned Request to send the API call to the service.
// the "output" return value is not valid until after Send returns without error.
//
// See DeleteApplication for more information on using the DeleteApplication
// API call, and error handling.
//
// This method is useful when you want to inject custom logic or configuration
// into the SDK's request lifecycle. Such as custom headers, or retry logic.
//
//
// // Example sending a request using the DeleteApplicationRequest method.
// req, resp := client.DeleteApplicationRequest(params)
//
// err := req.Send()
// if err == nil { // resp is now filled
// fmt.Println(resp)
// }
//
// See also, https://docs.aws.amazon.com/goto/WebAPI/kinesisanalyticsv2-2018-05-23/DeleteApplication
func (c *KinesisAnalyticsV2) DeleteApplicationRequest(input *DeleteApplicationInput) (req *request.Request, output *DeleteApplicationOutput) {
op := &request.Operation{
Name: opDeleteApplication,
HTTPMethod: "POST",
HTTPPath: "/",
}
if input == nil {
input = &DeleteApplicationInput{}
}
output = &DeleteApplicationOutput{}
req = c.newRequest(op, input, output)
req.Handlers.Unmarshal.Swap(jsonrpc.UnmarshalHandler.Name, protocol.UnmarshalDiscardBodyHandler)
return
}
// DeleteApplication API operation for Amazon Kinesis Analytics.
//
// Deletes the specified application. Kinesis Data Analytics halts application
// execution and deletes the application.
//
// Returns awserr.Error for service API and SDK errors. Use runtime type assertions
// with awserr.Error's Code and Message methods to get detailed information about
// the error.
//
// See the AWS API reference guide for Amazon Kinesis Analytics's
// API operation DeleteApplication for usage and error information.
//
// Returned Error Codes:
// * ErrCodeConcurrentModificationException "ConcurrentModificationException"
// Exception thrown as a result of concurrent modifications to an application.
// This error can be the result of attempting to modify an application without
// using the current application ID.
//
// * ErrCodeResourceNotFoundException "ResourceNotFoundException"
// Specified application can't be found.
//
// * ErrCodeResourceInUseException "ResourceInUseException"
// The application is not available for this operation.
//
// * ErrCodeInvalidArgumentException "InvalidArgumentException"
// The specified input parameter value is not valid.
//
// * ErrCodeInvalidRequestException "InvalidRequestException"
// The request JSON is not valid for the operation.
//
// * ErrCodeInvalidApplicationConfigurationException "InvalidApplicationConfigurationException"
// The user-provided application configuration is not valid.
//
// See also, https://docs.aws.amazon.com/goto/WebAPI/kinesisanalyticsv2-2018-05-23/DeleteApplication
func (c *KinesisAnalyticsV2) DeleteApplication(input *DeleteApplicationInput) (*DeleteApplicationOutput, error) {
req, out := c.DeleteApplicationRequest(input)
return out, req.Send()
}
// DeleteApplicationWithContext is the same as DeleteApplication with the addition of
// the ability to pass a context and additional request options.
//
// See DeleteApplication for details on how to use this API operation.
//
// The context must be non-nil and will be used for request cancellation. If
// the context is nil a panic will occur. In the future the SDK may create
// sub-contexts for http.Requests. See https://golang.org/pkg/context/
// for more information on using Contexts.
func (c *KinesisAnalyticsV2) DeleteApplicationWithContext(ctx aws.Context, input *DeleteApplicationInput, opts ...request.Option) (*DeleteApplicationOutput, error) {
req, out := c.DeleteApplicationRequest(input)
req.SetContext(ctx)
req.ApplyOptions(opts...)
return out, req.Send()
}
const opDeleteApplicationCloudWatchLoggingOption = "DeleteApplicationCloudWatchLoggingOption"
// DeleteApplicationCloudWatchLoggingOptionRequest generates a "aws/request.Request" representing the
// client's request for the DeleteApplicationCloudWatchLoggingOption operation. The "output" return
// value will be populated with the request's response once the request completes
// successfully.
//
// Use "Send" method on the returned Request to send the API call to the service.
// the "output" return value is not valid until after Send returns without error.
//
// See DeleteApplicationCloudWatchLoggingOption for more information on using the DeleteApplicationCloudWatchLoggingOption
// API call, and error handling.
//
// This method is useful when you want to inject custom logic or configuration
// into the SDK's request lifecycle. Such as custom headers, or retry logic.
//
//
// // Example sending a request using the DeleteApplicationCloudWatchLoggingOptionRequest method.
// req, resp := client.DeleteApplicationCloudWatchLoggingOptionRequest(params)
//
// err := req.Send()
// if err == nil { // resp is now filled
// fmt.Println(resp)
// }
//
// See also, https://docs.aws.amazon.com/goto/WebAPI/kinesisanalyticsv2-2018-05-23/DeleteApplicationCloudWatchLoggingOption
func (c *KinesisAnalyticsV2) DeleteApplicationCloudWatchLoggingOptionRequest(input *DeleteApplicationCloudWatchLoggingOptionInput) (req *request.Request, output *DeleteApplicationCloudWatchLoggingOptionOutput) {
op := &request.Operation{
Name: opDeleteApplicationCloudWatchLoggingOption,
HTTPMethod: "POST",
HTTPPath: "/",
}
if input == nil {
input = &DeleteApplicationCloudWatchLoggingOptionInput{}
}
output = &DeleteApplicationCloudWatchLoggingOptionOutput{}
req = c.newRequest(op, input, output)
return
}
// DeleteApplicationCloudWatchLoggingOption API operation for Amazon Kinesis Analytics.
//
// Deletes an Amazon CloudWatch log stream from an Amazon Kinesis Data Analytics
// application.
//
// Returns awserr.Error for service API and SDK errors. Use runtime type assertions
// with awserr.Error's Code and Message methods to get detailed information about
// the error.
//
// See the AWS API reference guide for Amazon Kinesis Analytics's
// API operation DeleteApplicationCloudWatchLoggingOption for usage and error information.
//
// Returned Error Codes:
// * ErrCodeResourceNotFoundException "ResourceNotFoundException"
// Specified application can't be found.
//
// * ErrCodeResourceInUseException "ResourceInUseException"
// The application is not available for this operation.
//
// * ErrCodeInvalidArgumentException "InvalidArgumentException"
// The specified input parameter value is not valid.
//
// * ErrCodeConcurrentModificationException "ConcurrentModificationException"
// Exception thrown as a result of concurrent modifications to an application.
// This error can be the result of attempting to modify an application without
// using the current application ID.
//
// * ErrCodeInvalidRequestException "InvalidRequestException"
// The request JSON is not valid for the operation.
//
// * ErrCodeInvalidApplicationConfigurationException "InvalidApplicationConfigurationException"
// The user-provided application configuration is not valid.
//
// See also, https://docs.aws.amazon.com/goto/WebAPI/kinesisanalyticsv2-2018-05-23/DeleteApplicationCloudWatchLoggingOption
func (c *KinesisAnalyticsV2) DeleteApplicationCloudWatchLoggingOption(input *DeleteApplicationCloudWatchLoggingOptionInput) (*DeleteApplicationCloudWatchLoggingOptionOutput, error) {
req, out := c.DeleteApplicationCloudWatchLoggingOptionRequest(input)
return out, req.Send()
}
// DeleteApplicationCloudWatchLoggingOptionWithContext is the same as DeleteApplicationCloudWatchLoggingOption with the addition of
// the ability to pass a context and additional request options.
//
// See DeleteApplicationCloudWatchLoggingOption for details on how to use this API operation.
//
// The context must be non-nil and will be used for request cancellation. If
// the context is nil a panic will occur. In the future the SDK may create
// sub-contexts for http.Requests. See https://golang.org/pkg/context/
// for more information on using Contexts.
func (c *KinesisAnalyticsV2) DeleteApplicationCloudWatchLoggingOptionWithContext(ctx aws.Context, input *DeleteApplicationCloudWatchLoggingOptionInput, opts ...request.Option) (*DeleteApplicationCloudWatchLoggingOptionOutput, error) {
req, out := c.DeleteApplicationCloudWatchLoggingOptionRequest(input)
req.SetContext(ctx)
req.ApplyOptions(opts...)
return out, req.Send()
}
const opDeleteApplicationInputProcessingConfiguration = "DeleteApplicationInputProcessingConfiguration"
// DeleteApplicationInputProcessingConfigurationRequest generates a "aws/request.Request" representing the
// client's request for the DeleteApplicationInputProcessingConfiguration operation. The "output" return
// value will be populated with the request's response once the request completes
// successfully.
//
// Use "Send" method on the returned Request to send the API call to the service.
// the "output" return value is not valid until after Send returns without error.
//
// See DeleteApplicationInputProcessingConfiguration for more information on using the DeleteApplicationInputProcessingConfiguration
// API call, and error handling.
//
// This method is useful when you want to inject custom logic or configuration
// into the SDK's request lifecycle. Such as custom headers, or retry logic.
//
//
// // Example sending a request using the DeleteApplicationInputProcessingConfigurationRequest method.
// req, resp := client.DeleteApplicationInputProcessingConfigurationRequest(params)
//
// err := req.Send()
// if err == nil { // resp is now filled
// fmt.Println(resp)
// }
//
// See also, https://docs.aws.amazon.com/goto/WebAPI/kinesisanalyticsv2-2018-05-23/DeleteApplicationInputProcessingConfiguration
func (c *KinesisAnalyticsV2) DeleteApplicationInputProcessingConfigurationRequest(input *DeleteApplicationInputProcessingConfigurationInput) (req *request.Request, output *DeleteApplicationInputProcessingConfigurationOutput) {
op := &request.Operation{
Name: opDeleteApplicationInputProcessingConfiguration,
HTTPMethod: "POST",
HTTPPath: "/",
}
if input == nil {
input = &DeleteApplicationInputProcessingConfigurationInput{}
}
output = &DeleteApplicationInputProcessingConfigurationOutput{}
req = c.newRequest(op, input, output)
return
}
// DeleteApplicationInputProcessingConfiguration API operation for Amazon Kinesis Analytics.
//
// Deletes an InputProcessingConfiguration from an input.
//
// Returns awserr.Error for service API and SDK errors. Use runtime type assertions
// with awserr.Error's Code and Message methods to get detailed information about
// the error.
//
// See the AWS API reference guide for Amazon Kinesis Analytics's
// API operation DeleteApplicationInputProcessingConfiguration for usage and error information.
//
// Returned Error Codes:
// * ErrCodeResourceNotFoundException "ResourceNotFoundException"
// Specified application can't be found.
//
// * ErrCodeResourceInUseException "ResourceInUseException"
// The application is not available for this operation.
//
// * ErrCodeInvalidArgumentException "InvalidArgumentException"
// The specified input parameter value is not valid.
//
// * ErrCodeConcurrentModificationException "ConcurrentModificationException"
// Exception thrown as a result of concurrent modifications to an application.
// This error can be the result of attempting to modify an application without
// using the current application ID.
//
// * ErrCodeInvalidRequestException "InvalidRequestException"
// The request JSON is not valid for the operation.
//
// See also, https://docs.aws.amazon.com/goto/WebAPI/kinesisanalyticsv2-2018-05-23/DeleteApplicationInputProcessingConfiguration
func (c *KinesisAnalyticsV2) DeleteApplicationInputProcessingConfiguration(input *DeleteApplicationInputProcessingConfigurationInput) (*DeleteApplicationInputProcessingConfigurationOutput, error) {
req, out := c.DeleteApplicationInputProcessingConfigurationRequest(input)
return out, req.Send()
}
// DeleteApplicationInputProcessingConfigurationWithContext is the same as DeleteApplicationInputProcessingConfiguration with the addition of
// the ability to pass a context and additional request options.
//
// See DeleteApplicationInputProcessingConfiguration for details on how to use this API operation.
//
// The context must be non-nil and will be used for request cancellation. If
// the context is nil a panic will occur. In the future the SDK may create
// sub-contexts for http.Requests. See https://golang.org/pkg/context/
// for more information on using Contexts.
func (c *KinesisAnalyticsV2) DeleteApplicationInputProcessingConfigurationWithContext(ctx aws.Context, input *DeleteApplicationInputProcessingConfigurationInput, opts ...request.Option) (*DeleteApplicationInputProcessingConfigurationOutput, error) {
req, out := c.DeleteApplicationInputProcessingConfigurationRequest(input)
req.SetContext(ctx)
req.ApplyOptions(opts...)
return out, req.Send()
}
const opDeleteApplicationOutput = "DeleteApplicationOutput"
// DeleteApplicationOutputRequest generates a "aws/request.Request" representing the
// client's request for the DeleteApplicationOutput operation. The "output" return
// value will be populated with the request's response once the request completes
// successfully.
//
// Use "Send" method on the returned Request to send the API call to the service.
// the "output" return value is not valid until after Send returns without error.
//
// See DeleteApplicationOutput for more information on using the DeleteApplicationOutput
// API call, and error handling.
//
// This method is useful when you want to inject custom logic or configuration
// into the SDK's request lifecycle. Such as custom headers, or retry logic.
//
//
// // Example sending a request using the DeleteApplicationOutputRequest method.
// req, resp := client.DeleteApplicationOutputRequest(params)
//
// err := req.Send()
// if err == nil { // resp is now filled
// fmt.Println(resp)
// }
//
// See also, https://docs.aws.amazon.com/goto/WebAPI/kinesisanalyticsv2-2018-05-23/DeleteApplicationOutput
func (c *KinesisAnalyticsV2) DeleteApplicationOutputRequest(input *DeleteApplicationOutputInput) (req *request.Request, output *DeleteApplicationOutputOutput) {
op := &request.Operation{
Name: opDeleteApplicationOutput,
HTTPMethod: "POST",
HTTPPath: "/",
}
if input == nil {
input = &DeleteApplicationOutputInput{}
}
output = &DeleteApplicationOutputOutput{}
req = c.newRequest(op, input, output)
return
}
// DeleteApplicationOutput API operation for Amazon Kinesis Analytics.
//
// Deletes the output destination configuration from your SQL-based Amazon Kinesis
// Data Analytics application's configuration. Kinesis Data Analytics will no
// longer write data from the corresponding in-application stream to the external
// output destination.
//
// Returns awserr.Error for service API and SDK errors. Use runtime type assertions
// with awserr.Error's Code and Message methods to get detailed information about
// the error.
//
// See the AWS API reference guide for Amazon Kinesis Analytics's
// API operation DeleteApplicationOutput for usage and error information.
//
// Returned Error Codes:
// * ErrCodeResourceNotFoundException "ResourceNotFoundException"
// Specified application can't be found.
//
// * ErrCodeResourceInUseException "ResourceInUseException"
// The application is not available for this operation.
//
// * ErrCodeInvalidArgumentException "InvalidArgumentException"
// The specified input parameter value is not valid.
//
// * ErrCodeConcurrentModificationException "ConcurrentModificationException"
// Exception thrown as a result of concurrent modifications to an application.
// This error can be the result of attempting to modify an application without
// using the current application ID.
//
// * ErrCodeInvalidRequestException "InvalidRequestException"
// The request JSON is not valid for the operation.
//
// See also, https://docs.aws.amazon.com/goto/WebAPI/kinesisanalyticsv2-2018-05-23/DeleteApplicationOutput
func (c *KinesisAnalyticsV2) DeleteApplicationOutput(input *DeleteApplicationOutputInput) (*DeleteApplicationOutputOutput, error) {
req, out := c.DeleteApplicationOutputRequest(input)
return out, req.Send()
}
// DeleteApplicationOutputWithContext is the same as DeleteApplicationOutput with the addition of
// the ability to pass a context and additional request options.
//
// See DeleteApplicationOutput for details on how to use this API operation.
//
// The context must be non-nil and will be used for request cancellation. If
// the context is nil a panic will occur. In the future the SDK may create
// sub-contexts for http.Requests. See https://golang.org/pkg/context/
// for more information on using Contexts.
func (c *KinesisAnalyticsV2) DeleteApplicationOutputWithContext(ctx aws.Context, input *DeleteApplicationOutputInput, opts ...request.Option) (*DeleteApplicationOutputOutput, error) {
req, out := c.DeleteApplicationOutputRequest(input)
req.SetContext(ctx)
req.ApplyOptions(opts...)
return out, req.Send()
}
const opDeleteApplicationReferenceDataSource = "DeleteApplicationReferenceDataSource"
// DeleteApplicationReferenceDataSourceRequest generates a "aws/request.Request" representing the
// client's request for the DeleteApplicationReferenceDataSource operation. The "output" return
// value will be populated with the request's response once the request completes
// successfully.
//
// Use "Send" method on the returned Request to send the API call to the service.
// the "output" return value is not valid until after Send returns without error.
//
// See DeleteApplicationReferenceDataSource for more information on using the DeleteApplicationReferenceDataSource
// API call, and error handling.
//
// This method is useful when you want to inject custom logic or configuration
// into the SDK's request lifecycle. Such as custom headers, or retry logic.
//
//
// // Example sending a request using the DeleteApplicationReferenceDataSourceRequest method.
// req, resp := client.DeleteApplicationReferenceDataSourceRequest(params)
//
// err := req.Send()
// if err == nil { // resp is now filled
// fmt.Println(resp)
// }
//
// See also, https://docs.aws.amazon.com/goto/WebAPI/kinesisanalyticsv2-2018-05-23/DeleteApplicationReferenceDataSource
func (c *KinesisAnalyticsV2) DeleteApplicationReferenceDataSourceRequest(input *DeleteApplicationReferenceDataSourceInput) (req *request.Request, output *DeleteApplicationReferenceDataSourceOutput) {
op := &request.Operation{
Name: opDeleteApplicationReferenceDataSource,
HTTPMethod: "POST",
HTTPPath: "/",
}
if input == nil {
input = &DeleteApplicationReferenceDataSourceInput{}
}
output = &DeleteApplicationReferenceDataSourceOutput{}
req = c.newRequest(op, input, output)
return
}
// DeleteApplicationReferenceDataSource API operation for Amazon Kinesis Analytics.
//
// Deletes a reference data source configuration from the specified SQL-based
// Amazon Kinesis Data Analytics application's configuration.
//
// If the application is running, Kinesis Data Analytics immediately removes
// the in-application table that you created using the AddApplicationReferenceDataSource
// operation.
//
// Returns awserr.Error for service API and SDK errors. Use runtime type assertions
// with awserr.Error's Code and Message methods to get detailed information about
// the error.
//
// See the AWS API reference guide for Amazon Kinesis Analytics's
// API operation DeleteApplicationReferenceDataSource for usage and error information.
//
// Returned Error Codes:
// * ErrCodeResourceNotFoundException "ResourceNotFoundException"
// Specified application can't be found.
//
// * ErrCodeResourceInUseException "ResourceInUseException"
// The application is not available for this operation.
//
// * ErrCodeInvalidArgumentException "InvalidArgumentException"
// The specified input parameter value is not valid.
//
// * ErrCodeConcurrentModificationException "ConcurrentModificationException"
// Exception thrown as a result of concurrent modifications to an application.
// This error can be the result of attempting to modify an application without
// using the current application ID.
//
// * ErrCodeInvalidRequestException "InvalidRequestException"
// The request JSON is not valid for the operation.
//
// See also, https://docs.aws.amazon.com/goto/WebAPI/kinesisanalyticsv2-2018-05-23/DeleteApplicationReferenceDataSource
func (c *KinesisAnalyticsV2) DeleteApplicationReferenceDataSource(input *DeleteApplicationReferenceDataSourceInput) (*DeleteApplicationReferenceDataSourceOutput, error) {
req, out := c.DeleteApplicationReferenceDataSourceRequest(input)
return out, req.Send()
}
// DeleteApplicationReferenceDataSourceWithContext is the same as DeleteApplicationReferenceDataSource with the addition of
// the ability to pass a context and additional request options.
//
// See DeleteApplicationReferenceDataSource for details on how to use this API operation.
//
// The context must be non-nil and will be used for request cancellation. If
// the context is nil a panic will occur. In the future the SDK may create
// sub-contexts for http.Requests. See https://golang.org/pkg/context/
// for more information on using Contexts.
func (c *KinesisAnalyticsV2) DeleteApplicationReferenceDataSourceWithContext(ctx aws.Context, input *DeleteApplicationReferenceDataSourceInput, opts ...request.Option) (*DeleteApplicationReferenceDataSourceOutput, error) {
req, out := c.DeleteApplicationReferenceDataSourceRequest(input)
req.SetContext(ctx)
req.ApplyOptions(opts...)
return out, req.Send()
}
const opDeleteApplicationSnapshot = "DeleteApplicationSnapshot"
// DeleteApplicationSnapshotRequest generates a "aws/request.Request" representing the
// client's request for the DeleteApplicationSnapshot operation. The "output" return
// value will be populated with the request's response once the request completes
// successfully.
//
// Use "Send" method on the returned Request to send the API call to the service.
// the "output" return value is not valid until after Send returns without error.
//
// See DeleteApplicationSnapshot for more information on using the DeleteApplicationSnapshot
// API call, and error handling.
//
// This method is useful when you want to inject custom logic or configuration
// into the SDK's request lifecycle. Such as custom headers, or retry logic.
//
//
// // Example sending a request using the DeleteApplicationSnapshotRequest method.
// req, resp := client.DeleteApplicationSnapshotRequest(params)
//
// err := req.Send()
// if err == nil { // resp is now filled
// fmt.Println(resp)
// }
//
// See also, https://docs.aws.amazon.com/goto/WebAPI/kinesisanalyticsv2-2018-05-23/DeleteApplicationSnapshot
func (c *KinesisAnalyticsV2) DeleteApplicationSnapshotRequest(input *DeleteApplicationSnapshotInput) (req *request.Request, output *DeleteApplicationSnapshotOutput) {
op := &request.Operation{
Name: opDeleteApplicationSnapshot,
HTTPMethod: "POST",
HTTPPath: "/",
}
if input == nil {
input = &DeleteApplicationSnapshotInput{}
}
output = &DeleteApplicationSnapshotOutput{}
req = c.newRequest(op, input, output)
req.Handlers.Unmarshal.Swap(jsonrpc.UnmarshalHandler.Name, protocol.UnmarshalDiscardBodyHandler)
return
}
// DeleteApplicationSnapshot API operation for Amazon Kinesis Analytics.
//
// Deletes a snapshot of application state.
//
// Returns awserr.Error for service API and SDK errors. Use runtime type assertions
// with awserr.Error's Code and Message methods to get detailed information about
// the error.
//
// See the AWS API reference guide for Amazon Kinesis Analytics's
// API operation DeleteApplicationSnapshot for usage and error information.
//
// Returned Error Codes:
// * ErrCodeResourceInUseException "ResourceInUseException"
// The application is not available for this operation.
//
// * ErrCodeInvalidArgumentException "InvalidArgumentException"
// The specified input parameter value is not valid.
//
// * ErrCodeUnsupportedOperationException "UnsupportedOperationException"
// The request was rejected because a specified parameter is not supported or
// a specified resource is not valid for this operation.
//
// * ErrCodeInvalidRequestException "InvalidRequestException"
// The request JSON is not valid for the operation.
//
// * ErrCodeResourceNotFoundException "ResourceNotFoundException"
// Specified application can't be found.
//
// See also, https://docs.aws.amazon.com/goto/WebAPI/kinesisanalyticsv2-2018-05-23/DeleteApplicationSnapshot
func (c *KinesisAnalyticsV2) DeleteApplicationSnapshot(input *DeleteApplicationSnapshotInput) (*DeleteApplicationSnapshotOutput, error) {
req, out := c.DeleteApplicationSnapshotRequest(input)
return out, req.Send()
}
// DeleteApplicationSnapshotWithContext is the same as DeleteApplicationSnapshot with the addition of
// the ability to pass a context and additional request options.
//
// See DeleteApplicationSnapshot for details on how to use this API operation.
//
// The context must be non-nil and will be used for request cancellation. If
// the context is nil a panic will occur. In the future the SDK may create
// sub-contexts for http.Requests. See https://golang.org/pkg/context/
// for more information on using Contexts.
func (c *KinesisAnalyticsV2) DeleteApplicationSnapshotWithContext(ctx aws.Context, input *DeleteApplicationSnapshotInput, opts ...request.Option) (*DeleteApplicationSnapshotOutput, error) {
req, out := c.DeleteApplicationSnapshotRequest(input)
req.SetContext(ctx)
req.ApplyOptions(opts...)
return out, req.Send()
}
const opDescribeApplication = "DescribeApplication"
// DescribeApplicationRequest generates a "aws/request.Request" representing the
// client's request for the DescribeApplication operation. The "output" return
// value will be populated with the request's response once the request completes
// successfully.
//
// Use "Send" method on the returned Request to send the API call to the service.
// the "output" return value is not valid until after Send returns without error.
//
// See DescribeApplication for more information on using the DescribeApplication
// API call, and error handling.
//
// This method is useful when you want to inject custom logic or configuration
// into the SDK's request lifecycle. Such as custom headers, or retry logic.
//
//
// // Example sending a request using the DescribeApplicationRequest method.
// req, resp := client.DescribeApplicationRequest(params)
//
// err := req.Send()
// if err == nil { // resp is now filled
// fmt.Println(resp)
// }
//
// See also, https://docs.aws.amazon.com/goto/WebAPI/kinesisanalyticsv2-2018-05-23/DescribeApplication
func (c *KinesisAnalyticsV2) DescribeApplicationRequest(input *DescribeApplicationInput) (req *request.Request, output *DescribeApplicationOutput) {
op := &request.Operation{
Name: opDescribeApplication,
HTTPMethod: "POST",
HTTPPath: "/",
}
if input == nil {
input = &DescribeApplicationInput{}
}
output = &DescribeApplicationOutput{}
req = c.newRequest(op, input, output)
return
}
// DescribeApplication API operation for Amazon Kinesis Analytics.
//
// Returns information about a specific Amazon Kinesis Data Analytics application.
//
// If you want to retrieve a list of all applications in your account, use the
// ListApplications operation.
//
// Returns awserr.Error for service API and SDK errors. Use runtime type assertions
// with awserr.Error's Code and Message methods to get detailed information about
// the error.
//
// See the AWS API reference guide for Amazon Kinesis Analytics's
// API operation DescribeApplication for usage and error information.
//
// Returned Error Codes:
// * ErrCodeResourceNotFoundException "ResourceNotFoundException"
// Specified application can't be found.
//
// * ErrCodeInvalidArgumentException "InvalidArgumentException"
// The specified input parameter value is not valid.
//
// * ErrCodeInvalidRequestException "InvalidRequestException"
// The request JSON is not valid for the operation.
//
// See also, https://docs.aws.amazon.com/goto/WebAPI/kinesisanalyticsv2-2018-05-23/DescribeApplication
func (c *KinesisAnalyticsV2) DescribeApplication(input *DescribeApplicationInput) (*DescribeApplicationOutput, error) {
req, out := c.DescribeApplicationRequest(input)
return out, req.Send()
}
// DescribeApplicationWithContext is the same as DescribeApplication with the addition of
// the ability to pass a context and additional request options.
//
// See DescribeApplication for details on how to use this API operation.
//
// The context must be non-nil and will be used for request cancellation. If
// the context is nil a panic will occur. In the future the SDK may create
// sub-contexts for http.Requests. See https://golang.org/pkg/context/
// for more information on using Contexts.
func (c *KinesisAnalyticsV2) DescribeApplicationWithContext(ctx aws.Context, input *DescribeApplicationInput, opts ...request.Option) (*DescribeApplicationOutput, error) {
req, out := c.DescribeApplicationRequest(input)
req.SetContext(ctx)
req.ApplyOptions(opts...)
return out, req.Send()
}
const opDescribeApplicationSnapshot = "DescribeApplicationSnapshot"
// DescribeApplicationSnapshotRequest generates a "aws/request.Request" representing the
// client's request for the DescribeApplicationSnapshot operation. The "output" return
// value will be populated with the request's response once the request completes
// successfully.
//
// Use "Send" method on the returned Request to send the API call to the service.
// the "output" return value is not valid until after Send returns without error.
//
// See DescribeApplicationSnapshot for more information on using the DescribeApplicationSnapshot
// API call, and error handling.
//
// This method is useful when you want to inject custom logic or configuration
// into the SDK's request lifecycle. Such as custom headers, or retry logic.
//
//
// // Example sending a request using the DescribeApplicationSnapshotRequest method.
// req, resp := client.DescribeApplicationSnapshotRequest(params)
//
// err := req.Send()
// if err == nil { // resp is now filled
// fmt.Println(resp)
// }
//
// See also, https://docs.aws.amazon.com/goto/WebAPI/kinesisanalyticsv2-2018-05-23/DescribeApplicationSnapshot
func (c *KinesisAnalyticsV2) DescribeApplicationSnapshotRequest(input *DescribeApplicationSnapshotInput) (req *request.Request, output *DescribeApplicationSnapshotOutput) {
op := &request.Operation{
Name: opDescribeApplicationSnapshot,
HTTPMethod: "POST",
HTTPPath: "/",
}
if input == nil {
input = &DescribeApplicationSnapshotInput{}
}
output = &DescribeApplicationSnapshotOutput{}
req = c.newRequest(op, input, output)
return
}
// DescribeApplicationSnapshot API operation for Amazon Kinesis Analytics.
//
// Returns information about a snapshot of application state data.
//
// Returns awserr.Error for service API and SDK errors. Use runtime type assertions
// with awserr.Error's Code and Message methods to get detailed information about
// the error.
//
// See the AWS API reference guide for Amazon Kinesis Analytics's
// API operation DescribeApplicationSnapshot for usage and error information.
//
// Returned Error Codes:
// * ErrCodeResourceNotFoundException "ResourceNotFoundException"
// Specified application can't be found.
//
// * ErrCodeInvalidArgumentException "InvalidArgumentException"
// The specified input parameter value is not valid.
//
// * ErrCodeUnsupportedOperationException "UnsupportedOperationException"
// The request was rejected because a specified parameter is not supported or
// a specified resource is not valid for this operation.
//
// See also, https://docs.aws.amazon.com/goto/WebAPI/kinesisanalyticsv2-2018-05-23/DescribeApplicationSnapshot
func (c *KinesisAnalyticsV2) DescribeApplicationSnapshot(input *DescribeApplicationSnapshotInput) (*DescribeApplicationSnapshotOutput, error) {
req, out := c.DescribeApplicationSnapshotRequest(input)
return out, req.Send()
}
// DescribeApplicationSnapshotWithContext is the same as DescribeApplicationSnapshot with the addition of
// the ability to pass a context and additional request options.
//
// See DescribeApplicationSnapshot for details on how to use this API operation.
//
// The context must be non-nil and will be used for request cancellation. If
// the context is nil a panic will occur. In the future the SDK may create
// sub-contexts for http.Requests. See https://golang.org/pkg/context/
// for more information on using Contexts.
func (c *KinesisAnalyticsV2) DescribeApplicationSnapshotWithContext(ctx aws.Context, input *DescribeApplicationSnapshotInput, opts ...request.Option) (*DescribeApplicationSnapshotOutput, error) {
req, out := c.DescribeApplicationSnapshotRequest(input)
req.SetContext(ctx)
req.ApplyOptions(opts...)
return out, req.Send()
}
const opDiscoverInputSchema = "DiscoverInputSchema"
// DiscoverInputSchemaRequest generates a "aws/request.Request" representing the
// client's request for the DiscoverInputSchema operation. The "output" return
// value will be populated with the request's response once the request completes
// successfully.
//
// Use "Send" method on the returned Request to send the API call to the service.
// the "output" return value is not valid until after Send returns without error.
//
// See DiscoverInputSchema for more information on using the DiscoverInputSchema
// API call, and error handling.
//
// This method is useful when you want to inject custom logic or configuration
// into the SDK's request lifecycle. Such as custom headers, or retry logic.
//
//
// // Example sending a request using the DiscoverInputSchemaRequest method.
// req, resp := client.DiscoverInputSchemaRequest(params)
//
// err := req.Send()
// if err == nil { // resp is now filled
// fmt.Println(resp)
// }
//
// See also, https://docs.aws.amazon.com/goto/WebAPI/kinesisanalyticsv2-2018-05-23/DiscoverInputSchema
func (c *KinesisAnalyticsV2) DiscoverInputSchemaRequest(input *DiscoverInputSchemaInput) (req *request.Request, output *DiscoverInputSchemaOutput) {
op := &request.Operation{
Name: opDiscoverInputSchema,
HTTPMethod: "POST",
HTTPPath: "/",
}
if input == nil {
input = &DiscoverInputSchemaInput{}
}
output = &DiscoverInputSchemaOutput{}
req = c.newRequest(op, input, output)
return
}
// DiscoverInputSchema API operation for Amazon Kinesis Analytics.
//
// Infers a schema for an SQL-based Amazon Kinesis Data Analytics application
// by evaluating sample records on the specified streaming source (Kinesis data
// stream or Kinesis Data Firehose delivery stream) or Amazon S3 object. In
// the response, the operation returns the inferred schema and also the sample
// records that the operation used to infer the schema.
//
// You can use the inferred schema when configuring a streaming source for your
// application. When you create an application using the Kinesis Data Analytics
// console, the console uses this operation to infer a schema and show it in
// the console user interface.
//
// Returns awserr.Error for service API and SDK errors. Use runtime type assertions
// with awserr.Error's Code and Message methods to get detailed information about
// the error.
//
// See the AWS API reference guide for Amazon Kinesis Analytics's
// API operation DiscoverInputSchema for usage and error information.
//
// Returned Error Codes:
// * ErrCodeInvalidArgumentException "InvalidArgumentException"
// The specified input parameter value is not valid.
//
// * ErrCodeUnableToDetectSchemaException "UnableToDetectSchemaException"
// The data format is not valid. Amazon Kinesis Data Analytics cannot detect
// the schema for the given streaming source.
//
// * ErrCodeResourceProvisionedThroughputExceededException "ResourceProvisionedThroughputExceededException"
// Discovery failed to get a record from the streaming source because of the
// Amazon Kinesis Streams ProvisionedThroughputExceededException. For more information,
// see GetRecords (http://docs.aws.amazon.com/kinesis/latest/APIReference/API_GetRecords.html)
// in the Amazon Kinesis Streams API Reference.
//
// * ErrCodeServiceUnavailableException "ServiceUnavailableException"
// The service cannot complete the request.
//
// * ErrCodeInvalidRequestException "InvalidRequestException"
// The request JSON is not valid for the operation.
//
// See also, https://docs.aws.amazon.com/goto/WebAPI/kinesisanalyticsv2-2018-05-23/DiscoverInputSchema
func (c *KinesisAnalyticsV2) DiscoverInputSchema(input *DiscoverInputSchemaInput) (*DiscoverInputSchemaOutput, error) {
req, out := c.DiscoverInputSchemaRequest(input)
return out, req.Send()
}
// DiscoverInputSchemaWithContext is the same as DiscoverInputSchema with the addition of
// the ability to pass a context and additional request options.
//
// See DiscoverInputSchema for details on how to use this API operation.
//
// The context must be non-nil and will be used for request cancellation. If
// the context is nil a panic will occur. In the future the SDK may create
// sub-contexts for http.Requests. See https://golang.org/pkg/context/
// for more information on using Contexts.
func (c *KinesisAnalyticsV2) DiscoverInputSchemaWithContext(ctx aws.Context, input *DiscoverInputSchemaInput, opts ...request.Option) (*DiscoverInputSchemaOutput, error) {
req, out := c.DiscoverInputSchemaRequest(input)
req.SetContext(ctx)
req.ApplyOptions(opts...)
return out, req.Send()
}
const opListApplicationSnapshots = "ListApplicationSnapshots"
// ListApplicationSnapshotsRequest generates a "aws/request.Request" representing the
// client's request for the ListApplicationSnapshots operation. The "output" return
// value will be populated with the request's response once the request completes
// successfully.
//
// Use "Send" method on the returned Request to send the API call to the service.
// the "output" return value is not valid until after Send returns without error.
//
// See ListApplicationSnapshots for more information on using the ListApplicationSnapshots
// API call, and error handling.
//
// This method is useful when you want to inject custom logic or configuration
// into the SDK's request lifecycle. Such as custom headers, or retry logic.
//
//
// // Example sending a request using the ListApplicationSnapshotsRequest method.
// req, resp := client.ListApplicationSnapshotsRequest(params)
//
// err := req.Send()
// if err == nil { // resp is now filled
// fmt.Println(resp)
// }
//
// See also, https://docs.aws.amazon.com/goto/WebAPI/kinesisanalyticsv2-2018-05-23/ListApplicationSnapshots
func (c *KinesisAnalyticsV2) ListApplicationSnapshotsRequest(input *ListApplicationSnapshotsInput) (req *request.Request, output *ListApplicationSnapshotsOutput) {
op := &request.Operation{
Name: opListApplicationSnapshots,
HTTPMethod: "POST",
HTTPPath: "/",
}
if input == nil {
input = &ListApplicationSnapshotsInput{}
}
output = &ListApplicationSnapshotsOutput{}
req = c.newRequest(op, input, output)
return
}
// ListApplicationSnapshots API operation for Amazon Kinesis Analytics.
//
// Lists information about the current application snapshots.
//
// Returns awserr.Error for service API and SDK errors. Use runtime type assertions
// with awserr.Error's Code and Message methods to get detailed information about
// the error.
//
// See the AWS API reference guide for Amazon Kinesis Analytics's
// API operation ListApplicationSnapshots for usage and error information.
//
// Returned Error Codes:
// * ErrCodeInvalidArgumentException "InvalidArgumentException"
// The specified input parameter value is not valid.
//
// * ErrCodeUnsupportedOperationException "UnsupportedOperationException"
// The request was rejected because a specified parameter is not supported or
// a specified resource is not valid for this operation.
//
// See also, https://docs.aws.amazon.com/goto/WebAPI/kinesisanalyticsv2-2018-05-23/ListApplicationSnapshots
func (c *KinesisAnalyticsV2) ListApplicationSnapshots(input *ListApplicationSnapshotsInput) (*ListApplicationSnapshotsOutput, error) {
req, out := c.ListApplicationSnapshotsRequest(input)
return out, req.Send()
}
// ListApplicationSnapshotsWithContext is the same as ListApplicationSnapshots with the addition of
// the ability to pass a context and additional request options.
//
// See ListApplicationSnapshots for details on how to use this API operation.
//
// The context must be non-nil and will be used for request cancellation. If
// the context is nil a panic will occur. In the future the SDK may create
// sub-contexts for http.Requests. See https://golang.org/pkg/context/
// for more information on using Contexts.
func (c *KinesisAnalyticsV2) ListApplicationSnapshotsWithContext(ctx aws.Context, input *ListApplicationSnapshotsInput, opts ...request.Option) (*ListApplicationSnapshotsOutput, error) {
req, out := c.ListApplicationSnapshotsRequest(input)
req.SetContext(ctx)
req.ApplyOptions(opts...)
return out, req.Send()
}
const opListApplications = "ListApplications"
// ListApplicationsRequest generates a "aws/request.Request" representing the
// client's request for the ListApplications operation. The "output" return
// value will be populated with the request's response once the request completes
// successfully.
//
// Use "Send" method on the returned Request to send the API call to the service.
// the "output" return value is not valid until after Send returns without error.
//
// See ListApplications for more information on using the ListApplications
// API call, and error handling.
//
// This method is useful when you want to inject custom logic or configuration
// into the SDK's request lifecycle. Such as custom headers, or retry logic.
//
//
// // Example sending a request using the ListApplicationsRequest method.
// req, resp := client.ListApplicationsRequest(params)
//
// err := req.Send()
// if err == nil { // resp is now filled
// fmt.Println(resp)
// }
//
// See also, https://docs.aws.amazon.com/goto/WebAPI/kinesisanalyticsv2-2018-05-23/ListApplications
func (c *KinesisAnalyticsV2) ListApplicationsRequest(input *ListApplicationsInput) (req *request.Request, output *ListApplicationsOutput) {
op := &request.Operation{
Name: opListApplications,
HTTPMethod: "POST",
HTTPPath: "/",
}
if input == nil {
input = &ListApplicationsInput{}
}
output = &ListApplicationsOutput{}
req = c.newRequest(op, input, output)
return
}
// ListApplications API operation for Amazon Kinesis Analytics.
//
// Returns a list of Amazon Kinesis Data Analytics applications in your account.
// For each application, the response includes the application name, Amazon
// Resource Name (ARN), and status.
//
// If you want detailed information about a specific application, use DescribeApplication.
//
// Returns awserr.Error for service API and SDK errors. Use runtime type assertions
// with awserr.Error's Code and Message methods to get detailed information about
// the error.
//
// See the AWS API reference guide for Amazon Kinesis Analytics's
// API operation ListApplications for usage and error information.
//
// Returned Error Codes:
// * ErrCodeInvalidRequestException "InvalidRequestException"
// The request JSON is not valid for the operation.
//
// See also, https://docs.aws.amazon.com/goto/WebAPI/kinesisanalyticsv2-2018-05-23/ListApplications
func (c *KinesisAnalyticsV2) ListApplications(input *ListApplicationsInput) (*ListApplicationsOutput, error) {
req, out := c.ListApplicationsRequest(input)
return out, req.Send()
}
// ListApplicationsWithContext is the same as ListApplications with the addition of
// the ability to pass a context and additional request options.
//
// See ListApplications for details on how to use this API operation.
//
// The context must be non-nil and will be used for request cancellation. If
// the context is nil a panic will occur. In the future the SDK may create
// sub-contexts for http.Requests. See https://golang.org/pkg/context/
// for more information on using Contexts.
func (c *KinesisAnalyticsV2) ListApplicationsWithContext(ctx aws.Context, input *ListApplicationsInput, opts ...request.Option) (*ListApplicationsOutput, error) {
req, out := c.ListApplicationsRequest(input)
req.SetContext(ctx)
req.ApplyOptions(opts...)
return out, req.Send()
}
const opListTagsForResource = "ListTagsForResource"
// ListTagsForResourceRequest generates a "aws/request.Request" representing the
// client's request for the ListTagsForResource operation. The "output" return
// value will be populated with the request's response once the request completes
// successfully.
//
// Use "Send" method on the returned Request to send the API call to the service.
// the "output" return value is not valid until after Send returns without error.
//
// See ListTagsForResource for more information on using the ListTagsForResource
// API call, and error handling.
//
// This method is useful when you want to inject custom logic or configuration
// into the SDK's request lifecycle. Such as custom headers, or retry logic.
//
//
// // Example sending a request using the ListTagsForResourceRequest method.
// req, resp := client.ListTagsForResourceRequest(params)
//
// err := req.Send()
// if err == nil { // resp is now filled
// fmt.Println(resp)
// }
//
// See also, https://docs.aws.amazon.com/goto/WebAPI/kinesisanalyticsv2-2018-05-23/ListTagsForResource
func (c *KinesisAnalyticsV2) ListTagsForResourceRequest(input *ListTagsForResourceInput) (req *request.Request, output *ListTagsForResourceOutput) {
op := &request.Operation{
Name: opListTagsForResource,
HTTPMethod: "POST",
HTTPPath: "/",
}
if input == nil {
input = &ListTagsForResourceInput{}
}
output = &ListTagsForResourceOutput{}
req = c.newRequest(op, input, output)
return
}
// ListTagsForResource API operation for Amazon Kinesis Analytics.
//
// Retrieves the list of key-value tags assigned to the application.
//
// Returns awserr.Error for service API and SDK errors. Use runtime type assertions
// with awserr.Error's Code and Message methods to get detailed information about
// the error.
//
// See the AWS API reference guide for Amazon Kinesis Analytics's
// API operation ListTagsForResource for usage and error information.
//
// Returned Error Codes:
// * ErrCodeResourceNotFoundException "ResourceNotFoundException"
// Specified application can't be found.
//
// * ErrCodeInvalidArgumentException "InvalidArgumentException"
// The specified input parameter value is not valid.
//
// * ErrCodeConcurrentModificationException "ConcurrentModificationException"
// Exception thrown as a result of concurrent modifications to an application.
// This error can be the result of attempting to modify an application without
// using the current application ID.
//
// See also, https://docs.aws.amazon.com/goto/WebAPI/kinesisanalyticsv2-2018-05-23/ListTagsForResource
func (c *KinesisAnalyticsV2) ListTagsForResource(input *ListTagsForResourceInput) (*ListTagsForResourceOutput, error) {
req, out := c.ListTagsForResourceRequest(input)
return out, req.Send()
}
// ListTagsForResourceWithContext is the same as ListTagsForResource with the addition of
// the ability to pass a context and additional request options.
//
// See ListTagsForResource for details on how to use this API operation.
//
// The context must be non-nil and will be used for request cancellation. If
// the context is nil a panic will occur. In the future the SDK may create
// sub-contexts for http.Requests. See https://golang.org/pkg/context/
// for more information on using Contexts.
func (c *KinesisAnalyticsV2) ListTagsForResourceWithContext(ctx aws.Context, input *ListTagsForResourceInput, opts ...request.Option) (*ListTagsForResourceOutput, error) {
req, out := c.ListTagsForResourceRequest(input)
req.SetContext(ctx)
req.ApplyOptions(opts...)
return out, req.Send()
}
const opStartApplication = "StartApplication"
// StartApplicationRequest generates a "aws/request.Request" representing the
// client's request for the StartApplication operation. The "output" return
// value will be populated with the request's response once the request completes
// successfully.
//
// Use "Send" method on the returned Request to send the API call to the service.
// the "output" return value is not valid until after Send returns without error.
//
// See StartApplication for more information on using the StartApplication
// API call, and error handling.
//
// This method is useful when you want to inject custom logic or configuration
// into the SDK's request lifecycle. Such as custom headers, or retry logic.
//
//
// // Example sending a request using the StartApplicationRequest method.
// req, resp := client.StartApplicationRequest(params)
//
// err := req.Send()
// if err == nil { // resp is now filled
// fmt.Println(resp)
// }
//
// See also, https://docs.aws.amazon.com/goto/WebAPI/kinesisanalyticsv2-2018-05-23/StartApplication
func (c *KinesisAnalyticsV2) StartApplicationRequest(input *StartApplicationInput) (req *request.Request, output *StartApplicationOutput) {
op := &request.Operation{
Name: opStartApplication,
HTTPMethod: "POST",
HTTPPath: "/",
}
if input == nil {
input = &StartApplicationInput{}
}
output = &StartApplicationOutput{}
req = c.newRequest(op, input, output)
req.Handlers.Unmarshal.Swap(jsonrpc.UnmarshalHandler.Name, protocol.UnmarshalDiscardBodyHandler)
return
}
// StartApplication API operation for Amazon Kinesis Analytics.
//
// Starts the specified Amazon Kinesis Data Analytics application. After creating
// an application, you must exclusively call this operation to start your application.
//
// Returns awserr.Error for service API and SDK errors. Use runtime type assertions
// with awserr.Error's Code and Message methods to get detailed information about
// the error.
//
// See the AWS API reference guide for Amazon Kinesis Analytics's
// API operation StartApplication for usage and error information.
//
// Returned Error Codes:
// * ErrCodeResourceNotFoundException "ResourceNotFoundException"
// Specified application can't be found.
//
// * ErrCodeResourceInUseException "ResourceInUseException"
// The application is not available for this operation.
//
// * ErrCodeInvalidArgumentException "InvalidArgumentException"
// The specified input parameter value is not valid.
//
// * ErrCodeInvalidApplicationConfigurationException "InvalidApplicationConfigurationException"
// The user-provided application configuration is not valid.
//
// * ErrCodeInvalidRequestException "InvalidRequestException"
// The request JSON is not valid for the operation.
//
// See also, https://docs.aws.amazon.com/goto/WebAPI/kinesisanalyticsv2-2018-05-23/StartApplication
func (c *KinesisAnalyticsV2) StartApplication(input *StartApplicationInput) (*StartApplicationOutput, error) {
req, out := c.StartApplicationRequest(input)
return out, req.Send()
}
// StartApplicationWithContext is the same as StartApplication with the addition of
// the ability to pass a context and additional request options.
//
// See StartApplication for details on how to use this API operation.
//
// The context must be non-nil and will be used for request cancellation. If
// the context is nil a panic will occur. In the future the SDK may create
// sub-contexts for http.Requests. See https://golang.org/pkg/context/
// for more information on using Contexts.
func (c *KinesisAnalyticsV2) StartApplicationWithContext(ctx aws.Context, input *StartApplicationInput, opts ...request.Option) (*StartApplicationOutput, error) {
req, out := c.StartApplicationRequest(input)
req.SetContext(ctx)
req.ApplyOptions(opts...)
return out, req.Send()
}
const opStopApplication = "StopApplication"
// StopApplicationRequest generates a "aws/request.Request" representing the
// client's request for the StopApplication operation. The "output" return
// value will be populated with the request's response once the request completes
// successfully.
//
// Use "Send" method on the returned Request to send the API call to the service.
// the "output" return value is not valid until after Send returns without error.
//
// See StopApplication for more information on using the StopApplication
// API call, and error handling.
//
// This method is useful when you want to inject custom logic or configuration
// into the SDK's request lifecycle. Such as custom headers, or retry logic.
//
//
// // Example sending a request using the StopApplicationRequest method.
// req, resp := client.StopApplicationRequest(params)
//
// err := req.Send()
// if err == nil { // resp is now filled
// fmt.Println(resp)
// }
//
// See also, https://docs.aws.amazon.com/goto/WebAPI/kinesisanalyticsv2-2018-05-23/StopApplication
func (c *KinesisAnalyticsV2) StopApplicationRequest(input *StopApplicationInput) (req *request.Request, output *StopApplicationOutput) {
op := &request.Operation{
Name: opStopApplication,
HTTPMethod: "POST",
HTTPPath: "/",
}
if input == nil {
input = &StopApplicationInput{}
}
output = &StopApplicationOutput{}
req = c.newRequest(op, input, output)
req.Handlers.Unmarshal.Swap(jsonrpc.UnmarshalHandler.Name, protocol.UnmarshalDiscardBodyHandler)
return
}
// StopApplication API operation for Amazon Kinesis Analytics.
//
// Stops the application from processing data. You can stop an application only
// if it is in the running state. You can use the DescribeApplication operation
// to find the application state.
//
// Returns awserr.Error for service API and SDK errors. Use runtime type assertions
// with awserr.Error's Code and Message methods to get detailed information about
// the error.
//
// See the AWS API reference guide for Amazon Kinesis Analytics's
// API operation StopApplication for usage and error information.
//
// Returned Error Codes:
// * ErrCodeResourceNotFoundException "ResourceNotFoundException"
// Specified application can't be found.
//
// * ErrCodeResourceInUseException "ResourceInUseException"
// The application is not available for this operation.
//
// * ErrCodeInvalidArgumentException "InvalidArgumentException"
// The specified input parameter value is not valid.
//
// * ErrCodeInvalidRequestException "InvalidRequestException"
// The request JSON is not valid for the operation.
//
// * ErrCodeInvalidApplicationConfigurationException "InvalidApplicationConfigurationException"
// The user-provided application configuration is not valid.
//
// See also, https://docs.aws.amazon.com/goto/WebAPI/kinesisanalyticsv2-2018-05-23/StopApplication
func (c *KinesisAnalyticsV2) StopApplication(input *StopApplicationInput) (*StopApplicationOutput, error) {
req, out := c.StopApplicationRequest(input)
return out, req.Send()
}
// StopApplicationWithContext is the same as StopApplication with the addition of
// the ability to pass a context and additional request options.
//
// See StopApplication for details on how to use this API operation.
//
// The context must be non-nil and will be used for request cancellation. If
// the context is nil a panic will occur. In the future the SDK may create
// sub-contexts for http.Requests. See https://golang.org/pkg/context/
// for more information on using Contexts.
func (c *KinesisAnalyticsV2) StopApplicationWithContext(ctx aws.Context, input *StopApplicationInput, opts ...request.Option) (*StopApplicationOutput, error) {
req, out := c.StopApplicationRequest(input)
req.SetContext(ctx)
req.ApplyOptions(opts...)
return out, req.Send()
}
const opTagResource = "TagResource"
// TagResourceRequest generates a "aws/request.Request" representing the
// client's request for the TagResource operation. The "output" return
// value will be populated with the request's response once the request completes
// successfully.
//
// Use "Send" method on the returned Request to send the API call to the service.
// the "output" return value is not valid until after Send returns without error.
//
// See TagResource for more information on using the TagResource
// API call, and error handling.
//
// This method is useful when you want to inject custom logic or configuration
// into the SDK's request lifecycle. Such as custom headers, or retry logic.
//
//
// // Example sending a request using the TagResourceRequest method.
// req, resp := client.TagResourceRequest(params)
//
// err := req.Send()
// if err == nil { // resp is now filled
// fmt.Println(resp)
// }
//
// See also, https://docs.aws.amazon.com/goto/WebAPI/kinesisanalyticsv2-2018-05-23/TagResource
func (c *KinesisAnalyticsV2) TagResourceRequest(input *TagResourceInput) (req *request.Request, output *TagResourceOutput) {
op := &request.Operation{
Name: opTagResource,
HTTPMethod: "POST",
HTTPPath: "/",
}
if input == nil {
input = &TagResourceInput{}
}
output = &TagResourceOutput{}
req = c.newRequest(op, input, output)
req.Handlers.Unmarshal.Swap(jsonrpc.UnmarshalHandler.Name, protocol.UnmarshalDiscardBodyHandler)
return
}
// TagResource API operation for Amazon Kinesis Analytics.
//
// 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.
//
// Returns awserr.Error for service API and SDK errors. Use runtime type assertions
// with awserr.Error's Code and Message methods to get detailed information about
// the error.
//
// See the AWS API reference guide for Amazon Kinesis Analytics's
// API operation TagResource for usage and error information.
//
// Returned Error Codes:
// * ErrCodeResourceNotFoundException "ResourceNotFoundException"
// Specified application can't be found.
//
// * ErrCodeResourceInUseException "ResourceInUseException"
// The application is not available for this operation.
//
// * ErrCodeTooManyTagsException "TooManyTagsException"
// Application created with too many tags, or too many tags added to an application.
// Note that the maximum number of application tags includes system tags. The
// maximum number of user-defined application tags is 50.
//
// * ErrCodeInvalidArgumentException "InvalidArgumentException"
// The specified input parameter value is not valid.
//
// * ErrCodeConcurrentModificationException "ConcurrentModificationException"
// Exception thrown as a result of concurrent modifications to an application.
// This error can be the result of attempting to modify an application without
// using the current application ID.
//
// See also, https://docs.aws.amazon.com/goto/WebAPI/kinesisanalyticsv2-2018-05-23/TagResource
func (c *KinesisAnalyticsV2) TagResource(input *TagResourceInput) (*TagResourceOutput, error) {
req, out := c.TagResourceRequest(input)
return out, req.Send()
}
// TagResourceWithContext is the same as TagResource with the addition of
// the ability to pass a context and additional request options.
//
// See TagResource for details on how to use this API operation.
//
// The context must be non-nil and will be used for request cancellation. If
// the context is nil a panic will occur. In the future the SDK may create
// sub-contexts for http.Requests. See https://golang.org/pkg/context/
// for more information on using Contexts.
func (c *KinesisAnalyticsV2) TagResourceWithContext(ctx aws.Context, input *TagResourceInput, opts ...request.Option) (*TagResourceOutput, error) {
req, out := c.TagResourceRequest(input)
req.SetContext(ctx)
req.ApplyOptions(opts...)
return out, req.Send()
}
const opUntagResource = "UntagResource"
// UntagResourceRequest generates a "aws/request.Request" representing the
// client's request for the UntagResource operation. The "output" return
// value will be populated with the request's response once the request completes
// successfully.
//
// Use "Send" method on the returned Request to send the API call to the service.
// the "output" return value is not valid until after Send returns without error.
//
// See UntagResource for more information on using the UntagResource
// API call, and error handling.
//
// This method is useful when you want to inject custom logic or configuration
// into the SDK's request lifecycle. Such as custom headers, or retry logic.
//
//
// // Example sending a request using the UntagResourceRequest method.
// req, resp := client.UntagResourceRequest(params)
//
// err := req.Send()
// if err == nil { // resp is now filled
// fmt.Println(resp)
// }
//
// See also, https://docs.aws.amazon.com/goto/WebAPI/kinesisanalyticsv2-2018-05-23/UntagResource
func (c *KinesisAnalyticsV2) UntagResourceRequest(input *UntagResourceInput) (req *request.Request, output *UntagResourceOutput) {
op := &request.Operation{
Name: opUntagResource,
HTTPMethod: "POST",
HTTPPath: "/",
}
if input == nil {
input = &UntagResourceInput{}
}
output = &UntagResourceOutput{}
req = c.newRequest(op, input, output)
req.Handlers.Unmarshal.Swap(jsonrpc.UnmarshalHandler.Name, protocol.UnmarshalDiscardBodyHandler)
return
}
// UntagResource API operation for Amazon Kinesis Analytics.
//
// Removes one or more tags from a Kinesis Analytics application.
//
// Returns awserr.Error for service API and SDK errors. Use runtime type assertions
// with awserr.Error's Code and Message methods to get detailed information about
// the error.
//
// See the AWS API reference guide for Amazon Kinesis Analytics's
// API operation UntagResource for usage and error information.
//
// Returned Error Codes:
// * ErrCodeResourceNotFoundException "ResourceNotFoundException"
// Specified application can't be found.
//
// * ErrCodeResourceInUseException "ResourceInUseException"
// The application is not available for this operation.
//
// * ErrCodeTooManyTagsException "TooManyTagsException"
// Application created with too many tags, or too many tags added to an application.
// Note that the maximum number of application tags includes system tags. The
// maximum number of user-defined application tags is 50.
//
// * ErrCodeInvalidArgumentException "InvalidArgumentException"
// The specified input parameter value is not valid.
//
// * ErrCodeConcurrentModificationException "ConcurrentModificationException"
// Exception thrown as a result of concurrent modifications to an application.
// This error can be the result of attempting to modify an application without
// using the current application ID.
//
// See also, https://docs.aws.amazon.com/goto/WebAPI/kinesisanalyticsv2-2018-05-23/UntagResource
func (c *KinesisAnalyticsV2) UntagResource(input *UntagResourceInput) (*UntagResourceOutput, error) {
req, out := c.UntagResourceRequest(input)
return out, req.Send()
}
// UntagResourceWithContext is the same as UntagResource with the addition of
// the ability to pass a context and additional request options.
//
// See UntagResource for details on how to use this API operation.
//
// The context must be non-nil and will be used for request cancellation. If
// the context is nil a panic will occur. In the future the SDK may create
// sub-contexts for http.Requests. See https://golang.org/pkg/context/
// for more information on using Contexts.
func (c *KinesisAnalyticsV2) UntagResourceWithContext(ctx aws.Context, input *UntagResourceInput, opts ...request.Option) (*UntagResourceOutput, error) {
req, out := c.UntagResourceRequest(input)
req.SetContext(ctx)
req.ApplyOptions(opts...)
return out, req.Send()
}
const opUpdateApplication = "UpdateApplication"
// UpdateApplicationRequest generates a "aws/request.Request" representing the
// client's request for the UpdateApplication operation. The "output" return
// value will be populated with the request's response once the request completes
// successfully.
//
// Use "Send" method on the returned Request to send the API call to the service.
// the "output" return value is not valid until after Send returns without error.
//
// See UpdateApplication for more information on using the UpdateApplication
// API call, and error handling.
//
// This method is useful when you want to inject custom logic or configuration
// into the SDK's request lifecycle. Such as custom headers, or retry logic.
//
//
// // Example sending a request using the UpdateApplicationRequest method.
// req, resp := client.UpdateApplicationRequest(params)
//
// err := req.Send()
// if err == nil { // resp is now filled
// fmt.Println(resp)
// }
//
// See also, https://docs.aws.amazon.com/goto/WebAPI/kinesisanalyticsv2-2018-05-23/UpdateApplication
func (c *KinesisAnalyticsV2) UpdateApplicationRequest(input *UpdateApplicationInput) (req *request.Request, output *UpdateApplicationOutput) {
op := &request.Operation{
Name: opUpdateApplication,
HTTPMethod: "POST",
HTTPPath: "/",
}
if input == nil {
input = &UpdateApplicationInput{}
}
output = &UpdateApplicationOutput{}
req = c.newRequest(op, input, output)
return
}
// UpdateApplication API operation for Amazon Kinesis Analytics.
//
// 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.
//
// Returns awserr.Error for service API and SDK errors. Use runtime type assertions
// with awserr.Error's Code and Message methods to get detailed information about
// the error.
//
// See the AWS API reference guide for Amazon Kinesis Analytics's
// API operation UpdateApplication for usage and error information.
//
// Returned Error Codes:
// * ErrCodeCodeValidationException "CodeValidationException"
// The user-provided application code (query) is not valid. This can be a simple
// syntax error.
//
// * ErrCodeResourceNotFoundException "ResourceNotFoundException"
// Specified application can't be found.
//
// * ErrCodeResourceInUseException "ResourceInUseException"
// The application is not available for this operation.
//
// * ErrCodeInvalidArgumentException "InvalidArgumentException"
// The specified input parameter value is not valid.
//
// * ErrCodeConcurrentModificationException "ConcurrentModificationException"
// Exception thrown as a result of concurrent modifications to an application.
// This error can be the result of attempting to modify an application without
// using the current application ID.
//
// * ErrCodeInvalidRequestException "InvalidRequestException"
// The request JSON is not valid for the operation.
//
// * ErrCodeInvalidApplicationConfigurationException "InvalidApplicationConfigurationException"
// The user-provided application configuration is not valid.
//
// See also, https://docs.aws.amazon.com/goto/WebAPI/kinesisanalyticsv2-2018-05-23/UpdateApplication
func (c *KinesisAnalyticsV2) UpdateApplication(input *UpdateApplicationInput) (*UpdateApplicationOutput, error) {
req, out := c.UpdateApplicationRequest(input)
return out, req.Send()
}
// UpdateApplicationWithContext is the same as UpdateApplication with the addition of
// the ability to pass a context and additional request options.
//
// See UpdateApplication for details on how to use this API operation.
//
// The context must be non-nil and will be used for request cancellation. If
// the context is nil a panic will occur. In the future the SDK may create
// sub-contexts for http.Requests. See https://golang.org/pkg/context/
// for more information on using Contexts.
func (c *KinesisAnalyticsV2) UpdateApplicationWithContext(ctx aws.Context, input *UpdateApplicationInput, opts ...request.Option) (*UpdateApplicationOutput, error) {
req, out := c.UpdateApplicationRequest(input)
req.SetContext(ctx)
req.ApplyOptions(opts...)
return out, req.Send()
}
type AddApplicationCloudWatchLoggingOptionInput struct {
_ struct{} `type:"structure"`
// The Kinesis Data Analytics application name.
//
// ApplicationName is a required field
ApplicationName *string `min:"1" type:"string" required:"true"`
// Provides the Amazon CloudWatch log stream Amazon Resource Name (ARN).
//
// CloudWatchLoggingOption is a required field
CloudWatchLoggingOption *CloudWatchLoggingOption `type:"structure" required:"true"`
// The version ID of the Kinesis Data Analytics application. You can retrieve
// the application version ID using DescribeApplication.
//
// CurrentApplicationVersionId is a required field
CurrentApplicationVersionId *int64 `min:"1" type:"long" required:"true"`
}
// String returns the string representation
func (s AddApplicationCloudWatchLoggingOptionInput) String() string {
return awsutil.Prettify(s)
}
// GoString returns the string representation
func (s AddApplicationCloudWatchLoggingOptionInput) GoString() string {
return s.String()
}
// Validate inspects the fields of the type to determine if they are valid.
func (s *AddApplicationCloudWatchLoggingOptionInput) Validate() error {
invalidParams := request.ErrInvalidParams{Context: "AddApplicationCloudWatchLoggingOptionInput"}
if s.ApplicationName == nil {
invalidParams.Add(request.NewErrParamRequired("ApplicationName"))
}
if s.ApplicationName != nil && len(*s.ApplicationName) < 1 {
invalidParams.Add(request.NewErrParamMinLen("ApplicationName", 1))
}
if s.CloudWatchLoggingOption == nil {
invalidParams.Add(request.NewErrParamRequired("CloudWatchLoggingOption"))
}
if s.CurrentApplicationVersionId == nil {
invalidParams.Add(request.NewErrParamRequired("CurrentApplicationVersionId"))
}
if s.CurrentApplicationVersionId != nil && *s.CurrentApplicationVersionId < 1 {
invalidParams.Add(request.NewErrParamMinValue("CurrentApplicationVersionId", 1))
}
if s.CloudWatchLoggingOption != nil {
if err := s.CloudWatchLoggingOption.Validate(); err != nil {
invalidParams.AddNested("CloudWatchLoggingOption", err.(request.ErrInvalidParams))
}
}
if invalidParams.Len() > 0 {
return invalidParams
}
return nil
}
// SetApplicationName sets the ApplicationName field's value.
func (s *AddApplicationCloudWatchLoggingOptionInput) SetApplicationName(v string) *AddApplicationCloudWatchLoggingOptionInput {
s.ApplicationName = &v
return s
}
// SetCloudWatchLoggingOption sets the CloudWatchLoggingOption field's value.
func (s *AddApplicationCloudWatchLoggingOptionInput) SetCloudWatchLoggingOption(v *CloudWatchLoggingOption) *AddApplicationCloudWatchLoggingOptionInput {
s.CloudWatchLoggingOption = v
return s
}
// SetCurrentApplicationVersionId sets the CurrentApplicationVersionId field's value.
func (s *AddApplicationCloudWatchLoggingOptionInput) SetCurrentApplicationVersionId(v int64) *AddApplicationCloudWatchLoggingOptionInput {
s.CurrentApplicationVersionId = &v
return s
}
type AddApplicationCloudWatchLoggingOptionOutput struct {
_ struct{} `type:"structure"`
// The application's ARN.
ApplicationARN *string `min:"1" type:"string"`
// The new version ID of the Kinesis Data Analytics application. Kinesis Data
// Analytics updates the ApplicationVersionId each time you change the CloudWatch
// logging options.
ApplicationVersionId *int64 `min:"1" type:"long"`
// The descriptions of the current CloudWatch logging options for the Kinesis
// Data Analytics application.
CloudWatchLoggingOptionDescriptions []*CloudWatchLoggingOptionDescription `type:"list"`
}
// String returns the string representation
func (s AddApplicationCloudWatchLoggingOptionOutput) String() string {
return awsutil.Prettify(s)
}
// GoString returns the string representation
func (s AddApplicationCloudWatchLoggingOptionOutput) GoString() string {
return s.String()
}
// SetApplicationARN sets the ApplicationARN field's value.
func (s *AddApplicationCloudWatchLoggingOptionOutput) SetApplicationARN(v string) *AddApplicationCloudWatchLoggingOptionOutput {
s.ApplicationARN = &v
return s
}
// SetApplicationVersionId sets the ApplicationVersionId field's value.
func (s *AddApplicationCloudWatchLoggingOptionOutput) SetApplicationVersionId(v int64) *AddApplicationCloudWatchLoggingOptionOutput {
s.ApplicationVersionId = &v
return s
}
// SetCloudWatchLoggingOptionDescriptions sets the CloudWatchLoggingOptionDescriptions field's value.
func (s *AddApplicationCloudWatchLoggingOptionOutput) SetCloudWatchLoggingOptionDescriptions(v []*CloudWatchLoggingOptionDescription) *AddApplicationCloudWatchLoggingOptionOutput {
s.CloudWatchLoggingOptionDescriptions = v
return s
}
type AddApplicationInputInput struct {
_ struct{} `type:"structure"`
// The name of your existing application to which you want to add the streaming
// source.
//
// ApplicationName is a required field
ApplicationName *string `min:"1" type:"string" required:"true"`
// The current version of your application. You can use the DescribeApplication
// operation to find the current application version.
//
// CurrentApplicationVersionId is a required field
CurrentApplicationVersionId *int64 `min:"1" type:"long" required:"true"`
// The Input to add.
//
// Input is a required field
Input *Input `type:"structure" required:"true"`
}
// String returns the string representation
func (s AddApplicationInputInput) String() string {
return awsutil.Prettify(s)
}
// GoString returns the string representation
func (s AddApplicationInputInput) GoString() string {
return s.String()
}
// Validate inspects the fields of the type to determine if they are valid.
func (s *AddApplicationInputInput) Validate() error {
invalidParams := request.ErrInvalidParams{Context: "AddApplicationInputInput"}
if s.ApplicationName == nil {
invalidParams.Add(request.NewErrParamRequired("ApplicationName"))
}
if s.ApplicationName != nil && len(*s.ApplicationName) < 1 {
invalidParams.Add(request.NewErrParamMinLen("ApplicationName", 1))
}
if s.CurrentApplicationVersionId == nil {
invalidParams.Add(request.NewErrParamRequired("CurrentApplicationVersionId"))
}
if s.CurrentApplicationVersionId != nil && *s.CurrentApplicationVersionId < 1 {
invalidParams.Add(request.NewErrParamMinValue("CurrentApplicationVersionId", 1))
}
if s.Input == nil {
invalidParams.Add(request.NewErrParamRequired("Input"))
}
if s.Input != nil {
if err := s.Input.Validate(); err != nil {
invalidParams.AddNested("Input", err.(request.ErrInvalidParams))
}
}
if invalidParams.Len() > 0 {
return invalidParams
}
return nil
}
// SetApplicationName sets the ApplicationName field's value.
func (s *AddApplicationInputInput) SetApplicationName(v string) *AddApplicationInputInput {
s.ApplicationName = &v
return s
}
// SetCurrentApplicationVersionId sets the CurrentApplicationVersionId field's value.
func (s *AddApplicationInputInput) SetCurrentApplicationVersionId(v int64) *AddApplicationInputInput {
s.CurrentApplicationVersionId = &v
return s
}
// SetInput sets the Input field's value.
func (s *AddApplicationInputInput) SetInput(v *Input) *AddApplicationInputInput {
s.Input = v
return s
}
type AddApplicationInputOutput struct {
_ struct{} `type:"structure"`
// The Amazon Resource Name (ARN) of the application.
ApplicationARN *string `min:"1" type:"string"`
// Provides the current application version.
ApplicationVersionId *int64 `min:"1" type:"long"`
// Describes the application input configuration.
InputDescriptions []*InputDescription `type:"list"`
}
// String returns the string representation
func (s AddApplicationInputOutput) String() string {
return awsutil.Prettify(s)
}
// GoString returns the string representation
func (s AddApplicationInputOutput) GoString() string {
return s.String()
}
// SetApplicationARN sets the ApplicationARN field's value.
func (s *AddApplicationInputOutput) SetApplicationARN(v string) *AddApplicationInputOutput {
s.ApplicationARN = &v
return s
}
// SetApplicationVersionId sets the ApplicationVersionId field's value.
func (s *AddApplicationInputOutput) SetApplicationVersionId(v int64) *AddApplicationInputOutput {
s.ApplicationVersionId = &v
return s
}
// SetInputDescriptions sets the InputDescriptions field's value.
func (s *AddApplicationInputOutput) SetInputDescriptions(v []*InputDescription) *AddApplicationInputOutput {
s.InputDescriptions = v
return s
}
type AddApplicationInputProcessingConfigurationInput struct {
_ struct{} `type:"structure"`
// The name of the application to which you want to add the input processing
// configuration.
//
// ApplicationName is a required field
ApplicationName *string `min:"1" type:"string" required:"true"`
// The version of the application to which you want to add the input processing
// configuration. You can use the DescribeApplication operation to get the current
// application version. If the version specified is not the current version,
// the ConcurrentModificationException is returned.
//
// CurrentApplicationVersionId is a required field
CurrentApplicationVersionId *int64 `min:"1" type:"long" required:"true"`
// The ID of the input configuration to add the input processing configuration
// to. You can get a list of the input IDs for an application using the DescribeApplication
// operation.
//
// InputId is a required field
InputId *string `min:"1" type:"string" required:"true"`
// The InputProcessingConfiguration to add to the application.
//
// InputProcessingConfiguration is a required field
InputProcessingConfiguration *InputProcessingConfiguration `type:"structure" required:"true"`
}
// String returns the string representation
func (s AddApplicationInputProcessingConfigurationInput) String() string {
return awsutil.Prettify(s)
}
// GoString returns the string representation
func (s AddApplicationInputProcessingConfigurationInput) GoString() string {
return s.String()
}
// Validate inspects the fields of the type to determine if they are valid.
func (s *AddApplicationInputProcessingConfigurationInput) Validate() error {
invalidParams := request.ErrInvalidParams{Context: "AddApplicationInputProcessingConfigurationInput"}
if s.ApplicationName == nil {
invalidParams.Add(request.NewErrParamRequired("ApplicationName"))
}
if s.ApplicationName != nil && len(*s.ApplicationName) < 1 {
invalidParams.Add(request.NewErrParamMinLen("ApplicationName", 1))
}
if s.CurrentApplicationVersionId == nil {
invalidParams.Add(request.NewErrParamRequired("CurrentApplicationVersionId"))
}
if s.CurrentApplicationVersionId != nil && *s.CurrentApplicationVersionId < 1 {
invalidParams.Add(request.NewErrParamMinValue("CurrentApplicationVersionId", 1))
}
if s.InputId == nil {
invalidParams.Add(request.NewErrParamRequired("InputId"))
}
if s.InputId != nil && len(*s.InputId) < 1 {
invalidParams.Add(request.NewErrParamMinLen("InputId", 1))
}
if s.InputProcessingConfiguration == nil {
invalidParams.Add(request.NewErrParamRequired("InputProcessingConfiguration"))
}
if s.InputProcessingConfiguration != nil {
if err := s.InputProcessingConfiguration.Validate(); err != nil {
invalidParams.AddNested("InputProcessingConfiguration", err.(request.ErrInvalidParams))
}
}
if invalidParams.Len() > 0 {
return invalidParams
}
return nil
}
// SetApplicationName sets the ApplicationName field's value.
func (s *AddApplicationInputProcessingConfigurationInput) SetApplicationName(v string) *AddApplicationInputProcessingConfigurationInput {
s.ApplicationName = &v
return s
}
// SetCurrentApplicationVersionId sets the CurrentApplicationVersionId field's value.
func (s *AddApplicationInputProcessingConfigurationInput) SetCurrentApplicationVersionId(v int64) *AddApplicationInputProcessingConfigurationInput {
s.CurrentApplicationVersionId = &v
return s
}
// SetInputId sets the InputId field's value.
func (s *AddApplicationInputProcessingConfigurationInput) SetInputId(v string) *AddApplicationInputProcessingConfigurationInput {
s.InputId = &v
return s
}
// SetInputProcessingConfiguration sets the InputProcessingConfiguration field's value.
func (s *AddApplicationInputProcessingConfigurationInput) SetInputProcessingConfiguration(v *InputProcessingConfiguration) *AddApplicationInputProcessingConfigurationInput {
s.InputProcessingConfiguration = v
return s
}
type AddApplicationInputProcessingConfigurationOutput struct {
_ struct{} `type:"structure"`
// The Amazon Resource Name (ARN) of the application.
ApplicationARN *string `min:"1" type:"string"`
// Provides the current application version.
ApplicationVersionId *int64 `min:"1" type:"long"`
// The input ID that is associated with the application input. This is the ID
// that Amazon Kinesis Data Analytics assigns to each input configuration that
// you add to your application.
InputId *string `min:"1" type:"string"`
// The description of the preprocessor that executes on records in this input
// before the application's code is run.
InputProcessingConfigurationDescription *InputProcessingConfigurationDescription `type:"structure"`
}
// String returns the string representation
func (s AddApplicationInputProcessingConfigurationOutput) String() string {
return awsutil.Prettify(s)
}
// GoString returns the string representation
func (s AddApplicationInputProcessingConfigurationOutput) GoString() string {
return s.String()
}
// SetApplicationARN sets the ApplicationARN field's value.
func (s *AddApplicationInputProcessingConfigurationOutput) SetApplicationARN(v string) *AddApplicationInputProcessingConfigurationOutput {
s.ApplicationARN = &v
return s
}
// SetApplicationVersionId sets the ApplicationVersionId field's value.
func (s *AddApplicationInputProcessingConfigurationOutput) SetApplicationVersionId(v int64) *AddApplicationInputProcessingConfigurationOutput {
s.ApplicationVersionId = &v
return s
}
// SetInputId sets the InputId field's value.
func (s *AddApplicationInputProcessingConfigurationOutput) SetInputId(v string) *AddApplicationInputProcessingConfigurationOutput {
s.InputId = &v
return s
}
// SetInputProcessingConfigurationDescription sets the InputProcessingConfigurationDescription field's value.
func (s *AddApplicationInputProcessingConfigurationOutput) SetInputProcessingConfigurationDescription(v *InputProcessingConfigurationDescription) *AddApplicationInputProcessingConfigurationOutput {
s.InputProcessingConfigurationDescription = v
return s
}
type AddApplicationOutputInput struct {
_ struct{} `type:"structure"`
// The name of the application to which you want to add the output configuration.
//
// ApplicationName is a required field
ApplicationName *string `min:"1" type:"string" required:"true"`
// The version of the application to which you want to add the output configuration.
// You can use the DescribeApplication operation to get the current application
// version. If the version specified is not the current version, the ConcurrentModificationException
// is returned.
//
// CurrentApplicationVersionId is a required field
CurrentApplicationVersionId *int64 `min:"1" type:"long" required:"true"`
// An array of objects, each describing one output configuration. In the output
// configuration, you specify the name of an in-application stream, a destination
// (that is, a Kinesis data stream, a Kinesis Data Firehose delivery stream,
// or an AWS Lambda function), and record the formation to use when writing
// to the destination.
//
// Output is a required field
Output *Output `type:"structure" required:"true"`
}
// String returns the string representation
func (s AddApplicationOutputInput) String() string {
return awsutil.Prettify(s)
}
// GoString returns the string representation
func (s AddApplicationOutputInput) GoString() string {
return s.String()
}
// Validate inspects the fields of the type to determine if they are valid.
func (s *AddApplicationOutputInput) Validate() error {
invalidParams := request.ErrInvalidParams{Context: "AddApplicationOutputInput"}
if s.ApplicationName == nil {
invalidParams.Add(request.NewErrParamRequired("ApplicationName"))
}
if s.ApplicationName != nil && len(*s.ApplicationName) < 1 {
invalidParams.Add(request.NewErrParamMinLen("ApplicationName", 1))
}
if s.CurrentApplicationVersionId == nil {
invalidParams.Add(request.NewErrParamRequired("CurrentApplicationVersionId"))
}
if s.CurrentApplicationVersionId != nil && *s.CurrentApplicationVersionId < 1 {
invalidParams.Add(request.NewErrParamMinValue("CurrentApplicationVersionId", 1))
}
if s.Output == nil {
invalidParams.Add(request.NewErrParamRequired("Output"))
}
if s.Output != nil {
if err := s.Output.Validate(); err != nil {
invalidParams.AddNested("Output", err.(request.ErrInvalidParams))
}
}
if invalidParams.Len() > 0 {
return invalidParams
}
return nil
}
// SetApplicationName sets the ApplicationName field's value.
func (s *AddApplicationOutputInput) SetApplicationName(v string) *AddApplicationOutputInput {
s.ApplicationName = &v
return s
}
// SetCurrentApplicationVersionId sets the CurrentApplicationVersionId field's value.
func (s *AddApplicationOutputInput) SetCurrentApplicationVersionId(v int64) *AddApplicationOutputInput {
s.CurrentApplicationVersionId = &v
return s
}
// SetOutput sets the Output field's value.
func (s *AddApplicationOutputInput) SetOutput(v *Output) *AddApplicationOutputInput {
s.Output = v
return s
}
type AddApplicationOutputOutput struct {
_ struct{} `type:"structure"`
// The application Amazon Resource Name (ARN).
ApplicationARN *string `min:"1" type:"string"`
// The updated application version ID. Kinesis Data Analytics increments this
// ID when the application is updated.
ApplicationVersionId *int64 `min:"1" type:"long"`
// Describes the application output configuration. For more information, see
// Configuring Application Output (https://docs.aws.amazon.com/kinesisanalytics/latest/dev/how-it-works-output.html).
OutputDescriptions []*OutputDescription `type:"list"`
}
// String returns the string representation
func (s AddApplicationOutputOutput) String() string {
return awsutil.Prettify(s)
}
// GoString returns the string representation
func (s AddApplicationOutputOutput) GoString() string {
return s.String()
}
// SetApplicationARN sets the ApplicationARN field's value.
func (s *AddApplicationOutputOutput) SetApplicationARN(v string) *AddApplicationOutputOutput {
s.ApplicationARN = &v
return s
}
// SetApplicationVersionId sets the ApplicationVersionId field's value.
func (s *AddApplicationOutputOutput) SetApplicationVersionId(v int64) *AddApplicationOutputOutput {
s.ApplicationVersionId = &v
return s
}
// SetOutputDescriptions sets the OutputDescriptions field's value.
func (s *AddApplicationOutputOutput) SetOutputDescriptions(v []*OutputDescription) *AddApplicationOutputOutput {
s.OutputDescriptions = v
return s
}
type AddApplicationReferenceDataSourceInput struct {
_ struct{} `type:"structure"`
// The name of an existing application.
//
// ApplicationName is a required field
ApplicationName *string `min:"1" type:"string" required:"true"`
// The version of the application for which you are adding the reference data
// source. You can use the DescribeApplication operation to get the current
// application version. If the version specified is not the current version,
// the ConcurrentModificationException is returned.
//
// CurrentApplicationVersionId is a required field
CurrentApplicationVersionId *int64 `min:"1" type:"long" required:"true"`
// The reference data source can be an object in your Amazon S3 bucket. Kinesis
// Data Analytics reads the object and copies the data into the in-application
// table that is created. You provide an S3 bucket, object key name, and the
// resulting in-application table that is created.
//
// ReferenceDataSource is a required field
ReferenceDataSource *ReferenceDataSource `type:"structure" required:"true"`
}
// String returns the string representation
func (s AddApplicationReferenceDataSourceInput) String() string {
return awsutil.Prettify(s)
}
// GoString returns the string representation
func (s AddApplicationReferenceDataSourceInput) GoString() string {
return s.String()
}
// Validate inspects the fields of the type to determine if they are valid.
func (s *AddApplicationReferenceDataSourceInput) Validate() error {
invalidParams := request.ErrInvalidParams{Context: "AddApplicationReferenceDataSourceInput"}
if s.ApplicationName == nil {
invalidParams.Add(request.NewErrParamRequired("ApplicationName"))
}
if s.ApplicationName != nil && len(*s.ApplicationName) < 1 {
invalidParams.Add(request.NewErrParamMinLen("ApplicationName", 1))
}
if s.CurrentApplicationVersionId == nil {
invalidParams.Add(request.NewErrParamRequired("CurrentApplicationVersionId"))
}
if s.CurrentApplicationVersionId != nil && *s.CurrentApplicationVersionId < 1 {
invalidParams.Add(request.NewErrParamMinValue("CurrentApplicationVersionId", 1))
}
if s.ReferenceDataSource == nil {
invalidParams.Add(request.NewErrParamRequired("ReferenceDataSource"))
}
if s.ReferenceDataSource != nil {
if err := s.ReferenceDataSource.Validate(); err != nil {
invalidParams.AddNested("ReferenceDataSource", err.(request.ErrInvalidParams))
}
}
if invalidParams.Len() > 0 {
return invalidParams
}
return nil
}
// SetApplicationName sets the ApplicationName field's value.
func (s *AddApplicationReferenceDataSourceInput) SetApplicationName(v string) *AddApplicationReferenceDataSourceInput {
s.ApplicationName = &v
return s
}
// SetCurrentApplicationVersionId sets the CurrentApplicationVersionId field's value.
func (s *AddApplicationReferenceDataSourceInput) SetCurrentApplicationVersionId(v int64) *AddApplicationReferenceDataSourceInput {
s.CurrentApplicationVersionId = &v
return s
}
// SetReferenceDataSource sets the ReferenceDataSource field's value.
func (s *AddApplicationReferenceDataSourceInput) SetReferenceDataSource(v *ReferenceDataSource) *AddApplicationReferenceDataSourceInput {
s.ReferenceDataSource = v
return s
}
type AddApplicationReferenceDataSourceOutput struct {
_ struct{} `type:"structure"`
// The application Amazon Resource Name (ARN).
ApplicationARN *string `min:"1" type:"string"`
// The updated application version ID. Amazon Kinesis Data Analytics increments
// this ID when the application is updated.
ApplicationVersionId *int64 `min:"1" type:"long"`
// Describes reference data sources configured for the application.
ReferenceDataSourceDescriptions []*ReferenceDataSourceDescription `type:"list"`
}
// String returns the string representation
func (s AddApplicationReferenceDataSourceOutput) String() string {
return awsutil.Prettify(s)
}
// GoString returns the string representation
func (s AddApplicationReferenceDataSourceOutput) GoString() string {
return s.String()
}
// SetApplicationARN sets the ApplicationARN field's value.
func (s *AddApplicationReferenceDataSourceOutput) SetApplicationARN(v string) *AddApplicationReferenceDataSourceOutput {
s.ApplicationARN = &v
return s
}
// SetApplicationVersionId sets the ApplicationVersionId field's value.
func (s *AddApplicationReferenceDataSourceOutput) SetApplicationVersionId(v int64) *AddApplicationReferenceDataSourceOutput {
s.ApplicationVersionId = &v
return s
}
// SetReferenceDataSourceDescriptions sets the ReferenceDataSourceDescriptions field's value.
func (s *AddApplicationReferenceDataSourceOutput) SetReferenceDataSourceDescriptions(v []*ReferenceDataSourceDescription) *AddApplicationReferenceDataSourceOutput {
s.ReferenceDataSourceDescriptions = v
return s
}
// Describes code configuration for a Java-based Kinesis Data Analytics application.
type ApplicationCodeConfiguration struct {
_ struct{} `type:"structure"`
// The location and type of the application code.
CodeContent *CodeContent `type:"structure"`
// Specifies whether the code content is in text or zip format.
//
// CodeContentType is a required field
CodeContentType *string `type:"string" required:"true" enum:"CodeContentType"`
}
// String returns the string representation
func (s ApplicationCodeConfiguration) String() string {
return awsutil.Prettify(s)
}
// GoString returns the string representation
func (s ApplicationCodeConfiguration) GoString() string {
return s.String()
}
// Validate inspects the fields of the type to determine if they are valid.
func (s *ApplicationCodeConfiguration) Validate() error {
invalidParams := request.ErrInvalidParams{Context: "ApplicationCodeConfiguration"}
if s.CodeContentType == nil {
invalidParams.Add(request.NewErrParamRequired("CodeContentType"))
}
if s.CodeContent != nil {
if err := s.CodeContent.Validate(); err != nil {
invalidParams.AddNested("CodeContent", err.(request.ErrInvalidParams))
}
}
if invalidParams.Len() > 0 {
return invalidParams
}
return nil
}
// SetCodeContent sets the CodeContent field's value.
func (s *ApplicationCodeConfiguration) SetCodeContent(v *CodeContent) *ApplicationCodeConfiguration {
s.CodeContent = v
return s
}
// SetCodeContentType sets the CodeContentType field's value.
func (s *ApplicationCodeConfiguration) SetCodeContentType(v string) *ApplicationCodeConfiguration {
s.CodeContentType = &v
return s
}
// Describes code configuration for a Java-based Kinesis Data Analytics application.
type ApplicationCodeConfigurationDescription struct {
_ struct{} `type:"structure"`
// Describes details about the location and format of the application code.
CodeContentDescription *CodeContentDescription `type:"structure"`
// Specifies whether the code content is in text or zip format.
//
// CodeContentType is a required field
CodeContentType *string `type:"string" required:"true" enum:"CodeContentType"`
}
// String returns the string representation
func (s ApplicationCodeConfigurationDescription) String() string {
return awsutil.Prettify(s)
}
// GoString returns the string representation
func (s ApplicationCodeConfigurationDescription) GoString() string {
return s.String()
}
// SetCodeContentDescription sets the CodeContentDescription field's value.
func (s *ApplicationCodeConfigurationDescription) SetCodeContentDescription(v *CodeContentDescription) *ApplicationCodeConfigurationDescription {
s.CodeContentDescription = v
return s
}
// SetCodeContentType sets the CodeContentType field's value.
func (s *ApplicationCodeConfigurationDescription) SetCodeContentType(v string) *ApplicationCodeConfigurationDescription {
s.CodeContentType = &v
return s
}
// Describes updates to a Java-based Amazon Kinesis Data Analytics application.
type ApplicationCodeConfigurationUpdate struct {
_ struct{} `type:"structure"`
// Describes updates to the code content type.
CodeContentTypeUpdate *string `type:"string" enum:"CodeContentType"`
// Describes updates to the code content of an application.
CodeContentUpdate *CodeContentUpdate `type:"structure"`
}
// String returns the string representation
func (s ApplicationCodeConfigurationUpdate) String() string {
return awsutil.Prettify(s)
}
// GoString returns the string representation
func (s ApplicationCodeConfigurationUpdate) GoString() string {
return s.String()
}
// Validate inspects the fields of the type to determine if they are valid.
func (s *ApplicationCodeConfigurationUpdate) Validate() error {
invalidParams := request.ErrInvalidParams{Context: "ApplicationCodeConfigurationUpdate"}
if s.CodeContentUpdate != nil {
if err := s.CodeContentUpdate.Validate(); err != nil {
invalidParams.AddNested("CodeContentUpdate", err.(request.ErrInvalidParams))
}
}
if invalidParams.Len() > 0 {
return invalidParams
}
return nil
}
// SetCodeContentTypeUpdate sets the CodeContentTypeUpdate field's value.
func (s *ApplicationCodeConfigurationUpdate) SetCodeContentTypeUpdate(v string) *ApplicationCodeConfigurationUpdate {
s.CodeContentTypeUpdate = &v
return s
}
// SetCodeContentUpdate sets the CodeContentUpdate field's value.
func (s *ApplicationCodeConfigurationUpdate) SetCodeContentUpdate(v *CodeContentUpdate) *ApplicationCodeConfigurationUpdate {
s.CodeContentUpdate = v
return s
}
// Specifies the creation parameters for an Amazon Kinesis Data Analytics application.
type ApplicationConfiguration struct {
_ struct{} `type:"structure"`
// The code location and type parameters for a Java-based Kinesis Data Analytics
// application.
//
// ApplicationCodeConfiguration is a required field
ApplicationCodeConfiguration *ApplicationCodeConfiguration `type:"structure" required:"true"`
// Describes whether snapshots are enabled for a Java-based Kinesis Data Analytics
// application.
ApplicationSnapshotConfiguration *ApplicationSnapshotConfiguration `type:"structure"`
// Describes execution properties for a Java-based Kinesis Data Analytics application.
EnvironmentProperties *EnvironmentProperties `type:"structure"`
// The creation and update parameters for a Java-based Kinesis Data Analytics
// application.
FlinkApplicationConfiguration *FlinkApplicationConfiguration `type:"structure"`
// The creation and update parameters for an SQL-based Kinesis Data Analytics
// application.
SqlApplicationConfiguration *SqlApplicationConfiguration `type:"structure"`
}
// String returns the string representation
func (s ApplicationConfiguration) String() string {
return awsutil.Prettify(s)
}
// GoString returns the string representation
func (s ApplicationConfiguration) GoString() string {
return s.String()
}
// Validate inspects the fields of the type to determine if they are valid.
func (s *ApplicationConfiguration) Validate() error {
invalidParams := request.ErrInvalidParams{Context: "ApplicationConfiguration"}
if s.ApplicationCodeConfiguration == nil {
invalidParams.Add(request.NewErrParamRequired("ApplicationCodeConfiguration"))
}
if s.ApplicationCodeConfiguration != nil {
if err := s.ApplicationCodeConfiguration.Validate(); err != nil {
invalidParams.AddNested("ApplicationCodeConfiguration", err.(request.ErrInvalidParams))
}
}
if s.ApplicationSnapshotConfiguration != nil {
if err := s.ApplicationSnapshotConfiguration.Validate(); err != nil {
invalidParams.AddNested("ApplicationSnapshotConfiguration", err.(request.ErrInvalidParams))
}
}
if s.EnvironmentProperties != nil {
if err := s.EnvironmentProperties.Validate(); err != nil {
invalidParams.AddNested("EnvironmentProperties", err.(request.ErrInvalidParams))
}
}
if s.FlinkApplicationConfiguration != nil {
if err := s.FlinkApplicationConfiguration.Validate(); err != nil {
invalidParams.AddNested("FlinkApplicationConfiguration", err.(request.ErrInvalidParams))
}
}
if s.SqlApplicationConfiguration != nil {
if err := s.SqlApplicationConfiguration.Validate(); err != nil {
invalidParams.AddNested("SqlApplicationConfiguration", err.(request.ErrInvalidParams))
}
}
if invalidParams.Len() > 0 {
return invalidParams
}
return nil
}
// SetApplicationCodeConfiguration sets the ApplicationCodeConfiguration field's value.
func (s *ApplicationConfiguration) SetApplicationCodeConfiguration(v *ApplicationCodeConfiguration) *ApplicationConfiguration {
s.ApplicationCodeConfiguration = v
return s
}
// SetApplicationSnapshotConfiguration sets the ApplicationSnapshotConfiguration field's value.
func (s *ApplicationConfiguration) SetApplicationSnapshotConfiguration(v *ApplicationSnapshotConfiguration) *ApplicationConfiguration {
s.ApplicationSnapshotConfiguration = v
return s
}
// SetEnvironmentProperties sets the EnvironmentProperties field's value.
func (s *ApplicationConfiguration) SetEnvironmentProperties(v *EnvironmentProperties) *ApplicationConfiguration {
s.EnvironmentProperties = v
return s
}
// SetFlinkApplicationConfiguration sets the FlinkApplicationConfiguration field's value.
func (s *ApplicationConfiguration) SetFlinkApplicationConfiguration(v *FlinkApplicationConfiguration) *ApplicationConfiguration {
s.FlinkApplicationConfiguration = v
return s
}
// SetSqlApplicationConfiguration sets the SqlApplicationConfiguration field's value.
func (s *ApplicationConfiguration) SetSqlApplicationConfiguration(v *SqlApplicationConfiguration) *ApplicationConfiguration {
s.SqlApplicationConfiguration = v
return s
}
// Describes details about the application code and starting parameters for
// an Amazon Kinesis Data Analytics application.
type ApplicationConfigurationDescription struct {
_ struct{} `type:"structure"`
// The details about the application code for a Java-based Kinesis Data Analytics
// application.
ApplicationCodeConfigurationDescription *ApplicationCodeConfigurationDescription `type:"structure"`
// Describes whether snapshots are enabled for a Java-based Kinesis Data Analytics
// application.
ApplicationSnapshotConfigurationDescription *ApplicationSnapshotConfigurationDescription `type:"structure"`
// Describes execution properties for a Java-based Kinesis Data Analytics application.
EnvironmentPropertyDescriptions *EnvironmentPropertyDescriptions `type:"structure"`
// The details about a Java-based Kinesis Data Analytics application.
FlinkApplicationConfigurationDescription *FlinkApplicationConfigurationDescription `type:"structure"`
// The details about the starting properties for a Kinesis Data Analytics application.
RunConfigurationDescription *RunConfigurationDescription `type:"structure"`
// The details about inputs, outputs, and reference data sources for an SQL-based
// Kinesis Data Analytics application.
SqlApplicationConfigurationDescription *SqlApplicationConfigurationDescription `type:"structure"`
}
// String returns the string representation
func (s ApplicationConfigurationDescription) String() string {
return awsutil.Prettify(s)
}
// GoString returns the string representation
func (s ApplicationConfigurationDescription) GoString() string {
return s.String()
}
// SetApplicationCodeConfigurationDescription sets the ApplicationCodeConfigurationDescription field's value.
func (s *ApplicationConfigurationDescription) SetApplicationCodeConfigurationDescription(v *ApplicationCodeConfigurationDescription) *ApplicationConfigurationDescription {
s.ApplicationCodeConfigurationDescription = v
return s
}
// SetApplicationSnapshotConfigurationDescription sets the ApplicationSnapshotConfigurationDescription field's value.
func (s *ApplicationConfigurationDescription) SetApplicationSnapshotConfigurationDescription(v *ApplicationSnapshotConfigurationDescription) *ApplicationConfigurationDescription {
s.ApplicationSnapshotConfigurationDescription = v
return s
}
// SetEnvironmentPropertyDescriptions sets the EnvironmentPropertyDescriptions field's value.
func (s *ApplicationConfigurationDescription) SetEnvironmentPropertyDescriptions(v *EnvironmentPropertyDescriptions) *ApplicationConfigurationDescription {
s.EnvironmentPropertyDescriptions = v
return s
}
// SetFlinkApplicationConfigurationDescription sets the FlinkApplicationConfigurationDescription field's value.
func (s *ApplicationConfigurationDescription) SetFlinkApplicationConfigurationDescription(v *FlinkApplicationConfigurationDescription) *ApplicationConfigurationDescription {
s.FlinkApplicationConfigurationDescription = v
return s
}
// SetRunConfigurationDescription sets the RunConfigurationDescription field's value.
func (s *ApplicationConfigurationDescription) SetRunConfigurationDescription(v *RunConfigurationDescription) *ApplicationConfigurationDescription {
s.RunConfigurationDescription = v
return s
}
// SetSqlApplicationConfigurationDescription sets the SqlApplicationConfigurationDescription field's value.
func (s *ApplicationConfigurationDescription) SetSqlApplicationConfigurationDescription(v *SqlApplicationConfigurationDescription) *ApplicationConfigurationDescription {
s.SqlApplicationConfigurationDescription = v
return s
}
// Describes updates to an application's configuration.
type ApplicationConfigurationUpdate struct {
_ struct{} `type:"structure"`
// Describes updates to a Java-based Kinesis Data Analytics application's code
// configuration.
ApplicationCodeConfigurationUpdate *ApplicationCodeConfigurationUpdate `type:"structure"`
// Describes whether snapshots are enabled for a Java-based Kinesis Data Analytics
// application.
ApplicationSnapshotConfigurationUpdate *ApplicationSnapshotConfigurationUpdate `type:"structure"`
// Describes updates to the environment properties for a Java-based Kinesis
// Data Analytics application.
EnvironmentPropertyUpdates *EnvironmentPropertyUpdates `type:"structure"`
// Describes updates to a Java-based Kinesis Data Analytics application's configuration.
FlinkApplicationConfigurationUpdate *FlinkApplicationConfigurationUpdate `type:"structure"`
// Describes updates to an SQL-based Kinesis Data Analytics application's configuration.
SqlApplicationConfigurationUpdate *SqlApplicationConfigurationUpdate `type:"structure"`
}
// String returns the string representation
func (s ApplicationConfigurationUpdate) String() string {
return awsutil.Prettify(s)
}
// GoString returns the string representation
func (s ApplicationConfigurationUpdate) GoString() string {
return s.String()
}
// Validate inspects the fields of the type to determine if they are valid.
func (s *ApplicationConfigurationUpdate) Validate() error {
invalidParams := request.ErrInvalidParams{Context: "ApplicationConfigurationUpdate"}
if s.ApplicationCodeConfigurationUpdate != nil {
if err := s.ApplicationCodeConfigurationUpdate.Validate(); err != nil {
invalidParams.AddNested("ApplicationCodeConfigurationUpdate", err.(request.ErrInvalidParams))
}
}
if s.ApplicationSnapshotConfigurationUpdate != nil {
if err := s.ApplicationSnapshotConfigurationUpdate.Validate(); err != nil {
invalidParams.AddNested("ApplicationSnapshotConfigurationUpdate", err.(request.ErrInvalidParams))
}
}
if s.EnvironmentPropertyUpdates != nil {
if err := s.EnvironmentPropertyUpdates.Validate(); err != nil {
invalidParams.AddNested("EnvironmentPropertyUpdates", err.(request.ErrInvalidParams))
}
}
if s.FlinkApplicationConfigurationUpdate != nil {
if err := s.FlinkApplicationConfigurationUpdate.Validate(); err != nil {
invalidParams.AddNested("FlinkApplicationConfigurationUpdate", err.(request.ErrInvalidParams))
}
}
if s.SqlApplicationConfigurationUpdate != nil {
if err := s.SqlApplicationConfigurationUpdate.Validate(); err != nil {
invalidParams.AddNested("SqlApplicationConfigurationUpdate", err.(request.ErrInvalidParams))
}
}
if invalidParams.Len() > 0 {
return invalidParams
}
return nil
}
// SetApplicationCodeConfigurationUpdate sets the ApplicationCodeConfigurationUpdate field's value.
func (s *ApplicationConfigurationUpdate) SetApplicationCodeConfigurationUpdate(v *ApplicationCodeConfigurationUpdate) *ApplicationConfigurationUpdate {
s.ApplicationCodeConfigurationUpdate = v
return s
}
// SetApplicationSnapshotConfigurationUpdate sets the ApplicationSnapshotConfigurationUpdate field's value.
func (s *ApplicationConfigurationUpdate) SetApplicationSnapshotConfigurationUpdate(v *ApplicationSnapshotConfigurationUpdate) *ApplicationConfigurationUpdate {
s.ApplicationSnapshotConfigurationUpdate = v
return s
}
// SetEnvironmentPropertyUpdates sets the EnvironmentPropertyUpdates field's value.
func (s *ApplicationConfigurationUpdate) SetEnvironmentPropertyUpdates(v *EnvironmentPropertyUpdates) *ApplicationConfigurationUpdate {
s.EnvironmentPropertyUpdates = v
return s
}
// SetFlinkApplicationConfigurationUpdate sets the FlinkApplicationConfigurationUpdate field's value.
func (s *ApplicationConfigurationUpdate) SetFlinkApplicationConfigurationUpdate(v *FlinkApplicationConfigurationUpdate) *ApplicationConfigurationUpdate {
s.FlinkApplicationConfigurationUpdate = v
return s
}
// SetSqlApplicationConfigurationUpdate sets the SqlApplicationConfigurationUpdate field's value.
func (s *ApplicationConfigurationUpdate) SetSqlApplicationConfigurationUpdate(v *SqlApplicationConfigurationUpdate) *ApplicationConfigurationUpdate {
s.SqlApplicationConfigurationUpdate = v
return s
}
// Describes the application, including the application Amazon Resource Name
// (ARN), status, latest version, and input and output configurations.
type ApplicationDetail struct {
_ struct{} `type:"structure"`
// The ARN of the application.
//
// ApplicationARN is a required field
ApplicationARN *string `min:"1" type:"string" required:"true"`
// Provides details about the application's SQL or Java code and starting parameters.
ApplicationConfigurationDescription *ApplicationConfigurationDescription `type:"structure"`
// The description of the application.
ApplicationDescription *string `type:"string"`
// The name of the application.
//
// ApplicationName is a required field
ApplicationName *string `min:"1" type:"string" required:"true"`
// The status of the application.
//
// ApplicationStatus is a required field
ApplicationStatus *string `type:"string" required:"true" enum:"ApplicationStatus"`
// Provides the current application version. Kinesis Data Analytics updates
// the ApplicationVersionId each time you update the application.
//
// ApplicationVersionId is a required field
ApplicationVersionId *int64 `min:"1" type:"long" required:"true"`
// Describes the application Amazon CloudWatch logging options.
CloudWatchLoggingOptionDescriptions []*CloudWatchLoggingOptionDescription `type:"list"`
// The current timestamp when the application was created.
CreateTimestamp *time.Time `type:"timestamp"`
// The current timestamp when the application was last updated.
LastUpdateTimestamp *time.Time `type:"timestamp"`
// The runtime environment for the application (SQL-1.0 or FLINK-1_6).
//
// RuntimeEnvironment is a required field
RuntimeEnvironment *string `type:"string" required:"true" enum:"RuntimeEnvironment"`
// Specifies the IAM role that the application uses to access external resources.
ServiceExecutionRole *string `min:"1" type:"string"`
}
// String returns the string representation
func (s ApplicationDetail) String() string {
return awsutil.Prettify(s)
}
// GoString returns the string representation
func (s ApplicationDetail) GoString() string {
return s.String()
}
// SetApplicationARN sets the ApplicationARN field's value.
func (s *ApplicationDetail) SetApplicationARN(v string) *ApplicationDetail {
s.ApplicationARN = &v
return s
}
// SetApplicationConfigurationDescription sets the ApplicationConfigurationDescription field's value.
func (s *ApplicationDetail) SetApplicationConfigurationDescription(v *ApplicationConfigurationDescription) *ApplicationDetail {
s.ApplicationConfigurationDescription = v
return s
}
// SetApplicationDescription sets the ApplicationDescription field's value.
func (s *ApplicationDetail) SetApplicationDescription(v string) *ApplicationDetail {
s.ApplicationDescription = &v
return s
}
// SetApplicationName sets the ApplicationName field's value.
func (s *ApplicationDetail) SetApplicationName(v string) *ApplicationDetail {
s.ApplicationName = &v
return s
}
// SetApplicationStatus sets the ApplicationStatus field's value.
func (s *ApplicationDetail) SetApplicationStatus(v string) *ApplicationDetail {
s.ApplicationStatus = &v
return s
}
// SetApplicationVersionId sets the ApplicationVersionId field's value.
func (s *ApplicationDetail) SetApplicationVersionId(v int64) *ApplicationDetail {
s.ApplicationVersionId = &v
return s
}
// SetCloudWatchLoggingOptionDescriptions sets the CloudWatchLoggingOptionDescriptions field's value.
func (s *ApplicationDetail) SetCloudWatchLoggingOptionDescriptions(v []*CloudWatchLoggingOptionDescription) *ApplicationDetail {
s.CloudWatchLoggingOptionDescriptions = v
return s
}
// SetCreateTimestamp sets the CreateTimestamp field's value.
func (s *ApplicationDetail) SetCreateTimestamp(v time.Time) *ApplicationDetail {
s.CreateTimestamp = &v
return s
}
// SetLastUpdateTimestamp sets the LastUpdateTimestamp field's value.
func (s *ApplicationDetail) SetLastUpdateTimestamp(v time.Time) *ApplicationDetail {
s.LastUpdateTimestamp = &v
return s
}
// SetRuntimeEnvironment sets the RuntimeEnvironment field's value.
func (s *ApplicationDetail) SetRuntimeEnvironment(v string) *ApplicationDetail {
s.RuntimeEnvironment = &v
return s
}
// SetServiceExecutionRole sets the ServiceExecutionRole field's value.
func (s *ApplicationDetail) SetServiceExecutionRole(v string) *ApplicationDetail {
s.ServiceExecutionRole = &v
return s
}
// Specifies the method and snapshot to use when restarting an application using
// previously saved application state.
type ApplicationRestoreConfiguration struct {
_ struct{} `type:"structure"`
// Specifies how the application should be restored.
//
// ApplicationRestoreType is a required field
ApplicationRestoreType *string `type:"string" required:"true" enum:"ApplicationRestoreType"`
// The identifier of an existing snapshot of application state to use to restart
// an application. The application uses this value if RESTORE_FROM_CUSTOM_SNAPSHOT
// is specified for the ApplicationRestoreType.
SnapshotName *string `min:"1" type:"string"`
}
// String returns the string representation
func (s ApplicationRestoreConfiguration) String() string {
return awsutil.Prettify(s)
}