kinesisanalyticsv2

package

Go to main page

Versions in this module

v0

v0.24.0

Jul 22, 2020

v0.23.0

May 28, 2020

v0.22.0

Apr 27, 2020

v0.21.0

Apr 22, 2020

v0.20.0

Mar 17, 2020

v0.19.0

Jan 30, 2020

Changes in this version

type RuntimeEnvironment

+ const RuntimeEnvironmentFlink18

v0.18.0

Dec 12, 2019

Changes in this version

+ type AddApplicationVpcConfigurationInput struct

+ ApplicationName *string

+ CurrentApplicationVersionId *int64

+ VpcConfiguration *VpcConfiguration

+ func (s *AddApplicationVpcConfigurationInput) Validate() error

+ func (s AddApplicationVpcConfigurationInput) String() string

+ type AddApplicationVpcConfigurationOutput struct

+ ApplicationARN *string

+ ApplicationVersionId *int64

+ VpcConfigurationDescription *VpcConfigurationDescription

+ func (s AddApplicationVpcConfigurationOutput) String() string

+ type AddApplicationVpcConfigurationRequest struct

+ Copy func(*AddApplicationVpcConfigurationInput) AddApplicationVpcConfigurationRequest

+ Input *AddApplicationVpcConfigurationInput

+ func (r AddApplicationVpcConfigurationRequest) Send(ctx context.Context) (*AddApplicationVpcConfigurationResponse, error)

+ type AddApplicationVpcConfigurationResponse struct

+ func (r *AddApplicationVpcConfigurationResponse) SDKResponseMetdata() *aws.Response

type ApplicationConfiguration

+ VpcConfigurations []VpcConfiguration

type ApplicationConfigurationDescription

+ VpcConfigurationDescriptions []VpcConfigurationDescription

type ApplicationConfigurationUpdate

+ VpcConfigurationUpdates []VpcConfigurationUpdate

type CheckpointConfigurationUpdate

+ func (s *CheckpointConfigurationUpdate) Validate() error

type Client

+ func (c *Client) AddApplicationVpcConfigurationRequest(input *AddApplicationVpcConfigurationInput) AddApplicationVpcConfigurationRequest

+ func (c *Client) DeleteApplicationVpcConfigurationRequest(input *DeleteApplicationVpcConfigurationInput) DeleteApplicationVpcConfigurationRequest

+ type DeleteApplicationVpcConfigurationInput struct

+ ApplicationName *string

+ CurrentApplicationVersionId *int64

+ VpcConfigurationId *string

+ func (s *DeleteApplicationVpcConfigurationInput) Validate() error

+ func (s DeleteApplicationVpcConfigurationInput) String() string

+ type DeleteApplicationVpcConfigurationOutput struct

+ ApplicationARN *string

+ ApplicationVersionId *int64

+ func (s DeleteApplicationVpcConfigurationOutput) String() string

+ type DeleteApplicationVpcConfigurationRequest struct

+ Copy func(*DeleteApplicationVpcConfigurationInput) DeleteApplicationVpcConfigurationRequest

+ Input *DeleteApplicationVpcConfigurationInput

+ func (r DeleteApplicationVpcConfigurationRequest) Send(ctx context.Context) (*DeleteApplicationVpcConfigurationResponse, error)

+ type DeleteApplicationVpcConfigurationResponse struct

+ func (r *DeleteApplicationVpcConfigurationResponse) SDKResponseMetdata() *aws.Response

+ type FlinkRunConfiguration struct

+ AllowNonRestoredState *bool

+ func (s FlinkRunConfiguration) String() string

type RunConfiguration

+ FlinkRunConfiguration *FlinkRunConfiguration

type RunConfigurationUpdate

+ FlinkRunConfiguration *FlinkRunConfiguration

+ type VpcConfiguration struct

+ SecurityGroupIds []string

+ SubnetIds []string

+ func (s *VpcConfiguration) Validate() error

+ func (s VpcConfiguration) String() string

+ type VpcConfigurationDescription struct

+ SecurityGroupIds []string

+ SubnetIds []string

+ VpcConfigurationId *string

+ VpcId *string

+ func (s VpcConfigurationDescription) String() string

+ type VpcConfigurationUpdate struct

+ SecurityGroupIdUpdates []string

+ SubnetIdUpdates []string

+ VpcConfigurationId *string

+ func (s *VpcConfigurationUpdate) Validate() error

+ func (s VpcConfigurationUpdate) String() string

v0.17.0

Nov 21, 2019

v0.16.0

Nov 13, 2019

v0.15.0

Oct 18, 2019

v0.14.0

Oct 8, 2019

v0.13.0

Oct 2, 2019

v0.12.0

Sep 17, 2019

v0.11.0

Aug 23, 2019

v0.10.0

Jul 25, 2019

v0.9.0

May 28, 2019

Changes in this version

+ const ErrCodeTooManyTagsException

+ const ServiceID

+ type AddApplicationCloudWatchLoggingOptionResponse struct

+ func (r *AddApplicationCloudWatchLoggingOptionResponse) SDKResponseMetdata() *aws.Response

+ type AddApplicationInputProcessingConfigurationResponse struct

+ func (r *AddApplicationInputProcessingConfigurationResponse) SDKResponseMetdata() *aws.Response

+ type AddApplicationInputResponse struct

+ func (r *AddApplicationInputResponse) SDKResponseMetdata() *aws.Response

+ type AddApplicationOutputResponse struct

+ func (r *AddApplicationOutputResponse) SDKResponseMetdata() *aws.Response

+ type AddApplicationReferenceDataSourceResponse struct

+ func (r *AddApplicationReferenceDataSourceResponse) SDKResponseMetdata() *aws.Response

+ type Client struct

+ func (c *Client) AddApplicationCloudWatchLoggingOptionRequest(input *AddApplicationCloudWatchLoggingOptionInput) AddApplicationCloudWatchLoggingOptionRequest

+ func (c *Client) AddApplicationInputProcessingConfigurationRequest(input *AddApplicationInputProcessingConfigurationInput) AddApplicationInputProcessingConfigurationRequest

+ func (c *Client) AddApplicationInputRequest(input *AddApplicationInputInput) AddApplicationInputRequest

+ func (c *Client) AddApplicationOutputRequest(input *AddApplicationOutputInput) AddApplicationOutputRequest

+ func (c *Client) AddApplicationReferenceDataSourceRequest(input *AddApplicationReferenceDataSourceInput) AddApplicationReferenceDataSourceRequest

+ func (c *Client) CreateApplicationRequest(input *CreateApplicationInput) CreateApplicationRequest

+ func (c *Client) CreateApplicationSnapshotRequest(input *CreateApplicationSnapshotInput) CreateApplicationSnapshotRequest

+ func (c *Client) DeleteApplicationCloudWatchLoggingOptionRequest(input *DeleteApplicationCloudWatchLoggingOptionInput) DeleteApplicationCloudWatchLoggingOptionRequest

+ func (c *Client) DeleteApplicationInputProcessingConfigurationRequest(input *DeleteApplicationInputProcessingConfigurationInput) DeleteApplicationInputProcessingConfigurationRequest

+ func (c *Client) DeleteApplicationOutputRequest(input *DeleteApplicationOutputInput) DeleteApplicationOutputRequest

+ func (c *Client) DeleteApplicationReferenceDataSourceRequest(input *DeleteApplicationReferenceDataSourceInput) DeleteApplicationReferenceDataSourceRequest

+ func (c *Client) DeleteApplicationRequest(input *DeleteApplicationInput) DeleteApplicationRequest

+ func (c *Client) DeleteApplicationSnapshotRequest(input *DeleteApplicationSnapshotInput) DeleteApplicationSnapshotRequest

+ func (c *Client) DescribeApplicationRequest(input *DescribeApplicationInput) DescribeApplicationRequest

+ func (c *Client) DescribeApplicationSnapshotRequest(input *DescribeApplicationSnapshotInput) DescribeApplicationSnapshotRequest

+ func (c *Client) DiscoverInputSchemaRequest(input *DiscoverInputSchemaInput) DiscoverInputSchemaRequest

+ func (c *Client) ListApplicationSnapshotsRequest(input *ListApplicationSnapshotsInput) ListApplicationSnapshotsRequest

+ func (c *Client) ListApplicationsRequest(input *ListApplicationsInput) ListApplicationsRequest

+ func (c *Client) ListTagsForResourceRequest(input *ListTagsForResourceInput) ListTagsForResourceRequest

+ func (c *Client) StartApplicationRequest(input *StartApplicationInput) StartApplicationRequest

+ func (c *Client) StopApplicationRequest(input *StopApplicationInput) StopApplicationRequest

+ func (c *Client) TagResourceRequest(input *TagResourceInput) TagResourceRequest

+ func (c *Client) UntagResourceRequest(input *UntagResourceInput) UntagResourceRequest

+ func (c *Client) UpdateApplicationRequest(input *UpdateApplicationInput) UpdateApplicationRequest

type CreateApplicationInput

+ Tags []Tag

+ type CreateApplicationResponse struct

+ func (r *CreateApplicationResponse) SDKResponseMetdata() *aws.Response

+ type CreateApplicationSnapshotResponse struct

+ func (r *CreateApplicationSnapshotResponse) SDKResponseMetdata() *aws.Response

+ type DeleteApplicationCloudWatchLoggingOptionResponse struct

+ func (r *DeleteApplicationCloudWatchLoggingOptionResponse) SDKResponseMetdata() *aws.Response

+ type DeleteApplicationInputProcessingConfigurationResponse struct

+ func (r *DeleteApplicationInputProcessingConfigurationResponse) SDKResponseMetdata() *aws.Response

+ type DeleteApplicationOutputResponse struct

+ func (r *DeleteApplicationOutputResponse) SDKResponseMetdata() *aws.Response

+ type DeleteApplicationReferenceDataSourceResponse struct

+ func (r *DeleteApplicationReferenceDataSourceResponse) SDKResponseMetdata() *aws.Response

+ type DeleteApplicationResponse struct

+ func (r *DeleteApplicationResponse) SDKResponseMetdata() *aws.Response

+ type DeleteApplicationSnapshotResponse struct

+ func (r *DeleteApplicationSnapshotResponse) SDKResponseMetdata() *aws.Response

+ type DescribeApplicationResponse struct

+ func (r *DescribeApplicationResponse) SDKResponseMetdata() *aws.Response

+ type DescribeApplicationSnapshotResponse struct

+ func (r *DescribeApplicationSnapshotResponse) SDKResponseMetdata() *aws.Response

+ type DiscoverInputSchemaResponse struct

+ func (r *DiscoverInputSchemaResponse) SDKResponseMetdata() *aws.Response

+ type ListApplicationSnapshotsResponse struct

+ func (r *ListApplicationSnapshotsResponse) SDKResponseMetdata() *aws.Response

+ type ListApplicationsResponse struct

+ func (r *ListApplicationsResponse) SDKResponseMetdata() *aws.Response

+ type ListTagsForResourceInput struct

+ ResourceARN *string

+ func (s *ListTagsForResourceInput) Validate() error

+ func (s ListTagsForResourceInput) String() string

+ type ListTagsForResourceOutput struct

+ Tags []Tag

+ func (s ListTagsForResourceOutput) String() string

+ type ListTagsForResourceRequest struct

+ Copy func(*ListTagsForResourceInput) ListTagsForResourceRequest

+ Input *ListTagsForResourceInput

+ func (r ListTagsForResourceRequest) Send(ctx context.Context) (*ListTagsForResourceResponse, error)

+ type ListTagsForResourceResponse struct

+ func (r *ListTagsForResourceResponse) SDKResponseMetdata() *aws.Response

+ type StartApplicationResponse struct

+ func (r *StartApplicationResponse) SDKResponseMetdata() *aws.Response

+ type StopApplicationResponse struct

+ func (r *StopApplicationResponse) SDKResponseMetdata() *aws.Response

+ type Tag struct

+ Key *string

+ Value *string

+ func (s *Tag) Validate() error

+ func (s Tag) String() string

+ type TagResourceInput struct

+ ResourceARN *string

+ Tags []Tag

+ func (s *TagResourceInput) Validate() error

+ func (s TagResourceInput) String() string

+ type TagResourceOutput struct

+ func (s TagResourceOutput) String() string

+ type TagResourceRequest struct

+ Copy func(*TagResourceInput) TagResourceRequest

+ Input *TagResourceInput

+ func (r TagResourceRequest) Send(ctx context.Context) (*TagResourceResponse, error)

+ type TagResourceResponse struct

+ func (r *TagResourceResponse) SDKResponseMetdata() *aws.Response

+ type UntagResourceInput struct

+ ResourceARN *string

+ TagKeys []string

+ func (s *UntagResourceInput) Validate() error

+ func (s UntagResourceInput) String() string

+ type UntagResourceOutput struct

+ func (s UntagResourceOutput) String() string

+ type UntagResourceRequest struct

+ Copy func(*UntagResourceInput) UntagResourceRequest

+ Input *UntagResourceInput

+ func (r UntagResourceRequest) Send(ctx context.Context) (*UntagResourceResponse, error)

+ type UntagResourceResponse struct

+ func (r *UntagResourceResponse) SDKResponseMetdata() *aws.Response

+ type UpdateApplicationResponse struct

+ func (r *UpdateApplicationResponse) SDKResponseMetdata() *aws.Response

v0.8.0

Apr 25, 2019

v0.7.0

Jan 3, 2019

v0.6.0

Dec 3, 2018

Changes in this version

+ const EndpointsID

+ const ErrCodeCodeValidationException

+ const ErrCodeConcurrentModificationException

+ const ErrCodeInvalidApplicationConfigurationException

+ const ErrCodeInvalidArgumentException

+ const ErrCodeInvalidRequestException

+ const ErrCodeLimitExceededException

+ const ErrCodeResourceInUseException

+ const ErrCodeResourceNotFoundException

+ const ErrCodeResourceProvisionedThroughputExceededException

+ const ErrCodeServiceUnavailableException

+ const ErrCodeUnableToDetectSchemaException

+ const ErrCodeUnsupportedOperationException

+ const ServiceName

+ type AddApplicationCloudWatchLoggingOptionInput struct

+ ApplicationName *string

+ CloudWatchLoggingOption *CloudWatchLoggingOption

+ CurrentApplicationVersionId *int64

+ func (s *AddApplicationCloudWatchLoggingOptionInput) Validate() error

+ func (s AddApplicationCloudWatchLoggingOptionInput) GoString() string

+ func (s AddApplicationCloudWatchLoggingOptionInput) String() string

+ type AddApplicationCloudWatchLoggingOptionOutput struct

+ ApplicationARN *string

+ ApplicationVersionId *int64

+ CloudWatchLoggingOptionDescriptions []CloudWatchLoggingOptionDescription

+ func (s AddApplicationCloudWatchLoggingOptionOutput) GoString() string

+ func (s AddApplicationCloudWatchLoggingOptionOutput) SDKResponseMetadata() aws.Response

+ func (s AddApplicationCloudWatchLoggingOptionOutput) String() string

+ type AddApplicationCloudWatchLoggingOptionRequest struct

+ Copy func(*AddApplicationCloudWatchLoggingOptionInput) AddApplicationCloudWatchLoggingOptionRequest

+ Input *AddApplicationCloudWatchLoggingOptionInput

+ func (r AddApplicationCloudWatchLoggingOptionRequest) Send() (*AddApplicationCloudWatchLoggingOptionOutput, error)

+ type AddApplicationInputInput struct

+ ApplicationName *string

+ CurrentApplicationVersionId *int64

+ Input *Input

+ func (s *AddApplicationInputInput) Validate() error

+ func (s AddApplicationInputInput) GoString() string

+ func (s AddApplicationInputInput) String() string

+ type AddApplicationInputOutput struct

+ ApplicationARN *string

+ ApplicationVersionId *int64

+ InputDescriptions []InputDescription

+ func (s AddApplicationInputOutput) GoString() string

+ func (s AddApplicationInputOutput) SDKResponseMetadata() aws.Response

+ func (s AddApplicationInputOutput) String() string

+ type AddApplicationInputProcessingConfigurationInput struct

+ ApplicationName *string

+ CurrentApplicationVersionId *int64

+ InputId *string

+ InputProcessingConfiguration *InputProcessingConfiguration

+ func (s *AddApplicationInputProcessingConfigurationInput) Validate() error

+ func (s AddApplicationInputProcessingConfigurationInput) GoString() string

+ func (s AddApplicationInputProcessingConfigurationInput) String() string

+ type AddApplicationInputProcessingConfigurationOutput struct

+ ApplicationARN *string

+ ApplicationVersionId *int64

+ InputId *string

+ InputProcessingConfigurationDescription *InputProcessingConfigurationDescription

+ func (s AddApplicationInputProcessingConfigurationOutput) GoString() string

+ func (s AddApplicationInputProcessingConfigurationOutput) SDKResponseMetadata() aws.Response

+ func (s AddApplicationInputProcessingConfigurationOutput) String() string

+ type AddApplicationInputProcessingConfigurationRequest struct

+ Copy func(*AddApplicationInputProcessingConfigurationInput) AddApplicationInputProcessingConfigurationRequest

+ Input *AddApplicationInputProcessingConfigurationInput

+ func (r AddApplicationInputProcessingConfigurationRequest) Send() (*AddApplicationInputProcessingConfigurationOutput, error)

+ type AddApplicationInputRequest struct

+ Copy func(*AddApplicationInputInput) AddApplicationInputRequest

+ Input *AddApplicationInputInput

+ func (r AddApplicationInputRequest) Send() (*AddApplicationInputOutput, error)

+ type AddApplicationOutputInput struct

+ ApplicationName *string

+ CurrentApplicationVersionId *int64

+ Output *Output

+ func (s *AddApplicationOutputInput) Validate() error

+ func (s AddApplicationOutputInput) GoString() string

+ func (s AddApplicationOutputInput) String() string

+ type AddApplicationOutputOutput struct

+ ApplicationARN *string

+ ApplicationVersionId *int64

+ OutputDescriptions []OutputDescription

+ func (s AddApplicationOutputOutput) GoString() string

+ func (s AddApplicationOutputOutput) SDKResponseMetadata() aws.Response

+ func (s AddApplicationOutputOutput) String() string

+ type AddApplicationOutputRequest struct

+ Copy func(*AddApplicationOutputInput) AddApplicationOutputRequest

+ Input *AddApplicationOutputInput

+ func (r AddApplicationOutputRequest) Send() (*AddApplicationOutputOutput, error)

+ type AddApplicationReferenceDataSourceInput struct

+ ApplicationName *string

+ CurrentApplicationVersionId *int64

+ ReferenceDataSource *ReferenceDataSource

+ func (s *AddApplicationReferenceDataSourceInput) Validate() error

+ func (s AddApplicationReferenceDataSourceInput) GoString() string

+ func (s AddApplicationReferenceDataSourceInput) String() string

+ type AddApplicationReferenceDataSourceOutput struct

+ ApplicationARN *string

+ ApplicationVersionId *int64

+ ReferenceDataSourceDescriptions []ReferenceDataSourceDescription

+ func (s AddApplicationReferenceDataSourceOutput) GoString() string

+ func (s AddApplicationReferenceDataSourceOutput) SDKResponseMetadata() aws.Response

+ func (s AddApplicationReferenceDataSourceOutput) String() string

+ type AddApplicationReferenceDataSourceRequest struct

+ Copy func(*AddApplicationReferenceDataSourceInput) AddApplicationReferenceDataSourceRequest

+ Input *AddApplicationReferenceDataSourceInput

+ func (r AddApplicationReferenceDataSourceRequest) Send() (*AddApplicationReferenceDataSourceOutput, error)

+ type ApplicationCodeConfiguration struct

+ CodeContent *CodeContent

+ CodeContentType CodeContentType

+ func (s *ApplicationCodeConfiguration) Validate() error

+ func (s ApplicationCodeConfiguration) GoString() string

+ func (s ApplicationCodeConfiguration) String() string

+ type ApplicationCodeConfigurationDescription struct

+ CodeContentDescription *CodeContentDescription

+ CodeContentType CodeContentType

+ func (s ApplicationCodeConfigurationDescription) GoString() string

+ func (s ApplicationCodeConfigurationDescription) String() string

+ type ApplicationCodeConfigurationUpdate struct

+ CodeContentTypeUpdate CodeContentType

+ CodeContentUpdate *CodeContentUpdate

+ func (s *ApplicationCodeConfigurationUpdate) Validate() error

+ func (s ApplicationCodeConfigurationUpdate) GoString() string

+ func (s ApplicationCodeConfigurationUpdate) String() string

+ type ApplicationConfiguration struct

+ ApplicationCodeConfiguration *ApplicationCodeConfiguration

+ ApplicationSnapshotConfiguration *ApplicationSnapshotConfiguration

+ EnvironmentProperties *EnvironmentProperties

+ FlinkApplicationConfiguration *FlinkApplicationConfiguration

+ SqlApplicationConfiguration *SqlApplicationConfiguration

+ func (s *ApplicationConfiguration) Validate() error

+ func (s ApplicationConfiguration) GoString() string

+ func (s ApplicationConfiguration) String() string

+ type ApplicationConfigurationDescription struct

+ ApplicationCodeConfigurationDescription *ApplicationCodeConfigurationDescription

+ ApplicationSnapshotConfigurationDescription *ApplicationSnapshotConfigurationDescription

+ EnvironmentPropertyDescriptions *EnvironmentPropertyDescriptions

+ FlinkApplicationConfigurationDescription *FlinkApplicationConfigurationDescription

+ RunConfigurationDescription *RunConfigurationDescription

+ SqlApplicationConfigurationDescription *SqlApplicationConfigurationDescription

+ func (s ApplicationConfigurationDescription) GoString() string

+ func (s ApplicationConfigurationDescription) String() string

+ type ApplicationConfigurationUpdate struct

+ ApplicationCodeConfigurationUpdate *ApplicationCodeConfigurationUpdate

+ ApplicationSnapshotConfigurationUpdate *ApplicationSnapshotConfigurationUpdate

+ EnvironmentPropertyUpdates *EnvironmentPropertyUpdates

+ FlinkApplicationConfigurationUpdate *FlinkApplicationConfigurationUpdate

+ SqlApplicationConfigurationUpdate *SqlApplicationConfigurationUpdate

+ func (s *ApplicationConfigurationUpdate) Validate() error

+ func (s ApplicationConfigurationUpdate) GoString() string

+ func (s ApplicationConfigurationUpdate) String() string

+ type ApplicationDetail struct

+ ApplicationARN *string

+ ApplicationConfigurationDescription *ApplicationConfigurationDescription

+ ApplicationDescription *string

+ ApplicationName *string

+ ApplicationStatus ApplicationStatus

+ ApplicationVersionId *int64

+ CloudWatchLoggingOptionDescriptions []CloudWatchLoggingOptionDescription

+ CreateTimestamp *time.Time

+ LastUpdateTimestamp *time.Time

+ RuntimeEnvironment RuntimeEnvironment

+ ServiceExecutionRole *string

+ func (s ApplicationDetail) GoString() string

+ func (s ApplicationDetail) String() string

+ type ApplicationRestoreConfiguration struct

+ ApplicationRestoreType ApplicationRestoreType

+ SnapshotName *string

+ func (s *ApplicationRestoreConfiguration) Validate() error

+ func (s ApplicationRestoreConfiguration) GoString() string

+ func (s ApplicationRestoreConfiguration) String() string

+ type ApplicationRestoreType string

+ const ApplicationRestoreTypeRestoreFromCustomSnapshot

+ const ApplicationRestoreTypeRestoreFromLatestSnapshot

+ const ApplicationRestoreTypeSkipRestoreFromSnapshot

+ func (enum ApplicationRestoreType) MarshalValue() (string, error)

+ func (enum ApplicationRestoreType) MarshalValueBuf(b []byte) ([]byte, error)

+ type ApplicationSnapshotConfiguration struct

+ SnapshotsEnabled *bool

+ func (s *ApplicationSnapshotConfiguration) Validate() error

+ func (s ApplicationSnapshotConfiguration) GoString() string

+ func (s ApplicationSnapshotConfiguration) String() string

+ type ApplicationSnapshotConfigurationDescription struct

+ SnapshotsEnabled *bool

+ func (s ApplicationSnapshotConfigurationDescription) GoString() string

+ func (s ApplicationSnapshotConfigurationDescription) String() string

+ type ApplicationSnapshotConfigurationUpdate struct

+ SnapshotsEnabledUpdate *bool

+ func (s *ApplicationSnapshotConfigurationUpdate) Validate() error

+ func (s ApplicationSnapshotConfigurationUpdate) GoString() string

+ func (s ApplicationSnapshotConfigurationUpdate) String() string

+ type ApplicationStatus string

+ const ApplicationStatusDeleting

+ const ApplicationStatusReady

+ const ApplicationStatusRunning

+ const ApplicationStatusStarting

+ const ApplicationStatusStopping

+ const ApplicationStatusUpdating

+ func (enum ApplicationStatus) MarshalValue() (string, error)

+ func (enum ApplicationStatus) MarshalValueBuf(b []byte) ([]byte, error)

+ type ApplicationSummary struct

+ ApplicationARN *string

+ ApplicationName *string

+ ApplicationStatus ApplicationStatus

+ ApplicationVersionId *int64

+ RuntimeEnvironment RuntimeEnvironment

+ func (s ApplicationSummary) GoString() string

+ func (s ApplicationSummary) String() string

+ type CSVMappingParameters struct

+ RecordColumnDelimiter *string

+ RecordRowDelimiter *string

+ func (s *CSVMappingParameters) Validate() error

+ func (s CSVMappingParameters) GoString() string

+ func (s CSVMappingParameters) String() string

+ type CheckpointConfiguration struct

+ CheckpointInterval *int64

+ CheckpointingEnabled *bool

+ ConfigurationType ConfigurationType

+ MinPauseBetweenCheckpoints *int64

+ func (s *CheckpointConfiguration) Validate() error

+ func (s CheckpointConfiguration) GoString() string

+ func (s CheckpointConfiguration) String() string

+ type CheckpointConfigurationDescription struct

+ CheckpointInterval *int64

+ CheckpointingEnabled *bool

+ ConfigurationType ConfigurationType

