nwfs

Documentation

Index

• type Config
• type Fs
  • func NewFs(config Config, logger ecslogger.ILogger) Fs
  • func (f Fs) Delete(file NewFile) error
  • func (f Fs) Unprocessable(file NewFile) error
  • func (f Fs) Watch(ctx context.Context, chanFiles chan NewFile) error
• type IFs
• type NewFile

Types

type Config

type Config struct {
	Dir                string
	IgnoreDirs         []string
	SkipReadingContent bool
}

type Fs

type Fs struct {
	Config
	// contains filtered or unexported fields
}

func NewFs

func NewFs(config Config, logger ecslogger.ILogger) Fs

NewFs creates a new Fs instance.

func (Fs) Delete

func (f Fs) Delete(file NewFile) error

Delete deletes a file from the directory

func (Fs) Unprocessable

func (f Fs) Unprocessable(file NewFile) error

Unprocessable moves a file to unprocessable directory

func (Fs) Watch

func (f Fs) Watch(ctx context.Context, chanFiles chan NewFile) error

Watch watches the directory for top and nested new files and sends them to the channel, it also processes existing files. Files are uploaded after 100ms without a WRITE or CREATE event.

type IFs

type IFs interface {
	Watch(ctx context.Context, chanFiles chan NewFile) error
	Delete(file NewFile) error
	Unprocessable(file NewFile) error
}

type NewFile

type NewFile struct {
	Name         string
	Path         string
	RelativePath string
	Bytes        []byte
	ReceivedTime time.Time
}