ktail

README

kinesis-tailf

tail -f command for Amazon Kinesis.

Install

go get -u github.com/fujiwara/kinesis-tailf/cmd/kinesis-tailf

Usage

Required flags are below.

• -stream
• -region or AWS_REGION environment variable

Usage of kinesis-tailf:
  -end string
    	end timestamp
  -lf
    	append LF(\n) to each record
  -region string
    	region (default AWS_REGION environment variable)
  -shard-key string
    	shard key
  -start string
    	start timestamp
  -stream string
    	stream name

kinesis-tailf supports decoding packed records by Kinesis Producer Library (KPL).

Licence

MIT

Documentation

Index

• Variables
• type App
  • func New(sess *session.Session, name string) *App
  • func (app *App) Run(ctx context.Context, shardKey string, startTs, endTs time.Time) error
• type IterateParams

Variables

var (
	LF = []byte{'\n'}
)

Types

type App

type App struct {
	StreamName string
	AppendLF   bool
	// contains filtered or unexported fields
}

func New

func New(sess *session.Session, name string) *App

func (*App) Run

func (app *App) Run(ctx context.Context, shardKey string, startTs, endTs time.Time) error

type IterateParams

type IterateParams struct {
	StreamName     string
	ShardID        string
	StartTimestamp time.Time
	EndTimestamp   time.Time
}