firehose

Apr 26, 2016

Changes in this version

type BufferingHints

+ func (s *BufferingHints) Validate() error

type CopyCommand

+ func (s *CopyCommand) Validate() error

type CreateDeliveryStreamInput

+ func (s *CreateDeliveryStreamInput) Validate() error

type DeleteDeliveryStreamInput

+ func (s *DeleteDeliveryStreamInput) Validate() error

type DescribeDeliveryStreamInput

+ func (s *DescribeDeliveryStreamInput) Validate() error

type ElasticsearchBufferingHints

+ func (s *ElasticsearchBufferingHints) Validate() error

type ElasticsearchDestinationConfiguration

+ func (s *ElasticsearchDestinationConfiguration) Validate() error

type ElasticsearchDestinationUpdate

+ func (s *ElasticsearchDestinationUpdate) Validate() error

type EncryptionConfiguration

+ func (s *EncryptionConfiguration) Validate() error

type KMSEncryptionConfig

+ func (s *KMSEncryptionConfig) Validate() error

type ListDeliveryStreamsInput

+ func (s *ListDeliveryStreamsInput) Validate() error

type PutRecordBatchInput

+ func (s *PutRecordBatchInput) Validate() error

type PutRecordInput

+ func (s *PutRecordInput) Validate() error

type Record

+ func (s *Record) Validate() error

type RedshiftDestinationConfiguration

+ func (s *RedshiftDestinationConfiguration) Validate() error

type RedshiftDestinationUpdate

+ func (s *RedshiftDestinationUpdate) Validate() error

type S3DestinationConfiguration

+ func (s *S3DestinationConfiguration) Validate() error

type S3DestinationUpdate

+ func (s *S3DestinationUpdate) Validate() error

type UpdateDestinationInput

+ func (s *UpdateDestinationInput) Validate() error

Apr 19, 2016

Changes in this version

+ const ElasticsearchIndexRotationPeriodNoRotation

+ const ElasticsearchIndexRotationPeriodOneDay

+ const ElasticsearchIndexRotationPeriodOneHour

+ const ElasticsearchIndexRotationPeriodOneMonth

+ const ElasticsearchIndexRotationPeriodOneWeek

+ const ElasticsearchS3BackupModeAllDocuments

+ const ElasticsearchS3BackupModeFailedDocumentsOnly

+ type CloudWatchLoggingOptions struct

+ Enabled *bool

+ LogGroupName *string

+ LogStreamName *string

+ func (s CloudWatchLoggingOptions) GoString() string

+ func (s CloudWatchLoggingOptions) String() string

type CreateDeliveryStreamInput

+ ElasticsearchDestinationConfiguration *ElasticsearchDestinationConfiguration

type DestinationDescription

+ ElasticsearchDestinationDescription *ElasticsearchDestinationDescription

+ type ElasticsearchBufferingHints struct

+ IntervalInSeconds *int64

+ SizeInMBs *int64

+ func (s ElasticsearchBufferingHints) GoString() string

+ func (s ElasticsearchBufferingHints) String() string

+ type ElasticsearchDestinationConfiguration struct

+ BufferingHints *ElasticsearchBufferingHints

+ CloudWatchLoggingOptions *CloudWatchLoggingOptions

+ DomainARN *string

+ IndexName *string

+ IndexRotationPeriod *string

+ RetryOptions *ElasticsearchRetryOptions

+ RoleARN *string

+ S3BackupMode *string

+ S3Configuration *S3DestinationConfiguration

+ TypeName *string

+ func (s ElasticsearchDestinationConfiguration) GoString() string

+ func (s ElasticsearchDestinationConfiguration) String() string

+ type ElasticsearchDestinationDescription struct

+ BufferingHints *ElasticsearchBufferingHints

+ CloudWatchLoggingOptions *CloudWatchLoggingOptions

+ DomainARN *string

+ IndexName *string

+ IndexRotationPeriod *string

+ RetryOptions *ElasticsearchRetryOptions

+ RoleARN *string

+ S3BackupMode *string

+ S3DestinationDescription *S3DestinationDescription

+ TypeName *string

+ func (s ElasticsearchDestinationDescription) GoString() string

+ func (s ElasticsearchDestinationDescription) String() string

+ type ElasticsearchDestinationUpdate struct

+ BufferingHints *ElasticsearchBufferingHints

+ CloudWatchLoggingOptions *CloudWatchLoggingOptions

+ DomainARN *string

+ IndexName *string

+ IndexRotationPeriod *string

+ RetryOptions *ElasticsearchRetryOptions

