firehose

Feb 8, 2017

Changes in this version

+ const ErrCodeConcurrentModificationException

+ const ErrCodeInvalidArgumentException

+ const ErrCodeLimitExceededException

+ const ErrCodeResourceInUseException

+ const ErrCodeResourceNotFoundException

+ const ErrCodeServiceUnavailableException

Dec 22, 2016

Changes in this version

+ const ProcessorParameterNameLambdaArn

+ const ProcessorParameterNameNumberOfRetries

+ const ProcessorTypeLambda

+ const RedshiftS3BackupModeDisabled

+ const RedshiftS3BackupModeEnabled

+ const S3BackupModeDisabled

+ const S3BackupModeEnabled

type CreateDeliveryStreamInput

+ ExtendedS3DestinationConfiguration *ExtendedS3DestinationConfiguration

+ func (s *CreateDeliveryStreamInput) SetExtendedS3DestinationConfiguration(v *ExtendedS3DestinationConfiguration) *CreateDeliveryStreamInput

type DestinationDescription

+ ExtendedS3DestinationDescription *ExtendedS3DestinationDescription

+ func (s *DestinationDescription) SetExtendedS3DestinationDescription(v *ExtendedS3DestinationDescription) *DestinationDescription

type ElasticsearchDestinationConfiguration

+ ProcessingConfiguration *ProcessingConfiguration

+ func (s *ElasticsearchDestinationConfiguration) SetProcessingConfiguration(v *ProcessingConfiguration) *ElasticsearchDestinationConfiguration

type ElasticsearchDestinationDescription

+ ProcessingConfiguration *ProcessingConfiguration

+ func (s *ElasticsearchDestinationDescription) SetProcessingConfiguration(v *ProcessingConfiguration) *ElasticsearchDestinationDescription

type ElasticsearchDestinationUpdate

+ ProcessingConfiguration *ProcessingConfiguration

+ func (s *ElasticsearchDestinationUpdate) SetProcessingConfiguration(v *ProcessingConfiguration) *ElasticsearchDestinationUpdate

+ type ExtendedS3DestinationConfiguration struct

+ BucketARN *string

+ BufferingHints *BufferingHints

+ CloudWatchLoggingOptions *CloudWatchLoggingOptions

+ CompressionFormat *string

+ EncryptionConfiguration *EncryptionConfiguration

+ Prefix *string

+ ProcessingConfiguration *ProcessingConfiguration

+ RoleARN *string

+ S3BackupConfiguration *S3DestinationConfiguration

+ S3BackupMode *string

+ func (s *ExtendedS3DestinationConfiguration) SetBucketARN(v string) *ExtendedS3DestinationConfiguration

+ func (s *ExtendedS3DestinationConfiguration) SetBufferingHints(v *BufferingHints) *ExtendedS3DestinationConfiguration

+ func (s *ExtendedS3DestinationConfiguration) SetCloudWatchLoggingOptions(v *CloudWatchLoggingOptions) *ExtendedS3DestinationConfiguration

+ func (s *ExtendedS3DestinationConfiguration) SetCompressionFormat(v string) *ExtendedS3DestinationConfiguration

+ func (s *ExtendedS3DestinationConfiguration) SetEncryptionConfiguration(v *EncryptionConfiguration) *ExtendedS3DestinationConfiguration

+ func (s *ExtendedS3DestinationConfiguration) SetPrefix(v string) *ExtendedS3DestinationConfiguration

+ func (s *ExtendedS3DestinationConfiguration) SetProcessingConfiguration(v *ProcessingConfiguration) *ExtendedS3DestinationConfiguration

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

+ func (s *ExtendedS3DestinationConfiguration) SetS3BackupConfiguration(v *S3DestinationConfiguration) *ExtendedS3DestinationConfiguration

+ func (s *ExtendedS3DestinationConfiguration) SetS3BackupMode(v string) *ExtendedS3DestinationConfiguration

+ func (s *ExtendedS3DestinationConfiguration) Validate() error

+ func (s ExtendedS3DestinationConfiguration) GoString() string

+ func (s ExtendedS3DestinationConfiguration) String() string

+ type ExtendedS3DestinationDescription struct

+ BucketARN *string

+ BufferingHints *BufferingHints

+ CloudWatchLoggingOptions *CloudWatchLoggingOptions

+ CompressionFormat *string

+ EncryptionConfiguration *EncryptionConfiguration

+ Prefix *string

+ ProcessingConfiguration *ProcessingConfiguration

+ RoleARN *string

+ S3BackupDescription *S3DestinationDescription

+ S3BackupMode *string

+ func (s *ExtendedS3DestinationDescription) SetBucketARN(v string) *ExtendedS3DestinationDescription

+ func (s *ExtendedS3DestinationDescription) SetBufferingHints(v *BufferingHints) *ExtendedS3DestinationDescription

+ func (s *ExtendedS3DestinationDescription) SetCloudWatchLoggingOptions(v *CloudWatchLoggingOptions) *ExtendedS3DestinationDescription

+ func (s *ExtendedS3DestinationDescription) SetCompressionFormat(v string) *ExtendedS3DestinationDescription

+ func (s *ExtendedS3DestinationDescription) SetEncryptionConfiguration(v *EncryptionConfiguration) *ExtendedS3DestinationDescription

+ func (s *ExtendedS3DestinationDescription) SetPrefix(v string) *ExtendedS3DestinationDescription

+ func (s *ExtendedS3DestinationDescription) SetProcessingConfiguration(v *ProcessingConfiguration) *ExtendedS3DestinationDescription

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

