firehose

package

Go to main page

Versions in this module

v0

v0.4.0

May 26, 2018

Changes in this version

+ type DataFormatConversionConfiguration struct

+ Enabled *bool

+ InputFormatConfiguration *InputFormatConfiguration

+ OutputFormatConfiguration *OutputFormatConfiguration

+ SchemaConfiguration *SchemaConfiguration

+ func (s *DataFormatConversionConfiguration) Validate() error

+ func (s DataFormatConversionConfiguration) GoString() string

+ func (s DataFormatConversionConfiguration) String() string

+ type Deserializer struct

+ HiveJsonSerDe *HiveJsonSerDe

+ OpenXJsonSerDe *OpenXJsonSerDe

+ func (s Deserializer) GoString() string

+ func (s Deserializer) String() string

type ExtendedS3DestinationConfiguration

+ DataFormatConversionConfiguration *DataFormatConversionConfiguration

type ExtendedS3DestinationDescription

+ DataFormatConversionConfiguration *DataFormatConversionConfiguration

type ExtendedS3DestinationUpdate

+ DataFormatConversionConfiguration *DataFormatConversionConfiguration

type Firehose

+ func (c *Firehose) ListTagsForDeliveryStreamRequest(input *ListTagsForDeliveryStreamInput) ListTagsForDeliveryStreamRequest

+ func (c *Firehose) TagDeliveryStreamRequest(input *TagDeliveryStreamInput) TagDeliveryStreamRequest

+ func (c *Firehose) UntagDeliveryStreamRequest(input *UntagDeliveryStreamInput) UntagDeliveryStreamRequest

+ type HiveJsonSerDe struct

+ TimestampFormats []string

+ func (s HiveJsonSerDe) GoString() string

+ func (s HiveJsonSerDe) String() string

+ type InputFormatConfiguration struct

+ Deserializer *Deserializer

+ func (s InputFormatConfiguration) GoString() string

+ func (s InputFormatConfiguration) String() string

+ type ListTagsForDeliveryStreamInput struct

+ DeliveryStreamName *string

+ ExclusiveStartTagKey *string

+ Limit *int64

+ func (s *ListTagsForDeliveryStreamInput) Validate() error

+ func (s ListTagsForDeliveryStreamInput) GoString() string

+ func (s ListTagsForDeliveryStreamInput) String() string

+ type ListTagsForDeliveryStreamOutput struct

+ HasMoreTags *bool

+ Tags []Tag

+ func (s ListTagsForDeliveryStreamOutput) GoString() string

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

+ func (s ListTagsForDeliveryStreamOutput) String() string

+ type ListTagsForDeliveryStreamRequest struct

+ Copy func(*ListTagsForDeliveryStreamInput) ListTagsForDeliveryStreamRequest

+ Input *ListTagsForDeliveryStreamInput

+ func (r ListTagsForDeliveryStreamRequest) Send() (*ListTagsForDeliveryStreamOutput, error)

+ type OpenXJsonSerDe struct

+ CaseInsensitive *bool

+ ColumnToJsonKeyMappings map[string]string

+ ConvertDotsInJsonKeysToUnderscores *bool

+ func (s OpenXJsonSerDe) GoString() string

+ func (s OpenXJsonSerDe) String() string

+ type OrcCompression string

+ const OrcCompressionNone

+ const OrcCompressionSnappy

+ const OrcCompressionZlib

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

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

+ type OrcFormatVersion string

+ const OrcFormatVersionV011

+ const OrcFormatVersionV012

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

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

+ type OrcSerDe struct

+ BlockSizeBytes *int64

+ BloomFilterColumns []string

+ BloomFilterFalsePositiveProbability *float64

+ Compression OrcCompression

+ DictionaryKeyThreshold *float64

+ EnablePadding *bool

+ FormatVersion OrcFormatVersion

+ PaddingTolerance *float64

+ RowIndexStride *int64

+ StripeSizeBytes *int64

+ func (s *OrcSerDe) Validate() error

+ func (s OrcSerDe) GoString() string

