input

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

type FileConfig struct {
	Format  string
	Pattern string
}

type ReaderEOFNotifier func() error

type ReaderFactory func() io.Reader

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

type S3Config struct {
	AccessKey string
	SecretKey string
	Region    string
	Bucket    string
	Format    string `description:"A valid format name."`
	Prefix    string `description:"Limits the response to keys that begin with the specified prefix."`
	Delimiter string `description:"A delimiter is a character you use to group keys."`
	Marker    string `description:"Specifies the key to start with when listing objects in a bucket."`
	MaxKeys   int    `description:"Sets the maximum number of keys returned."`
	TrackFile string `description:"File for track the read files."`
	Gzip      bool
}

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

type TailConfig struct {
	Format    string `description:"A valid format name"`
	File      string `description:"File to be read"`
	MustExist bool   `description:"Fail early if the file does not exist"`
	Poll      bool   `description:"Poll for file changes instead of using inotify"`
	LimitRate int64  `description:"Maximum read rate (lines per second)"`
}