+ func (s *ExtendedS3DestinationDescription) SetS3BackupDescription(v *S3DestinationDescription) *ExtendedS3DestinationDescription

+ func (s *ExtendedS3DestinationDescription) SetS3BackupMode(v string) *ExtendedS3DestinationDescription

+ func (s ExtendedS3DestinationDescription) GoString() string

+ func (s ExtendedS3DestinationDescription) String() string

+ type ExtendedS3DestinationUpdate struct

+ BucketARN *string

+ BufferingHints *BufferingHints

+ CloudWatchLoggingOptions *CloudWatchLoggingOptions

+ CompressionFormat *string

+ EncryptionConfiguration *EncryptionConfiguration

+ Prefix *string

+ ProcessingConfiguration *ProcessingConfiguration

+ RoleARN *string

+ S3BackupMode *string

+ S3BackupUpdate *S3DestinationUpdate

+ func (s *ExtendedS3DestinationUpdate) SetBucketARN(v string) *ExtendedS3DestinationUpdate

+ func (s *ExtendedS3DestinationUpdate) SetBufferingHints(v *BufferingHints) *ExtendedS3DestinationUpdate

+ func (s *ExtendedS3DestinationUpdate) SetCloudWatchLoggingOptions(v *CloudWatchLoggingOptions) *ExtendedS3DestinationUpdate

+ func (s *ExtendedS3DestinationUpdate) SetCompressionFormat(v string) *ExtendedS3DestinationUpdate

+ func (s *ExtendedS3DestinationUpdate) SetEncryptionConfiguration(v *EncryptionConfiguration) *ExtendedS3DestinationUpdate

+ func (s *ExtendedS3DestinationUpdate) SetPrefix(v string) *ExtendedS3DestinationUpdate

+ func (s *ExtendedS3DestinationUpdate) SetProcessingConfiguration(v *ProcessingConfiguration) *ExtendedS3DestinationUpdate

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

+ func (s *ExtendedS3DestinationUpdate) SetS3BackupMode(v string) *ExtendedS3DestinationUpdate

+ func (s *ExtendedS3DestinationUpdate) SetS3BackupUpdate(v *S3DestinationUpdate) *ExtendedS3DestinationUpdate

+ func (s *ExtendedS3DestinationUpdate) Validate() error

+ func (s ExtendedS3DestinationUpdate) GoString() string

+ func (s ExtendedS3DestinationUpdate) String() string

+ type ProcessingConfiguration struct

+ Enabled *bool

+ Processors []*Processor

+ func (s *ProcessingConfiguration) SetEnabled(v bool) *ProcessingConfiguration

+ func (s *ProcessingConfiguration) SetProcessors(v []*Processor) *ProcessingConfiguration

+ func (s *ProcessingConfiguration) Validate() error

+ func (s ProcessingConfiguration) GoString() string

+ func (s ProcessingConfiguration) String() string

+ type Processor struct

+ Parameters []*ProcessorParameter

+ Type *string

+ func (s *Processor) SetParameters(v []*ProcessorParameter) *Processor

+ func (s *Processor) SetType(v string) *Processor

+ func (s *Processor) Validate() error

+ func (s Processor) GoString() string

+ func (s Processor) String() string

+ type ProcessorParameter struct

+ ParameterName *string

+ ParameterValue *string

+ func (s *ProcessorParameter) SetParameterName(v string) *ProcessorParameter

+ func (s *ProcessorParameter) SetParameterValue(v string) *ProcessorParameter

+ func (s *ProcessorParameter) Validate() error

+ func (s ProcessorParameter) GoString() string

+ func (s ProcessorParameter) String() string

type RedshiftDestinationConfiguration

+ ProcessingConfiguration *ProcessingConfiguration

+ S3BackupConfiguration *S3DestinationConfiguration

+ S3BackupMode *string

+ func (s *RedshiftDestinationConfiguration) SetProcessingConfiguration(v *ProcessingConfiguration) *RedshiftDestinationConfiguration

+ func (s *RedshiftDestinationConfiguration) SetS3BackupConfiguration(v *S3DestinationConfiguration) *RedshiftDestinationConfiguration

+ func (s *RedshiftDestinationConfiguration) SetS3BackupMode(v string) *RedshiftDestinationConfiguration

type RedshiftDestinationDescription

+ ProcessingConfiguration *ProcessingConfiguration

+ S3BackupDescription *S3DestinationDescription

+ S3BackupMode *string

+ func (s *RedshiftDestinationDescription) SetProcessingConfiguration(v *ProcessingConfiguration) *RedshiftDestinationDescription

+ func (s *RedshiftDestinationDescription) SetS3BackupDescription(v *S3DestinationDescription) *RedshiftDestinationDescription

+ func (s *RedshiftDestinationDescription) SetS3BackupMode(v string) *RedshiftDestinationDescription

type RedshiftDestinationUpdate

+ ProcessingConfiguration *ProcessingConfiguration

+ S3BackupMode *string

+ S3BackupUpdate *S3DestinationUpdate

+ func (s *RedshiftDestinationUpdate) SetProcessingConfiguration(v *ProcessingConfiguration) *RedshiftDestinationUpdate

+ func (s *RedshiftDestinationUpdate) SetS3BackupMode(v string) *RedshiftDestinationUpdate

+ func (s *RedshiftDestinationUpdate) SetS3BackupUpdate(v *S3DestinationUpdate) *RedshiftDestinationUpdate

type UpdateDestinationInput