+ func (s OrcSerDe) String() string

+ type OutputFormatConfiguration struct

+ Serializer *Serializer

+ func (s *OutputFormatConfiguration) Validate() error

+ func (s OutputFormatConfiguration) GoString() string

+ func (s OutputFormatConfiguration) String() string

+ type ParquetCompression string

+ const ParquetCompressionGzip

+ const ParquetCompressionSnappy

+ const ParquetCompressionUncompressed

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

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

+ type ParquetSerDe struct

+ BlockSizeBytes *int64

+ Compression ParquetCompression

+ EnableDictionaryCompression *bool

+ MaxPaddingBytes *int64

+ PageSizeBytes *int64

+ WriterVersion ParquetWriterVersion

+ func (s *ParquetSerDe) Validate() error

+ func (s ParquetSerDe) GoString() string

+ func (s ParquetSerDe) String() string

+ type ParquetWriterVersion string

+ const ParquetWriterVersionV1

+ const ParquetWriterVersionV2

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

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

+ type SchemaConfiguration struct

+ CatalogId *string

+ DatabaseName *string

+ Region *string

+ RoleARN *string

+ TableName *string

+ VersionId *string

+ func (s SchemaConfiguration) GoString() string

+ func (s SchemaConfiguration) String() string

+ type Serializer struct

+ OrcSerDe *OrcSerDe

+ ParquetSerDe *ParquetSerDe

+ func (s *Serializer) Validate() error

+ func (s Serializer) GoString() string

+ func (s Serializer) String() string

+ type Tag struct

+ Key *string

+ Value *string

+ func (s *Tag) Validate() error

+ func (s Tag) GoString() string

+ func (s Tag) String() string

+ type TagDeliveryStreamInput struct

+ DeliveryStreamName *string

+ Tags []Tag

+ func (s *TagDeliveryStreamInput) Validate() error

+ func (s TagDeliveryStreamInput) GoString() string

+ func (s TagDeliveryStreamInput) String() string

+ type TagDeliveryStreamOutput struct

+ func (s TagDeliveryStreamOutput) GoString() string

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

+ func (s TagDeliveryStreamOutput) String() string

+ type TagDeliveryStreamRequest struct

+ Copy func(*TagDeliveryStreamInput) TagDeliveryStreamRequest

+ Input *TagDeliveryStreamInput

+ func (r TagDeliveryStreamRequest) Send() (*TagDeliveryStreamOutput, error)

+ type UntagDeliveryStreamInput struct

+ DeliveryStreamName *string

+ TagKeys []string

+ func (s *UntagDeliveryStreamInput) Validate() error

+ func (s UntagDeliveryStreamInput) GoString() string

+ func (s UntagDeliveryStreamInput) String() string

+ type UntagDeliveryStreamOutput struct

+ func (s UntagDeliveryStreamOutput) GoString() string

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

+ func (s UntagDeliveryStreamOutput) String() string

+ type UntagDeliveryStreamRequest struct

+ Copy func(*UntagDeliveryStreamInput) UntagDeliveryStreamRequest

+ Input *UntagDeliveryStreamInput

+ func (r UntagDeliveryStreamRequest) Send() (*UntagDeliveryStreamOutput, error)

v0.3.0

Mar 8, 2018

Changes in this version

type CompressionFormat

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

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

type CreateDeliveryStreamRequest

+ Copy func(*CreateDeliveryStreamInput) CreateDeliveryStreamRequest

type DeleteDeliveryStreamRequest

+ Copy func(*DeleteDeliveryStreamInput) DeleteDeliveryStreamRequest

type DeliveryStreamStatus

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

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

type DeliveryStreamType

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

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

type DescribeDeliveryStreamRequest

+ Copy func(*DescribeDeliveryStreamInput) DescribeDeliveryStreamRequest

type ElasticsearchIndexRotationPeriod

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

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

type ElasticsearchS3BackupMode

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

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

type HECEndpointType

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

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

type ListDeliveryStreamsRequest

