Documentation ¶ Index ¶ func StartWatchingDir(ctx context.Context, dir string, resetDelay time.Duration, ...) error type Queue func NewQueue[T any]() *Queue[T] func (q *Queue[T]) Put(v T) func (q *Queue[T]) Subscribe(ctx context.Context, fn func(v T)) Constants ¶ This section is empty. Variables ¶ This section is empty. Functions ¶ func StartWatchingDir ¶ func StartWatchingDir(ctx context.Context, dir string, resetDelay time.Duration, callback func(filePath string)) error Types ¶ type Queue ¶ type Queue[T any] struct { // contains filtered or unexported fields } func NewQueue ¶ func NewQueue[T any]() *Queue[T] func (*Queue[T]) Put ¶ func (q *Queue[T]) Put(v T) func (*Queue[T]) Subscribe ¶ func (q *Queue[T]) Subscribe(ctx context.Context, fn func(v T)) Source Files ¶ View all Source files notify.go queue.go Click to show internal directories. Click to hide internal directories.