Versions in this module Expand all Collapse all v1 v1.48.2 Nov 21, 2023 Changes in this version + const ApplicationStatusDeleting + const ApplicationStatusReady + const ApplicationStatusRunning + const ApplicationStatusStarting + const ApplicationStatusStopping + const ApplicationStatusUpdating + const EndpointsID + const ErrCodeCodeValidationException + const ErrCodeConcurrentModificationException + const ErrCodeInvalidApplicationConfigurationException + const ErrCodeInvalidArgumentException + const ErrCodeLimitExceededException + const ErrCodeResourceInUseException + const ErrCodeResourceNotFoundException + const ErrCodeResourceProvisionedThroughputExceededException + const ErrCodeServiceUnavailableException + const ErrCodeTooManyTagsException + const ErrCodeUnableToDetectSchemaException + const ErrCodeUnsupportedOperationException + const InputStartingPositionLastStoppedPoint + const InputStartingPositionNow + const InputStartingPositionTrimHorizon + const RecordFormatTypeCsv + const RecordFormatTypeJson + const ServiceID + const ServiceName + func ApplicationStatus_Values() []string + func InputStartingPosition_Values() []string + func RecordFormatType_Values() []string + type AddApplicationCloudWatchLoggingOptionInput struct + ApplicationName *string + CloudWatchLoggingOption *CloudWatchLoggingOption + CurrentApplicationVersionId *int64 + func (s *AddApplicationCloudWatchLoggingOptionInput) SetApplicationName(v string) *AddApplicationCloudWatchLoggingOptionInput + func (s *AddApplicationCloudWatchLoggingOptionInput) SetCloudWatchLoggingOption(v *CloudWatchLoggingOption) *AddApplicationCloudWatchLoggingOptionInput + func (s *AddApplicationCloudWatchLoggingOptionInput) SetCurrentApplicationVersionId(v int64) *AddApplicationCloudWatchLoggingOptionInput + func (s *AddApplicationCloudWatchLoggingOptionInput) Validate() error + func (s AddApplicationCloudWatchLoggingOptionInput) GoString() string + func (s AddApplicationCloudWatchLoggingOptionInput) String() string + type AddApplicationCloudWatchLoggingOptionOutput struct + func (s AddApplicationCloudWatchLoggingOptionOutput) GoString() string + func (s AddApplicationCloudWatchLoggingOptionOutput) String() string + type AddApplicationInputInput struct + ApplicationName *string + CurrentApplicationVersionId *int64 + Input *Input + func (s *AddApplicationInputInput) SetApplicationName(v string) *AddApplicationInputInput + func (s *AddApplicationInputInput) SetCurrentApplicationVersionId(v int64) *AddApplicationInputInput + func (s *AddApplicationInputInput) SetInput(v *Input) *AddApplicationInputInput + func (s *AddApplicationInputInput) Validate() error + func (s AddApplicationInputInput) GoString() string + func (s AddApplicationInputInput) String() string + type AddApplicationInputOutput struct + func (s AddApplicationInputOutput) GoString() string + func (s AddApplicationInputOutput) String() string + type AddApplicationInputProcessingConfigurationInput struct + ApplicationName *string + CurrentApplicationVersionId *int64 + InputId *string + InputProcessingConfiguration *InputProcessingConfiguration + func (s *AddApplicationInputProcessingConfigurationInput) SetApplicationName(v string) *AddApplicationInputProcessingConfigurationInput + func (s *AddApplicationInputProcessingConfigurationInput) SetCurrentApplicationVersionId(v int64) *AddApplicationInputProcessingConfigurationInput + func (s *AddApplicationInputProcessingConfigurationInput) SetInputId(v string) *AddApplicationInputProcessingConfigurationInput + func (s *AddApplicationInputProcessingConfigurationInput) SetInputProcessingConfiguration(v *InputProcessingConfiguration) *AddApplicationInputProcessingConfigurationInput + func (s *AddApplicationInputProcessingConfigurationInput) Validate() error + func (s AddApplicationInputProcessingConfigurationInput) GoString() string + func (s AddApplicationInputProcessingConfigurationInput) String() string + type AddApplicationInputProcessingConfigurationOutput struct + func (s AddApplicationInputProcessingConfigurationOutput) GoString() string + func (s AddApplicationInputProcessingConfigurationOutput) String() string + type AddApplicationOutputInput struct + ApplicationName *string + CurrentApplicationVersionId *int64 + Output *Output + func (s *AddApplicationOutputInput) SetApplicationName(v string) *AddApplicationOutputInput + func (s *AddApplicationOutputInput) SetCurrentApplicationVersionId(v int64) *AddApplicationOutputInput + func (s *AddApplicationOutputInput) SetOutput(v *Output) *AddApplicationOutputInput + func (s *AddApplicationOutputInput) Validate() error + func (s AddApplicationOutputInput) GoString() string + func (s AddApplicationOutputInput) String() string + type AddApplicationOutputOutput struct + func (s AddApplicationOutputOutput) GoString() string + func (s AddApplicationOutputOutput) String() string + type AddApplicationReferenceDataSourceInput struct + ApplicationName *string + CurrentApplicationVersionId *int64 + ReferenceDataSource *ReferenceDataSource + func (s *AddApplicationReferenceDataSourceInput) SetApplicationName(v string) *AddApplicationReferenceDataSourceInput + func (s *AddApplicationReferenceDataSourceInput) SetCurrentApplicationVersionId(v int64) *AddApplicationReferenceDataSourceInput + func (s *AddApplicationReferenceDataSourceInput) SetReferenceDataSource(v *ReferenceDataSource) *AddApplicationReferenceDataSourceInput + func (s *AddApplicationReferenceDataSourceInput) Validate() error + func (s AddApplicationReferenceDataSourceInput) GoString() string + func (s AddApplicationReferenceDataSourceInput) String() string + type AddApplicationReferenceDataSourceOutput struct + func (s AddApplicationReferenceDataSourceOutput) GoString() string + func (s AddApplicationReferenceDataSourceOutput) String() string + type ApplicationDetail struct + ApplicationARN *string + ApplicationCode *string + ApplicationDescription *string + ApplicationName *string + ApplicationStatus *string + ApplicationVersionId *int64 + CloudWatchLoggingOptionDescriptions []*CloudWatchLoggingOptionDescription + CreateTimestamp *time.Time + InputDescriptions []*InputDescription + LastUpdateTimestamp *time.Time + OutputDescriptions []*OutputDescription + ReferenceDataSourceDescriptions []*ReferenceDataSourceDescription + func (s *ApplicationDetail) SetApplicationARN(v string) *ApplicationDetail + func (s *ApplicationDetail) SetApplicationCode(v string) *ApplicationDetail + func (s *ApplicationDetail) SetApplicationDescription(v string) *ApplicationDetail + func (s *ApplicationDetail) SetApplicationName(v string) *ApplicationDetail + func (s *ApplicationDetail) SetApplicationStatus(v string) *ApplicationDetail + func (s *ApplicationDetail) SetApplicationVersionId(v int64) *ApplicationDetail + func (s *ApplicationDetail) SetCloudWatchLoggingOptionDescriptions(v []*CloudWatchLoggingOptionDescription) *ApplicationDetail + func (s *ApplicationDetail) SetCreateTimestamp(v time.Time) *ApplicationDetail + func (s *ApplicationDetail) SetInputDescriptions(v []*InputDescription) *ApplicationDetail + func (s *ApplicationDetail) SetLastUpdateTimestamp(v time.Time) *ApplicationDetail + func (s *ApplicationDetail) SetOutputDescriptions(v []*OutputDescription) *ApplicationDetail + func (s *ApplicationDetail) SetReferenceDataSourceDescriptions(v []*ReferenceDataSourceDescription) *ApplicationDetail + func (s ApplicationDetail) GoString() string + func (s ApplicationDetail) String() string + type ApplicationSummary struct + ApplicationARN *string + ApplicationName *string + ApplicationStatus *string + func (s *ApplicationSummary) SetApplicationARN(v string) *ApplicationSummary + func (s *ApplicationSummary) SetApplicationName(v string) *ApplicationSummary + func (s *ApplicationSummary) SetApplicationStatus(v string) *ApplicationSummary + func (s ApplicationSummary) GoString() string + func (s ApplicationSummary) String() string + type ApplicationUpdate struct + ApplicationCodeUpdate *string + CloudWatchLoggingOptionUpdates []*CloudWatchLoggingOptionUpdate + InputUpdates []*InputUpdate + OutputUpdates []*OutputUpdate + ReferenceDataSourceUpdates []*ReferenceDataSourceUpdate + func (s *ApplicationUpdate) SetApplicationCodeUpdate(v string) *ApplicationUpdate + func (s *ApplicationUpdate) SetCloudWatchLoggingOptionUpdates(v []*CloudWatchLoggingOptionUpdate) *ApplicationUpdate + func (s *ApplicationUpdate) SetInputUpdates(v []*InputUpdate) *ApplicationUpdate + func (s *ApplicationUpdate) SetOutputUpdates(v []*OutputUpdate) *ApplicationUpdate + func (s *ApplicationUpdate) SetReferenceDataSourceUpdates(v []*ReferenceDataSourceUpdate) *ApplicationUpdate + func (s *ApplicationUpdate) Validate() error + func (s ApplicationUpdate) GoString() string + func (s ApplicationUpdate) String() string + type CSVMappingParameters struct + RecordColumnDelimiter *string + RecordRowDelimiter *string + func (s *CSVMappingParameters) SetRecordColumnDelimiter(v string) *CSVMappingParameters + func (s *CSVMappingParameters) SetRecordRowDelimiter(v string) *CSVMappingParameters + func (s *CSVMappingParameters) Validate() error + func (s CSVMappingParameters) GoString() string + func (s CSVMappingParameters) String() string + type CloudWatchLoggingOption struct + LogStreamARN *string + RoleARN *string + func (s *CloudWatchLoggingOption) SetLogStreamARN(v string) *CloudWatchLoggingOption + func (s *CloudWatchLoggingOption) SetRoleARN(v string) *CloudWatchLoggingOption + 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) SetCloudWatchLoggingOptionId(v string) *CloudWatchLoggingOptionDescription + func (s *CloudWatchLoggingOptionDescription) SetLogStreamARN(v string) *CloudWatchLoggingOptionDescription + func (s *CloudWatchLoggingOptionDescription) SetRoleARN(v string) *CloudWatchLoggingOptionDescription + func (s CloudWatchLoggingOptionDescription) GoString() string + func (s CloudWatchLoggingOptionDescription) String() string + type CloudWatchLoggingOptionUpdate struct + CloudWatchLoggingOptionId *string + LogStreamARNUpdate *string + RoleARNUpdate *string + func (s *CloudWatchLoggingOptionUpdate) SetCloudWatchLoggingOptionId(v string) *CloudWatchLoggingOptionUpdate + func (s *CloudWatchLoggingOptionUpdate) SetLogStreamARNUpdate(v string) *CloudWatchLoggingOptionUpdate + func (s *CloudWatchLoggingOptionUpdate) SetRoleARNUpdate(v string) *CloudWatchLoggingOptionUpdate + func (s *CloudWatchLoggingOptionUpdate) Validate() error + func (s CloudWatchLoggingOptionUpdate) GoString() string + func (s CloudWatchLoggingOptionUpdate) String() string + type CodeValidationException struct + Message_ *string + RespMetadata protocol.ResponseMetadata + func (s *CodeValidationException) Code() string + func (s *CodeValidationException) Error() string + func (s *CodeValidationException) Message() string + func (s *CodeValidationException) OrigErr() error + func (s *CodeValidationException) RequestID() string + func (s *CodeValidationException) StatusCode() int + func (s CodeValidationException) GoString() string + func (s CodeValidationException) String() string + type ConcurrentModificationException struct + Message_ *string + RespMetadata protocol.ResponseMetadata + func (s *ConcurrentModificationException) Code() string + func (s *ConcurrentModificationException) Error() string + func (s *ConcurrentModificationException) Message() string + func (s *ConcurrentModificationException) OrigErr() error + func (s *ConcurrentModificationException) RequestID() string + func (s *ConcurrentModificationException) StatusCode() int + func (s ConcurrentModificationException) GoString() string + func (s ConcurrentModificationException) String() string + type CreateApplicationInput struct + ApplicationCode *string + ApplicationDescription *string + ApplicationName *string + CloudWatchLoggingOptions []*CloudWatchLoggingOption + Inputs []*Input + Outputs []*Output + Tags []*Tag + func (s *CreateApplicationInput) SetApplicationCode(v string) *CreateApplicationInput + func (s *CreateApplicationInput) SetApplicationDescription(v string) *CreateApplicationInput + func (s *CreateApplicationInput) SetApplicationName(v string) *CreateApplicationInput + func (s *CreateApplicationInput) SetCloudWatchLoggingOptions(v []*CloudWatchLoggingOption) *CreateApplicationInput + func (s *CreateApplicationInput) SetInputs(v []*Input) *CreateApplicationInput + func (s *CreateApplicationInput) SetOutputs(v []*Output) *CreateApplicationInput + func (s *CreateApplicationInput) SetTags(v []*Tag) *CreateApplicationInput + func (s *CreateApplicationInput) Validate() error + func (s CreateApplicationInput) GoString() string + func (s CreateApplicationInput) String() string + type CreateApplicationOutput struct + ApplicationSummary *ApplicationSummary + func (s *CreateApplicationOutput) SetApplicationSummary(v *ApplicationSummary) *CreateApplicationOutput + func (s CreateApplicationOutput) GoString() string + func (s CreateApplicationOutput) String() string + type DeleteApplicationCloudWatchLoggingOptionInput struct + ApplicationName *string + CloudWatchLoggingOptionId *string + CurrentApplicationVersionId *int64 + func (s *DeleteApplicationCloudWatchLoggingOptionInput) SetApplicationName(v string) *DeleteApplicationCloudWatchLoggingOptionInput + func (s *DeleteApplicationCloudWatchLoggingOptionInput) SetCloudWatchLoggingOptionId(v string) *DeleteApplicationCloudWatchLoggingOptionInput + func (s *DeleteApplicationCloudWatchLoggingOptionInput) SetCurrentApplicationVersionId(v int64) *DeleteApplicationCloudWatchLoggingOptionInput + func (s *DeleteApplicationCloudWatchLoggingOptionInput) Validate() error + func (s DeleteApplicationCloudWatchLoggingOptionInput) GoString() string + func (s DeleteApplicationCloudWatchLoggingOptionInput) String() string + type DeleteApplicationCloudWatchLoggingOptionOutput struct + func (s DeleteApplicationCloudWatchLoggingOptionOutput) GoString() string + func (s DeleteApplicationCloudWatchLoggingOptionOutput) String() string + type DeleteApplicationInput struct + ApplicationName *string + CreateTimestamp *time.Time + func (s *DeleteApplicationInput) SetApplicationName(v string) *DeleteApplicationInput + func (s *DeleteApplicationInput) SetCreateTimestamp(v time.Time) *DeleteApplicationInput + 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) SetApplicationName(v string) *DeleteApplicationInputProcessingConfigurationInput + func (s *DeleteApplicationInputProcessingConfigurationInput) SetCurrentApplicationVersionId(v int64) *DeleteApplicationInputProcessingConfigurationInput + func (s *DeleteApplicationInputProcessingConfigurationInput) SetInputId(v string) *DeleteApplicationInputProcessingConfigurationInput + func (s *DeleteApplicationInputProcessingConfigurationInput) Validate() error + func (s DeleteApplicationInputProcessingConfigurationInput) GoString() string + func (s DeleteApplicationInputProcessingConfigurationInput) String() string + type DeleteApplicationInputProcessingConfigurationOutput struct + func (s DeleteApplicationInputProcessingConfigurationOutput) GoString() string + func (s DeleteApplicationInputProcessingConfigurationOutput) String() string + type DeleteApplicationOutput struct + func (s DeleteApplicationOutput) GoString() string + func (s DeleteApplicationOutput) String() string + type DeleteApplicationOutputInput struct + ApplicationName *string + CurrentApplicationVersionId *int64 + OutputId *string + func (s *DeleteApplicationOutputInput) SetApplicationName(v string) *DeleteApplicationOutputInput + func (s *DeleteApplicationOutputInput) SetCurrentApplicationVersionId(v int64) *DeleteApplicationOutputInput + func (s *DeleteApplicationOutputInput) SetOutputId(v string) *DeleteApplicationOutputInput + func (s *DeleteApplicationOutputInput) Validate() error + func (s DeleteApplicationOutputInput) GoString() string + func (s DeleteApplicationOutputInput) String() string + type DeleteApplicationOutputOutput struct + func (s DeleteApplicationOutputOutput) GoString() string + func (s DeleteApplicationOutputOutput) String() string + type DeleteApplicationReferenceDataSourceInput struct + ApplicationName *string + CurrentApplicationVersionId *int64 + ReferenceId *string + func (s *DeleteApplicationReferenceDataSourceInput) SetApplicationName(v string) *DeleteApplicationReferenceDataSourceInput + func (s *DeleteApplicationReferenceDataSourceInput) SetCurrentApplicationVersionId(v int64) *DeleteApplicationReferenceDataSourceInput + func (s *DeleteApplicationReferenceDataSourceInput) SetReferenceId(v string) *DeleteApplicationReferenceDataSourceInput + func (s *DeleteApplicationReferenceDataSourceInput) Validate() error + func (s DeleteApplicationReferenceDataSourceInput) GoString() string + func (s DeleteApplicationReferenceDataSourceInput) String() string + type DeleteApplicationReferenceDataSourceOutput struct + func (s DeleteApplicationReferenceDataSourceOutput) GoString() string + func (s DeleteApplicationReferenceDataSourceOutput) String() string + type DescribeApplicationInput struct + ApplicationName *string + func (s *DescribeApplicationInput) SetApplicationName(v string) *DescribeApplicationInput + func (s *DescribeApplicationInput) Validate() error + func (s DescribeApplicationInput) GoString() string + func (s DescribeApplicationInput) String() string + type DescribeApplicationOutput struct + ApplicationDetail *ApplicationDetail + func (s *DescribeApplicationOutput) SetApplicationDetail(v *ApplicationDetail) *DescribeApplicationOutput + func (s DescribeApplicationOutput) GoString() string + func (s DescribeApplicationOutput) String() string + type DestinationSchema struct + RecordFormatType *string + func (s *DestinationSchema) SetRecordFormatType(v string) *DestinationSchema + func (s *DestinationSchema) Validate() error + func (s DestinationSchema) GoString() string + func (s DestinationSchema) String() string + type DiscoverInputSchemaInput struct + InputProcessingConfiguration *InputProcessingConfiguration + InputStartingPositionConfiguration *InputStartingPositionConfiguration + ResourceARN *string + RoleARN *string + S3Configuration *S3Configuration + func (s *DiscoverInputSchemaInput) SetInputProcessingConfiguration(v *InputProcessingConfiguration) *DiscoverInputSchemaInput + func (s *DiscoverInputSchemaInput) SetInputStartingPositionConfiguration(v *InputStartingPositionConfiguration) *DiscoverInputSchemaInput + func (s *DiscoverInputSchemaInput) SetResourceARN(v string) *DiscoverInputSchemaInput + func (s *DiscoverInputSchemaInput) SetRoleARN(v string) *DiscoverInputSchemaInput + func (s *DiscoverInputSchemaInput) SetS3Configuration(v *S3Configuration) *DiscoverInputSchemaInput + 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) SetInputSchema(v *SourceSchema) *DiscoverInputSchemaOutput + func (s *DiscoverInputSchemaOutput) SetParsedInputRecords(v [][]*string) *DiscoverInputSchemaOutput + func (s *DiscoverInputSchemaOutput) SetProcessedInputRecords(v []*string) *DiscoverInputSchemaOutput + func (s *DiscoverInputSchemaOutput) SetRawInputRecords(v []*string) *DiscoverInputSchemaOutput + func (s DiscoverInputSchemaOutput) GoString() string + func (s DiscoverInputSchemaOutput) String() string + type Input struct + InputParallelism *InputParallelism + InputProcessingConfiguration *InputProcessingConfiguration + InputSchema *SourceSchema + KinesisFirehoseInput *KinesisFirehoseInput + KinesisStreamsInput *KinesisStreamsInput + NamePrefix *string + func (s *Input) SetInputParallelism(v *InputParallelism) *Input + func (s *Input) SetInputProcessingConfiguration(v *InputProcessingConfiguration) *Input + func (s *Input) SetInputSchema(v *SourceSchema) *Input + func (s *Input) SetKinesisFirehoseInput(v *KinesisFirehoseInput) *Input + func (s *Input) SetKinesisStreamsInput(v *KinesisStreamsInput) *Input + func (s *Input) SetNamePrefix(v string) *Input + func (s *Input) Validate() error + func (s Input) GoString() string + func (s Input) String() string + type InputConfiguration struct + Id *string + InputStartingPositionConfiguration *InputStartingPositionConfiguration + func (s *InputConfiguration) SetId(v string) *InputConfiguration + func (s *InputConfiguration) SetInputStartingPositionConfiguration(v *InputStartingPositionConfiguration) *InputConfiguration + func (s *InputConfiguration) Validate() error + func (s InputConfiguration) GoString() string + func (s InputConfiguration) 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) SetInAppStreamNames(v []*string) *InputDescription + func (s *InputDescription) SetInputId(v string) *InputDescription + func (s *InputDescription) SetInputParallelism(v *InputParallelism) *InputDescription + func (s *InputDescription) SetInputProcessingConfigurationDescription(v *InputProcessingConfigurationDescription) *InputDescription + func (s *InputDescription) SetInputSchema(v *SourceSchema) *InputDescription + func (s *InputDescription) SetInputStartingPositionConfiguration(v *InputStartingPositionConfiguration) *InputDescription + func (s *InputDescription) SetKinesisFirehoseInputDescription(v *KinesisFirehoseInputDescription) *InputDescription + func (s *InputDescription) SetKinesisStreamsInputDescription(v *KinesisStreamsInputDescription) *InputDescription + func (s *InputDescription) SetNamePrefix(v string) *InputDescription + func (s InputDescription) GoString() string + func (s InputDescription) String() string + type InputLambdaProcessor struct + ResourceARN *string + RoleARN *string + func (s *InputLambdaProcessor) SetResourceARN(v string) *InputLambdaProcessor + func (s *InputLambdaProcessor) SetRoleARN(v string) *InputLambdaProcessor + 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) SetResourceARN(v string) *InputLambdaProcessorDescription + func (s *InputLambdaProcessorDescription) SetRoleARN(v string) *InputLambdaProcessorDescription + func (s InputLambdaProcessorDescription) GoString() string + func (s InputLambdaProcessorDescription) String() string + type InputLambdaProcessorUpdate struct + ResourceARNUpdate *string + RoleARNUpdate *string + func (s *InputLambdaProcessorUpdate) SetResourceARNUpdate(v string) *InputLambdaProcessorUpdate + func (s *InputLambdaProcessorUpdate) SetRoleARNUpdate(v string) *InputLambdaProcessorUpdate + func (s *InputLambdaProcessorUpdate) Validate() error + func (s InputLambdaProcessorUpdate) GoString() string + func (s InputLambdaProcessorUpdate) String() string + type InputParallelism struct + Count *int64 + func (s *InputParallelism) SetCount(v int64) *InputParallelism + func (s *InputParallelism) Validate() error + func (s InputParallelism) GoString() string + func (s InputParallelism) String() string + type InputParallelismUpdate struct + CountUpdate *int64 + func (s *InputParallelismUpdate) SetCountUpdate(v int64) *InputParallelismUpdate + func (s *InputParallelismUpdate) Validate() error + func (s InputParallelismUpdate) GoString() string + func (s InputParallelismUpdate) String() string + type InputProcessingConfiguration struct + InputLambdaProcessor *InputLambdaProcessor + func (s *InputProcessingConfiguration) SetInputLambdaProcessor(v *InputLambdaProcessor) *InputProcessingConfiguration + func (s *InputProcessingConfiguration) Validate() error + func (s InputProcessingConfiguration) GoString() string + func (s InputProcessingConfiguration) String() string + type InputProcessingConfigurationDescription struct + InputLambdaProcessorDescription *InputLambdaProcessorDescription + func (s *InputProcessingConfigurationDescription) SetInputLambdaProcessorDescription(v *InputLambdaProcessorDescription) *InputProcessingConfigurationDescription + func (s InputProcessingConfigurationDescription) GoString() string + func (s InputProcessingConfigurationDescription) String() string + type InputProcessingConfigurationUpdate struct + InputLambdaProcessorUpdate *InputLambdaProcessorUpdate + func (s *InputProcessingConfigurationUpdate) SetInputLambdaProcessorUpdate(v *InputLambdaProcessorUpdate) *InputProcessingConfigurationUpdate + 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) SetRecordColumnUpdates(v []*RecordColumn) *InputSchemaUpdate + func (s *InputSchemaUpdate) SetRecordEncodingUpdate(v string) *InputSchemaUpdate + func (s *InputSchemaUpdate) SetRecordFormatUpdate(v *RecordFormat) *InputSchemaUpdate + func (s *InputSchemaUpdate) Validate() error + func (s InputSchemaUpdate) GoString() string + func (s InputSchemaUpdate) String() string + type InputStartingPositionConfiguration struct + InputStartingPosition *string + func (s *InputStartingPositionConfiguration) SetInputStartingPosition(v string) *InputStartingPositionConfiguration + 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) SetInputId(v string) *InputUpdate + func (s *InputUpdate) SetInputParallelismUpdate(v *InputParallelismUpdate) *InputUpdate + func (s *InputUpdate) SetInputProcessingConfigurationUpdate(v *InputProcessingConfigurationUpdate) *InputUpdate + func (s *InputUpdate) SetInputSchemaUpdate(v *InputSchemaUpdate) *InputUpdate + func (s *InputUpdate) SetKinesisFirehoseInputUpdate(v *KinesisFirehoseInputUpdate) *InputUpdate + func (s *InputUpdate) SetKinesisStreamsInputUpdate(v *KinesisStreamsInputUpdate) *InputUpdate + func (s *InputUpdate) SetNamePrefixUpdate(v string) *InputUpdate + func (s *InputUpdate) Validate() error + func (s InputUpdate) GoString() string + func (s InputUpdate) String() string + type InvalidApplicationConfigurationException struct + Message_ *string + RespMetadata protocol.ResponseMetadata + func (s *InvalidApplicationConfigurationException) Code() string + func (s *InvalidApplicationConfigurationException) Error() string + func (s *InvalidApplicationConfigurationException) Message() string + func (s *InvalidApplicationConfigurationException) OrigErr() error + func (s *InvalidApplicationConfigurationException) RequestID() string + func (s *InvalidApplicationConfigurationException) StatusCode() int + func (s InvalidApplicationConfigurationException) GoString() string + func (s InvalidApplicationConfigurationException) String() string + type InvalidArgumentException struct + Message_ *string + RespMetadata protocol.ResponseMetadata + func (s *InvalidArgumentException) Code() string + func (s *InvalidArgumentException) Error() string + func (s *InvalidArgumentException) Message() string + func (s *InvalidArgumentException) OrigErr() error + func (s *InvalidArgumentException) RequestID() string + func (s *InvalidArgumentException) StatusCode() int + func (s InvalidArgumentException) GoString() string + func (s InvalidArgumentException) String() string + type JSONMappingParameters struct + RecordRowPath *string + func (s *JSONMappingParameters) SetRecordRowPath(v string) *JSONMappingParameters + func (s *JSONMappingParameters) Validate() error + func (s JSONMappingParameters) GoString() string + func (s JSONMappingParameters) String() string + type KinesisAnalytics struct + func New(p client.ConfigProvider, cfgs ...*aws.Config) *KinesisAnalytics + func (c *KinesisAnalytics) AddApplicationCloudWatchLoggingOption(input *AddApplicationCloudWatchLoggingOptionInput) (*AddApplicationCloudWatchLoggingOptionOutput, error) + func (c *KinesisAnalytics) AddApplicationCloudWatchLoggingOptionRequest(input *AddApplicationCloudWatchLoggingOptionInput) (req *request.Request, output *AddApplicationCloudWatchLoggingOptionOutput) + func (c *KinesisAnalytics) AddApplicationCloudWatchLoggingOptionWithContext(ctx aws.Context, input *AddApplicationCloudWatchLoggingOptionInput, ...) (*AddApplicationCloudWatchLoggingOptionOutput, error) + func (c *KinesisAnalytics) AddApplicationInput(input *AddApplicationInputInput) (*AddApplicationInputOutput, error) + func (c *KinesisAnalytics) AddApplicationInputProcessingConfiguration(input *AddApplicationInputProcessingConfigurationInput) (*AddApplicationInputProcessingConfigurationOutput, error) + func (c *KinesisAnalytics) AddApplicationInputProcessingConfigurationRequest(input *AddApplicationInputProcessingConfigurationInput) (req *request.Request, output *AddApplicationInputProcessingConfigurationOutput) + func (c *KinesisAnalytics) AddApplicationInputProcessingConfigurationWithContext(ctx aws.Context, input *AddApplicationInputProcessingConfigurationInput, ...) (*AddApplicationInputProcessingConfigurationOutput, error) + func (c *KinesisAnalytics) AddApplicationInputRequest(input *AddApplicationInputInput) (req *request.Request, output *AddApplicationInputOutput) + func (c *KinesisAnalytics) AddApplicationInputWithContext(ctx aws.Context, input *AddApplicationInputInput, opts ...request.Option) (*AddApplicationInputOutput, error) + func (c *KinesisAnalytics) AddApplicationOutput(input *AddApplicationOutputInput) (*AddApplicationOutputOutput, error) + func (c *KinesisAnalytics) AddApplicationOutputRequest(input *AddApplicationOutputInput) (req *request.Request, output *AddApplicationOutputOutput) + func (c *KinesisAnalytics) AddApplicationOutputWithContext(ctx aws.Context, input *AddApplicationOutputInput, opts ...request.Option) (*AddApplicationOutputOutput, error) + func (c *KinesisAnalytics) AddApplicationReferenceDataSource(input *AddApplicationReferenceDataSourceInput) (*AddApplicationReferenceDataSourceOutput, error) + func (c *KinesisAnalytics) AddApplicationReferenceDataSourceRequest(input *AddApplicationReferenceDataSourceInput) (req *request.Request, output *AddApplicationReferenceDataSourceOutput) + func (c *KinesisAnalytics) AddApplicationReferenceDataSourceWithContext(ctx aws.Context, input *AddApplicationReferenceDataSourceInput, ...) (*AddApplicationReferenceDataSourceOutput, error) + func (c *KinesisAnalytics) CreateApplication(input *CreateApplicationInput) (*CreateApplicationOutput, error) + func (c *KinesisAnalytics) CreateApplicationRequest(input *CreateApplicationInput) (req *request.Request, output *CreateApplicationOutput) + func (c *KinesisAnalytics) CreateApplicationWithContext(ctx aws.Context, input *CreateApplicationInput, opts ...request.Option) (*CreateApplicationOutput, error) + func (c *KinesisAnalytics) DeleteApplication(input *DeleteApplicationInput) (*DeleteApplicationOutput, error) + func (c *KinesisAnalytics) DeleteApplicationCloudWatchLoggingOption(input *DeleteApplicationCloudWatchLoggingOptionInput) (*DeleteApplicationCloudWatchLoggingOptionOutput, error) + func (c *KinesisAnalytics) DeleteApplicationCloudWatchLoggingOptionRequest(input *DeleteApplicationCloudWatchLoggingOptionInput) (req *request.Request, output *DeleteApplicationCloudWatchLoggingOptionOutput) + func (c *KinesisAnalytics) DeleteApplicationCloudWatchLoggingOptionWithContext(ctx aws.Context, input *DeleteApplicationCloudWatchLoggingOptionInput, ...) (*DeleteApplicationCloudWatchLoggingOptionOutput, error) + func (c *KinesisAnalytics) DeleteApplicationInputProcessingConfiguration(input *DeleteApplicationInputProcessingConfigurationInput) (*DeleteApplicationInputProcessingConfigurationOutput, error) + func (c *KinesisAnalytics) DeleteApplicationInputProcessingConfigurationRequest(input *DeleteApplicationInputProcessingConfigurationInput) (req *request.Request, ...) + func (c *KinesisAnalytics) DeleteApplicationInputProcessingConfigurationWithContext(ctx aws.Context, input *DeleteApplicationInputProcessingConfigurationInput, ...) (*DeleteApplicationInputProcessingConfigurationOutput, error) + func (c *KinesisAnalytics) DeleteApplicationOutput(input *DeleteApplicationOutputInput) (*DeleteApplicationOutputOutput, error) + func (c *KinesisAnalytics) DeleteApplicationOutputRequest(input *DeleteApplicationOutputInput) (req *request.Request, output *DeleteApplicationOutputOutput) + func (c *KinesisAnalytics) DeleteApplicationOutputWithContext(ctx aws.Context, input *DeleteApplicationOutputInput, opts ...request.Option) (*DeleteApplicationOutputOutput, error) + func (c *KinesisAnalytics) DeleteApplicationReferenceDataSource(input *DeleteApplicationReferenceDataSourceInput) (*DeleteApplicationReferenceDataSourceOutput, error) + func (c *KinesisAnalytics) DeleteApplicationReferenceDataSourceRequest(input *DeleteApplicationReferenceDataSourceInput) (req *request.Request, output *DeleteApplicationReferenceDataSourceOutput) + func (c *KinesisAnalytics) DeleteApplicationReferenceDataSourceWithContext(ctx aws.Context, input *DeleteApplicationReferenceDataSourceInput, ...) (*DeleteApplicationReferenceDataSourceOutput, error) + func (c *KinesisAnalytics) DeleteApplicationRequest(input *DeleteApplicationInput) (req *request.Request, output *DeleteApplicationOutput) + func (c *KinesisAnalytics) DeleteApplicationWithContext(ctx aws.Context, input *DeleteApplicationInput, opts ...request.Option) (*DeleteApplicationOutput, error) + func (c *KinesisAnalytics) DescribeApplication(input *DescribeApplicationInput) (*DescribeApplicationOutput, error) + func (c *KinesisAnalytics) DescribeApplicationRequest(input *DescribeApplicationInput) (req *request.Request, output *DescribeApplicationOutput) + func (c *KinesisAnalytics) DescribeApplicationWithContext(ctx aws.Context, input *DescribeApplicationInput, opts ...request.Option) (*DescribeApplicationOutput, error) + func (c *KinesisAnalytics) DiscoverInputSchema(input *DiscoverInputSchemaInput) (*DiscoverInputSchemaOutput, error) + func (c *KinesisAnalytics) DiscoverInputSchemaRequest(input *DiscoverInputSchemaInput) (req *request.Request, output *DiscoverInputSchemaOutput) + func (c *KinesisAnalytics) DiscoverInputSchemaWithContext(ctx aws.Context, input *DiscoverInputSchemaInput, opts ...request.Option) (*DiscoverInputSchemaOutput, error) + func (c *KinesisAnalytics) ListApplications(input *ListApplicationsInput) (*ListApplicationsOutput, error) + func (c *KinesisAnalytics) ListApplicationsRequest(input *ListApplicationsInput) (req *request.Request, output *ListApplicationsOutput) + func (c *KinesisAnalytics) ListApplicationsWithContext(ctx aws.Context, input *ListApplicationsInput, opts ...request.Option) (*ListApplicationsOutput, error) + func (c *KinesisAnalytics) ListTagsForResource(input *ListTagsForResourceInput) (*ListTagsForResourceOutput, error) + func (c *KinesisAnalytics) ListTagsForResourceRequest(input *ListTagsForResourceInput) (req *request.Request, output *ListTagsForResourceOutput) + func (c *KinesisAnalytics) ListTagsForResourceWithContext(ctx aws.Context, input *ListTagsForResourceInput, opts ...request.Option) (*ListTagsForResourceOutput, error) + func (c *KinesisAnalytics) StartApplication(input *StartApplicationInput) (*StartApplicationOutput, error) + func (c *KinesisAnalytics) StartApplicationRequest(input *StartApplicationInput) (req *request.Request, output *StartApplicationOutput) + func (c *KinesisAnalytics) StartApplicationWithContext(ctx aws.Context, input *StartApplicationInput, opts ...request.Option) (*StartApplicationOutput, error) + func (c *KinesisAnalytics) StopApplication(input *StopApplicationInput) (*StopApplicationOutput, error) + func (c *KinesisAnalytics) StopApplicationRequest(input *StopApplicationInput) (req *request.Request, output *StopApplicationOutput) + func (c *KinesisAnalytics) StopApplicationWithContext(ctx aws.Context, input *StopApplicationInput, opts ...request.Option) (*StopApplicationOutput, error) + func (c *KinesisAnalytics) TagResource(input *TagResourceInput) (*TagResourceOutput, error) + func (c *KinesisAnalytics) TagResourceRequest(input *TagResourceInput) (req *request.Request, output *TagResourceOutput) + func (c *KinesisAnalytics) TagResourceWithContext(ctx aws.Context, input *TagResourceInput, opts ...request.Option) (*TagResourceOutput, error) + func (c *KinesisAnalytics) UntagResource(input *UntagResourceInput) (*UntagResourceOutput, error) + func (c *KinesisAnalytics) UntagResourceRequest(input *UntagResourceInput) (req *request.Request, output *UntagResourceOutput) + func (c *KinesisAnalytics) UntagResourceWithContext(ctx aws.Context, input *UntagResourceInput, opts ...request.Option) (*UntagResourceOutput, error) + func (c *KinesisAnalytics) UpdateApplication(input *UpdateApplicationInput) (*UpdateApplicationOutput, error) + func (c *KinesisAnalytics) UpdateApplicationRequest(input *UpdateApplicationInput) (req *request.Request, output *UpdateApplicationOutput) + func (c *KinesisAnalytics) UpdateApplicationWithContext(ctx aws.Context, input *UpdateApplicationInput, opts ...request.Option) (*UpdateApplicationOutput, error) + type KinesisFirehoseInput struct + ResourceARN *string + RoleARN *string + func (s *KinesisFirehoseInput) SetResourceARN(v string) *KinesisFirehoseInput + func (s *KinesisFirehoseInput) SetRoleARN(v string) *KinesisFirehoseInput + 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) SetResourceARN(v string) *KinesisFirehoseInputDescription + func (s *KinesisFirehoseInputDescription) SetRoleARN(v string) *KinesisFirehoseInputDescription + func (s KinesisFirehoseInputDescription) GoString() string + func (s KinesisFirehoseInputDescription) String() string + type KinesisFirehoseInputUpdate struct + ResourceARNUpdate *string + RoleARNUpdate *string + func (s *KinesisFirehoseInputUpdate) SetResourceARNUpdate(v string) *KinesisFirehoseInputUpdate + func (s *KinesisFirehoseInputUpdate) SetRoleARNUpdate(v string) *KinesisFirehoseInputUpdate + func (s *KinesisFirehoseInputUpdate) Validate() error + func (s KinesisFirehoseInputUpdate) GoString() string + func (s KinesisFirehoseInputUpdate) String() string + type KinesisFirehoseOutput struct + ResourceARN *string + RoleARN *string + func (s *KinesisFirehoseOutput) SetResourceARN(v string) *KinesisFirehoseOutput + func (s *KinesisFirehoseOutput) SetRoleARN(v string) *KinesisFirehoseOutput + 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) SetResourceARN(v string) *KinesisFirehoseOutputDescription + func (s *KinesisFirehoseOutputDescription) SetRoleARN(v string) *KinesisFirehoseOutputDescription + func (s KinesisFirehoseOutputDescription) GoString() string + func (s KinesisFirehoseOutputDescription) String() string + type KinesisFirehoseOutputUpdate struct + ResourceARNUpdate *string + RoleARNUpdate *string + func (s *KinesisFirehoseOutputUpdate) SetResourceARNUpdate(v string) *KinesisFirehoseOutputUpdate + func (s *KinesisFirehoseOutputUpdate) SetRoleARNUpdate(v string) *KinesisFirehoseOutputUpdate + func (s *KinesisFirehoseOutputUpdate) Validate() error + func (s KinesisFirehoseOutputUpdate) GoString() string + func (s KinesisFirehoseOutputUpdate) String() string + type KinesisStreamsInput struct + ResourceARN *string + RoleARN *string + func (s *KinesisStreamsInput) SetResourceARN(v string) *KinesisStreamsInput + func (s *KinesisStreamsInput) SetRoleARN(v string) *KinesisStreamsInput + 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) SetResourceARN(v string) *KinesisStreamsInputDescription + func (s *KinesisStreamsInputDescription) SetRoleARN(v string) *KinesisStreamsInputDescription + func (s KinesisStreamsInputDescription) GoString() string + func (s KinesisStreamsInputDescription) String() string + type KinesisStreamsInputUpdate struct + ResourceARNUpdate *string + RoleARNUpdate *string + func (s *KinesisStreamsInputUpdate) SetResourceARNUpdate(v string) *KinesisStreamsInputUpdate + func (s *KinesisStreamsInputUpdate) SetRoleARNUpdate(v string) *KinesisStreamsInputUpdate + func (s *KinesisStreamsInputUpdate) Validate() error + func (s KinesisStreamsInputUpdate) GoString() string + func (s KinesisStreamsInputUpdate) String() string + type KinesisStreamsOutput struct + ResourceARN *string + RoleARN *string + func (s *KinesisStreamsOutput) SetResourceARN(v string) *KinesisStreamsOutput + func (s *KinesisStreamsOutput) SetRoleARN(v string) *KinesisStreamsOutput + 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) SetResourceARN(v string) *KinesisStreamsOutputDescription + func (s *KinesisStreamsOutputDescription) SetRoleARN(v string) *KinesisStreamsOutputDescription + func (s KinesisStreamsOutputDescription) GoString() string + func (s KinesisStreamsOutputDescription) String() string + type KinesisStreamsOutputUpdate struct + ResourceARNUpdate *string + RoleARNUpdate *string + func (s *KinesisStreamsOutputUpdate) SetResourceARNUpdate(v string) *KinesisStreamsOutputUpdate + func (s *KinesisStreamsOutputUpdate) SetRoleARNUpdate(v string) *KinesisStreamsOutputUpdate + func (s *KinesisStreamsOutputUpdate) Validate() error + func (s KinesisStreamsOutputUpdate) GoString() string + func (s KinesisStreamsOutputUpdate) String() string + type LambdaOutput struct + ResourceARN *string + RoleARN *string + func (s *LambdaOutput) SetResourceARN(v string) *LambdaOutput + func (s *LambdaOutput) SetRoleARN(v string) *LambdaOutput + 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) SetResourceARN(v string) *LambdaOutputDescription + func (s *LambdaOutputDescription) SetRoleARN(v string) *LambdaOutputDescription + func (s LambdaOutputDescription) GoString() string + func (s LambdaOutputDescription) String() string + type LambdaOutputUpdate struct + ResourceARNUpdate *string + RoleARNUpdate *string + func (s *LambdaOutputUpdate) SetResourceARNUpdate(v string) *LambdaOutputUpdate + func (s *LambdaOutputUpdate) SetRoleARNUpdate(v string) *LambdaOutputUpdate + func (s *LambdaOutputUpdate) Validate() error + func (s LambdaOutputUpdate) GoString() string + func (s LambdaOutputUpdate) String() string + type LimitExceededException struct + Message_ *string + RespMetadata protocol.ResponseMetadata + func (s *LimitExceededException) Code() string + func (s *LimitExceededException) Error() string + func (s *LimitExceededException) Message() string + func (s *LimitExceededException) OrigErr() error + func (s *LimitExceededException) RequestID() string + func (s *LimitExceededException) StatusCode() int + func (s LimitExceededException) GoString() string + func (s LimitExceededException) String() string + type ListApplicationsInput struct + ExclusiveStartApplicationName *string + Limit *int64 + func (s *ListApplicationsInput) SetExclusiveStartApplicationName(v string) *ListApplicationsInput + func (s *ListApplicationsInput) SetLimit(v int64) *ListApplicationsInput + func (s *ListApplicationsInput) Validate() error + func (s ListApplicationsInput) GoString() string + func (s ListApplicationsInput) String() string + type ListApplicationsOutput struct + ApplicationSummaries []*ApplicationSummary + HasMoreApplications *bool + func (s *ListApplicationsOutput) SetApplicationSummaries(v []*ApplicationSummary) *ListApplicationsOutput + func (s *ListApplicationsOutput) SetHasMoreApplications(v bool) *ListApplicationsOutput + func (s ListApplicationsOutput) GoString() string + func (s ListApplicationsOutput) String() string + type ListTagsForResourceInput struct + ResourceARN *string + func (s *ListTagsForResourceInput) SetResourceARN(v string) *ListTagsForResourceInput + func (s *ListTagsForResourceInput) Validate() error + func (s ListTagsForResourceInput) GoString() string + func (s ListTagsForResourceInput) String() string + type ListTagsForResourceOutput struct + Tags []*Tag + func (s *ListTagsForResourceOutput) SetTags(v []*Tag) *ListTagsForResourceOutput + func (s ListTagsForResourceOutput) GoString() string + func (s ListTagsForResourceOutput) String() string + type MappingParameters struct + CSVMappingParameters *CSVMappingParameters + JSONMappingParameters *JSONMappingParameters + func (s *MappingParameters) SetCSVMappingParameters(v *CSVMappingParameters) *MappingParameters + func (s *MappingParameters) SetJSONMappingParameters(v *JSONMappingParameters) *MappingParameters + func (s *MappingParameters) Validate() error + func (s MappingParameters) GoString() string + func (s MappingParameters) String() string + type Output struct + DestinationSchema *DestinationSchema + KinesisFirehoseOutput *KinesisFirehoseOutput + KinesisStreamsOutput *KinesisStreamsOutput + LambdaOutput *LambdaOutput + Name *string + func (s *Output) SetDestinationSchema(v *DestinationSchema) *Output + func (s *Output) SetKinesisFirehoseOutput(v *KinesisFirehoseOutput) *Output + func (s *Output) SetKinesisStreamsOutput(v *KinesisStreamsOutput) *Output + func (s *Output) SetLambdaOutput(v *LambdaOutput) *Output + func (s *Output) SetName(v string) *Output + 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) SetDestinationSchema(v *DestinationSchema) *OutputDescription + func (s *OutputDescription) SetKinesisFirehoseOutputDescription(v *KinesisFirehoseOutputDescription) *OutputDescription + func (s *OutputDescription) SetKinesisStreamsOutputDescription(v *KinesisStreamsOutputDescription) *OutputDescription + func (s *OutputDescription) SetLambdaOutputDescription(v *LambdaOutputDescription) *OutputDescription + func (s *OutputDescription) SetName(v string) *OutputDescription + func (s *OutputDescription) SetOutputId(v string) *OutputDescription + 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) SetDestinationSchemaUpdate(v *DestinationSchema) *OutputUpdate + func (s *OutputUpdate) SetKinesisFirehoseOutputUpdate(v *KinesisFirehoseOutputUpdate) *OutputUpdate + func (s *OutputUpdate) SetKinesisStreamsOutputUpdate(v *KinesisStreamsOutputUpdate) *OutputUpdate + func (s *OutputUpdate) SetLambdaOutputUpdate(v *LambdaOutputUpdate) *OutputUpdate + func (s *OutputUpdate) SetNameUpdate(v string) *OutputUpdate + func (s *OutputUpdate) SetOutputId(v string) *OutputUpdate + func (s *OutputUpdate) Validate() error + func (s OutputUpdate) GoString() string + func (s OutputUpdate) String() string + type RecordColumn struct + Mapping *string + Name *string + SqlType *string + func (s *RecordColumn) SetMapping(v string) *RecordColumn + func (s *RecordColumn) SetName(v string) *RecordColumn + func (s *RecordColumn) SetSqlType(v string) *RecordColumn + func (s *RecordColumn) Validate() error + func (s RecordColumn) GoString() string + func (s RecordColumn) String() string + type RecordFormat struct + MappingParameters *MappingParameters + RecordFormatType *string + func (s *RecordFormat) SetMappingParameters(v *MappingParameters) *RecordFormat + func (s *RecordFormat) SetRecordFormatType(v string) *RecordFormat + func (s *RecordFormat) Validate() error + func (s RecordFormat) GoString() string + func (s RecordFormat) String() string + type ReferenceDataSource struct + ReferenceSchema *SourceSchema + S3ReferenceDataSource *S3ReferenceDataSource + TableName *string + func (s *ReferenceDataSource) SetReferenceSchema(v *SourceSchema) *ReferenceDataSource + func (s *ReferenceDataSource) SetS3ReferenceDataSource(v *S3ReferenceDataSource) *ReferenceDataSource + func (s *ReferenceDataSource) SetTableName(v string) *ReferenceDataSource + 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) SetReferenceId(v string) *ReferenceDataSourceDescription + func (s *ReferenceDataSourceDescription) SetReferenceSchema(v *SourceSchema) *ReferenceDataSourceDescription + func (s *ReferenceDataSourceDescription) SetS3ReferenceDataSourceDescription(v *S3ReferenceDataSourceDescription) *ReferenceDataSourceDescription + func (s *ReferenceDataSourceDescription) SetTableName(v string) *ReferenceDataSourceDescription + func (s ReferenceDataSourceDescription) GoString() string + func (s ReferenceDataSourceDescription) String() string + type ReferenceDataSourceUpdate struct + ReferenceId *string + ReferenceSchemaUpdate *SourceSchema + S3ReferenceDataSourceUpdate *S3ReferenceDataSourceUpdate + TableNameUpdate *string + func (s *ReferenceDataSourceUpdate) SetReferenceId(v string) *ReferenceDataSourceUpdate + func (s *ReferenceDataSourceUpdate) SetReferenceSchemaUpdate(v *SourceSchema) *ReferenceDataSourceUpdate + func (s *ReferenceDataSourceUpdate) SetS3ReferenceDataSourceUpdate(v *S3ReferenceDataSourceUpdate) *ReferenceDataSourceUpdate + func (s *ReferenceDataSourceUpdate) SetTableNameUpdate(v string) *ReferenceDataSourceUpdate + func (s *ReferenceDataSourceUpdate) Validate() error + func (s ReferenceDataSourceUpdate) GoString() string + func (s ReferenceDataSourceUpdate) String() string + type ResourceInUseException struct + Message_ *string + RespMetadata protocol.ResponseMetadata + func (s *ResourceInUseException) Code() string + func (s *ResourceInUseException) Error() string + func (s *ResourceInUseException) Message() string + func (s *ResourceInUseException) OrigErr() error + func (s *ResourceInUseException) RequestID() string + func (s *ResourceInUseException) StatusCode() int + func (s ResourceInUseException) GoString() string + func (s ResourceInUseException) String() string + type ResourceNotFoundException struct + Message_ *string + RespMetadata protocol.ResponseMetadata + func (s *ResourceNotFoundException) Code() string + func (s *ResourceNotFoundException) Error() string + func (s *ResourceNotFoundException) Message() string + func (s *ResourceNotFoundException) OrigErr() error + func (s *ResourceNotFoundException) RequestID() string + func (s *ResourceNotFoundException) StatusCode() int + func (s ResourceNotFoundException) GoString() string + func (s ResourceNotFoundException) String() string + type ResourceProvisionedThroughputExceededException struct + Message_ *string + RespMetadata protocol.ResponseMetadata + func (s *ResourceProvisionedThroughputExceededException) Code() string + func (s *ResourceProvisionedThroughputExceededException) Error() string + func (s *ResourceProvisionedThroughputExceededException) Message() string + func (s *ResourceProvisionedThroughputExceededException) OrigErr() error + func (s *ResourceProvisionedThroughputExceededException) RequestID() string + func (s *ResourceProvisionedThroughputExceededException) StatusCode() int + func (s ResourceProvisionedThroughputExceededException) GoString() string + func (s ResourceProvisionedThroughputExceededException) String() string + type S3Configuration struct + BucketARN *string + FileKey *string + RoleARN *string + func (s *S3Configuration) SetBucketARN(v string) *S3Configuration + func (s *S3Configuration) SetFileKey(v string) *S3Configuration + func (s *S3Configuration) SetRoleARN(v string) *S3Configuration + func (s *S3Configuration) Validate() error + func (s S3Configuration) GoString() string + func (s S3Configuration) String() string + type S3ReferenceDataSource struct + BucketARN *string + FileKey *string + ReferenceRoleARN *string + func (s *S3ReferenceDataSource) SetBucketARN(v string) *S3ReferenceDataSource + func (s *S3ReferenceDataSource) SetFileKey(v string) *S3ReferenceDataSource + func (s *S3ReferenceDataSource) SetReferenceRoleARN(v string) *S3ReferenceDataSource + 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) SetBucketARN(v string) *S3ReferenceDataSourceDescription + func (s *S3ReferenceDataSourceDescription) SetFileKey(v string) *S3ReferenceDataSourceDescription + func (s *S3ReferenceDataSourceDescription) SetReferenceRoleARN(v string) *S3ReferenceDataSourceDescription + func (s S3ReferenceDataSourceDescription) GoString() string + func (s S3ReferenceDataSourceDescription) String() string + type S3ReferenceDataSourceUpdate struct + BucketARNUpdate *string + FileKeyUpdate *string + ReferenceRoleARNUpdate *string + func (s *S3ReferenceDataSourceUpdate) SetBucketARNUpdate(v string) *S3ReferenceDataSourceUpdate + func (s *S3ReferenceDataSourceUpdate) SetFileKeyUpdate(v string) *S3ReferenceDataSourceUpdate + func (s *S3ReferenceDataSourceUpdate) SetReferenceRoleARNUpdate(v string) *S3ReferenceDataSourceUpdate + func (s *S3ReferenceDataSourceUpdate) Validate() error + func (s S3ReferenceDataSourceUpdate) GoString() string + func (s S3ReferenceDataSourceUpdate) String() string + type ServiceUnavailableException struct + Message_ *string + RespMetadata protocol.ResponseMetadata + func (s *ServiceUnavailableException) Code() string + func (s *ServiceUnavailableException) Error() string + func (s *ServiceUnavailableException) Message() string + func (s *ServiceUnavailableException) OrigErr() error + func (s *ServiceUnavailableException) RequestID() string + func (s *ServiceUnavailableException) StatusCode() int + func (s ServiceUnavailableException) GoString() string + func (s ServiceUnavailableException) String() string + type SourceSchema struct + RecordColumns []*RecordColumn + RecordEncoding *string + RecordFormat *RecordFormat + func (s *SourceSchema) SetRecordColumns(v []*RecordColumn) *SourceSchema + func (s *SourceSchema) SetRecordEncoding(v string) *SourceSchema + func (s *SourceSchema) SetRecordFormat(v *RecordFormat) *SourceSchema + func (s *SourceSchema) Validate() error + func (s SourceSchema) GoString() string + func (s SourceSchema) String() string + type StartApplicationInput struct + ApplicationName *string + InputConfigurations []*InputConfiguration + func (s *StartApplicationInput) SetApplicationName(v string) *StartApplicationInput + func (s *StartApplicationInput) SetInputConfigurations(v []*InputConfiguration) *StartApplicationInput + 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) String() string + type StopApplicationInput struct + ApplicationName *string + func (s *StopApplicationInput) SetApplicationName(v string) *StopApplicationInput + 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) String() string + type Tag struct + Key *string + Value *string + func (s *Tag) SetKey(v string) *Tag + func (s *Tag) SetValue(v string) *Tag + func (s *Tag) Validate() error + func (s Tag) GoString() string + func (s Tag) String() string + type TagResourceInput struct + ResourceARN *string + Tags []*Tag + func (s *TagResourceInput) SetResourceARN(v string) *TagResourceInput + func (s *TagResourceInput) SetTags(v []*Tag) *TagResourceInput + func (s *TagResourceInput) Validate() error + func (s TagResourceInput) GoString() string + func (s TagResourceInput) String() string + type TagResourceOutput struct + func (s TagResourceOutput) GoString() string + func (s TagResourceOutput) String() string + type TooManyTagsException struct + Message_ *string + RespMetadata protocol.ResponseMetadata + func (s *TooManyTagsException) Code() string + func (s *TooManyTagsException) Error() string + func (s *TooManyTagsException) Message() string + func (s *TooManyTagsException) OrigErr() error + func (s *TooManyTagsException) RequestID() string + func (s *TooManyTagsException) StatusCode() int + func (s TooManyTagsException) GoString() string + func (s TooManyTagsException) String() string + type UnableToDetectSchemaException struct + Message_ *string + ProcessedInputRecords []*string + RawInputRecords []*string + RespMetadata protocol.ResponseMetadata + func (s *UnableToDetectSchemaException) Code() string + func (s *UnableToDetectSchemaException) Error() string + func (s *UnableToDetectSchemaException) Message() string + func (s *UnableToDetectSchemaException) OrigErr() error + func (s *UnableToDetectSchemaException) RequestID() string + func (s *UnableToDetectSchemaException) StatusCode() int + func (s UnableToDetectSchemaException) GoString() string + func (s UnableToDetectSchemaException) String() string + type UnsupportedOperationException struct + Message_ *string + RespMetadata protocol.ResponseMetadata + func (s *UnsupportedOperationException) Code() string + func (s *UnsupportedOperationException) Error() string + func (s *UnsupportedOperationException) Message() string + func (s *UnsupportedOperationException) OrigErr() error + func (s *UnsupportedOperationException) RequestID() string + func (s *UnsupportedOperationException) StatusCode() int + func (s UnsupportedOperationException) GoString() string + func (s UnsupportedOperationException) String() string + type UntagResourceInput struct + ResourceARN *string + TagKeys []*string + func (s *UntagResourceInput) SetResourceARN(v string) *UntagResourceInput + func (s *UntagResourceInput) SetTagKeys(v []*string) *UntagResourceInput + func (s *UntagResourceInput) Validate() error + func (s UntagResourceInput) GoString() string + func (s UntagResourceInput) String() string + type UntagResourceOutput struct + func (s UntagResourceOutput) GoString() string + func (s UntagResourceOutput) String() string + type UpdateApplicationInput struct + ApplicationName *string + ApplicationUpdate *ApplicationUpdate + CurrentApplicationVersionId *int64 + func (s *UpdateApplicationInput) SetApplicationName(v string) *UpdateApplicationInput + func (s *UpdateApplicationInput) SetApplicationUpdate(v *ApplicationUpdate) *UpdateApplicationInput + func (s *UpdateApplicationInput) SetCurrentApplicationVersionId(v int64) *UpdateApplicationInput + func (s *UpdateApplicationInput) Validate() error + func (s UpdateApplicationInput) GoString() string + func (s UpdateApplicationInput) String() string + type UpdateApplicationOutput struct + func (s UpdateApplicationOutput) GoString() string + func (s UpdateApplicationOutput) String() string
Go to main page