+ MinPauseBetweenCheckpoints *int64

+ func (s CheckpointConfigurationDescription) GoString() string

+ func (s CheckpointConfigurationDescription) String() string

+ type CheckpointConfigurationUpdate struct

+ CheckpointIntervalUpdate *int64

+ CheckpointingEnabledUpdate *bool

+ ConfigurationTypeUpdate ConfigurationType

+ MinPauseBetweenCheckpointsUpdate *int64

+ func (s CheckpointConfigurationUpdate) GoString() string

+ func (s CheckpointConfigurationUpdate) String() string

+ type CloudWatchLoggingOption struct

+ LogStreamARN *string

+ func (s *CloudWatchLoggingOption) Validate() error

+ func (s CloudWatchLoggingOption) GoString() string

+ func (s CloudWatchLoggingOption) String() string

+ type CloudWatchLoggingOptionDescription struct

+ CloudWatchLoggingOptionId *string

+ LogStreamARN *string

+ RoleARN *string

+ func (s CloudWatchLoggingOptionDescription) GoString() string

+ func (s CloudWatchLoggingOptionDescription) String() string

+ type CloudWatchLoggingOptionUpdate struct

+ CloudWatchLoggingOptionId *string

+ LogStreamARNUpdate *string

+ func (s *CloudWatchLoggingOptionUpdate) Validate() error

+ func (s CloudWatchLoggingOptionUpdate) GoString() string

+ func (s CloudWatchLoggingOptionUpdate) String() string

+ type CodeContent struct

+ S3ContentLocation *S3ContentLocation

+ TextContent *string

+ ZipFileContent []byte

+ func (s *CodeContent) Validate() error

+ func (s CodeContent) GoString() string

+ func (s CodeContent) String() string

+ type CodeContentDescription struct

+ CodeMD5 *string

+ CodeSize *int64

+ S3ApplicationCodeLocationDescription *S3ApplicationCodeLocationDescription

+ TextContent *string

+ func (s CodeContentDescription) GoString() string

+ func (s CodeContentDescription) String() string

+ type CodeContentType string

+ const CodeContentTypePlaintext

+ const CodeContentTypeZipfile

+ func (enum CodeContentType) MarshalValue() (string, error)

+ func (enum CodeContentType) MarshalValueBuf(b []byte) ([]byte, error)

+ type CodeContentUpdate struct

+ S3ContentLocationUpdate *S3ContentLocationUpdate

+ TextContentUpdate *string

+ ZipFileContentUpdate []byte

+ func (s *CodeContentUpdate) Validate() error

+ func (s CodeContentUpdate) GoString() string

+ func (s CodeContentUpdate) String() string

+ type ConfigurationType string

+ const ConfigurationTypeCustom

+ const ConfigurationTypeDefault

+ func (enum ConfigurationType) MarshalValue() (string, error)

+ func (enum ConfigurationType) MarshalValueBuf(b []byte) ([]byte, error)

+ type CreateApplicationInput struct

+ ApplicationConfiguration *ApplicationConfiguration

+ ApplicationDescription *string

+ ApplicationName *string

+ CloudWatchLoggingOptions []CloudWatchLoggingOption

+ RuntimeEnvironment RuntimeEnvironment

+ ServiceExecutionRole *string

+ func (s *CreateApplicationInput) Validate() error

+ func (s CreateApplicationInput) GoString() string

+ func (s CreateApplicationInput) String() string

+ type CreateApplicationOutput struct

+ ApplicationDetail *ApplicationDetail

+ func (s CreateApplicationOutput) GoString() string

+ func (s CreateApplicationOutput) SDKResponseMetadata() aws.Response

+ func (s CreateApplicationOutput) String() string

+ type CreateApplicationRequest struct

+ Copy func(*CreateApplicationInput) CreateApplicationRequest

+ Input *CreateApplicationInput

+ func (r CreateApplicationRequest) Send() (*CreateApplicationOutput, error)

+ type CreateApplicationSnapshotInput struct

+ ApplicationName *string

+ SnapshotName *string

+ func (s *CreateApplicationSnapshotInput) Validate() error

+ func (s CreateApplicationSnapshotInput) GoString() string

+ func (s CreateApplicationSnapshotInput) String() string

+ type CreateApplicationSnapshotOutput struct

+ func (s CreateApplicationSnapshotOutput) GoString() string

+ func (s CreateApplicationSnapshotOutput) SDKResponseMetadata() aws.Response

+ func (s CreateApplicationSnapshotOutput) String() string

+ type CreateApplicationSnapshotRequest struct

+ Copy func(*CreateApplicationSnapshotInput) CreateApplicationSnapshotRequest

+ Input *CreateApplicationSnapshotInput

+ func (r CreateApplicationSnapshotRequest) Send() (*CreateApplicationSnapshotOutput, error)

+ type DeleteApplicationCloudWatchLoggingOptionInput struct

+ ApplicationName *string

+ CloudWatchLoggingOptionId *string

+ CurrentApplicationVersionId *int64

+ func (s *DeleteApplicationCloudWatchLoggingOptionInput) Validate() error

+ func (s DeleteApplicationCloudWatchLoggingOptionInput) GoString() string

+ func (s DeleteApplicationCloudWatchLoggingOptionInput) String() string

+ type DeleteApplicationCloudWatchLoggingOptionOutput struct

+ ApplicationARN *string

+ ApplicationVersionId *int64

+ CloudWatchLoggingOptionDescriptions []CloudWatchLoggingOptionDescription

+ func (s DeleteApplicationCloudWatchLoggingOptionOutput) GoString() string

+ func (s DeleteApplicationCloudWatchLoggingOptionOutput) SDKResponseMetadata() aws.Response

+ func (s DeleteApplicationCloudWatchLoggingOptionOutput) String() string

+ type DeleteApplicationCloudWatchLoggingOptionRequest struct

+ Copy func(*DeleteApplicationCloudWatchLoggingOptionInput) DeleteApplicationCloudWatchLoggingOptionRequest

+ Input *DeleteApplicationCloudWatchLoggingOptionInput

+ func (r DeleteApplicationCloudWatchLoggingOptionRequest) Send() (*DeleteApplicationCloudWatchLoggingOptionOutput, error)

+ type DeleteApplicationInput struct

+ ApplicationName *string

+ CreateTimestamp *time.Time

+ func (s *DeleteApplicationInput) Validate() error

+ func (s DeleteApplicationInput) GoString() string

+ func (s DeleteApplicationInput) String() string

+ type DeleteApplicationInputProcessingConfigurationInput struct

+ ApplicationName *string

+ CurrentApplicationVersionId *int64

+ InputId *string

+ func (s *DeleteApplicationInputProcessingConfigurationInput) Validate() error

+ func (s DeleteApplicationInputProcessingConfigurationInput) GoString() string

+ func (s DeleteApplicationInputProcessingConfigurationInput) String() string

+ type DeleteApplicationInputProcessingConfigurationOutput struct

+ ApplicationARN *string

+ ApplicationVersionId *int64

+ func (s DeleteApplicationInputProcessingConfigurationOutput) GoString() string

+ func (s DeleteApplicationInputProcessingConfigurationOutput) SDKResponseMetadata() aws.Response

+ func (s DeleteApplicationInputProcessingConfigurationOutput) String() string

+ type DeleteApplicationInputProcessingConfigurationRequest struct

+ Copy func(*DeleteApplicationInputProcessingConfigurationInput) DeleteApplicationInputProcessingConfigurationRequest

+ Input *DeleteApplicationInputProcessingConfigurationInput

+ func (r DeleteApplicationInputProcessingConfigurationRequest) Send() (*DeleteApplicationInputProcessingConfigurationOutput, error)

+ type DeleteApplicationOutput struct

+ func (s DeleteApplicationOutput) GoString() string

+ func (s DeleteApplicationOutput) SDKResponseMetadata() aws.Response

+ func (s DeleteApplicationOutput) String() string

+ type DeleteApplicationOutputInput struct

+ ApplicationName *string

+ CurrentApplicationVersionId *int64

+ OutputId *string

+ func (s *DeleteApplicationOutputInput) Validate() error

+ func (s DeleteApplicationOutputInput) GoString() string

+ func (s DeleteApplicationOutputInput) String() string

+ type DeleteApplicationOutputOutput struct

+ ApplicationARN *string

+ ApplicationVersionId *int64

+ func (s DeleteApplicationOutputOutput) GoString() string

+ func (s DeleteApplicationOutputOutput) SDKResponseMetadata() aws.Response

+ func (s DeleteApplicationOutputOutput) String() string

+ type DeleteApplicationOutputRequest struct

+ Copy func(*DeleteApplicationOutputInput) DeleteApplicationOutputRequest

+ Input *DeleteApplicationOutputInput

+ func (r DeleteApplicationOutputRequest) Send() (*DeleteApplicationOutputOutput, error)

+ type DeleteApplicationReferenceDataSourceInput struct

+ ApplicationName *string

+ CurrentApplicationVersionId *int64

+ ReferenceId *string

+ func (s *DeleteApplicationReferenceDataSourceInput) Validate() error

+ func (s DeleteApplicationReferenceDataSourceInput) GoString() string

+ func (s DeleteApplicationReferenceDataSourceInput) String() string

+ type DeleteApplicationReferenceDataSourceOutput struct

+ ApplicationARN *string

+ ApplicationVersionId *int64

+ func (s DeleteApplicationReferenceDataSourceOutput) GoString() string

+ func (s DeleteApplicationReferenceDataSourceOutput) SDKResponseMetadata() aws.Response

+ func (s DeleteApplicationReferenceDataSourceOutput) String() string

+ type DeleteApplicationReferenceDataSourceRequest struct

+ Copy func(*DeleteApplicationReferenceDataSourceInput) DeleteApplicationReferenceDataSourceRequest

+ Input *DeleteApplicationReferenceDataSourceInput

+ func (r DeleteApplicationReferenceDataSourceRequest) Send() (*DeleteApplicationReferenceDataSourceOutput, error)

+ type DeleteApplicationRequest struct

+ Copy func(*DeleteApplicationInput) DeleteApplicationRequest

+ Input *DeleteApplicationInput

+ func (r DeleteApplicationRequest) Send() (*DeleteApplicationOutput, error)

+ type DeleteApplicationSnapshotInput struct

+ ApplicationName *string

+ SnapshotCreationTimestamp *time.Time

+ SnapshotName *string

+ func (s *DeleteApplicationSnapshotInput) Validate() error

+ func (s DeleteApplicationSnapshotInput) GoString() string

+ func (s DeleteApplicationSnapshotInput) String() string

+ type DeleteApplicationSnapshotOutput struct

+ func (s DeleteApplicationSnapshotOutput) GoString() string

+ func (s DeleteApplicationSnapshotOutput) SDKResponseMetadata() aws.Response

+ func (s DeleteApplicationSnapshotOutput) String() string

+ type DeleteApplicationSnapshotRequest struct

+ Copy func(*DeleteApplicationSnapshotInput) DeleteApplicationSnapshotRequest

+ Input *DeleteApplicationSnapshotInput

+ func (r DeleteApplicationSnapshotRequest) Send() (*DeleteApplicationSnapshotOutput, error)

+ type DescribeApplicationInput struct

+ ApplicationName *string

+ IncludeAdditionalDetails *bool

+ func (s *DescribeApplicationInput) Validate() error

+ func (s DescribeApplicationInput) GoString() string

+ func (s DescribeApplicationInput) String() string

+ type DescribeApplicationOutput struct

+ ApplicationDetail *ApplicationDetail

+ func (s DescribeApplicationOutput) GoString() string

+ func (s DescribeApplicationOutput) SDKResponseMetadata() aws.Response

+ func (s DescribeApplicationOutput) String() string

+ type DescribeApplicationRequest struct

+ Copy func(*DescribeApplicationInput) DescribeApplicationRequest

+ Input *DescribeApplicationInput

+ func (r DescribeApplicationRequest) Send() (*DescribeApplicationOutput, error)

+ type DescribeApplicationSnapshotInput struct

+ ApplicationName *string

+ SnapshotName *string

+ func (s *DescribeApplicationSnapshotInput) Validate() error

+ func (s DescribeApplicationSnapshotInput) GoString() string

+ func (s DescribeApplicationSnapshotInput) String() string

+ type DescribeApplicationSnapshotOutput struct

+ SnapshotDetails *SnapshotDetails

+ func (s DescribeApplicationSnapshotOutput) GoString() string

+ func (s DescribeApplicationSnapshotOutput) SDKResponseMetadata() aws.Response

+ func (s DescribeApplicationSnapshotOutput) String() string

+ type DescribeApplicationSnapshotRequest struct

+ Copy func(*DescribeApplicationSnapshotInput) DescribeApplicationSnapshotRequest

+ Input *DescribeApplicationSnapshotInput

+ func (r DescribeApplicationSnapshotRequest) Send() (*DescribeApplicationSnapshotOutput, error)

+ type DestinationSchema struct

+ RecordFormatType RecordFormatType

+ func (s *DestinationSchema) Validate() error

+ func (s DestinationSchema) GoString() string

+ func (s DestinationSchema) String() string

+ type DiscoverInputSchemaInput struct

+ InputProcessingConfiguration *InputProcessingConfiguration

+ InputStartingPositionConfiguration *InputStartingPositionConfiguration

+ ResourceARN *string

+ S3Configuration *S3Configuration

+ ServiceExecutionRole *string

+ func (s *DiscoverInputSchemaInput) Validate() error

+ func (s DiscoverInputSchemaInput) GoString() string

+ func (s DiscoverInputSchemaInput) String() string

+ type DiscoverInputSchemaOutput struct

+ InputSchema *SourceSchema

+ ParsedInputRecords [][]string

+ ProcessedInputRecords []string

+ RawInputRecords []string

+ func (s DiscoverInputSchemaOutput) GoString() string

+ func (s DiscoverInputSchemaOutput) SDKResponseMetadata() aws.Response

+ func (s DiscoverInputSchemaOutput) String() string

+ type DiscoverInputSchemaRequest struct

+ Copy func(*DiscoverInputSchemaInput) DiscoverInputSchemaRequest

+ Input *DiscoverInputSchemaInput

+ func (r DiscoverInputSchemaRequest) Send() (*DiscoverInputSchemaOutput, error)

+ type EnvironmentProperties struct

+ PropertyGroups []PropertyGroup

+ func (s *EnvironmentProperties) Validate() error

+ func (s EnvironmentProperties) GoString() string

+ func (s EnvironmentProperties) String() string

+ type EnvironmentPropertyDescriptions struct

+ PropertyGroupDescriptions []PropertyGroup

+ func (s EnvironmentPropertyDescriptions) GoString() string

+ func (s EnvironmentPropertyDescriptions) String() string

+ type EnvironmentPropertyUpdates struct

+ PropertyGroups []PropertyGroup

+ func (s *EnvironmentPropertyUpdates) Validate() error

+ func (s EnvironmentPropertyUpdates) GoString() string

+ func (s EnvironmentPropertyUpdates) String() string

+ type FlinkApplicationConfiguration struct

+ CheckpointConfiguration *CheckpointConfiguration

+ MonitoringConfiguration *MonitoringConfiguration

+ ParallelismConfiguration *ParallelismConfiguration

+ func (s *FlinkApplicationConfiguration) Validate() error

+ func (s FlinkApplicationConfiguration) GoString() string

+ func (s FlinkApplicationConfiguration) String() string

+ type FlinkApplicationConfigurationDescription struct

+ CheckpointConfigurationDescription *CheckpointConfigurationDescription

+ JobPlanDescription *string

+ MonitoringConfigurationDescription *MonitoringConfigurationDescription

+ ParallelismConfigurationDescription *ParallelismConfigurationDescription

+ func (s FlinkApplicationConfigurationDescription) GoString() string

+ func (s FlinkApplicationConfigurationDescription) String() string

+ type FlinkApplicationConfigurationUpdate struct

+ CheckpointConfigurationUpdate *CheckpointConfigurationUpdate

+ MonitoringConfigurationUpdate *MonitoringConfigurationUpdate

+ ParallelismConfigurationUpdate *ParallelismConfigurationUpdate

+ func (s *FlinkApplicationConfigurationUpdate) Validate() error

+ func (s FlinkApplicationConfigurationUpdate) GoString() string

+ func (s FlinkApplicationConfigurationUpdate) String() string

+ type Input struct

+ InputParallelism *InputParallelism

+ InputProcessingConfiguration *InputProcessingConfiguration

+ InputSchema *SourceSchema

+ KinesisFirehoseInput *KinesisFirehoseInput

+ KinesisStreamsInput *KinesisStreamsInput

+ NamePrefix *string

+ func (s *Input) Validate() error

+ func (s Input) GoString() string

+ func (s Input) String() string

+ type InputDescription struct

+ InAppStreamNames []string

+ InputId *string

+ InputParallelism *InputParallelism

+ InputProcessingConfigurationDescription *InputProcessingConfigurationDescription

+ InputSchema *SourceSchema

+ InputStartingPositionConfiguration *InputStartingPositionConfiguration

+ KinesisFirehoseInputDescription *KinesisFirehoseInputDescription

+ KinesisStreamsInputDescription *KinesisStreamsInputDescription

+ NamePrefix *string

+ func (s InputDescription) GoString() string

+ func (s InputDescription) String() string

+ type InputLambdaProcessor struct

+ ResourceARN *string

+ func (s *InputLambdaProcessor) Validate() error

+ func (s InputLambdaProcessor) GoString() string

+ func (s InputLambdaProcessor) String() string

+ type InputLambdaProcessorDescription struct

