Versions in this module Expand all Collapse all v1 v1.11.0 Dec 6, 2022 Changes in this version + const CompressionFormatGzip + const CompressionFormatSnappy + const CompressionFormatUncompressed + const CompressionFormatZip + const DeliveryStreamStatusActive + const DeliveryStreamStatusCreating + const DeliveryStreamStatusDeleting + const DeliveryStreamTypeDirectPut + const DeliveryStreamTypeKinesisStreamAsSource + const ElasticsearchIndexRotationPeriodNoRotation + const ElasticsearchIndexRotationPeriodOneDay + const ElasticsearchIndexRotationPeriodOneHour + const ElasticsearchIndexRotationPeriodOneMonth + const ElasticsearchIndexRotationPeriodOneWeek + const ElasticsearchS3BackupModeAllDocuments + const ElasticsearchS3BackupModeFailedDocumentsOnly + const EndpointsID + const ErrCodeConcurrentModificationException + const ErrCodeInvalidArgumentException + const ErrCodeInvalidStreamTypeException + const ErrCodeLimitExceededException + const ErrCodeResourceInUseException + const ErrCodeResourceNotFoundException + const ErrCodeServiceUnavailableException + const NoEncryptionConfigNoEncryption + const ProcessorParameterNameLambdaArn + const ProcessorParameterNameNumberOfRetries + const ProcessorTypeLambda + const RedshiftS3BackupModeDisabled + const RedshiftS3BackupModeEnabled + const S3BackupModeDisabled + const S3BackupModeEnabled + const ServiceName + type BufferingHints struct + IntervalInSeconds *int64 + SizeInMBs *int64 + func (s *BufferingHints) SetIntervalInSeconds(v int64) *BufferingHints + func (s *BufferingHints) SetSizeInMBs(v int64) *BufferingHints + func (s *BufferingHints) Validate() error + func (s BufferingHints) GoString() string + func (s BufferingHints) String() string + type CloudWatchLoggingOptions struct + Enabled *bool + LogGroupName *string + LogStreamName *string + func (s *CloudWatchLoggingOptions) SetEnabled(v bool) *CloudWatchLoggingOptions + func (s *CloudWatchLoggingOptions) SetLogGroupName(v string) *CloudWatchLoggingOptions + func (s *CloudWatchLoggingOptions) SetLogStreamName(v string) *CloudWatchLoggingOptions + func (s CloudWatchLoggingOptions) GoString() string + func (s CloudWatchLoggingOptions) String() string + type CopyCommand struct + CopyOptions *string + DataTableColumns *string + DataTableName *string + func (s *CopyCommand) SetCopyOptions(v string) *CopyCommand + func (s *CopyCommand) SetDataTableColumns(v string) *CopyCommand + func (s *CopyCommand) SetDataTableName(v string) *CopyCommand + func (s *CopyCommand) Validate() error + func (s CopyCommand) GoString() string + func (s CopyCommand) String() string + type CreateDeliveryStreamInput struct + DeliveryStreamName *string + DeliveryStreamType *string + ElasticsearchDestinationConfiguration *ElasticsearchDestinationConfiguration + ExtendedS3DestinationConfiguration *ExtendedS3DestinationConfiguration + KinesisStreamSourceConfiguration *KinesisStreamSourceConfiguration + RedshiftDestinationConfiguration *RedshiftDestinationConfiguration + S3DestinationConfiguration *S3DestinationConfiguration + func (s *CreateDeliveryStreamInput) SetDeliveryStreamName(v string) *CreateDeliveryStreamInput + func (s *CreateDeliveryStreamInput) SetDeliveryStreamType(v string) *CreateDeliveryStreamInput + func (s *CreateDeliveryStreamInput) SetElasticsearchDestinationConfiguration(v *ElasticsearchDestinationConfiguration) *CreateDeliveryStreamInput + func (s *CreateDeliveryStreamInput) SetExtendedS3DestinationConfiguration(v *ExtendedS3DestinationConfiguration) *CreateDeliveryStreamInput + func (s *CreateDeliveryStreamInput) SetKinesisStreamSourceConfiguration(v *KinesisStreamSourceConfiguration) *CreateDeliveryStreamInput + func (s *CreateDeliveryStreamInput) SetRedshiftDestinationConfiguration(v *RedshiftDestinationConfiguration) *CreateDeliveryStreamInput + func (s *CreateDeliveryStreamInput) SetS3DestinationConfiguration(v *S3DestinationConfiguration) *CreateDeliveryStreamInput + func (s *CreateDeliveryStreamInput) Validate() error + func (s CreateDeliveryStreamInput) GoString() string + func (s CreateDeliveryStreamInput) String() string + type CreateDeliveryStreamOutput struct + DeliveryStreamARN *string + func (s *CreateDeliveryStreamOutput) SetDeliveryStreamARN(v string) *CreateDeliveryStreamOutput + func (s CreateDeliveryStreamOutput) GoString() string + func (s CreateDeliveryStreamOutput) String() string + type DeleteDeliveryStreamInput struct + DeliveryStreamName *string + func (s *DeleteDeliveryStreamInput) SetDeliveryStreamName(v string) *DeleteDeliveryStreamInput + func (s *DeleteDeliveryStreamInput) Validate() error + 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 + DeliveryStreamType *string + Destinations []*DestinationDescription + HasMoreDestinations *bool + LastUpdateTimestamp *time.Time + Source *SourceDescription + VersionId *string + 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) SetDeliveryStreamType(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) SetSource(v *SourceDescription) *DeliveryStreamDescription + func (s *DeliveryStreamDescription) SetVersionId(v string) *DeliveryStreamDescription + func (s DeliveryStreamDescription) GoString() string + func (s DeliveryStreamDescription) String() string + type DescribeDeliveryStreamInput struct + DeliveryStreamName *string + ExclusiveStartDestinationId *string + Limit *int64 + func (s *DescribeDeliveryStreamInput) SetDeliveryStreamName(v string) *DescribeDeliveryStreamInput + func (s *DescribeDeliveryStreamInput) SetExclusiveStartDestinationId(v string) *DescribeDeliveryStreamInput + func (s *DescribeDeliveryStreamInput) SetLimit(v int64) *DescribeDeliveryStreamInput + func (s *DescribeDeliveryStreamInput) Validate() error + func (s DescribeDeliveryStreamInput) GoString() string + func (s DescribeDeliveryStreamInput) String() string + type DescribeDeliveryStreamOutput struct + DeliveryStreamDescription *DeliveryStreamDescription + func (s *DescribeDeliveryStreamOutput) SetDeliveryStreamDescription(v *DeliveryStreamDescription) *DescribeDeliveryStreamOutput + func (s DescribeDeliveryStreamOutput) GoString() string + func (s DescribeDeliveryStreamOutput) String() string + type DestinationDescription struct + DestinationId *string + ElasticsearchDestinationDescription *ElasticsearchDestinationDescription + ExtendedS3DestinationDescription *ExtendedS3DestinationDescription + RedshiftDestinationDescription *RedshiftDestinationDescription + S3DestinationDescription *S3DestinationDescription + func (s *DestinationDescription) SetDestinationId(v string) *DestinationDescription + func (s *DestinationDescription) SetElasticsearchDestinationDescription(v *ElasticsearchDestinationDescription) *DestinationDescription + func (s *DestinationDescription) SetExtendedS3DestinationDescription(v *ExtendedS3DestinationDescription) *DestinationDescription + func (s *DestinationDescription) SetRedshiftDestinationDescription(v *RedshiftDestinationDescription) *DestinationDescription + func (s *DestinationDescription) SetS3DestinationDescription(v *S3DestinationDescription) *DestinationDescription + func (s DestinationDescription) GoString() string + func (s DestinationDescription) String() string + type ElasticsearchBufferingHints struct + IntervalInSeconds *int64 + SizeInMBs *int64 + func (s *ElasticsearchBufferingHints) SetIntervalInSeconds(v int64) *ElasticsearchBufferingHints + func (s *ElasticsearchBufferingHints) SetSizeInMBs(v int64) *ElasticsearchBufferingHints + func (s *ElasticsearchBufferingHints) Validate() error + func (s ElasticsearchBufferingHints) GoString() string + func (s ElasticsearchBufferingHints) String() string + type ElasticsearchDestinationConfiguration struct + BufferingHints *ElasticsearchBufferingHints + CloudWatchLoggingOptions *CloudWatchLoggingOptions + DomainARN *string + IndexName *string + IndexRotationPeriod *string + ProcessingConfiguration *ProcessingConfiguration + RetryOptions *ElasticsearchRetryOptions + RoleARN *string + S3BackupMode *string + S3Configuration *S3DestinationConfiguration + TypeName *string + 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) SetProcessingConfiguration(v *ProcessingConfiguration) *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 + func (s *ElasticsearchDestinationConfiguration) Validate() error + func (s ElasticsearchDestinationConfiguration) GoString() string + func (s ElasticsearchDestinationConfiguration) String() string + type ElasticsearchDestinationDescription struct + BufferingHints *ElasticsearchBufferingHints + CloudWatchLoggingOptions *CloudWatchLoggingOptions + DomainARN *string + IndexName *string + IndexRotationPeriod *string + ProcessingConfiguration *ProcessingConfiguration + RetryOptions *ElasticsearchRetryOptions + RoleARN *string + S3BackupMode *string + S3DestinationDescription *S3DestinationDescription + TypeName *string + 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) SetProcessingConfiguration(v *ProcessingConfiguration) *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 + func (s ElasticsearchDestinationDescription) GoString() string + func (s ElasticsearchDestinationDescription) String() string + type ElasticsearchDestinationUpdate struct + BufferingHints *ElasticsearchBufferingHints + CloudWatchLoggingOptions *CloudWatchLoggingOptions + DomainARN *string + IndexName *string + IndexRotationPeriod *string + ProcessingConfiguration *ProcessingConfiguration + RetryOptions *ElasticsearchRetryOptions + RoleARN *string + S3Update *S3DestinationUpdate + TypeName *string + 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) SetProcessingConfiguration(v *ProcessingConfiguration) *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 + func (s *ElasticsearchDestinationUpdate) Validate() error + func (s ElasticsearchDestinationUpdate) GoString() string + func (s ElasticsearchDestinationUpdate) String() string + type ElasticsearchRetryOptions struct + DurationInSeconds *int64 + func (s *ElasticsearchRetryOptions) SetDurationInSeconds(v int64) *ElasticsearchRetryOptions + func (s ElasticsearchRetryOptions) GoString() string + func (s ElasticsearchRetryOptions) String() string + type EncryptionConfiguration struct + KMSEncryptionConfig *KMSEncryptionConfig + NoEncryptionConfig *string + func (s *EncryptionConfiguration) SetKMSEncryptionConfig(v *KMSEncryptionConfig) *EncryptionConfiguration + func (s *EncryptionConfiguration) SetNoEncryptionConfig(v string) *EncryptionConfiguration + func (s *EncryptionConfiguration) Validate() error + func (s EncryptionConfiguration) GoString() string + func (s EncryptionConfiguration) String() string + 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 Firehose struct + func New(p client.ConfigProvider, cfgs ...*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) CreateDeliveryStreamWithContext(ctx aws.Context, input *CreateDeliveryStreamInput, opts ...request.Option) (*CreateDeliveryStreamOutput, error) + func (c *Firehose) DeleteDeliveryStream(input *DeleteDeliveryStreamInput) (*DeleteDeliveryStreamOutput, error) + func (c *Firehose) DeleteDeliveryStreamRequest(input *DeleteDeliveryStreamInput) (req *request.Request, output *DeleteDeliveryStreamOutput) + func (c *Firehose) DeleteDeliveryStreamWithContext(ctx aws.Context, input *DeleteDeliveryStreamInput, opts ...request.Option) (*DeleteDeliveryStreamOutput, error) + func (c *Firehose) DescribeDeliveryStream(input *DescribeDeliveryStreamInput) (*DescribeDeliveryStreamOutput, error) + func (c *Firehose) DescribeDeliveryStreamRequest(input *DescribeDeliveryStreamInput) (req *request.Request, output *DescribeDeliveryStreamOutput) + func (c *Firehose) DescribeDeliveryStreamWithContext(ctx aws.Context, input *DescribeDeliveryStreamInput, opts ...request.Option) (*DescribeDeliveryStreamOutput, error) + func (c *Firehose) GetKinesisStream(input *GetKinesisStreamInput) (*GetKinesisStreamOutput, error) + func (c *Firehose) GetKinesisStreamRequest(input *GetKinesisStreamInput) (req *request.Request, output *GetKinesisStreamOutput) + func (c *Firehose) GetKinesisStreamWithContext(ctx aws.Context, input *GetKinesisStreamInput, opts ...request.Option) (*GetKinesisStreamOutput, error) + func (c *Firehose) ListDeliveryStreams(input *ListDeliveryStreamsInput) (*ListDeliveryStreamsOutput, error) + func (c *Firehose) ListDeliveryStreamsRequest(input *ListDeliveryStreamsInput) (req *request.Request, output *ListDeliveryStreamsOutput) + func (c *Firehose) ListDeliveryStreamsWithContext(ctx aws.Context, input *ListDeliveryStreamsInput, opts ...request.Option) (*ListDeliveryStreamsOutput, error) + 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) PutRecordBatchWithContext(ctx aws.Context, input *PutRecordBatchInput, opts ...request.Option) (*PutRecordBatchOutput, error) + func (c *Firehose) PutRecordRequest(input *PutRecordInput) (req *request.Request, output *PutRecordOutput) + func (c *Firehose) PutRecordWithContext(ctx aws.Context, input *PutRecordInput, opts ...request.Option) (*PutRecordOutput, error) + func (c *Firehose) UpdateDestination(input *UpdateDestinationInput) (*UpdateDestinationOutput, error) + func (c *Firehose) UpdateDestinationRequest(input *UpdateDestinationInput) (req *request.Request, output *UpdateDestinationOutput) + func (c *Firehose) UpdateDestinationWithContext(ctx aws.Context, input *UpdateDestinationInput, opts ...request.Option) (*UpdateDestinationOutput, error) + type GetKinesisStreamInput struct + DeliveryStreamARN *string + func (s *GetKinesisStreamInput) SetDeliveryStreamARN(v string) *GetKinesisStreamInput + func (s *GetKinesisStreamInput) Validate() error + func (s GetKinesisStreamInput) GoString() string + func (s GetKinesisStreamInput) String() string + type GetKinesisStreamOutput struct + CredentialsForReadingKinesisStream *SessionCredentials + KinesisStreamARN *string + func (s *GetKinesisStreamOutput) SetCredentialsForReadingKinesisStream(v *SessionCredentials) *GetKinesisStreamOutput + func (s *GetKinesisStreamOutput) SetKinesisStreamARN(v string) *GetKinesisStreamOutput + func (s GetKinesisStreamOutput) GoString() string + func (s GetKinesisStreamOutput) String() string + type KMSEncryptionConfig struct + AWSKMSKeyARN *string + func (s *KMSEncryptionConfig) SetAWSKMSKeyARN(v string) *KMSEncryptionConfig + func (s *KMSEncryptionConfig) Validate() error + func (s KMSEncryptionConfig) GoString() string + func (s KMSEncryptionConfig) String() string + type KinesisStreamSourceConfiguration struct + KinesisStreamARN *string + RoleARN *string + func (s *KinesisStreamSourceConfiguration) SetKinesisStreamARN(v string) *KinesisStreamSourceConfiguration + func (s *KinesisStreamSourceConfiguration) SetRoleARN(v string) *KinesisStreamSourceConfiguration + func (s *KinesisStreamSourceConfiguration) Validate() error + func (s KinesisStreamSourceConfiguration) GoString() string + func (s KinesisStreamSourceConfiguration) String() string + type KinesisStreamSourceDescription struct + DeliveryStartTimestamp *time.Time + KinesisStreamARN *string + RoleARN *string + func (s *KinesisStreamSourceDescription) SetDeliveryStartTimestamp(v time.Time) *KinesisStreamSourceDescription + func (s *KinesisStreamSourceDescription) SetKinesisStreamARN(v string) *KinesisStreamSourceDescription + func (s *KinesisStreamSourceDescription) SetRoleARN(v string) *KinesisStreamSourceDescription + func (s KinesisStreamSourceDescription) GoString() string + func (s KinesisStreamSourceDescription) String() string + type ListDeliveryStreamsInput struct + DeliveryStreamType *string + ExclusiveStartDeliveryStreamName *string + Limit *int64 + func (s *ListDeliveryStreamsInput) SetDeliveryStreamType(v string) *ListDeliveryStreamsInput + func (s *ListDeliveryStreamsInput) SetExclusiveStartDeliveryStreamName(v string) *ListDeliveryStreamsInput + func (s *ListDeliveryStreamsInput) SetLimit(v int64) *ListDeliveryStreamsInput + func (s *ListDeliveryStreamsInput) Validate() error + func (s ListDeliveryStreamsInput) GoString() string + func (s ListDeliveryStreamsInput) String() string + type ListDeliveryStreamsOutput struct + DeliveryStreamNames []*string + HasMoreDeliveryStreams *bool + func (s *ListDeliveryStreamsOutput) SetDeliveryStreamNames(v []*string) *ListDeliveryStreamsOutput + func (s *ListDeliveryStreamsOutput) SetHasMoreDeliveryStreams(v bool) *ListDeliveryStreamsOutput + func (s ListDeliveryStreamsOutput) GoString() string + func (s ListDeliveryStreamsOutput) 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 PutRecordBatchInput struct + DeliveryStreamName *string + Records []*Record + func (s *PutRecordBatchInput) SetDeliveryStreamName(v string) *PutRecordBatchInput + func (s *PutRecordBatchInput) SetRecords(v []*Record) *PutRecordBatchInput + func (s *PutRecordBatchInput) Validate() error + func (s PutRecordBatchInput) GoString() string + func (s PutRecordBatchInput) String() string + type PutRecordBatchOutput struct + FailedPutCount *int64 + RequestResponses []*PutRecordBatchResponseEntry + func (s *PutRecordBatchOutput) SetFailedPutCount(v int64) *PutRecordBatchOutput + func (s *PutRecordBatchOutput) SetRequestResponses(v []*PutRecordBatchResponseEntry) *PutRecordBatchOutput + func (s PutRecordBatchOutput) GoString() string + func (s PutRecordBatchOutput) String() string + type PutRecordBatchResponseEntry struct + ErrorCode *string + ErrorMessage *string + RecordId *string + func (s *PutRecordBatchResponseEntry) SetErrorCode(v string) *PutRecordBatchResponseEntry + func (s *PutRecordBatchResponseEntry) SetErrorMessage(v string) *PutRecordBatchResponseEntry + func (s *PutRecordBatchResponseEntry) SetRecordId(v string) *PutRecordBatchResponseEntry + func (s PutRecordBatchResponseEntry) GoString() string + func (s PutRecordBatchResponseEntry) String() string + type PutRecordInput struct + DeliveryStreamName *string + Record *Record + func (s *PutRecordInput) SetDeliveryStreamName(v string) *PutRecordInput + func (s *PutRecordInput) SetRecord(v *Record) *PutRecordInput + func (s *PutRecordInput) Validate() error + func (s PutRecordInput) GoString() string + func (s PutRecordInput) String() string + type PutRecordOutput struct + RecordId *string + func (s *PutRecordOutput) SetRecordId(v string) *PutRecordOutput + func (s PutRecordOutput) GoString() string + func (s PutRecordOutput) String() string + type Record struct + Data []byte + func (s *Record) SetData(v []byte) *Record + func (s *Record) Validate() error + func (s Record) GoString() string + func (s Record) String() string + type RedshiftDestinationConfiguration struct + CloudWatchLoggingOptions *CloudWatchLoggingOptions + ClusterJDBCURL *string + CopyCommand *CopyCommand + Password *string + ProcessingConfiguration *ProcessingConfiguration + RetryOptions *RedshiftRetryOptions + RoleARN *string + S3BackupConfiguration *S3DestinationConfiguration + S3BackupMode *string + S3Configuration *S3DestinationConfiguration + Username *string + 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) SetProcessingConfiguration(v *ProcessingConfiguration) *RedshiftDestinationConfiguration + func (s *RedshiftDestinationConfiguration) SetRetryOptions(v *RedshiftRetryOptions) *RedshiftDestinationConfiguration + func (s *RedshiftDestinationConfiguration) SetRoleARN(v string) *RedshiftDestinationConfiguration + func (s *RedshiftDestinationConfiguration) SetS3BackupConfiguration(v *S3DestinationConfiguration) *RedshiftDestinationConfiguration + func (s *RedshiftDestinationConfiguration) SetS3BackupMode(v string) *RedshiftDestinationConfiguration + func (s *RedshiftDestinationConfiguration) SetS3Configuration(v *S3DestinationConfiguration) *RedshiftDestinationConfiguration + func (s *RedshiftDestinationConfiguration) SetUsername(v string) *RedshiftDestinationConfiguration + func (s *RedshiftDestinationConfiguration) Validate() error + func (s RedshiftDestinationConfiguration) GoString() string + func (s RedshiftDestinationConfiguration) String() string + type RedshiftDestinationDescription struct + CloudWatchLoggingOptions *CloudWatchLoggingOptions + ClusterJDBCURL *string + CopyCommand *CopyCommand + ProcessingConfiguration *ProcessingConfiguration + RetryOptions *RedshiftRetryOptions + RoleARN *string + S3BackupDescription *S3DestinationDescription + S3BackupMode *string + S3DestinationDescription *S3DestinationDescription + Username *string + func (s *RedshiftDestinationDescription) SetCloudWatchLoggingOptions(v *CloudWatchLoggingOptions) *RedshiftDestinationDescription + func (s *RedshiftDestinationDescription) SetClusterJDBCURL(v string) *RedshiftDestinationDescription + func (s *RedshiftDestinationDescription) SetCopyCommand(v *CopyCommand) *RedshiftDestinationDescription + func (s *RedshiftDestinationDescription) SetProcessingConfiguration(v *ProcessingConfiguration) *RedshiftDestinationDescription + func (s *RedshiftDestinationDescription) SetRetryOptions(v *RedshiftRetryOptions) *RedshiftDestinationDescription + func (s *RedshiftDestinationDescription) SetRoleARN(v string) *RedshiftDestinationDescription + func (s *RedshiftDestinationDescription) SetS3BackupDescription(v *S3DestinationDescription) *RedshiftDestinationDescription + func (s *RedshiftDestinationDescription) SetS3BackupMode(v string) *RedshiftDestinationDescription + func (s *RedshiftDestinationDescription) SetS3DestinationDescription(v *S3DestinationDescription) *RedshiftDestinationDescription + func (s *RedshiftDestinationDescription) SetUsername(v string) *RedshiftDestinationDescription + func (s RedshiftDestinationDescription) GoString() string + func (s RedshiftDestinationDescription) String() string + type RedshiftDestinationUpdate struct + CloudWatchLoggingOptions *CloudWatchLoggingOptions + ClusterJDBCURL *string + CopyCommand *CopyCommand + Password *string + ProcessingConfiguration *ProcessingConfiguration + RetryOptions *RedshiftRetryOptions + RoleARN *string + S3BackupMode *string + S3BackupUpdate *S3DestinationUpdate + S3Update *S3DestinationUpdate + Username *string + 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) SetProcessingConfiguration(v *ProcessingConfiguration) *RedshiftDestinationUpdate + func (s *RedshiftDestinationUpdate) SetRetryOptions(v *RedshiftRetryOptions) *RedshiftDestinationUpdate + func (s *RedshiftDestinationUpdate) SetRoleARN(v string) *RedshiftDestinationUpdate + func (s *RedshiftDestinationUpdate) SetS3BackupMode(v string) *RedshiftDestinationUpdate + func (s *RedshiftDestinationUpdate) SetS3BackupUpdate(v *S3DestinationUpdate) *RedshiftDestinationUpdate + func (s *RedshiftDestinationUpdate) SetS3Update(v *S3DestinationUpdate) *RedshiftDestinationUpdate + func (s *RedshiftDestinationUpdate) SetUsername(v string) *RedshiftDestinationUpdate + func (s *RedshiftDestinationUpdate) Validate() error + func (s RedshiftDestinationUpdate) GoString() string + func (s RedshiftDestinationUpdate) String() string + type RedshiftRetryOptions struct + DurationInSeconds *int64 + func (s *RedshiftRetryOptions) SetDurationInSeconds(v int64) *RedshiftRetryOptions + func (s RedshiftRetryOptions) GoString() string + func (s RedshiftRetryOptions) String() string + type S3DestinationConfiguration struct + BucketARN *string + BufferingHints *BufferingHints + CloudWatchLoggingOptions *CloudWatchLoggingOptions + CompressionFormat *string + EncryptionConfiguration *EncryptionConfiguration + Prefix *string + RoleARN *string + 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 + func (s *S3DestinationConfiguration) Validate() error + func (s S3DestinationConfiguration) GoString() string + func (s S3DestinationConfiguration) String() string + type S3DestinationDescription struct + BucketARN *string + BufferingHints *BufferingHints + CloudWatchLoggingOptions *CloudWatchLoggingOptions + CompressionFormat *string + EncryptionConfiguration *EncryptionConfiguration + Prefix *string + RoleARN *string + 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 + func (s S3DestinationDescription) GoString() string + func (s S3DestinationDescription) String() string + type S3DestinationUpdate struct + BucketARN *string + BufferingHints *BufferingHints + CloudWatchLoggingOptions *CloudWatchLoggingOptions + CompressionFormat *string + EncryptionConfiguration *EncryptionConfiguration + Prefix *string + RoleARN *string + 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 + func (s *S3DestinationUpdate) Validate() error + func (s S3DestinationUpdate) GoString() string + func (s S3DestinationUpdate) String() string + type SessionCredentials struct + AccessKeyId *string + Expiration *time.Time + SecretAccessKey *string + SessionToken *string + func (s *SessionCredentials) SetAccessKeyId(v string) *SessionCredentials + func (s *SessionCredentials) SetExpiration(v time.Time) *SessionCredentials + func (s *SessionCredentials) SetSecretAccessKey(v string) *SessionCredentials + func (s *SessionCredentials) SetSessionToken(v string) *SessionCredentials + func (s SessionCredentials) GoString() string + func (s SessionCredentials) String() string + type SourceDescription struct + KinesisStreamSourceDescription *KinesisStreamSourceDescription + func (s *SourceDescription) SetKinesisStreamSourceDescription(v *KinesisStreamSourceDescription) *SourceDescription + func (s SourceDescription) GoString() string + func (s SourceDescription) String() string + type UpdateDestinationInput struct + CurrentDeliveryStreamVersionId *string + DeliveryStreamName *string + DestinationId *string + ElasticsearchDestinationUpdate *ElasticsearchDestinationUpdate + ExtendedS3DestinationUpdate *ExtendedS3DestinationUpdate + RedshiftDestinationUpdate *RedshiftDestinationUpdate + S3DestinationUpdate *S3DestinationUpdate + 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) SetExtendedS3DestinationUpdate(v *ExtendedS3DestinationUpdate) *UpdateDestinationInput + func (s *UpdateDestinationInput) SetRedshiftDestinationUpdate(v *RedshiftDestinationUpdate) *UpdateDestinationInput + func (s *UpdateDestinationInput) SetS3DestinationUpdate(v *S3DestinationUpdate) *UpdateDestinationInput + func (s *UpdateDestinationInput) Validate() error + func (s UpdateDestinationInput) GoString() string + func (s UpdateDestinationInput) String() string + type UpdateDestinationOutput struct + func (s UpdateDestinationOutput) GoString() string + func (s UpdateDestinationOutput) String() string