kinesis

Documentation

Index

• type Producer
  • func NewProducer(c *ProducerConfig) (*Producer, error)
  • func (p *Producer) Stream() chan *kinesis.PutRecordsRequestEntry
  • func (p *Producer) Wait()
• type ProducerConfig
  • func NewProducerConfig() *ProducerConfig

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

func (*Producer) Wait

func (p *Producer) Wait()

Wait will block until the producer has finished replaying all messages

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