+ ExtendedS3DestinationUpdate *ExtendedS3DestinationUpdate

+ func (s *UpdateDestinationInput) SetExtendedS3DestinationUpdate(v *ExtendedS3DestinationUpdate) *UpdateDestinationInput

Dec 19, 2016

Changes in this version

+ const EndpointsID

Nov 1, 2016

Changes in this version

type BufferingHints

+ func (s *BufferingHints) SetIntervalInSeconds(v int64) *BufferingHints

+ func (s *BufferingHints) SetSizeInMBs(v int64) *BufferingHints

type CloudWatchLoggingOptions

+ func (s *CloudWatchLoggingOptions) SetEnabled(v bool) *CloudWatchLoggingOptions

+ func (s *CloudWatchLoggingOptions) SetLogGroupName(v string) *CloudWatchLoggingOptions

+ func (s *CloudWatchLoggingOptions) SetLogStreamName(v string) *CloudWatchLoggingOptions

type CopyCommand

+ func (s *CopyCommand) SetCopyOptions(v string) *CopyCommand

+ func (s *CopyCommand) SetDataTableColumns(v string) *CopyCommand

+ func (s *CopyCommand) SetDataTableName(v string) *CopyCommand

type CreateDeliveryStreamInput

+ func (s *CreateDeliveryStreamInput) SetDeliveryStreamName(v string) *CreateDeliveryStreamInput

+ func (s *CreateDeliveryStreamInput) SetElasticsearchDestinationConfiguration(v *ElasticsearchDestinationConfiguration) *CreateDeliveryStreamInput

+ func (s *CreateDeliveryStreamInput) SetRedshiftDestinationConfiguration(v *RedshiftDestinationConfiguration) *CreateDeliveryStreamInput

+ func (s *CreateDeliveryStreamInput) SetS3DestinationConfiguration(v *S3DestinationConfiguration) *CreateDeliveryStreamInput

type CreateDeliveryStreamOutput

+ func (s *CreateDeliveryStreamOutput) SetDeliveryStreamARN(v string) *CreateDeliveryStreamOutput

type DeleteDeliveryStreamInput

+ func (s *DeleteDeliveryStreamInput) SetDeliveryStreamName(v string) *DeleteDeliveryStreamInput

type DeliveryStreamDescription

+ func (s *DeliveryStreamDescription) SetCreateTimestamp(v time.Time) *DeliveryStreamDescription

+ func (s *DeliveryStreamDescription) SetDeliveryStreamARN(v string) *DeliveryStreamDescription

+ func (s *DeliveryStreamDescription) SetDeliveryStreamName(v string) *DeliveryStreamDescription

+ func (s *DeliveryStreamDescription) SetDeliveryStreamStatus(v string) *DeliveryStreamDescription

+ func (s *DeliveryStreamDescription) SetDestinations(v []*DestinationDescription) *DeliveryStreamDescription

+ func (s *DeliveryStreamDescription) SetHasMoreDestinations(v bool) *DeliveryStreamDescription

+ func (s *DeliveryStreamDescription) SetLastUpdateTimestamp(v time.Time) *DeliveryStreamDescription

+ func (s *DeliveryStreamDescription) SetVersionId(v string) *DeliveryStreamDescription

type DescribeDeliveryStreamInput

+ func (s *DescribeDeliveryStreamInput) SetDeliveryStreamName(v string) *DescribeDeliveryStreamInput

+ func (s *DescribeDeliveryStreamInput) SetExclusiveStartDestinationId(v string) *DescribeDeliveryStreamInput

+ func (s *DescribeDeliveryStreamInput) SetLimit(v int64) *DescribeDeliveryStreamInput

type DescribeDeliveryStreamOutput

+ func (s *DescribeDeliveryStreamOutput) SetDeliveryStreamDescription(v *DeliveryStreamDescription) *DescribeDeliveryStreamOutput

type DestinationDescription

+ func (s *DestinationDescription) SetDestinationId(v string) *DestinationDescription

+ func (s *DestinationDescription) SetElasticsearchDestinationDescription(v *ElasticsearchDestinationDescription) *DestinationDescription

+ func (s *DestinationDescription) SetRedshiftDestinationDescription(v *RedshiftDestinationDescription) *DestinationDescription

+ func (s *DestinationDescription) SetS3DestinationDescription(v *S3DestinationDescription) *DestinationDescription

type ElasticsearchBufferingHints

+ func (s *ElasticsearchBufferingHints) SetIntervalInSeconds(v int64) *ElasticsearchBufferingHints

+ func (s *ElasticsearchBufferingHints) SetSizeInMBs(v int64) *ElasticsearchBufferingHints

type ElasticsearchDestinationConfiguration

+ func (s *ElasticsearchDestinationConfiguration) SetBufferingHints(v *ElasticsearchBufferingHints) *ElasticsearchDestinationConfiguration

+ func (s *ElasticsearchDestinationConfiguration) SetCloudWatchLoggingOptions(v *CloudWatchLoggingOptions) *ElasticsearchDestinationConfiguration

+ func (s *ElasticsearchDestinationConfiguration) SetDomainARN(v string) *ElasticsearchDestinationConfiguration

+ func (s *ElasticsearchDestinationConfiguration) SetIndexName(v string) *ElasticsearchDestinationConfiguration

+ func (s *ElasticsearchDestinationConfiguration) SetIndexRotationPeriod(v string) *ElasticsearchDestinationConfiguration

+ func (s *ElasticsearchDestinationConfiguration) SetRetryOptions(v *ElasticsearchRetryOptions) *ElasticsearchDestinationConfiguration

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

