firehose

Documentation

Index

• type FireHoseClient
• type FireHoseProducer
  • func NewProducer(destination *backendconfig.DestinationT, o common.Opts) (*FireHoseProducer, error)
  • func (*FireHoseProducer) Close() 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(destination *backendconfig.DestinationT, o common.Opts) (*FireHoseProducer, error)

NewProducer creates a producer based on destination config

func (*FireHoseProducer) Close

func (*FireHoseProducer) Close() error

func (*FireHoseProducer) Produce

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

Produce creates a producer and send data to Firehose.