+ ResourceARN *string

+ RoleARN *string

+ func (s InputLambdaProcessorDescription) GoString() string

+ func (s InputLambdaProcessorDescription) String() string

+ type InputLambdaProcessorUpdate struct

+ ResourceARNUpdate *string

+ func (s *InputLambdaProcessorUpdate) Validate() error

+ func (s InputLambdaProcessorUpdate) GoString() string

+ func (s InputLambdaProcessorUpdate) String() string

+ type InputParallelism struct

+ Count *int64

+ func (s *InputParallelism) Validate() error

+ func (s InputParallelism) GoString() string

+ func (s InputParallelism) String() string

+ type InputParallelismUpdate struct

+ CountUpdate *int64

+ func (s *InputParallelismUpdate) Validate() error

+ func (s InputParallelismUpdate) GoString() string

+ func (s InputParallelismUpdate) String() string

+ type InputProcessingConfiguration struct

+ InputLambdaProcessor *InputLambdaProcessor

+ func (s *InputProcessingConfiguration) Validate() error

+ func (s InputProcessingConfiguration) GoString() string

+ func (s InputProcessingConfiguration) String() string

+ type InputProcessingConfigurationDescription struct

+ InputLambdaProcessorDescription *InputLambdaProcessorDescription

+ func (s InputProcessingConfigurationDescription) GoString() string

+ func (s InputProcessingConfigurationDescription) String() string

+ type InputProcessingConfigurationUpdate struct

+ InputLambdaProcessorUpdate *InputLambdaProcessorUpdate

+ func (s *InputProcessingConfigurationUpdate) Validate() error

+ func (s InputProcessingConfigurationUpdate) GoString() string

+ func (s InputProcessingConfigurationUpdate) String() string

+ type InputSchemaUpdate struct

+ RecordColumnUpdates []RecordColumn

+ RecordEncodingUpdate *string

+ RecordFormatUpdate *RecordFormat

+ func (s *InputSchemaUpdate) Validate() error

+ func (s InputSchemaUpdate) GoString() string

+ func (s InputSchemaUpdate) String() string

+ type InputStartingPosition string

+ const InputStartingPositionLastStoppedPoint

+ const InputStartingPositionNow

+ const InputStartingPositionTrimHorizon

+ func (enum InputStartingPosition) MarshalValue() (string, error)

+ func (enum InputStartingPosition) MarshalValueBuf(b []byte) ([]byte, error)

+ type InputStartingPositionConfiguration struct

+ InputStartingPosition InputStartingPosition

+ func (s InputStartingPositionConfiguration) GoString() string

+ func (s InputStartingPositionConfiguration) String() string

+ type InputUpdate struct

+ InputId *string

+ InputParallelismUpdate *InputParallelismUpdate

+ InputProcessingConfigurationUpdate *InputProcessingConfigurationUpdate

+ InputSchemaUpdate *InputSchemaUpdate

+ KinesisFirehoseInputUpdate *KinesisFirehoseInputUpdate

+ KinesisStreamsInputUpdate *KinesisStreamsInputUpdate

+ NamePrefixUpdate *string

+ func (s *InputUpdate) Validate() error

+ func (s InputUpdate) GoString() string

+ func (s InputUpdate) String() string

+ type JSONMappingParameters struct

+ RecordRowPath *string

+ func (s *JSONMappingParameters) Validate() error

+ func (s JSONMappingParameters) GoString() string

+ func (s JSONMappingParameters) String() string

+ type KinesisAnalyticsV2 struct

+ func New(config aws.Config) *KinesisAnalyticsV2

+ func (c *KinesisAnalyticsV2) AddApplicationCloudWatchLoggingOptionRequest(input *AddApplicationCloudWatchLoggingOptionInput) AddApplicationCloudWatchLoggingOptionRequest

+ func (c *KinesisAnalyticsV2) AddApplicationInputProcessingConfigurationRequest(input *AddApplicationInputProcessingConfigurationInput) AddApplicationInputProcessingConfigurationRequest

+ func (c *KinesisAnalyticsV2) AddApplicationInputRequest(input *AddApplicationInputInput) AddApplicationInputRequest

+ func (c *KinesisAnalyticsV2) AddApplicationOutputRequest(input *AddApplicationOutputInput) AddApplicationOutputRequest

+ func (c *KinesisAnalyticsV2) AddApplicationReferenceDataSourceRequest(input *AddApplicationReferenceDataSourceInput) AddApplicationReferenceDataSourceRequest

+ func (c *KinesisAnalyticsV2) CreateApplicationRequest(input *CreateApplicationInput) CreateApplicationRequest

+ func (c *KinesisAnalyticsV2) CreateApplicationSnapshotRequest(input *CreateApplicationSnapshotInput) CreateApplicationSnapshotRequest

+ func (c *KinesisAnalyticsV2) DeleteApplicationCloudWatchLoggingOptionRequest(input *DeleteApplicationCloudWatchLoggingOptionInput) DeleteApplicationCloudWatchLoggingOptionRequest

+ func (c *KinesisAnalyticsV2) DeleteApplicationInputProcessingConfigurationRequest(input *DeleteApplicationInputProcessingConfigurationInput) DeleteApplicationInputProcessingConfigurationRequest

+ func (c *KinesisAnalyticsV2) DeleteApplicationOutputRequest(input *DeleteApplicationOutputInput) DeleteApplicationOutputRequest

+ func (c *KinesisAnalyticsV2) DeleteApplicationReferenceDataSourceRequest(input *DeleteApplicationReferenceDataSourceInput) DeleteApplicationReferenceDataSourceRequest

+ func (c *KinesisAnalyticsV2) DeleteApplicationRequest(input *DeleteApplicationInput) DeleteApplicationRequest

+ func (c *KinesisAnalyticsV2) DeleteApplicationSnapshotRequest(input *DeleteApplicationSnapshotInput) DeleteApplicationSnapshotRequest

+ func (c *KinesisAnalyticsV2) DescribeApplicationRequest(input *DescribeApplicationInput) DescribeApplicationRequest

+ func (c *KinesisAnalyticsV2) DescribeApplicationSnapshotRequest(input *DescribeApplicationSnapshotInput) DescribeApplicationSnapshotRequest

+ func (c *KinesisAnalyticsV2) DiscoverInputSchemaRequest(input *DiscoverInputSchemaInput) DiscoverInputSchemaRequest

+ func (c *KinesisAnalyticsV2) ListApplicationSnapshotsRequest(input *ListApplicationSnapshotsInput) ListApplicationSnapshotsRequest

+ func (c *KinesisAnalyticsV2) ListApplicationsRequest(input *ListApplicationsInput) ListApplicationsRequest

+ func (c *KinesisAnalyticsV2) StartApplicationRequest(input *StartApplicationInput) StartApplicationRequest

+ func (c *KinesisAnalyticsV2) StopApplicationRequest(input *StopApplicationInput) StopApplicationRequest

+ func (c *KinesisAnalyticsV2) UpdateApplicationRequest(input *UpdateApplicationInput) UpdateApplicationRequest

+ type KinesisFirehoseInput struct

+ ResourceARN *string

+ func (s *KinesisFirehoseInput) Validate() error

+ func (s KinesisFirehoseInput) GoString() string

+ func (s KinesisFirehoseInput) String() string

+ type KinesisFirehoseInputDescription struct

+ ResourceARN *string

+ RoleARN *string

+ func (s KinesisFirehoseInputDescription) GoString() string

+ func (s KinesisFirehoseInputDescription) String() string

+ type KinesisFirehoseInputUpdate struct

+ ResourceARNUpdate *string

+ func (s *KinesisFirehoseInputUpdate) Validate() error

+ func (s KinesisFirehoseInputUpdate) GoString() string

+ func (s KinesisFirehoseInputUpdate) String() string

+ type KinesisFirehoseOutput struct

+ ResourceARN *string

+ func (s *KinesisFirehoseOutput) Validate() error

+ func (s KinesisFirehoseOutput) GoString() string

+ func (s KinesisFirehoseOutput) String() string

+ type KinesisFirehoseOutputDescription struct

+ ResourceARN *string

+ RoleARN *string

+ func (s KinesisFirehoseOutputDescription) GoString() string

+ func (s KinesisFirehoseOutputDescription) String() string

+ type KinesisFirehoseOutputUpdate struct

+ ResourceARNUpdate *string

+ func (s *KinesisFirehoseOutputUpdate) Validate() error

+ func (s KinesisFirehoseOutputUpdate) GoString() string

+ func (s KinesisFirehoseOutputUpdate) String() string

+ type KinesisStreamsInput struct

+ ResourceARN *string

+ func (s *KinesisStreamsInput) Validate() error

+ func (s KinesisStreamsInput) GoString() string

+ func (s KinesisStreamsInput) String() string

+ type KinesisStreamsInputDescription struct

+ ResourceARN *string

