kinesisanalytics

package

Go to main page

Versions in this module

v0

v0.4.0

May 26, 2018

v0.3.0

Mar 8, 2018

Changes in this version

type AddApplicationCloudWatchLoggingOptionRequest

+ Copy func(*AddApplicationCloudWatchLoggingOptionInput) AddApplicationCloudWatchLoggingOptionRequest

type AddApplicationInputProcessingConfigurationRequest

+ Copy func(*AddApplicationInputProcessingConfigurationInput) AddApplicationInputProcessingConfigurationRequest

type AddApplicationInputRequest

+ Copy func(*AddApplicationInputInput) AddApplicationInputRequest

type AddApplicationOutputRequest

+ Copy func(*AddApplicationOutputInput) AddApplicationOutputRequest

type AddApplicationReferenceDataSourceRequest

+ Copy func(*AddApplicationReferenceDataSourceInput) AddApplicationReferenceDataSourceRequest

type ApplicationStatus

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

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

type CreateApplicationRequest

+ Copy func(*CreateApplicationInput) CreateApplicationRequest

type DeleteApplicationCloudWatchLoggingOptionRequest

+ Copy func(*DeleteApplicationCloudWatchLoggingOptionInput) DeleteApplicationCloudWatchLoggingOptionRequest

type DeleteApplicationInputProcessingConfigurationRequest

+ Copy func(*DeleteApplicationInputProcessingConfigurationInput) DeleteApplicationInputProcessingConfigurationRequest

type DeleteApplicationOutputRequest

+ Copy func(*DeleteApplicationOutputInput) DeleteApplicationOutputRequest

type DeleteApplicationReferenceDataSourceRequest

+ Copy func(*DeleteApplicationReferenceDataSourceInput) DeleteApplicationReferenceDataSourceRequest

type DeleteApplicationRequest

+ Copy func(*DeleteApplicationInput) DeleteApplicationRequest

type DescribeApplicationRequest

+ Copy func(*DescribeApplicationInput) DescribeApplicationRequest

type DiscoverInputSchemaRequest

+ Copy func(*DiscoverInputSchemaInput) DiscoverInputSchemaRequest

type InputStartingPosition

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

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

type ListApplicationsRequest

+ Copy func(*ListApplicationsInput) ListApplicationsRequest

type RecordFormatType

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

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

type StartApplicationRequest

+ Copy func(*StartApplicationInput) StartApplicationRequest

type StopApplicationRequest

+ Copy func(*StopApplicationInput) StopApplicationRequest

type UpdateApplicationRequest

+ Copy func(*UpdateApplicationInput) UpdateApplicationRequest

v0.2.0

Jan 15, 2018

Changes in this version

+ 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

v0.1.0

Dec 21, 2017

Changes in this version

+ const EndpointsID

+ const ErrCodeCodeValidationException

+ const ErrCodeConcurrentModificationException

+ const ErrCodeInvalidApplicationConfigurationException

+ const ErrCodeInvalidArgumentException

+ const ErrCodeLimitExceededException

+ const ErrCodeResourceInUseException

+ const ErrCodeResourceNotFoundException

+ const ErrCodeResourceProvisionedThroughputExceededException

+ const ErrCodeServiceUnavailableException

+ const ErrCodeUnableToDetectSchemaException

+ const ServiceName

+ 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) SDKResponseMetadata() aws.Response

+ func (s AddApplicationCloudWatchLoggingOptionOutput) String() string

+ type AddApplicationCloudWatchLoggingOptionRequest struct

+ Input *AddApplicationCloudWatchLoggingOptionInput

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

+ 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) SDKResponseMetadata() aws.Response

+ 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) SDKResponseMetadata() aws.Response

+ func (s AddApplicationInputProcessingConfigurationOutput) String() string

+ type AddApplicationInputProcessingConfigurationRequest struct

+ Input *AddApplicationInputProcessingConfigurationInput

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

+ type AddApplicationInputRequest struct

+ Input *AddApplicationInputInput

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

+ 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) SDKResponseMetadata() aws.Response

+ func (s AddApplicationOutputOutput) String() string

+ type AddApplicationOutputRequest struct

+ Input *AddApplicationOutputInput

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

+ 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) SDKResponseMetadata() aws.Response

+ func (s AddApplicationReferenceDataSourceOutput) String() string

+ type AddApplicationReferenceDataSourceRequest struct

+ Input *AddApplicationReferenceDataSourceInput

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

+ type ApplicationDetail struct

+ ApplicationARN *string

+ ApplicationCode *string

+ ApplicationDescription *string

+ ApplicationName *string

+ ApplicationStatus ApplicationStatus

+ 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 ApplicationStatus) *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 ApplicationStatus string

