kinesis

package
v0.4.5 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 9, 2020 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type KinesisMessage

type KinesisMessage struct {
	LogEvents []interface{} `json:"logEvents"`
}

type Message

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

type MessageReader

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

MessageReader is a log source that reads from kinesis shard.

func (*MessageReader) MessageRead

func (mr *MessageReader) MessageRead(ctx context.Context) (*logspray.Message, error)

MessageRead implements the LogSourcer interface

type Watcher

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

Watcher watches for shards being added

func New

func New(stream string, region string, messagesChannelSize int) *Watcher

func (*Watcher) Next

func (w *Watcher) Next(ctx context.Context) ([]*sources.Update, error)

Next should be called each time you wish to watch for an update.

func (*Watcher) ReadTarget

func (w *Watcher) ReadTarget(ctx context.Context, shardId string, fromStart bool) (sources.MessageReader, error)

ReadTarget creates a new log source from a kinesis shard

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL