Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type API ¶
type API struct {
Client firehoseiface.FirehoseAPI
}
API wraps a Kinesis Firehose client interface
func (*API) PutRecord ¶
func (a *API) PutRecord(ctx aws.Context, data []byte, stream string) (*firehose.PutRecordOutput, error)
PutRecord is a convenience wrapper for putting a record into a Kinesis Firehose stream.
func (*API) PutRecordBatch ¶
func (a *API) PutRecordBatch(ctx aws.Context, data [][]byte, stream string) (*firehose.PutRecordBatchOutput, error)
PutRecordBatch is a convenience wrapper for putting multiple records into a Kinesis Firehose stream. This function becomes recursive for any records that failed the PutRecord operation.
Click to show internal directories.
Click to hide internal directories.