kinesisanalytics

package

Go to main page

Versions in this module

v1

v1.13.9

Mar 6, 2018

Changes in this version

+ 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 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 DiscoverInputSchemaInput

+ InputProcessingConfiguration *InputProcessingConfiguration

+ S3Configuration *S3Configuration

+ func (s *DiscoverInputSchemaInput) SetInputProcessingConfiguration(v *InputProcessingConfiguration) *DiscoverInputSchemaInput

+ func (s *DiscoverInputSchemaInput) SetS3Configuration(v *S3Configuration) *DiscoverInputSchemaInput

type DiscoverInputSchemaOutput

+ ProcessedInputRecords []*string

+ func (s *DiscoverInputSchemaOutput) SetProcessedInputRecords(v []*string) *DiscoverInputSchemaOutput

type Input

+ InputProcessingConfiguration *InputProcessingConfiguration

+ func (s *Input) SetInputProcessingConfiguration(v *InputProcessingConfiguration) *Input

type InputDescription

+ InputProcessingConfigurationDescription *InputProcessingConfigurationDescription

+ func (s *InputDescription) SetInputProcessingConfigurationDescription(v *InputProcessingConfigurationDescription) *InputDescription

+ 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 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 InputUpdate

+ InputProcessingConfigurationUpdate *InputProcessingConfigurationUpdate

+ func (s *InputUpdate) SetInputProcessingConfigurationUpdate(v *InputProcessingConfigurationUpdate) *InputUpdate

type KinesisAnalytics

+ 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) 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)

+ 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 Output

+ LambdaOutput *LambdaOutput

+ func (s *Output) SetLambdaOutput(v *LambdaOutput) *Output

type OutputDescription

+ LambdaOutputDescription *LambdaOutputDescription

+ func (s *OutputDescription) SetLambdaOutputDescription(v *LambdaOutputDescription) *OutputDescription

type OutputUpdate

+ LambdaOutputUpdate *LambdaOutputUpdate

+ func (s *OutputUpdate) SetLambdaOutputUpdate(v *LambdaOutputUpdate) *OutputUpdate

+ 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

v1.10.18

Jul 27, 2017

Changes in this version

+ const ErrCodeServiceUnavailableException

v1.9.0

Jun 19, 2017

Changes in this version

+ 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 ApplicationDetail

+ CloudWatchLoggingOptionDescriptions []*CloudWatchLoggingOptionDescription

+ func (s *ApplicationDetail) SetCloudWatchLoggingOptionDescriptions(v []*CloudWatchLoggingOptionDescription) *ApplicationDetail

type ApplicationUpdate

+ CloudWatchLoggingOptionUpdates []*CloudWatchLoggingOptionUpdate

+ func (s *ApplicationUpdate) SetCloudWatchLoggingOptionUpdates(v []*CloudWatchLoggingOptionUpdate) *ApplicationUpdate

+ 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 CreateApplicationInput

+ CloudWatchLoggingOptions []*CloudWatchLoggingOption

+ func (s *CreateApplicationInput) SetCloudWatchLoggingOptions(v []*CloudWatchLoggingOption) *CreateApplicationInput

+ 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 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) AddApplicationInputWithContext(ctx aws.Context, input *AddApplicationInputInput, opts ...request.Option) (*AddApplicationInputOutput, error)

+ func (c *KinesisAnalytics) AddApplicationOutputWithContext(ctx aws.Context, input *AddApplicationOutputInput, opts ...request.Option) (*AddApplicationOutputOutput, error)

+ func (c *KinesisAnalytics) AddApplicationReferenceDataSourceWithContext(ctx aws.Context, input *AddApplicationReferenceDataSourceInput, ...) (*AddApplicationReferenceDataSourceOutput, error)

+ func (c *KinesisAnalytics) CreateApplicationWithContext(ctx aws.Context, input *CreateApplicationInput, opts ...request.Option) (*CreateApplicationOutput, 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) DeleteApplicationOutputWithContext(ctx aws.Context, input *DeleteApplicationOutputInput, opts ...request.Option) (*DeleteApplicationOutputOutput, error)

+ func (c *KinesisAnalytics) DeleteApplicationReferenceDataSourceWithContext(ctx aws.Context, input *DeleteApplicationReferenceDataSourceInput, ...) (*DeleteApplicationReferenceDataSourceOutput, error)

+ func (c *KinesisAnalytics) DeleteApplicationWithContext(ctx aws.Context, input *DeleteApplicationInput, opts ...request.Option) (*DeleteApplicationOutput, error)

