flyonthewall

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 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

type NewFile

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