+ const ApplicationStatusDeleting

+ const ApplicationStatusReady

+ const ApplicationStatusRunning

+ const ApplicationStatusStarting

+ const ApplicationStatusStopping

+ const ApplicationStatusUpdating

+ type ApplicationSummary struct

+ ApplicationARN *string

+ ApplicationName *string

+ ApplicationStatus ApplicationStatus

+ func (s *ApplicationSummary) SetApplicationARN(v string) *ApplicationSummary

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

+ func (s *ApplicationSummary) SetApplicationStatus(v ApplicationStatus) *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 CreateApplicationInput struct

+ ApplicationCode *string

+ ApplicationDescription *string

+ ApplicationName *string

+ CloudWatchLoggingOptions []CloudWatchLoggingOption

+ 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) SetCloudWatchLoggingOptions(v []CloudWatchLoggingOption) *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) SDKResponseMetadata() aws.Response

+ func (s CreateApplicationOutput) String() string

+ type CreateApplicationRequest struct

+ Input *CreateApplicationInput

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

+ 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) SDKResponseMetadata() aws.Response

+ func (s DeleteApplicationCloudWatchLoggingOptionOutput) String() string

+ type DeleteApplicationCloudWatchLoggingOptionRequest struct

+ Input *DeleteApplicationCloudWatchLoggingOptionInput

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

+ 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) SDKResponseMetadata() aws.Response

+ func (s DeleteApplicationInputProcessingConfigurationOutput) String() string

+ type DeleteApplicationInputProcessingConfigurationRequest struct

+ Input *DeleteApplicationInputProcessingConfigurationInput

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

+ type DeleteApplicationOutput struct

+ func (s DeleteApplicationOutput) GoString() string

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

+ func (s DeleteApplicationOutput) String() string

+ type DeleteApplicationOutputInput struct

+ ApplicationName *string

+ CurrentApplicationVersionId *int64

+ OutputId *string

+ func (s *DeleteApplicationOutputInput) 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) SDKResponseMetadata() aws.Response

+ func (s DeleteApplicationOutputOutput) String() string

+ type DeleteApplicationOutputRequest struct

+ Input *DeleteApplicationOutputInput

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

+ 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) SDKResponseMetadata() aws.Response

+ func (s DeleteApplicationReferenceDataSourceOutput) String() string

+ type DeleteApplicationReferenceDataSourceRequest struct

+ Input *DeleteApplicationReferenceDataSourceInput

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

+ type DeleteApplicationRequest struct

+ Input *DeleteApplicationInput

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

+ 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) SDKResponseMetadata() aws.Response

+ func (s DescribeApplicationOutput) String() string

+ type DescribeApplicationRequest struct

+ Input *DescribeApplicationInput

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

+ type DestinationSchema struct

+ RecordFormatType RecordFormatType

+ func (s *DestinationSchema) SetRecordFormatType(v RecordFormatType) *DestinationSchema

+ 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) SDKResponseMetadata() aws.Response

+ func (s DiscoverInputSchemaOutput) String() string

+ type DiscoverInputSchemaRequest struct

+ Input *DiscoverInputSchemaInput

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

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

+ const InputStartingPositionLastStoppedPoint

+ const InputStartingPositionNow

+ const InputStartingPositionTrimHorizon

+ type InputStartingPositionConfiguration struct

+ InputStartingPosition InputStartingPosition

+ func (s *InputStartingPositionConfiguration) SetInputStartingPosition(v InputStartingPosition) *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 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(config aws.Config) *KinesisAnalytics

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ 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) SDKResponseMetadata() aws.Response

+ func (s ListApplicationsOutput) String() string

+ type ListApplicationsRequest struct

+ Input *ListApplicationsInput

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

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

+ func (s *RecordFormat) SetMappingParameters(v *MappingParameters) *RecordFormat

+ func (s *RecordFormat) SetRecordFormatType(v RecordFormatType) *RecordFormat

+ func (s *RecordFormat) Validate() error

+ func (s RecordFormat) GoString() string

+ func (s RecordFormat) String() string

+ type RecordFormatType string

+ const RecordFormatTypeCsv

+ const RecordFormatTypeJson

+ 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 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 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) SDKResponseMetadata() aws.Response

+ func (s StartApplicationOutput) String() string

+ type StartApplicationRequest struct

+ Input *StartApplicationInput

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

+ 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) SDKResponseMetadata() aws.Response

+ func (s StopApplicationOutput) String() string

+ type StopApplicationRequest struct

+ Input *StopApplicationInput

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

+ 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) SDKResponseMetadata() aws.Response

+ func (s UpdateApplicationOutput) String() string

+ type UpdateApplicationRequest struct

+ Input *UpdateApplicationInput

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

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