+ RoleARN *string

+ S3Update *S3DestinationUpdate

+ TypeName *string

+ func (s ElasticsearchDestinationUpdate) GoString() string

+ func (s ElasticsearchDestinationUpdate) String() string

+ type ElasticsearchRetryOptions struct

+ DurationInSeconds *int64

+ func (s ElasticsearchRetryOptions) GoString() string

+ func (s ElasticsearchRetryOptions) String() string

type RedshiftDestinationConfiguration

+ CloudWatchLoggingOptions *CloudWatchLoggingOptions

type RedshiftDestinationDescription

+ CloudWatchLoggingOptions *CloudWatchLoggingOptions

type RedshiftDestinationUpdate

+ CloudWatchLoggingOptions *CloudWatchLoggingOptions

type S3DestinationConfiguration

+ CloudWatchLoggingOptions *CloudWatchLoggingOptions

type S3DestinationDescription

+ CloudWatchLoggingOptions *CloudWatchLoggingOptions

type S3DestinationUpdate

+ CloudWatchLoggingOptions *CloudWatchLoggingOptions

type UpdateDestinationInput

+ ElasticsearchDestinationUpdate *ElasticsearchDestinationUpdate

Oct 29, 2015

Changes in this version

+ const ServiceName

Oct 7, 2015

Changes in this version

+ const CompressionFormatGzip

+ const CompressionFormatSnappy

+ const CompressionFormatUncompressed

+ const CompressionFormatZip

+ const DeliveryStreamStatusActive

+ const DeliveryStreamStatusCreating

+ const DeliveryStreamStatusDeleting

+ const NoEncryptionConfigNoEncryption

+ type BufferingHints struct

+ IntervalInSeconds *int64

+ SizeInMBs *int64

+ func (s BufferingHints) GoString() string

+ func (s BufferingHints) String() string

+ type CopyCommand struct

+ CopyOptions *string

+ DataTableColumns *string

+ DataTableName *string

+ func (s CopyCommand) GoString() string

+ func (s CopyCommand) String() string

+ type CreateDeliveryStreamInput struct

+ DeliveryStreamName *string

+ RedshiftDestinationConfiguration *RedshiftDestinationConfiguration

+ S3DestinationConfiguration *S3DestinationConfiguration

+ func (s CreateDeliveryStreamInput) GoString() string

+ func (s CreateDeliveryStreamInput) String() string

+ type CreateDeliveryStreamOutput struct

+ DeliveryStreamARN *string

+ func (s CreateDeliveryStreamOutput) GoString() string

+ func (s CreateDeliveryStreamOutput) String() string

+ type DeleteDeliveryStreamInput struct

+ DeliveryStreamName *string

+ func (s DeleteDeliveryStreamInput) GoString() string

+ func (s DeleteDeliveryStreamInput) String() string

+ type DeleteDeliveryStreamOutput struct

+ func (s DeleteDeliveryStreamOutput) GoString() string

+ func (s DeleteDeliveryStreamOutput) String() string

+ type DeliveryStreamDescription struct

+ CreateTimestamp *time.Time

+ DeliveryStreamARN *string

+ DeliveryStreamName *string

+ DeliveryStreamStatus *string

+ Destinations []*DestinationDescription

+ HasMoreDestinations *bool

+ LastUpdateTimestamp *time.Time

+ VersionId *string

+ func (s DeliveryStreamDescription) GoString() string

+ func (s DeliveryStreamDescription) String() string

+ type DescribeDeliveryStreamInput struct

+ DeliveryStreamName *string

+ ExclusiveStartDestinationId *string

+ Limit *int64

+ func (s DescribeDeliveryStreamInput) GoString() string

+ func (s DescribeDeliveryStreamInput) String() string

+ type DescribeDeliveryStreamOutput struct

+ DeliveryStreamDescription *DeliveryStreamDescription

+ func (s DescribeDeliveryStreamOutput) GoString() string

+ func (s DescribeDeliveryStreamOutput) String() string

+ type DestinationDescription struct

+ DestinationId *string

+ RedshiftDestinationDescription *RedshiftDestinationDescription

+ S3DestinationDescription *S3DestinationDescription

+ func (s DestinationDescription) GoString() string

+ func (s DestinationDescription) String() string

+ type EncryptionConfiguration struct

+ KMSEncryptionConfig *KMSEncryptionConfig

+ NoEncryptionConfig *string

+ func (s EncryptionConfiguration) GoString() string

+ func (s EncryptionConfiguration) String() string

