Versions in this module Expand all Collapse all v0 v0.0.1 Nov 3, 2022 Changes in this version + var ErrRecordSizeExceeded = errors.New("kinesis: record size exceeded") + type Config struct + BacklogSize int + Backoff backoff.Backoff + BufferSize int + Client kinesisiface.KinesisAPI + FlushInterval time.Duration + Logger log.Interface + StreamName string + type Producer struct + func New(config Config) *Producer + func (p *Producer) Put(data []byte, partitionKey string) error + func (p *Producer) Start() + func (p *Producer) Stop()