kinesis

Documentation

Index

• type KinesisMessage
• type Message
• type MessageReader
  • func (mr *MessageReader) MessageRead(ctx context.Context) (*logspray.Message, error)
• type Watcher
  • func New(stream string, region string, messagesChannelSize int) *Watcher
  • func (w *Watcher) Next(ctx context.Context) ([]*sources.Update, error)
  • func (w *Watcher) ReadTarget(ctx context.Context, shardId string, fromStart bool) (sources.MessageReader, error)

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