+ RoleARN *string

+ func (s KinesisStreamsInputDescription) GoString() string

+ func (s KinesisStreamsInputDescription) String() string

+ type KinesisStreamsInputUpdate struct

+ ResourceARNUpdate *string

+ func (s *KinesisStreamsInputUpdate) Validate() error

+ func (s KinesisStreamsInputUpdate) GoString() string

+ func (s KinesisStreamsInputUpdate) String() string

+ type KinesisStreamsOutput struct

+ ResourceARN *string

+ func (s *KinesisStreamsOutput) Validate() error

+ func (s KinesisStreamsOutput) GoString() string

+ func (s KinesisStreamsOutput) String() string

+ type KinesisStreamsOutputDescription struct

+ ResourceARN *string

+ RoleARN *string

+ func (s KinesisStreamsOutputDescription) GoString() string

+ func (s KinesisStreamsOutputDescription) String() string

+ type KinesisStreamsOutputUpdate struct

+ ResourceARNUpdate *string

+ func (s *KinesisStreamsOutputUpdate) Validate() error

+ func (s KinesisStreamsOutputUpdate) GoString() string

+ func (s KinesisStreamsOutputUpdate) String() string

+ type LambdaOutput struct

+ ResourceARN *string

+ func (s *LambdaOutput) Validate() error

+ func (s LambdaOutput) GoString() string

+ func (s LambdaOutput) String() string

+ type LambdaOutputDescription struct

+ ResourceARN *string

+ RoleARN *string

+ func (s LambdaOutputDescription) GoString() string

+ func (s LambdaOutputDescription) String() string

+ type LambdaOutputUpdate struct

+ ResourceARNUpdate *string

+ func (s *LambdaOutputUpdate) Validate() error

+ func (s LambdaOutputUpdate) GoString() string

+ func (s LambdaOutputUpdate) String() string

+ type ListApplicationSnapshotsInput struct

+ ApplicationName *string

+ Limit *int64

+ NextToken *string

+ func (s *ListApplicationSnapshotsInput) Validate() error

+ func (s ListApplicationSnapshotsInput) GoString() string

+ func (s ListApplicationSnapshotsInput) String() string

+ type ListApplicationSnapshotsOutput struct

+ NextToken *string

+ SnapshotSummaries []SnapshotDetails

+ func (s ListApplicationSnapshotsOutput) GoString() string

+ func (s ListApplicationSnapshotsOutput) SDKResponseMetadata() aws.Response

+ func (s ListApplicationSnapshotsOutput) String() string

+ type ListApplicationSnapshotsRequest struct

+ Copy func(*ListApplicationSnapshotsInput) ListApplicationSnapshotsRequest

+ Input *ListApplicationSnapshotsInput

+ func (r ListApplicationSnapshotsRequest) Send() (*ListApplicationSnapshotsOutput, error)

+ type ListApplicationsInput struct

+ Limit *int64

+ NextToken *string

+ func (s *ListApplicationsInput) Validate() error

+ func (s ListApplicationsInput) GoString() string

+ func (s ListApplicationsInput) String() string

+ type ListApplicationsOutput struct

+ ApplicationSummaries []ApplicationSummary

+ NextToken *string

+ func (s ListApplicationsOutput) GoString() string

+ func (s ListApplicationsOutput) SDKResponseMetadata() aws.Response

+ func (s ListApplicationsOutput) String() string

+ type ListApplicationsRequest struct

+ Copy func(*ListApplicationsInput) ListApplicationsRequest

+ Input *ListApplicationsInput

+ func (r ListApplicationsRequest) Send() (*ListApplicationsOutput, error)

+ type LogLevel string

+ const LogLevelDebug

+ const LogLevelError

+ const LogLevelInfo

+ const LogLevelWarn

+ func (enum LogLevel) MarshalValue() (string, error)

+ func (enum LogLevel) MarshalValueBuf(b []byte) ([]byte, error)

+ type MappingParameters struct

+ CSVMappingParameters *CSVMappingParameters

+ JSONMappingParameters *JSONMappingParameters

+ func (s *MappingParameters) Validate() error

+ func (s MappingParameters) GoString() string

+ func (s MappingParameters) String() string

+ type MetricsLevel string

+ const MetricsLevelApplication

+ const MetricsLevelOperator

+ const MetricsLevelParallelism

+ const MetricsLevelTask

+ func (enum MetricsLevel) MarshalValue() (string, error)

+ func (enum MetricsLevel) MarshalValueBuf(b []byte) ([]byte, error)

+ type MonitoringConfiguration struct

+ ConfigurationType ConfigurationType

+ LogLevel LogLevel

+ MetricsLevel MetricsLevel

+ func (s *MonitoringConfiguration) Validate() error

+ func (s MonitoringConfiguration) GoString() string

+ func (s MonitoringConfiguration) String() string

+ type MonitoringConfigurationDescription struct

+ ConfigurationType ConfigurationType

+ LogLevel LogLevel

+ MetricsLevel MetricsLevel

+ func (s MonitoringConfigurationDescription) GoString() string

+ func (s MonitoringConfigurationDescription) String() string

+ type MonitoringConfigurationUpdate struct

+ ConfigurationTypeUpdate ConfigurationType

+ LogLevelUpdate LogLevel

+ MetricsLevelUpdate MetricsLevel

+ func (s MonitoringConfigurationUpdate) GoString() string

+ func (s MonitoringConfigurationUpdate) String() string

+ type Output struct

+ DestinationSchema *DestinationSchema

+ KinesisFirehoseOutput *KinesisFirehoseOutput

+ KinesisStreamsOutput *KinesisStreamsOutput

+ LambdaOutput *LambdaOutput

+ Name *string

+ func (s *Output) Validate() error

+ func (s Output) GoString() string

+ func (s Output) String() string

+ type OutputDescription struct

+ DestinationSchema *DestinationSchema

+ KinesisFirehoseOutputDescription *KinesisFirehoseOutputDescription

+ KinesisStreamsOutputDescription *KinesisStreamsOutputDescription

+ LambdaOutputDescription *LambdaOutputDescription

+ Name *string

+ OutputId *string

+ func (s OutputDescription) GoString() string

+ func (s OutputDescription) String() string

+ type OutputUpdate struct

+ DestinationSchemaUpdate *DestinationSchema

+ KinesisFirehoseOutputUpdate *KinesisFirehoseOutputUpdate

+ KinesisStreamsOutputUpdate *KinesisStreamsOutputUpdate

+ LambdaOutputUpdate *LambdaOutputUpdate

+ NameUpdate *string

+ OutputId *string

+ func (s *OutputUpdate) Validate() error

+ func (s OutputUpdate) GoString() string

+ func (s OutputUpdate) String() string

+ type ParallelismConfiguration struct

+ AutoScalingEnabled *bool

+ ConfigurationType ConfigurationType

+ Parallelism *int64

+ ParallelismPerKPU *int64

+ func (s *ParallelismConfiguration) Validate() error

+ func (s ParallelismConfiguration) GoString() string

+ func (s ParallelismConfiguration) String() string

+ type ParallelismConfigurationDescription struct

+ AutoScalingEnabled *bool

+ ConfigurationType ConfigurationType

+ CurrentParallelism *int64

+ Parallelism *int64

+ ParallelismPerKPU *int64

+ func (s ParallelismConfigurationDescription) GoString() string

+ func (s ParallelismConfigurationDescription) String() string

+ type ParallelismConfigurationUpdate struct

+ AutoScalingEnabledUpdate *bool

+ ConfigurationTypeUpdate ConfigurationType

+ ParallelismPerKPUUpdate *int64

+ ParallelismUpdate *int64

+ func (s *ParallelismConfigurationUpdate) Validate() error

+ func (s ParallelismConfigurationUpdate) GoString() string

+ func (s ParallelismConfigurationUpdate) String() string

+ type PropertyGroup struct

+ PropertyGroupId *string

+ PropertyMap map[string]string

+ func (s *PropertyGroup) Validate() error

+ func (s PropertyGroup) GoString() string

+ func (s PropertyGroup) String() string

+ type RecordColumn struct

+ Mapping *string

+ Name *string

+ SqlType *string

+ func (s *RecordColumn) Validate() error

+ func (s RecordColumn) GoString() string

+ func (s RecordColumn) String() string

+ type RecordFormat struct

+ MappingParameters *MappingParameters

+ RecordFormatType RecordFormatType

+ func (s *RecordFormat) Validate() error

+ func (s RecordFormat) GoString() string

+ func (s RecordFormat) String() string

+ type RecordFormatType string

+ const RecordFormatTypeCsv

+ const RecordFormatTypeJson

+ func (enum RecordFormatType) MarshalValue() (string, error)

+ func (enum RecordFormatType) MarshalValueBuf(b []byte) ([]byte, error)

+ type ReferenceDataSource struct

+ ReferenceSchema *SourceSchema

+ S3ReferenceDataSource *S3ReferenceDataSource