+ type Firehose struct

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ type KMSEncryptionConfig struct

+ AWSKMSKeyARN *string

+ func (s KMSEncryptionConfig) GoString() string

+ func (s KMSEncryptionConfig) String() string

+ type ListDeliveryStreamsInput struct

+ ExclusiveStartDeliveryStreamName *string

+ Limit *int64

+ func (s ListDeliveryStreamsInput) GoString() string

+ func (s ListDeliveryStreamsInput) String() string

+ type ListDeliveryStreamsOutput struct

+ DeliveryStreamNames []*string

+ HasMoreDeliveryStreams *bool

+ func (s ListDeliveryStreamsOutput) GoString() string

+ func (s ListDeliveryStreamsOutput) String() string

+ type PutRecordBatchInput struct

+ DeliveryStreamName *string

+ Records []*Record

+ func (s PutRecordBatchInput) GoString() string

+ func (s PutRecordBatchInput) String() string

+ type PutRecordBatchOutput struct

+ FailedPutCount *int64

+ RequestResponses []*PutRecordBatchResponseEntry

+ func (s PutRecordBatchOutput) GoString() string

+ func (s PutRecordBatchOutput) String() string

+ type PutRecordBatchResponseEntry struct

+ ErrorCode *string

+ ErrorMessage *string

+ RecordId *string

+ func (s PutRecordBatchResponseEntry) GoString() string

+ func (s PutRecordBatchResponseEntry) String() string

+ type PutRecordInput struct

+ DeliveryStreamName *string

+ Record *Record

+ func (s PutRecordInput) GoString() string

+ func (s PutRecordInput) String() string

+ type PutRecordOutput struct

+ RecordId *string

+ func (s PutRecordOutput) GoString() string

+ func (s PutRecordOutput) String() string

+ type Record struct

+ Data []byte

+ func (s Record) GoString() string

+ func (s Record) String() string

+ type RedshiftDestinationConfiguration struct

+ ClusterJDBCURL *string

+ CopyCommand *CopyCommand

+ Password *string

+ RoleARN *string

+ S3Configuration *S3DestinationConfiguration

+ Username *string

+ func (s RedshiftDestinationConfiguration) GoString() string

+ func (s RedshiftDestinationConfiguration) String() string

+ type RedshiftDestinationDescription struct

+ ClusterJDBCURL *string

+ CopyCommand *CopyCommand

+ RoleARN *string

+ S3DestinationDescription *S3DestinationDescription

+ Username *string

+ func (s RedshiftDestinationDescription) GoString() string

+ func (s RedshiftDestinationDescription) String() string

+ type RedshiftDestinationUpdate struct

+ ClusterJDBCURL *string

+ CopyCommand *CopyCommand

+ Password *string

+ RoleARN *string

+ S3Update *S3DestinationUpdate

+ Username *string

+ func (s RedshiftDestinationUpdate) GoString() string

+ func (s RedshiftDestinationUpdate) String() string

+ type S3DestinationConfiguration struct

+ BucketARN *string

+ BufferingHints *BufferingHints

+ CompressionFormat *string

+ EncryptionConfiguration *EncryptionConfiguration

+ Prefix *string

+ RoleARN *string

+ func (s S3DestinationConfiguration) GoString() string

+ func (s S3DestinationConfiguration) String() string

+ type S3DestinationDescription struct

+ BucketARN *string

+ BufferingHints *BufferingHints

+ CompressionFormat *string

+ EncryptionConfiguration *EncryptionConfiguration

+ Prefix *string

+ RoleARN *string

+ func (s S3DestinationDescription) GoString() string

+ func (s S3DestinationDescription) String() string

+ type S3DestinationUpdate struct

+ BucketARN *string

+ BufferingHints *BufferingHints

+ CompressionFormat *string

+ EncryptionConfiguration *EncryptionConfiguration

+ Prefix *string

+ RoleARN *string

+ func (s S3DestinationUpdate) GoString() string

+ func (s S3DestinationUpdate) String() string

+ type UpdateDestinationInput struct

+ CurrentDeliveryStreamVersionId *string

+ DeliveryStreamName *string

+ DestinationId *string

+ RedshiftDestinationUpdate *RedshiftDestinationUpdate

+ S3DestinationUpdate *S3DestinationUpdate

+ func (s UpdateDestinationInput) GoString() string

+ func (s UpdateDestinationInput) String() string

+ type UpdateDestinationOutput struct

+ func (s UpdateDestinationOutput) GoString() string

+ func (s UpdateDestinationOutput) String() string