Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Producer ¶
type Producer struct {
// contains filtered or unexported fields
}
Producer implements a replay producer that uses kinesis batch writes as the streaming mechanism
func NewProducer ¶
func NewProducer(c *ProducerConfig) (*Producer, error)
NewProducer returns a new kinesis producer
func (*Producer) Stream ¶
func (p *Producer) Stream() chan *kinesis.PutRecordsRequestEntry
Stream returns a channel that accepts kinesis messages to replay which are buffered by time/count and written in bulk to kinesis
type ProducerConfig ¶
type ProducerConfig struct {
BackoffInterval time.Duration `validate:"required"`
BackoffMaxInterval time.Duration `validate:"required"`
BufferWindow time.Duration `validate:"required"`
Client kinesisiface.KinesisAPI `validate:"required"`
Log logrus.FieldLogger `validate:"required"`
StreamName string `validate:"required"`
}
ProducerConfig defines producer configuration settings
func NewProducerConfig ¶
func NewProducerConfig() *ProducerConfig
NewProducerConfig returns a new ProducerConfig valueu with appropriate defaults
Source Files
Click to show internal directories.
Click to hide internal directories.