+ TableName *string

+ func (s *ReferenceDataSource) Validate() error

+ func (s ReferenceDataSource) GoString() string

+ func (s ReferenceDataSource) String() string

+ type ReferenceDataSourceDescription struct

+ ReferenceId *string

+ ReferenceSchema *SourceSchema

+ S3ReferenceDataSourceDescription *S3ReferenceDataSourceDescription

+ TableName *string

+ func (s ReferenceDataSourceDescription) GoString() string

+ func (s ReferenceDataSourceDescription) String() string

+ type ReferenceDataSourceUpdate struct

+ ReferenceId *string

+ ReferenceSchemaUpdate *SourceSchema

+ S3ReferenceDataSourceUpdate *S3ReferenceDataSourceUpdate

+ TableNameUpdate *string

+ func (s *ReferenceDataSourceUpdate) Validate() error

+ func (s ReferenceDataSourceUpdate) GoString() string

+ func (s ReferenceDataSourceUpdate) String() string

+ type RunConfiguration struct

+ ApplicationRestoreConfiguration *ApplicationRestoreConfiguration

+ SqlRunConfigurations []SqlRunConfiguration

+ func (s *RunConfiguration) Validate() error

+ func (s RunConfiguration) GoString() string

+ func (s RunConfiguration) String() string

+ type RunConfigurationDescription struct

+ ApplicationRestoreConfigurationDescription *ApplicationRestoreConfiguration

+ func (s RunConfigurationDescription) GoString() string

+ func (s RunConfigurationDescription) String() string

+ type RunConfigurationUpdate struct

+ ApplicationRestoreConfiguration *ApplicationRestoreConfiguration

+ func (s *RunConfigurationUpdate) Validate() error

+ func (s RunConfigurationUpdate) GoString() string

+ func (s RunConfigurationUpdate) String() string

+ type RuntimeEnvironment string

+ const RuntimeEnvironmentFlink16

+ const RuntimeEnvironmentSql10

+ func (enum RuntimeEnvironment) MarshalValue() (string, error)

+ func (enum RuntimeEnvironment) MarshalValueBuf(b []byte) ([]byte, error)

+ type S3ApplicationCodeLocationDescription struct

+ BucketARN *string

+ FileKey *string

+ ObjectVersion *string

+ func (s S3ApplicationCodeLocationDescription) GoString() string

+ func (s S3ApplicationCodeLocationDescription) String() string

+ type S3Configuration struct

+ BucketARN *string

+ FileKey *string

+ func (s *S3Configuration) Validate() error

+ func (s S3Configuration) GoString() string

+ func (s S3Configuration) String() string

+ type S3ContentLocation struct

+ BucketARN *string

+ FileKey *string

+ ObjectVersion *string

+ func (s *S3ContentLocation) Validate() error

+ func (s S3ContentLocation) GoString() string

+ func (s S3ContentLocation) String() string

+ type S3ContentLocationUpdate struct

+ BucketARNUpdate *string

+ FileKeyUpdate *string

+ ObjectVersionUpdate *string

+ func (s *S3ContentLocationUpdate) Validate() error

+ func (s S3ContentLocationUpdate) GoString() string

+ func (s S3ContentLocationUpdate) String() string

+ type S3ReferenceDataSource struct

+ BucketARN *string

+ FileKey *string

+ func (s *S3ReferenceDataSource) Validate() error

+ func (s S3ReferenceDataSource) GoString() string

+ func (s S3ReferenceDataSource) String() string

+ type S3ReferenceDataSourceDescription struct

+ BucketARN *string

+ FileKey *string

+ ReferenceRoleARN *string

+ func (s S3ReferenceDataSourceDescription) GoString() string

+ func (s S3ReferenceDataSourceDescription) String() string

+ type S3ReferenceDataSourceUpdate struct

+ BucketARNUpdate *string

+ FileKeyUpdate *string

+ func (s *S3ReferenceDataSourceUpdate) Validate() error

+ func (s S3ReferenceDataSourceUpdate) GoString() string

+ func (s S3ReferenceDataSourceUpdate) String() string

+ type SnapshotDetails struct

+ ApplicationVersionId *int64

+ SnapshotCreationTimestamp *time.Time

+ SnapshotName *string

+ SnapshotStatus SnapshotStatus

+ func (s SnapshotDetails) GoString() string

+ func (s SnapshotDetails) String() string

+ type SnapshotStatus string

+ const SnapshotStatusCreating

+ const SnapshotStatusDeleting

+ const SnapshotStatusFailed

+ const SnapshotStatusReady

+ func (enum SnapshotStatus) MarshalValue() (string, error)

+ func (enum SnapshotStatus) MarshalValueBuf(b []byte) ([]byte, error)

+ type SourceSchema struct

+ RecordColumns []RecordColumn

+ RecordEncoding *string

+ RecordFormat *RecordFormat

+ func (s *SourceSchema) Validate() error

+ func (s SourceSchema) GoString() string

+ func (s SourceSchema) String() string

+ type SqlApplicationConfiguration struct

+ Inputs []Input

+ Outputs []Output

+ ReferenceDataSources []ReferenceDataSource

+ func (s *SqlApplicationConfiguration) Validate() error

+ func (s SqlApplicationConfiguration) GoString() string

+ func (s SqlApplicationConfiguration) String() string

+ type SqlApplicationConfigurationDescription struct

+ InputDescriptions []InputDescription

+ OutputDescriptions []OutputDescription

+ ReferenceDataSourceDescriptions []ReferenceDataSourceDescription

+ func (s SqlApplicationConfigurationDescription) GoString() string

+ func (s SqlApplicationConfigurationDescription) String() string

+ type SqlApplicationConfigurationUpdate struct

+ InputUpdates []InputUpdate

+ OutputUpdates []OutputUpdate

+ ReferenceDataSourceUpdates []ReferenceDataSourceUpdate

+ func (s *SqlApplicationConfigurationUpdate) Validate() error

+ func (s SqlApplicationConfigurationUpdate) GoString() string

+ func (s SqlApplicationConfigurationUpdate) String() string

+ type SqlRunConfiguration struct

+ InputId *string

+ InputStartingPositionConfiguration *InputStartingPositionConfiguration

+ func (s *SqlRunConfiguration) Validate() error

+ func (s SqlRunConfiguration) GoString() string

+ func (s SqlRunConfiguration) String() string

+ type StartApplicationInput struct

+ ApplicationName *string

+ RunConfiguration *RunConfiguration

+ func (s *StartApplicationInput) Validate() error

+ func (s StartApplicationInput) GoString() string

+ func (s StartApplicationInput) String() string

+ type StartApplicationOutput struct

+ func (s StartApplicationOutput) GoString() string

+ func (s StartApplicationOutput) SDKResponseMetadata() aws.Response

+ func (s StartApplicationOutput) String() string

+ type StartApplicationRequest struct

+ Copy func(*StartApplicationInput) StartApplicationRequest

+ Input *StartApplicationInput

+ func (r StartApplicationRequest) Send() (*StartApplicationOutput, error)

+ type StopApplicationInput struct

+ ApplicationName *string

+ func (s *StopApplicationInput) Validate() error

+ func (s StopApplicationInput) GoString() string

+ func (s StopApplicationInput) String() string

+ type StopApplicationOutput struct

+ func (s StopApplicationOutput) GoString() string

+ func (s StopApplicationOutput) SDKResponseMetadata() aws.Response

+ func (s StopApplicationOutput) String() string

+ type StopApplicationRequest struct

+ Copy func(*StopApplicationInput) StopApplicationRequest

+ Input *StopApplicationInput

+ func (r StopApplicationRequest) Send() (*StopApplicationOutput, error)

+ type UpdateApplicationInput struct

+ ApplicationConfigurationUpdate *ApplicationConfigurationUpdate

+ ApplicationName *string

+ CloudWatchLoggingOptionUpdates []CloudWatchLoggingOptionUpdate

+ CurrentApplicationVersionId *int64

+ RunConfigurationUpdate *RunConfigurationUpdate

+ ServiceExecutionRoleUpdate *string

+ func (s *UpdateApplicationInput) Validate() error

+ func (s UpdateApplicationInput) GoString() string

+ func (s UpdateApplicationInput) String() string

+ type UpdateApplicationOutput struct

+ ApplicationDetail *ApplicationDetail

+ func (s UpdateApplicationOutput) GoString() string

+ func (s UpdateApplicationOutput) SDKResponseMetadata() aws.Response

+ func (s UpdateApplicationOutput) String() string

+ type UpdateApplicationRequest struct

+ Copy func(*UpdateApplicationInput) UpdateApplicationRequest

+ Input *UpdateApplicationInput

+ func (r UpdateApplicationRequest) Send() (*UpdateApplicationOutput, error)

Other modules containing this package

github.com/aws/aws-sdk-go-v2/service/kinesisanalyticsv2

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL