filewatch

Documentation

Index

• type FullHandler
• type TailHandler
• type TailHandlerWithIO
• type Watcher
  • func New(ctx context.Context) (*Watcher, error)
  • func (w *Watcher) Close()
  • func (w *Watcher) RegisterFullHandler(fullpath string, handler FullHandler)
  • func (w *Watcher) RegisterTailHandler(fullpath string, handler TailHandler)

Types

type FullHandler

type FullHandler func(io.ReadCloser) error

FullHandler handle full text as io.ReadCloser

type TailHandler

type TailHandler func(line string, allLines []string) error

TailHandler let you can do what you want depends on currentLine and allLines allLines include currentLine

type TailHandlerWithIO

type TailHandlerWithIO struct {
	Handler TailHandler
	TailIO  *tail.Tail
}

type Watcher

type Watcher struct {

	// tail
	EndLineForTail string

	// wait all fw things done
	Wait sync.WaitGroup
	// contains filtered or unexported fields
}

func New

func New(ctx context.Context) (*Watcher, error)

func (*Watcher) Close

func (w *Watcher) Close()

func (*Watcher) RegisterFullHandler

func (w *Watcher) RegisterFullHandler(fullpath string, handler FullHandler)

func (*Watcher) RegisterTailHandler

func (w *Watcher) RegisterTailHandler(fullpath string, handler TailHandler)