+ Copy func(*ListDeliveryStreamsInput) ListDeliveryStreamsRequest

type NoEncryptionConfig

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

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

type ProcessorParameterName

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

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

type ProcessorType

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

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

type PutRecordBatchRequest

+ Copy func(*PutRecordBatchInput) PutRecordBatchRequest

type PutRecordRequest

+ Copy func(*PutRecordInput) PutRecordRequest

type RedshiftS3BackupMode

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

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

type S3BackupMode

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

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

type SplunkS3BackupMode

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

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

type UpdateDestinationRequest

+ Copy func(*UpdateDestinationInput) UpdateDestinationRequest

v0.2.0

Jan 15, 2018

Changes in this version

type CreateDeliveryStreamInput

+ SplunkDestinationConfiguration *SplunkDestinationConfiguration

+ func (s *CreateDeliveryStreamInput) SetSplunkDestinationConfiguration(v *SplunkDestinationConfiguration) *CreateDeliveryStreamInput

type DestinationDescription

+ SplunkDestinationDescription *SplunkDestinationDescription

+ func (s *DestinationDescription) SetSplunkDestinationDescription(v *SplunkDestinationDescription) *DestinationDescription

+ type HECEndpointType string

+ const HECEndpointTypeEvent

+ const HECEndpointTypeRaw

type ProcessorParameterName

+ const ProcessorParameterNameBufferIntervalInSeconds

+ const ProcessorParameterNameBufferSizeInMbs

+ const ProcessorParameterNameRoleArn

+ type SplunkDestinationConfiguration struct

+ CloudWatchLoggingOptions *CloudWatchLoggingOptions

+ HECAcknowledgmentTimeoutInSeconds *int64

+ HECEndpoint *string

+ HECEndpointType HECEndpointType

+ HECToken *string

+ ProcessingConfiguration *ProcessingConfiguration

+ RetryOptions *SplunkRetryOptions

+ S3BackupMode SplunkS3BackupMode

+ S3Configuration *S3DestinationConfiguration

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

+ func (s *SplunkDestinationConfiguration) SetHECAcknowledgmentTimeoutInSeconds(v int64) *SplunkDestinationConfiguration

+ func (s *SplunkDestinationConfiguration) SetHECEndpoint(v string) *SplunkDestinationConfiguration

+ func (s *SplunkDestinationConfiguration) SetHECEndpointType(v HECEndpointType) *SplunkDestinationConfiguration

+ func (s *SplunkDestinationConfiguration) SetHECToken(v string) *SplunkDestinationConfiguration

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

+ func (s *SplunkDestinationConfiguration) SetRetryOptions(v *SplunkRetryOptions) *SplunkDestinationConfiguration

+ func (s *SplunkDestinationConfiguration) SetS3BackupMode(v SplunkS3BackupMode) *SplunkDestinationConfiguration

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

+ func (s *SplunkDestinationConfiguration) Validate() error

+ func (s SplunkDestinationConfiguration) GoString() string

+ func (s SplunkDestinationConfiguration) String() string

+ type SplunkDestinationDescription struct

+ CloudWatchLoggingOptions *CloudWatchLoggingOptions

+ HECAcknowledgmentTimeoutInSeconds *int64

+ HECEndpoint *string

+ HECEndpointType HECEndpointType

+ HECToken *string

+ ProcessingConfiguration *ProcessingConfiguration

+ RetryOptions *SplunkRetryOptions

+ S3BackupMode SplunkS3BackupMode

+ S3DestinationDescription *S3DestinationDescription

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

+ func (s *SplunkDestinationDescription) SetHECAcknowledgmentTimeoutInSeconds(v int64) *SplunkDestinationDescription

+ func (s *SplunkDestinationDescription) SetHECEndpoint(v string) *SplunkDestinationDescription

+ func (s *SplunkDestinationDescription) SetHECEndpointType(v HECEndpointType) *SplunkDestinationDescription

+ func (s *SplunkDestinationDescription) SetHECToken(v string) *SplunkDestinationDescription

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

