firehose

type Config struct {
	// StreamName: the name of the Kinesis Firehose.
	FireHoseName string

	// Region is the AWS region of the Kinesis Firehose
	Region string

	// FlushInterval: how often to flush the buffer.
	FlushInterval time.Duration

	// BufferSize: the batch request size (cannot be greater than 500).
	BufferSize int

	// BacklogSize
	BacklogSize int

	// Backoff: strategy to use for failures.
	Backoff backoff.Backoff

	// Logger: the logger used.
	Logger log.Logger

	// Client is a firehose API instance
	Client firehoseiface.FirehoseAPI
}

type Producer struct {
	Config
	// contains filtered or unexported fields
}