firehosebatch

package

v1.16.0 Latest Latest Go to latest Published: Mar 10, 2021 License: AGPL-3.0 Imports: 6 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/panther-labs/panther

Documentation ¶

Index ¶

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

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func BatchSend ¶ added in v1.14.0

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.

Types ¶

This section is empty.

Source Files ¶

View all Source files

firehosebatch.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL