watcher

Sep 2, 2022

Changes in this version

+ var HelperDestination string

+ var HelperExt string

+ var HelperFile string

+ var HelperOperation string

+ var HelperPath string

+ var HelperPattern string

+ func TestEventSetup(t *testing.T) *event.Event

+ func TestProducerConsumer() (Producer, Consumer)

+ func TestSimulateMultipleEvents(operationList []string, t *testing.T) []event.Event

type PathConsumer

+ Pattern regexp.Regexp

type PathWatcher

+ func TestPathWatcher() *PathWatcher

Jan 10, 2022

Changes in this version

+ func Hash(ev event.Event) string

type PathWatcher

+ Queue *Q

+ func (pw *PathWatcher) Notify(path, event string)

+ func (pw *PathWatcher) Poll(interval int)

type Producer

+ Notify func(path, event string)

+ type Q struct

+ Queue map[string]event.Event

+ func NewQueue() *Q

+ func (q *Q) Add(ev event.Event)

+ func (q *Q) Empty() bool

+ func (q *Q) Remove(hash string)

+ func (q *Q) Retrieve(hash string) event.Event

+ func (q *Q) Size() int

Dec 31, 2021

Changes in this version

+ type Consumer interface

+ Process func(e *event.Event)

+ ProcessDirEvent func(e *event.Event)

+ Receive func(path, event string)

+ type PathConsumer struct

+ Destination string

+ Ext string

+ Path string

+ func (pc *PathConsumer) Process(e *event.Event)

+ func (pc *PathConsumer) ProcessDirEvent(e *event.Event)

+ func (pc *PathConsumer) Receive(path, ev string)

+ type PathWatcher struct

+ Consumers []*Consumer

+ Path string

+ Watcher fsnotify.Watcher

+ func (pw *PathWatcher) AddPath(path string)

+ func (pw *PathWatcher) Observe()

+ func (pw *PathWatcher) Register(consumer *Consumer)

+ func (pw *PathWatcher) Unregister(consumer *Consumer)

+ type Producer interface

+ Observe func()

+ Register func(consumer *Consumer)

+ Unregister func(consumer *Consumer)