+ func (s *SplunkDestinationDescription) SetRetryOptions(v *SplunkRetryOptions) *SplunkDestinationDescription

+ func (s *SplunkDestinationDescription) SetS3BackupMode(v SplunkS3BackupMode) *SplunkDestinationDescription

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

+ func (s SplunkDestinationDescription) GoString() string

+ func (s SplunkDestinationDescription) String() string

+ type SplunkDestinationUpdate struct

+ CloudWatchLoggingOptions *CloudWatchLoggingOptions

+ HECAcknowledgmentTimeoutInSeconds *int64

+ HECEndpoint *string

+ HECEndpointType HECEndpointType

+ HECToken *string

+ ProcessingConfiguration *ProcessingConfiguration

+ RetryOptions *SplunkRetryOptions

+ S3BackupMode SplunkS3BackupMode

+ S3Update *S3DestinationUpdate

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

+ func (s *SplunkDestinationUpdate) SetHECAcknowledgmentTimeoutInSeconds(v int64) *SplunkDestinationUpdate

+ func (s *SplunkDestinationUpdate) SetHECEndpoint(v string) *SplunkDestinationUpdate

+ func (s *SplunkDestinationUpdate) SetHECEndpointType(v HECEndpointType) *SplunkDestinationUpdate

+ func (s *SplunkDestinationUpdate) SetHECToken(v string) *SplunkDestinationUpdate

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

+ func (s *SplunkDestinationUpdate) SetRetryOptions(v *SplunkRetryOptions) *SplunkDestinationUpdate

+ func (s *SplunkDestinationUpdate) SetS3BackupMode(v SplunkS3BackupMode) *SplunkDestinationUpdate

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

+ func (s *SplunkDestinationUpdate) Validate() error

+ func (s SplunkDestinationUpdate) GoString() string

+ func (s SplunkDestinationUpdate) String() string

+ type SplunkRetryOptions struct

+ DurationInSeconds *int64

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

+ func (s SplunkRetryOptions) GoString() string

+ func (s SplunkRetryOptions) String() string

+ type SplunkS3BackupMode string

+ const SplunkS3BackupModeAllEvents

+ const SplunkS3BackupModeFailedEventsOnly

type UpdateDestinationInput

+ SplunkDestinationUpdate *SplunkDestinationUpdate

+ func (s *UpdateDestinationInput) SetSplunkDestinationUpdate(v *SplunkDestinationUpdate) *UpdateDestinationInput

v0.1.0

Dec 21, 2017

Changes in this version

+ const EndpointsID

+ const ErrCodeConcurrentModificationException

+ const ErrCodeInvalidArgumentException

+ const ErrCodeInvalidStreamTypeException

+ const ErrCodeLimitExceededException

+ const ErrCodeResourceInUseException

+ const ErrCodeResourceNotFoundException

+ const ErrCodeServiceUnavailableException

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

+ const CompressionFormatGzip

+ const CompressionFormatSnappy

+ const CompressionFormatUncompressed

+ const CompressionFormatZip

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

+ ElasticsearchDestinationConfiguration *ElasticsearchDestinationConfiguration

+ ExtendedS3DestinationConfiguration *ExtendedS3DestinationConfiguration

+ KinesisStreamSourceConfiguration *KinesisStreamSourceConfiguration

+ RedshiftDestinationConfiguration *RedshiftDestinationConfiguration

+ S3DestinationConfiguration *S3DestinationConfiguration

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

+ func (s *CreateDeliveryStreamInput) SetDeliveryStreamType(v DeliveryStreamType) *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) SDKResponseMetadata() aws.Response

+ func (s CreateDeliveryStreamOutput) String() string

+ type CreateDeliveryStreamRequest struct

+ Input *CreateDeliveryStreamInput

+ func (r CreateDeliveryStreamRequest) Send() (*CreateDeliveryStreamOutput, error)

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

+ func (s DeleteDeliveryStreamOutput) String() string

+ type DeleteDeliveryStreamRequest struct

