Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Send ¶
func Send(ctx context.Context, client firehoseiface.FirehoseAPI, input firehose.PutRecordBatchInput, maxRetries int) error
Will call PutRecordBatch, retrying individual record failures. TODO This method doesn't currently handle requests greater than 4MB or 500 records
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.