nwfs

Documentation

Index

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

Types

type Fs

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

func NewFs

func NewFs(dir string, logger ecslogger.ILogger) Fs

NewFs creates a new Fs instance.

func (Fs) Delete

func (f Fs) Delete(file string) error

Delete deletes a file from the directory

func (Fs) Unprocessable

func (f Fs) Unprocessable(file string) 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 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 string) error
	Unprocessable(file string) error
}

type NewFile

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