+ Input *DeleteDeliveryStreamInput

+ func (r DeleteDeliveryStreamRequest) Send() (*DeleteDeliveryStreamOutput, error)

+ type DeliveryStreamDescription struct

+ CreateTimestamp *time.Time

+ DeliveryStreamARN *string

+ DeliveryStreamName *string

+ DeliveryStreamStatus DeliveryStreamStatus

+ DeliveryStreamType DeliveryStreamType

+ 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 DeliveryStreamStatus) *DeliveryStreamDescription

+ func (s *DeliveryStreamDescription) SetDeliveryStreamType(v DeliveryStreamType) *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 DeliveryStreamStatus string

+ const DeliveryStreamStatusActive

+ const DeliveryStreamStatusCreating

+ const DeliveryStreamStatusDeleting

+ type DeliveryStreamType string

+ const DeliveryStreamTypeDirectPut

+ const DeliveryStreamTypeKinesisStreamAsSource

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

+ func (s DescribeDeliveryStreamOutput) String() string

+ type DescribeDeliveryStreamRequest struct

+ Input *DescribeDeliveryStreamInput

+ func (r DescribeDeliveryStreamRequest) Send() (*DescribeDeliveryStreamOutput, error)

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

+ ProcessingConfiguration *ProcessingConfiguration

+ RetryOptions *ElasticsearchRetryOptions

+ RoleARN *string

+ S3BackupMode ElasticsearchS3BackupMode

+ 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 ElasticsearchIndexRotationPeriod) *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 ElasticsearchS3BackupMode) *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 ElasticsearchIndexRotationPeriod

+ ProcessingConfiguration *ProcessingConfiguration

+ RetryOptions *ElasticsearchRetryOptions

+ RoleARN *string

+ S3BackupMode ElasticsearchS3BackupMode

+ 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 ElasticsearchIndexRotationPeriod) *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 ElasticsearchS3BackupMode) *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 ElasticsearchIndexRotationPeriod

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

+ const ElasticsearchIndexRotationPeriodNoRotation

+ const ElasticsearchIndexRotationPeriodOneDay

+ const ElasticsearchIndexRotationPeriodOneHour

+ const ElasticsearchIndexRotationPeriodOneMonth

+ const ElasticsearchIndexRotationPeriodOneWeek

+ type ElasticsearchRetryOptions struct

+ DurationInSeconds *int64

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

+ func (s ElasticsearchRetryOptions) GoString() string

+ func (s ElasticsearchRetryOptions) String() string

+ type ElasticsearchS3BackupMode string

+ const ElasticsearchS3BackupModeAllDocuments

+ const ElasticsearchS3BackupModeFailedDocumentsOnly

+ type EncryptionConfiguration struct

+ KMSEncryptionConfig *KMSEncryptionConfig

+ NoEncryptionConfig NoEncryptionConfig

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

+ func (s *EncryptionConfiguration) SetNoEncryptionConfig(v NoEncryptionConfig) *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 CompressionFormat

+ EncryptionConfiguration *EncryptionConfiguration

+ Prefix *string

+ ProcessingConfiguration *ProcessingConfiguration

+ RoleARN *string

+ S3BackupConfiguration *S3DestinationConfiguration

+ S3BackupMode S3BackupMode

+ 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 CompressionFormat) *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 S3BackupMode) *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 CompressionFormat

+ EncryptionConfiguration *EncryptionConfiguration

+ Prefix *string

+ ProcessingConfiguration *ProcessingConfiguration

+ RoleARN *string

+ S3BackupDescription *S3DestinationDescription

+ S3BackupMode S3BackupMode

+ 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 CompressionFormat) *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 S3BackupMode) *ExtendedS3DestinationDescription

+ func (s ExtendedS3DestinationDescription) GoString() string

+ func (s ExtendedS3DestinationDescription) String() string

+ type ExtendedS3DestinationUpdate struct

+ BucketARN *string

+ BufferingHints *BufferingHints

+ CloudWatchLoggingOptions *CloudWatchLoggingOptions

