notification

package

v0.11.100 Latest Latest Go to latest Published: Nov 10, 2023 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation ¶

This section is empty.

This section is empty.

func AnyFilter(filters []FilterEvent, event fsnotify.Event) bool

AnyFilter is a cumulative filter which returns true (hence passes) only ifat least one of the provided filters pass.

func FilterEverything(_ fsnotify.Event) bool

func FilterNothing(_ fsnotify.Event) bool

type Event struct {
	Timestamp     time.Time
	TimerInterval time.Duration
}

func (ev Event) IsTimer() bool

type EventSource interface {
	Events() <-chan Event
	Close()
	Wait()
	Stop()
	Run()
}

type FilterEvent func(event fsnotify.Event) bool

FilterEvent returns true if the given event is relevant and should be handled

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

func NewUnlimitedEventSource() (*UnlimitedEventSource, error)

func (es *UnlimitedEventSource) AddFile(notifyFilePath string) error

func (es *UnlimitedEventSource) Close()

func (es *UnlimitedEventSource) Events() <-chan Event

func (es *UnlimitedEventSource) Run()

func (es *UnlimitedEventSource) SetInterval(interval time.Duration) error

func (es *UnlimitedEventSource) Stop()

func (es *UnlimitedEventSource) Wait()

Wait stops the caller until the EventSource is exhausted