+ func (s *ElasticsearchDestinationConfiguration) SetS3BackupMode(v string) *ElasticsearchDestinationConfiguration

+ func (s *ElasticsearchDestinationConfiguration) SetS3Configuration(v *S3DestinationConfiguration) *ElasticsearchDestinationConfiguration

+ func (s *ElasticsearchDestinationConfiguration) SetTypeName(v string) *ElasticsearchDestinationConfiguration

type ElasticsearchDestinationDescription

+ func (s *ElasticsearchDestinationDescription) SetBufferingHints(v *ElasticsearchBufferingHints) *ElasticsearchDestinationDescription

+ func (s *ElasticsearchDestinationDescription) SetCloudWatchLoggingOptions(v *CloudWatchLoggingOptions) *ElasticsearchDestinationDescription

+ func (s *ElasticsearchDestinationDescription) SetDomainARN(v string) *ElasticsearchDestinationDescription

+ func (s *ElasticsearchDestinationDescription) SetIndexName(v string) *ElasticsearchDestinationDescription

+ func (s *ElasticsearchDestinationDescription) SetIndexRotationPeriod(v string) *ElasticsearchDestinationDescription

+ func (s *ElasticsearchDestinationDescription) SetRetryOptions(v *ElasticsearchRetryOptions) *ElasticsearchDestinationDescription

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

+ func (s *ElasticsearchDestinationDescription) SetS3BackupMode(v string) *ElasticsearchDestinationDescription

+ func (s *ElasticsearchDestinationDescription) SetS3DestinationDescription(v *S3DestinationDescription) *ElasticsearchDestinationDescription

+ func (s *ElasticsearchDestinationDescription) SetTypeName(v string) *ElasticsearchDestinationDescription

type ElasticsearchDestinationUpdate

+ func (s *ElasticsearchDestinationUpdate) SetBufferingHints(v *ElasticsearchBufferingHints) *ElasticsearchDestinationUpdate

+ func (s *ElasticsearchDestinationUpdate) SetCloudWatchLoggingOptions(v *CloudWatchLoggingOptions) *ElasticsearchDestinationUpdate

+ func (s *ElasticsearchDestinationUpdate) SetDomainARN(v string) *ElasticsearchDestinationUpdate

+ func (s *ElasticsearchDestinationUpdate) SetIndexName(v string) *ElasticsearchDestinationUpdate

+ func (s *ElasticsearchDestinationUpdate) SetIndexRotationPeriod(v string) *ElasticsearchDestinationUpdate

+ func (s *ElasticsearchDestinationUpdate) SetRetryOptions(v *ElasticsearchRetryOptions) *ElasticsearchDestinationUpdate

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

+ func (s *ElasticsearchDestinationUpdate) SetS3Update(v *S3DestinationUpdate) *ElasticsearchDestinationUpdate

+ func (s *ElasticsearchDestinationUpdate) SetTypeName(v string) *ElasticsearchDestinationUpdate

type ElasticsearchRetryOptions

+ func (s *ElasticsearchRetryOptions) SetDurationInSeconds(v int64) *ElasticsearchRetryOptions

type EncryptionConfiguration

+ func (s *EncryptionConfiguration) SetKMSEncryptionConfig(v *KMSEncryptionConfig) *EncryptionConfiguration

+ func (s *EncryptionConfiguration) SetNoEncryptionConfig(v string) *EncryptionConfiguration

type KMSEncryptionConfig

+ func (s *KMSEncryptionConfig) SetAWSKMSKeyARN(v string) *KMSEncryptionConfig

type ListDeliveryStreamsInput

+ func (s *ListDeliveryStreamsInput) SetExclusiveStartDeliveryStreamName(v string) *ListDeliveryStreamsInput

+ func (s *ListDeliveryStreamsInput) SetLimit(v int64) *ListDeliveryStreamsInput

type ListDeliveryStreamsOutput

+ func (s *ListDeliveryStreamsOutput) SetDeliveryStreamNames(v []*string) *ListDeliveryStreamsOutput

+ func (s *ListDeliveryStreamsOutput) SetHasMoreDeliveryStreams(v bool) *ListDeliveryStreamsOutput

type PutRecordBatchInput

+ func (s *PutRecordBatchInput) SetDeliveryStreamName(v string) *PutRecordBatchInput

+ func (s *PutRecordBatchInput) SetRecords(v []*Record) *PutRecordBatchInput

type PutRecordBatchOutput

+ func (s *PutRecordBatchOutput) SetFailedPutCount(v int64) *PutRecordBatchOutput

+ func (s *PutRecordBatchOutput) SetRequestResponses(v []*PutRecordBatchResponseEntry) *PutRecordBatchOutput

type PutRecordBatchResponseEntry

+ func (s *PutRecordBatchResponseEntry) SetErrorCode(v string) *PutRecordBatchResponseEntry

+ func (s *PutRecordBatchResponseEntry) SetErrorMessage(v string) *PutRecordBatchResponseEntry

+ func (s *PutRecordBatchResponseEntry) SetRecordId(v string) *PutRecordBatchResponseEntry

type PutRecordInput

+ func (s *PutRecordInput) SetDeliveryStreamName(v string) *PutRecordInput

+ func (s *PutRecordInput) SetRecord(v *Record) *PutRecordInput

type PutRecordOutput

+ func (s *PutRecordOutput) SetRecordId(v string) *PutRecordOutput

type Record

+ func (s *Record) SetData(v []byte) *Record

type RedshiftDestinationConfiguration