+ CompressionFormat CompressionFormat

+ EncryptionConfiguration *EncryptionConfiguration

+ Prefix *string

+ ProcessingConfiguration *ProcessingConfiguration

+ RoleARN *string

+ S3BackupMode S3BackupMode

+ 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 CompressionFormat) *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 S3BackupMode) *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(config aws.Config) *Firehose

+ func (c *Firehose) CreateDeliveryStreamRequest(input *CreateDeliveryStreamInput) CreateDeliveryStreamRequest

+ func (c *Firehose) DeleteDeliveryStreamRequest(input *DeleteDeliveryStreamInput) DeleteDeliveryStreamRequest

+ func (c *Firehose) DescribeDeliveryStreamRequest(input *DescribeDeliveryStreamInput) DescribeDeliveryStreamRequest

+ func (c *Firehose) GetKinesisStreamRequest(input *GetKinesisStreamInput) GetKinesisStreamRequest

+ func (c *Firehose) ListDeliveryStreamsRequest(input *ListDeliveryStreamsInput) ListDeliveryStreamsRequest

+ func (c *Firehose) PutRecordBatchRequest(input *PutRecordBatchInput) PutRecordBatchRequest

+ func (c *Firehose) PutRecordRequest(input *PutRecordInput) PutRecordRequest

+ func (c *Firehose) UpdateDestinationRequest(input *UpdateDestinationInput) UpdateDestinationRequest

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

+ func (s GetKinesisStreamOutput) String() string

+ type GetKinesisStreamRequest struct

+ Input *GetKinesisStreamInput

+ func (r GetKinesisStreamRequest) Send() (*GetKinesisStreamOutput, error)

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

+ ExclusiveStartDeliveryStreamName *string

+ Limit *int64

+ func (s *ListDeliveryStreamsInput) SetDeliveryStreamType(v DeliveryStreamType) *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) SDKResponseMetadata() aws.Response

+ func (s ListDeliveryStreamsOutput) String() string

+ type ListDeliveryStreamsRequest struct

+ Input *ListDeliveryStreamsInput

+ func (r ListDeliveryStreamsRequest) Send() (*ListDeliveryStreamsOutput, error)

+ type NoEncryptionConfig string

+ const NoEncryptionConfigNoEncryption

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

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

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

+ func (s *Processor) Validate() error

+ func (s Processor) GoString() string

+ func (s Processor) String() string

+ type ProcessorParameter struct

+ ParameterName ProcessorParameterName

+ ParameterValue *string

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

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

+ func (s *ProcessorParameter) Validate() error

+ func (s ProcessorParameter) GoString() string

+ func (s ProcessorParameter) String() string

+ type ProcessorParameterName string

+ const ProcessorParameterNameLambdaArn

+ const ProcessorParameterNameNumberOfRetries

+ type ProcessorType string

+ const ProcessorTypeLambda

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

+ func (s PutRecordBatchOutput) String() string

+ type PutRecordBatchRequest struct

+ Input *PutRecordBatchInput

+ func (r PutRecordBatchRequest) Send() (*PutRecordBatchOutput, error)

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

+ func (s PutRecordOutput) String() string

+ type PutRecordRequest struct

+ Input *PutRecordInput

+ func (r PutRecordRequest) Send() (*PutRecordOutput, error)

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

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

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

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

+ const RedshiftS3BackupModeDisabled

+ const RedshiftS3BackupModeEnabled

+ type S3BackupMode string

+ const S3BackupModeDisabled

+ const S3BackupModeEnabled

+ type S3DestinationConfiguration struct

+ BucketARN *string

+ BufferingHints *BufferingHints

+ CloudWatchLoggingOptions *CloudWatchLoggingOptions

+ CompressionFormat CompressionFormat

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

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

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

+ func (s UpdateDestinationOutput) String() string

+ type UpdateDestinationRequest struct

+ Input *UpdateDestinationInput

+ func (r UpdateDestinationRequest) Send() (*UpdateDestinationOutput, error)

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