Versions in this module Expand all Collapse all v0 v0.9.13 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
Go to main page