+ func (s *RedshiftDestinationConfiguration) SetCloudWatchLoggingOptions(v *CloudWatchLoggingOptions) *RedshiftDestinationConfiguration

+ func (s *RedshiftDestinationConfiguration) SetClusterJDBCURL(v string) *RedshiftDestinationConfiguration

+ func (s *RedshiftDestinationConfiguration) SetCopyCommand(v *CopyCommand) *RedshiftDestinationConfiguration

+ func (s *RedshiftDestinationConfiguration) SetPassword(v string) *RedshiftDestinationConfiguration

+ func (s *RedshiftDestinationConfiguration) SetRetryOptions(v *RedshiftRetryOptions) *RedshiftDestinationConfiguration

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

+ func (s *RedshiftDestinationConfiguration) SetS3Configuration(v *S3DestinationConfiguration) *RedshiftDestinationConfiguration

+ func (s *RedshiftDestinationConfiguration) SetUsername(v string) *RedshiftDestinationConfiguration

type RedshiftDestinationDescription

+ func (s *RedshiftDestinationDescription) SetCloudWatchLoggingOptions(v *CloudWatchLoggingOptions) *RedshiftDestinationDescription

+ func (s *RedshiftDestinationDescription) SetClusterJDBCURL(v string) *RedshiftDestinationDescription

+ func (s *RedshiftDestinationDescription) SetCopyCommand(v *CopyCommand) *RedshiftDestinationDescription

+ func (s *RedshiftDestinationDescription) SetRetryOptions(v *RedshiftRetryOptions) *RedshiftDestinationDescription

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

+ func (s *RedshiftDestinationDescription) SetS3DestinationDescription(v *S3DestinationDescription) *RedshiftDestinationDescription

+ func (s *RedshiftDestinationDescription) SetUsername(v string) *RedshiftDestinationDescription

type RedshiftDestinationUpdate

+ func (s *RedshiftDestinationUpdate) SetCloudWatchLoggingOptions(v *CloudWatchLoggingOptions) *RedshiftDestinationUpdate

+ func (s *RedshiftDestinationUpdate) SetClusterJDBCURL(v string) *RedshiftDestinationUpdate

+ func (s *RedshiftDestinationUpdate) SetCopyCommand(v *CopyCommand) *RedshiftDestinationUpdate

+ func (s *RedshiftDestinationUpdate) SetPassword(v string) *RedshiftDestinationUpdate

+ func (s *RedshiftDestinationUpdate) SetRetryOptions(v *RedshiftRetryOptions) *RedshiftDestinationUpdate

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

+ func (s *RedshiftDestinationUpdate) SetS3Update(v *S3DestinationUpdate) *RedshiftDestinationUpdate

+ func (s *RedshiftDestinationUpdate) SetUsername(v string) *RedshiftDestinationUpdate

type RedshiftRetryOptions

+ func (s *RedshiftRetryOptions) SetDurationInSeconds(v int64) *RedshiftRetryOptions

type S3DestinationConfiguration

+ func (s *S3DestinationConfiguration) SetBucketARN(v string) *S3DestinationConfiguration

+ func (s *S3DestinationConfiguration) SetBufferingHints(v *BufferingHints) *S3DestinationConfiguration

+ func (s *S3DestinationConfiguration) SetCloudWatchLoggingOptions(v *CloudWatchLoggingOptions) *S3DestinationConfiguration

+ func (s *S3DestinationConfiguration) SetCompressionFormat(v string) *S3DestinationConfiguration

+ func (s *S3DestinationConfiguration) SetEncryptionConfiguration(v *EncryptionConfiguration) *S3DestinationConfiguration

+ func (s *S3DestinationConfiguration) SetPrefix(v string) *S3DestinationConfiguration

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

type S3DestinationDescription

+ func (s *S3DestinationDescription) SetBucketARN(v string) *S3DestinationDescription

+ func (s *S3DestinationDescription) SetBufferingHints(v *BufferingHints) *S3DestinationDescription

+ func (s *S3DestinationDescription) SetCloudWatchLoggingOptions(v *CloudWatchLoggingOptions) *S3DestinationDescription

+ func (s *S3DestinationDescription) SetCompressionFormat(v string) *S3DestinationDescription

+ func (s *S3DestinationDescription) SetEncryptionConfiguration(v *EncryptionConfiguration) *S3DestinationDescription

+ func (s *S3DestinationDescription) SetPrefix(v string) *S3DestinationDescription

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

type S3DestinationUpdate

+ func (s *S3DestinationUpdate) SetBucketARN(v string) *S3DestinationUpdate

+ func (s *S3DestinationUpdate) SetBufferingHints(v *BufferingHints) *S3DestinationUpdate

+ func (s *S3DestinationUpdate) SetCloudWatchLoggingOptions(v *CloudWatchLoggingOptions) *S3DestinationUpdate

+ func (s *S3DestinationUpdate) SetCompressionFormat(v string) *S3DestinationUpdate

+ func (s *S3DestinationUpdate) SetEncryptionConfiguration(v *EncryptionConfiguration) *S3DestinationUpdate

+ func (s *S3DestinationUpdate) SetPrefix(v string) *S3DestinationUpdate

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

type UpdateDestinationInput

+ func (s *UpdateDestinationInput) SetCurrentDeliveryStreamVersionId(v string) *UpdateDestinationInput

+ func (s *UpdateDestinationInput) SetDeliveryStreamName(v string) *UpdateDestinationInput

+ func (s *UpdateDestinationInput) SetDestinationId(v string) *UpdateDestinationInput

