kinesisstream

type Config struct {
	// DBName is the name of the ark db. Either specify this or StreamName.
	DBName string
	// Environment is the name of the environment to point to. Default is _DEPLOY_ENV.
	Environment string
	// StreamName is the name of the Kinesis stream to send to. Either specify this or DBName.
	StreamName string
	// Region is the region where this is running. Defaults to _POD_REGION.
	Region string
	// KinesisPutRecordBatchMaxRecords overrides the default value (500) for the maximum number of records to send in a batch.
	KinesisPutRecordBatchMaxRecords int
	// KinesisPutRecordBatchMaxBytes overrides the default value (5000000) for the maximum number of bytes to send in as batch.
	KinesisPutRecordBatchMaxBytes int
	// KinesisPutRecordBatchMaxTime overrides the default value (10 minutes) for the maximum amount of time between writing an event and sending to the stream.
	KinesisPutRecordBatchMaxTime time.Duration
	// KinesisAPI defaults to an API object configured with Region, but can be overriden here.
	KinesisAPI kinesisiface.KinesisAPI
	// ErrLogger is a logger used to make sure errors from goroutines still get surfaced. Defaults to basic logger.Logger
	ErrLogger logger.KayveeLogger
}

type Logger struct {
	logger.KayveeLogger
	// contains filtered or unexported fields
}

type RequestErrorClassifier struct{}