ktail

package module
v0.1.1 Latest Latest
Warning

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

 Go to latest Published: Oct 24, 2017 License: MIT Imports: 11 Imported by: 0

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

Constants

This section is empty.

Variables

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

Functions

This section is empty.

Types

type App added in v0.1.0 

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

func New added in v0.1.0 

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

func (*App) Run added in v0.1.0 

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
}

Source Files

View all Source files

Directories

Path Synopsis
cmd
kinesis-tailf
Package kpl is a generated protocol buffer package.
 Package kpl is a generated protocol buffer package.
lambda
functions/grep

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.