+ func (s *UpdateDestinationInput) SetElasticsearchDestinationUpdate(v *ElasticsearchDestinationUpdate) *UpdateDestinationInput

+ func (s *UpdateDestinationInput) SetRedshiftDestinationUpdate(v *RedshiftDestinationUpdate) *UpdateDestinationInput

+ func (s *UpdateDestinationInput) SetS3DestinationUpdate(v *S3DestinationUpdate) *UpdateDestinationInput

May 19, 2016

Changes in this version

type RedshiftDestinationConfiguration

+ RetryOptions *RedshiftRetryOptions

type RedshiftDestinationDescription

+ RetryOptions *RedshiftRetryOptions

type RedshiftDestinationUpdate

+ RetryOptions *RedshiftRetryOptions

+ type RedshiftRetryOptions struct

+ DurationInSeconds *int64

+ func (s RedshiftRetryOptions) GoString() string

+ func (s RedshiftRetryOptions) String() string

Apr 28, 2016

Changes in this version

type BufferingHints

+ func (s *BufferingHints) Validate() error

type CopyCommand

+ func (s *CopyCommand) Validate() error

type CreateDeliveryStreamInput

+ func (s *CreateDeliveryStreamInput) Validate() error

type DeleteDeliveryStreamInput

+ func (s *DeleteDeliveryStreamInput) Validate() error

type DescribeDeliveryStreamInput

+ func (s *DescribeDeliveryStreamInput) Validate() error

type ElasticsearchBufferingHints

+ func (s *ElasticsearchBufferingHints) Validate() error

type ElasticsearchDestinationConfiguration

+ func (s *ElasticsearchDestinationConfiguration) Validate() error

type ElasticsearchDestinationUpdate

+ func (s *ElasticsearchDestinationUpdate) Validate() error

type EncryptionConfiguration

+ func (s *EncryptionConfiguration) Validate() error

type KMSEncryptionConfig

+ func (s *KMSEncryptionConfig) Validate() error

type ListDeliveryStreamsInput

+ func (s *ListDeliveryStreamsInput) Validate() error

type PutRecordBatchInput

+ func (s *PutRecordBatchInput) Validate() error

type PutRecordInput

+ func (s *PutRecordInput) Validate() error

type Record

+ func (s *Record) Validate() error

type RedshiftDestinationConfiguration

+ func (s *RedshiftDestinationConfiguration) Validate() error

type RedshiftDestinationUpdate

+ func (s *RedshiftDestinationUpdate) Validate() error

type S3DestinationConfiguration

+ func (s *S3DestinationConfiguration) Validate() error

type S3DestinationUpdate

+ func (s *S3DestinationUpdate) Validate() error

type UpdateDestinationInput

+ func (s *UpdateDestinationInput) Validate() error

Apr 19, 2016

Changes in this version

+ const ElasticsearchIndexRotationPeriodNoRotation

+ const ElasticsearchIndexRotationPeriodOneDay

+ const ElasticsearchIndexRotationPeriodOneHour

+ const ElasticsearchIndexRotationPeriodOneMonth

+ const ElasticsearchIndexRotationPeriodOneWeek

+ const ElasticsearchS3BackupModeAllDocuments

+ const ElasticsearchS3BackupModeFailedDocumentsOnly

+ type CloudWatchLoggingOptions struct

+ Enabled *bool

+ LogGroupName *string

+ LogStreamName *string

+ func (s CloudWatchLoggingOptions) GoString() string

+ func (s CloudWatchLoggingOptions) String() string

type CreateDeliveryStreamInput

+ ElasticsearchDestinationConfiguration *ElasticsearchDestinationConfiguration

type DestinationDescription

+ ElasticsearchDestinationDescription *ElasticsearchDestinationDescription

+ type ElasticsearchBufferingHints struct

+ IntervalInSeconds *int64

+ SizeInMBs *int64

+ func (s ElasticsearchBufferingHints) GoString() string

+ func (s ElasticsearchBufferingHints) String() string

+ type ElasticsearchDestinationConfiguration struct

+ BufferingHints *ElasticsearchBufferingHints

+ CloudWatchLoggingOptions *CloudWatchLoggingOptions

+ DomainARN *string

+ IndexName *string

+ IndexRotationPeriod *string

+ RetryOptions *ElasticsearchRetryOptions

+ RoleARN *string

+ S3BackupMode *string

+ S3Configuration *S3DestinationConfiguration

+ TypeName *string

+ func (s ElasticsearchDestinationConfiguration) GoString() string

+ func (s ElasticsearchDestinationConfiguration) String() string

+ type ElasticsearchDestinationDescription struct

+ BufferingHints *ElasticsearchBufferingHints

+ CloudWatchLoggingOptions *CloudWatchLoggingOptions

+ DomainARN *string

+ IndexName *string

+ IndexRotationPeriod *string

+ RetryOptions *ElasticsearchRetryOptions

+ RoleARN *string

+ S3BackupMode *string

+ S3DestinationDescription *S3DestinationDescription

+ TypeName *string

+ func (s ElasticsearchDestinationDescription) GoString() string

+ func (s ElasticsearchDestinationDescription) String() string

+ type ElasticsearchDestinationUpdate struct

+ BufferingHints *ElasticsearchBufferingHints

+ CloudWatchLoggingOptions *CloudWatchLoggingOptions

+ DomainARN *string

+ IndexName *string

+ IndexRotationPeriod *string

+ RetryOptions *ElasticsearchRetryOptions

+ RoleARN *string

+ S3Update *S3DestinationUpdate

+ TypeName *string

+ func (s ElasticsearchDestinationUpdate) GoString() string

+ func (s ElasticsearchDestinationUpdate) String() string

+ type ElasticsearchRetryOptions struct

+ DurationInSeconds *int64

+ func (s ElasticsearchRetryOptions) GoString() string

+ func (s ElasticsearchRetryOptions) String() string

type RedshiftDestinationConfiguration

+ CloudWatchLoggingOptions *CloudWatchLoggingOptions

type RedshiftDestinationDescription

+ CloudWatchLoggingOptions *CloudWatchLoggingOptions

type RedshiftDestinationUpdate

+ CloudWatchLoggingOptions *CloudWatchLoggingOptions

type S3DestinationConfiguration

+ CloudWatchLoggingOptions *CloudWatchLoggingOptions

type S3DestinationDescription

+ CloudWatchLoggingOptions *CloudWatchLoggingOptions

type S3DestinationUpdate

+ CloudWatchLoggingOptions *CloudWatchLoggingOptions

type UpdateDestinationInput

+ ElasticsearchDestinationUpdate *ElasticsearchDestinationUpdate

Oct 29, 2015

Changes in this version

+ const ServiceName

Oct 7, 2015

Changes in this version

+ const CompressionFormatGzip

+ const CompressionFormatSnappy

+ const CompressionFormatUncompressed

+ const CompressionFormatZip

+ const DeliveryStreamStatusActive

+ const DeliveryStreamStatusCreating

+ const DeliveryStreamStatusDeleting

+ const NoEncryptionConfigNoEncryption

+ type BufferingHints struct

+ IntervalInSeconds *int64

+ SizeInMBs *int64

+ func (s BufferingHints) GoString() string

+ func (s BufferingHints) String() string

+ type CopyCommand struct

+ CopyOptions *string

+ DataTableColumns *string

+ DataTableName *string

+ func (s CopyCommand) GoString() string

+ func (s CopyCommand) String() string

+ type CreateDeliveryStreamInput struct

+ DeliveryStreamName *string

+ RedshiftDestinationConfiguration *RedshiftDestinationConfiguration

+ S3DestinationConfiguration *S3DestinationConfiguration

+ func (s CreateDeliveryStreamInput) GoString() string

+ func (s CreateDeliveryStreamInput) String() string

+ type CreateDeliveryStreamOutput struct

+ DeliveryStreamARN *string

+ func (s CreateDeliveryStreamOutput) GoString() string

+ func (s CreateDeliveryStreamOutput) String() string

+ type DeleteDeliveryStreamInput struct

+ DeliveryStreamName *string

+ func (s DeleteDeliveryStreamInput) GoString() string

+ func (s DeleteDeliveryStreamInput) String() string

+ type DeleteDeliveryStreamOutput struct

+ func (s DeleteDeliveryStreamOutput) GoString() string

+ func (s DeleteDeliveryStreamOutput) String() string

+ type DeliveryStreamDescription struct

+ CreateTimestamp *time.Time

+ DeliveryStreamARN *string

+ DeliveryStreamName *string

+ DeliveryStreamStatus *string

+ Destinations []*DestinationDescription

+ HasMoreDestinations *bool

+ LastUpdateTimestamp *time.Time

+ VersionId *string

+ func (s DeliveryStreamDescription) GoString() string

+ func (s DeliveryStreamDescription) String() string

+ type DescribeDeliveryStreamInput struct

+ DeliveryStreamName *string

+ ExclusiveStartDestinationId *string

+ Limit *int64

+ func (s DescribeDeliveryStreamInput) GoString() string

+ func (s DescribeDeliveryStreamInput) String() string

+ type DescribeDeliveryStreamOutput struct

+ DeliveryStreamDescription *DeliveryStreamDescription

+ func (s DescribeDeliveryStreamOutput) GoString() string

+ func (s DescribeDeliveryStreamOutput) String() string

+ type DestinationDescription struct

+ DestinationId *string

+ RedshiftDestinationDescription *RedshiftDestinationDescription

+ S3DestinationDescription *S3DestinationDescription

+ func (s DestinationDescription) GoString() string

+ func (s DestinationDescription) String() string

+ type EncryptionConfiguration struct

+ KMSEncryptionConfig *KMSEncryptionConfig

+ NoEncryptionConfig *string

+ func (s EncryptionConfiguration) GoString() string

+ func (s EncryptionConfiguration) String() string

+ type Firehose struct

+ func New(config *aws.Config) *Firehose

+ func (c *Firehose) CreateDeliveryStream(input *CreateDeliveryStreamInput) (*CreateDeliveryStreamOutput, error)

+ func (c *Firehose) CreateDeliveryStreamRequest(input *CreateDeliveryStreamInput) (req *request.Request, output *CreateDeliveryStreamOutput)

+ func (c *Firehose) DeleteDeliveryStream(input *DeleteDeliveryStreamInput) (*DeleteDeliveryStreamOutput, error)

+ func (c *Firehose) DeleteDeliveryStreamRequest(input *DeleteDeliveryStreamInput) (req *request.Request, output *DeleteDeliveryStreamOutput)

+ func (c *Firehose) DescribeDeliveryStream(input *DescribeDeliveryStreamInput) (*DescribeDeliveryStreamOutput, error)

+ func (c *Firehose) DescribeDeliveryStreamRequest(input *DescribeDeliveryStreamInput) (req *request.Request, output *DescribeDeliveryStreamOutput)

+ func (c *Firehose) ListDeliveryStreams(input *ListDeliveryStreamsInput) (*ListDeliveryStreamsOutput, error)

+ func (c *Firehose) ListDeliveryStreamsRequest(input *ListDeliveryStreamsInput) (req *request.Request, output *ListDeliveryStreamsOutput)

+ func (c *Firehose) PutRecord(input *PutRecordInput) (*PutRecordOutput, error)

+ func (c *Firehose) PutRecordBatch(input *PutRecordBatchInput) (*PutRecordBatchOutput, error)

+ func (c *Firehose) PutRecordBatchRequest(input *PutRecordBatchInput) (req *request.Request, output *PutRecordBatchOutput)

+ func (c *Firehose) PutRecordRequest(input *PutRecordInput) (req *request.Request, output *PutRecordOutput)

+ func (c *Firehose) UpdateDestination(input *UpdateDestinationInput) (*UpdateDestinationOutput, error)

+ func (c *Firehose) UpdateDestinationRequest(input *UpdateDestinationInput) (req *request.Request, output *UpdateDestinationOutput)

+ type KMSEncryptionConfig struct

+ AWSKMSKeyARN *string

+ func (s KMSEncryptionConfig) GoString() string

+ func (s KMSEncryptionConfig) String() string

+ type ListDeliveryStreamsInput struct

+ ExclusiveStartDeliveryStreamName *string

+ Limit *int64

+ func (s ListDeliveryStreamsInput) GoString() string

+ func (s ListDeliveryStreamsInput) String() string

+ type ListDeliveryStreamsOutput struct

+ DeliveryStreamNames []*string

+ HasMoreDeliveryStreams *bool

+ func (s ListDeliveryStreamsOutput) GoString() string

+ func (s ListDeliveryStreamsOutput) String() string

+ type PutRecordBatchInput struct

+ DeliveryStreamName *string

+ Records []*Record

+ func (s PutRecordBatchInput) GoString() string

+ func (s PutRecordBatchInput) String() string

+ type PutRecordBatchOutput struct

+ FailedPutCount *int64

+ RequestResponses []*PutRecordBatchResponseEntry

+ func (s PutRecordBatchOutput) GoString() string

+ func (s PutRecordBatchOutput) String() string

+ type PutRecordBatchResponseEntry struct

+ ErrorCode *string

+ ErrorMessage *string

+ RecordId *string

+ func (s PutRecordBatchResponseEntry) GoString() string

+ func (s PutRecordBatchResponseEntry) String() string

+ type PutRecordInput struct

+ DeliveryStreamName *string

+ Record *Record

+ func (s PutRecordInput) GoString() string

+ func (s PutRecordInput) String() string

+ type PutRecordOutput struct

+ RecordId *string

+ func (s PutRecordOutput) GoString() string

+ func (s PutRecordOutput) String() string

+ type Record struct

+ Data []byte

+ func (s Record) GoString() string

+ func (s Record) String() string

+ type RedshiftDestinationConfiguration struct

+ ClusterJDBCURL *string

+ CopyCommand *CopyCommand

+ Password *string

+ RoleARN *string

+ S3Configuration *S3DestinationConfiguration

+ Username *string

+ func (s RedshiftDestinationConfiguration) GoString() string

+ func (s RedshiftDestinationConfiguration) String() string

+ type RedshiftDestinationDescription struct

+ ClusterJDBCURL *string

+ CopyCommand *CopyCommand

+ RoleARN *string

+ S3DestinationDescription *S3DestinationDescription

+ Username *string

+ func (s RedshiftDestinationDescription) GoString() string

+ func (s RedshiftDestinationDescription) String() string

+ type RedshiftDestinationUpdate struct

+ ClusterJDBCURL *string

+ CopyCommand *CopyCommand

+ Password *string

+ RoleARN *string

+ S3Update *S3DestinationUpdate

+ Username *string

+ func (s RedshiftDestinationUpdate) GoString() string

+ func (s RedshiftDestinationUpdate) String() string

+ type S3DestinationConfiguration struct

+ BucketARN *string

+ BufferingHints *BufferingHints

+ CompressionFormat *string

+ EncryptionConfiguration *EncryptionConfiguration

+ Prefix *string

+ RoleARN *string

+ func (s S3DestinationConfiguration) GoString() string

+ func (s S3DestinationConfiguration) String() string

+ type S3DestinationDescription struct

+ BucketARN *string

+ BufferingHints *BufferingHints

+ CompressionFormat *string

+ EncryptionConfiguration *EncryptionConfiguration

+ Prefix *string

+ RoleARN *string

+ func (s S3DestinationDescription) GoString() string

+ func (s S3DestinationDescription) String() string

+ type S3DestinationUpdate struct

+ BucketARN *string

+ BufferingHints *BufferingHints

+ CompressionFormat *string

+ EncryptionConfiguration *EncryptionConfiguration

+ Prefix *string

+ RoleARN *string

+ func (s S3DestinationUpdate) GoString() string

+ func (s S3DestinationUpdate) String() string

+ type UpdateDestinationInput struct

+ CurrentDeliveryStreamVersionId *string

+ DeliveryStreamName *string

+ DestinationId *string

+ RedshiftDestinationUpdate *RedshiftDestinationUpdate

+ S3DestinationUpdate *S3DestinationUpdate

+ func (s UpdateDestinationInput) GoString() string

+ func (s UpdateDestinationInput) String() string

+ type UpdateDestinationOutput struct

+ func (s UpdateDestinationOutput) GoString() string

+ func (s UpdateDestinationOutput) String() string