input

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

type FileConfig struct {
	Format  string
	Pattern string
}

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

type MongoConfig struct {
	Url        string `description:"server urls following the format from: http://godoc.org/labix.org/v2/mgo#Dial"`
	Database   string `description:"database name"`
	Collection string `description:"collection name"`
	BatchSize  int    `description:"sets the default batch size used when fetching documents from the database" default:1000`
}

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)"`
}