streams

type PartitionKeyProvider interface {
	PartitionKeyFor(event *publisher.Event) (string, error)
}

type StreamsConfig struct {
	Region               string          `config:"region"`
	DeliveryStreamName   string          `config:"stream_name"`
	PartitionKey         string          `config:"partition_key"`
	PartitionKeyProvider string          `config:"partition_key_provider"`
	BatchSize            int             `config:"batch_size"`
	BatchSizeBytes       int             `config:"batch_size_bytes"`
	MaxRetries           int             `config:"max_retries"`
	Timeout              time.Duration   `config:"timeout"`
	Backoff              backoff.Backoff `config:"backoff"`
	GZip                 bool            `config:"gzip"`
}