streamer

Documentation

Index

• type GetRecordsEntry
• type KinesisStreamer
  • func New(svc kinesisiface.KinesisAPI, iterators map[string]*string, pollFreqMs int64, ...) *KinesisStreamer
  • func (ks *KinesisStreamer) StartGetRecords() chan *GetRecordsEntry

Types

type GetRecordsEntry

type GetRecordsEntry struct {
	Created time.Time
	Shard   string
	Records []*kinesis.Record
	Err     error
}

GetRecordsEntry returns the results of the last get records request

type KinesisStreamer

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

KinesisStreamer this manages streaming data from a number of shards asynchronously

func New

func New(svc kinesisiface.KinesisAPI, iterators map[string]*string, pollFreqMs int64, logger *logrus.Logger) *KinesisStreamer

New return a new configured streamer

func (*KinesisStreamer) StartGetRecords

func (ks *KinesisStreamer) StartGetRecords() chan *GetRecordsEntry

StartGetRecords intiate the streaming of records using the configured iterators