firehosebatch

Documentation

Index

• func BatchSend(ctx context.Context, client firehoseiface.FirehoseAPI, ...) ([]*firehose.Record, error)
• func Send(ctx context.Context, client firehoseiface.FirehoseAPI, ...) error

Functions

func BatchSend

func BatchSend(ctx context.Context,
	client firehoseiface.FirehoseAPI,
	input firehose.PutRecordBatchInput,
	maxRetries int) ([]*firehose.Record, error)

BatchSend will break the input up into smaller requests based on the firehose size constraints, then call Send to forward those batches. Returns an error for non-retryable errors, and returns a list of records that are too big to send so the caller can handle those records as desired.

func Send

func Send(ctx context.Context, client firehoseiface.FirehoseAPI, input firehose.PutRecordBatchInput, maxRetries int) error

Send will call PutRecordBatch, retrying individual record failures.