+ func (c *KinesisAnalytics) DescribeApplicationWithContext(ctx aws.Context, input *DescribeApplicationInput, opts ...request.Option) (*DescribeApplicationOutput, error)

+ func (c *KinesisAnalytics) DiscoverInputSchemaWithContext(ctx aws.Context, input *DiscoverInputSchemaInput, opts ...request.Option) (*DiscoverInputSchemaOutput, error)

+ func (c *KinesisAnalytics) ListApplicationsWithContext(ctx aws.Context, input *ListApplicationsInput, opts ...request.Option) (*ListApplicationsOutput, error)

+ func (c *KinesisAnalytics) StartApplicationWithContext(ctx aws.Context, input *StartApplicationInput, opts ...request.Option) (*StartApplicationOutput, error)

+ func (c *KinesisAnalytics) StopApplicationWithContext(ctx aws.Context, input *StopApplicationInput, opts ...request.Option) (*StopApplicationOutput, error)

+ func (c *KinesisAnalytics) UpdateApplicationWithContext(ctx aws.Context, input *UpdateApplicationInput, opts ...request.Option) (*UpdateApplicationOutput, error)

v1.6.20

Feb 10, 2017

Changes in this version

+ const ErrCodeCodeValidationException

+ const ErrCodeConcurrentModificationException

+ const ErrCodeInvalidApplicationConfigurationException

+ const ErrCodeInvalidArgumentException

+ const ErrCodeLimitExceededException

+ const ErrCodeResourceInUseException

+ const ErrCodeResourceNotFoundException

+ const ErrCodeResourceProvisionedThroughputExceededException

+ const ErrCodeUnableToDetectSchemaException

v1.6.16

Jan 24, 2017

Changes in this version

+ const ApplicationStatusDeleting

+ const ApplicationStatusReady

+ const ApplicationStatusRunning

+ const ApplicationStatusStarting

+ const ApplicationStatusStopping

+ const ApplicationStatusUpdating

+ const EndpointsID

+ const InputStartingPositionLastStoppedPoint

+ const InputStartingPositionNow

+ const InputStartingPositionTrimHorizon

+ const RecordFormatTypeCsv

+ const RecordFormatTypeJson

+ const ServiceName

+ 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 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

+ 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) 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

+ InputUpdates []*InputUpdate

+ OutputUpdates []*OutputUpdate

+ ReferenceDataSourceUpdates []*ReferenceDataSourceUpdate

+ func (s *ApplicationUpdate) SetApplicationCodeUpdate(v string) *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 CreateApplicationInput struct

+ ApplicationCode *string

+ ApplicationDescription *string

+ ApplicationName *string

+ Inputs []*Input

+ Outputs []*Output

+ func (s *CreateApplicationInput) SetApplicationCode(v string) *CreateApplicationInput

+ func (s *CreateApplicationInput) SetApplicationDescription(v string) *CreateApplicationInput

+ func (s *CreateApplicationInput) SetApplicationName(v string) *CreateApplicationInput

+ func (s *CreateApplicationInput) SetInputs(v []*Input) *CreateApplicationInput

+ func (s *CreateApplicationInput) SetOutputs(v []*Output) *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 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 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) GoString() string

+ func (s DestinationSchema) String() string

+ type DiscoverInputSchemaInput struct

+ InputStartingPositionConfiguration *InputStartingPositionConfiguration

+ ResourceARN *string

+ RoleARN *string

+ func (s *DiscoverInputSchemaInput) SetInputStartingPositionConfiguration(v *InputStartingPositionConfiguration) *DiscoverInputSchemaInput

+ func (s *DiscoverInputSchemaInput) SetResourceARN(v string) *DiscoverInputSchemaInput

+ func (s *DiscoverInputSchemaInput) SetRoleARN(v string) *DiscoverInputSchemaInput

+ func (s *DiscoverInputSchemaInput) Validate() error

+ func (s DiscoverInputSchemaInput) GoString() string

+ func (s DiscoverInputSchemaInput) String() string

+ type DiscoverInputSchemaOutput struct

+ InputSchema *SourceSchema

+ ParsedInputRecords [][]*string

+ RawInputRecords []*string

+ func (s *DiscoverInputSchemaOutput) SetInputSchema(v *SourceSchema) *DiscoverInputSchemaOutput

+ func (s *DiscoverInputSchemaOutput) SetParsedInputRecords(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

+ InputSchema *SourceSchema

+ KinesisFirehoseInput *KinesisFirehoseInput

+ KinesisStreamsInput *KinesisStreamsInput

+ NamePrefix *string

+ func (s *Input) SetInputParallelism(v *InputParallelism) *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

+ 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) 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 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 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

+ 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) 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 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) AddApplicationInput(input *AddApplicationInputInput) (*AddApplicationInputOutput, error)

+ func (c *KinesisAnalytics) AddApplicationInputRequest(input *AddApplicationInputInput) (req *request.Request, output *AddApplicationInputOutput)

+ func (c *KinesisAnalytics) AddApplicationOutput(input *AddApplicationOutputInput) (*AddApplicationOutputOutput, error)

+ func (c *KinesisAnalytics) AddApplicationOutputRequest(input *AddApplicationOutputInput) (req *request.Request, output *AddApplicationOutputOutput)

+ func (c *KinesisAnalytics) AddApplicationReferenceDataSource(input *AddApplicationReferenceDataSourceInput) (*AddApplicationReferenceDataSourceOutput, error)

+ func (c *KinesisAnalytics) AddApplicationReferenceDataSourceRequest(input *AddApplicationReferenceDataSourceInput) (req *request.Request, output *AddApplicationReferenceDataSourceOutput)

+ func (c *KinesisAnalytics) CreateApplication(input *CreateApplicationInput) (*CreateApplicationOutput, error)

+ func (c *KinesisAnalytics) CreateApplicationRequest(input *CreateApplicationInput) (req *request.Request, output *CreateApplicationOutput)

+ func (c *KinesisAnalytics) DeleteApplication(input *DeleteApplicationInput) (*DeleteApplicationOutput, error)

+ func (c *KinesisAnalytics) DeleteApplicationOutput(input *DeleteApplicationOutputInput) (*DeleteApplicationOutputOutput, error)

+ func (c *KinesisAnalytics) DeleteApplicationOutputRequest(input *DeleteApplicationOutputInput) (req *request.Request, output *DeleteApplicationOutputOutput)

+ func (c *KinesisAnalytics) DeleteApplicationReferenceDataSource(input *DeleteApplicationReferenceDataSourceInput) (*DeleteApplicationReferenceDataSourceOutput, error)

+ func (c *KinesisAnalytics) DeleteApplicationReferenceDataSourceRequest(input *DeleteApplicationReferenceDataSourceInput) (req *request.Request, output *DeleteApplicationReferenceDataSourceOutput)

+ func (c *KinesisAnalytics) DeleteApplicationRequest(input *DeleteApplicationInput) (req *request.Request, output *DeleteApplicationOutput)

+ func (c *KinesisAnalytics) DescribeApplication(input *DescribeApplicationInput) (*DescribeApplicationOutput, error)

+ func (c *KinesisAnalytics) DescribeApplicationRequest(input *DescribeApplicationInput) (req *request.Request, output *DescribeApplicationOutput)

+ func (c *KinesisAnalytics) DiscoverInputSchema(input *DiscoverInputSchemaInput) (*DiscoverInputSchemaOutput, error)

+ func (c *KinesisAnalytics) DiscoverInputSchemaRequest(input *DiscoverInputSchemaInput) (req *request.Request, output *DiscoverInputSchemaOutput)

+ func (c *KinesisAnalytics) ListApplications(input *ListApplicationsInput) (*ListApplicationsOutput, error)

+ func (c *KinesisAnalytics) ListApplicationsRequest(input *ListApplicationsInput) (req *request.Request, output *ListApplicationsOutput)

+ func (c *KinesisAnalytics) StartApplication(input *StartApplicationInput) (*StartApplicationOutput, error)

+ func (c *KinesisAnalytics) StartApplicationRequest(input *StartApplicationInput) (req *request.Request, output *StartApplicationOutput)

+ func (c *KinesisAnalytics) StopApplication(input *StopApplicationInput) (*StopApplicationOutput, error)

+ func (c *KinesisAnalytics) StopApplicationRequest(input *StopApplicationInput) (req *request.Request, output *StopApplicationOutput)

+ func (c *KinesisAnalytics) UpdateApplication(input *UpdateApplicationInput) (*UpdateApplicationOutput, error)

+ func (c *KinesisAnalytics) UpdateApplicationRequest(input *UpdateApplicationInput) (req *request.Request, output *UpdateApplicationOutput)

+ 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 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 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

+ 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) 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

+ 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) 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

+ 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) 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 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 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 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

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