firehose

Documentation

Index

• type FireHoseClient
• type FireHoseProducer
  • func NewProducer(destinationConfig map[string]interface{}, o common.Opts) (*FireHoseProducer, error)
  • func (producer *FireHoseProducer) Produce(jsonData json.RawMessage, _ interface{}) (int, string, string)

Types

type FireHoseClient

type FireHoseClient interface {
	PutRecord(input *firehose.PutRecordInput) (*firehose.PutRecordOutput, error)
}

type FireHoseProducer

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

func NewProducer

func NewProducer(destinationConfig map[string]interface{}, o common.Opts) (*FireHoseProducer, error)

NewProducer creates a producer based on destination config

func (*FireHoseProducer) Produce

func (producer *FireHoseProducer) Produce(jsonData json.RawMessage, _ interface{}) (int, string, string)

Produce creates a producer and send data to Firehose.