kinesis

Documentation

Index

• func NewProducer(maxRetries int, streams map[string]string, overrideHost string, ...) (telemetry.Producer, error)
• type Metrics
• type Producer
  • func (p *Producer) Close() error
  • func (p *Producer) ProcessReliableAck(entry *telemetry.Record)
  • func (p *Producer) Produce(entry *telemetry.Record)
  • func (p *Producer) ReportError(message string, err error, logInfo logrus.LogInfo)

Functions

func NewProducer

func NewProducer(maxRetries int, streams map[string]string, overrideHost string, prometheusEnabled bool, metricsCollector metrics.MetricCollector, airbrakeHandler *airbrake.Handler, ackChan chan (*telemetry.Record), reliableAckTxTypes map[string]interface{}, logger *logrus.Logger) (telemetry.Producer, error)

NewProducer configures and tests the kinesis connection

Types

type Metrics

type Metrics struct {
	// contains filtered or unexported fields
}

Metrics stores metrics reported from this package

type Producer

type Producer struct {
	// contains filtered or unexported fields
}

Producer client to handle kinesis interactions

func (*Producer) Close

func (p *Producer) Close() error

Close the producer

func (*Producer) ProcessReliableAck

func (p *Producer) ProcessReliableAck(entry *telemetry.Record)

ProcessReliableAck sends to ackChan if reliable ack is configured

func (*Producer) Produce

func (p *Producer) Produce(entry *telemetry.Record)

Produce asynchronously sends the record payload to kineses

func (*Producer) ReportError

func (p *Producer) ReportError(message string, err error, logInfo logrus.LogInfo)

ReportError to airbrake and logger