collection

Oct 2, 2023

Changes in this version

+ func New(directory string, namer file.Namer, options ...file.CollectionOption) (file.Collection, error)

+ func WithArchive(directory string) file.CollectionOption

+ func WithArchiveTarGZ(directory string) file.CollectionOption

+ func WithArchiveZIP(directory string) file.CollectionOption

+ func WithCheckDirectory(directoryPath string) file.CollectionOption

+ func WithContext(ctx context.Context) file.CollectionOption

+ func WithFileCount(counter prometheus.Gauge, directory string) file.CollectionOption

+ type Context struct

+ func NewContext(collection file.Collection, ctx context.Context) *Context

+ func (collection *Context) Next() (*os.File, error)

+ type Files struct

+ func NewFiles(directory string, namer file.Namer) *Files

+ func (collection *Files) Count() int

+ func (collection *Files) Namer() file.Namer

+ func (collection *Files) Next() (*os.File, error)

+ type TarGZ struct

+ func NewTarGZ(collection file.Collection, directory string) *TarGZ

+ func (archive *TarGZ) Next() (*os.File, error)

+ type ZIP struct

+ func NewZIP(collection file.Collection, directory string) *ZIP

+ func (archive *ZIP) Next() (*os.File, error)