watcher

Documentation

Index

• type Debouncer
  • func NewDebouncer(interval time.Duration) *Debouncer
  • func (d *Debouncer) Stop()
  • func (d *Debouncer) Trigger(key string, fn func())
• type Event
• type Tailer
  • func NewTailer(path string) *Tailer
  • func (t *Tailer) Offset() int64
  • func (t *Tailer) ReadNewLines() ([][]byte, error)
  • func (t *Tailer) SeekEnd() error
• type Watcher
  • func New(logger *slog.Logger) *Watcher
  • func (w *Watcher) AddFile(path, sessionID string, seekEnd bool)
  • func (w *Watcher) Close() error
  • func (w *Watcher) Events() <-chan Event
  • func (w *Watcher) RemoveFile(path string)
  • func (w *Watcher) Watch(ctx context.Context, basePath string) error

Types

type Debouncer

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

func NewDebouncer

func NewDebouncer(interval time.Duration) *Debouncer

func (*Debouncer) Stop

func (d *Debouncer) Stop()

func (*Debouncer) Trigger

func (d *Debouncer) Trigger(key string, fn func())

type Event

type Event struct {
	SessionID string
	Path      string
	Lines     [][]byte
}

type Tailer

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

func NewTailer

func NewTailer(path string) *Tailer

NewTailer creates a tailer for path. Files ending in ".json" (but not ".jsonl") are treated as whole-file-rewrite sources; everything else is tailed by byte offset as an append-only line stream.

func (*Tailer) Offset

func (t *Tailer) Offset() int64

func (*Tailer) ReadNewLines

func (t *Tailer) ReadNewLines() ([][]byte, error)

func (*Tailer) SeekEnd

func (t *Tailer) SeekEnd() error

type Watcher

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

func New

func New(logger *slog.Logger) *Watcher

func (*Watcher) AddFile

func (w *Watcher) AddFile(path, sessionID string, seekEnd bool)

func (*Watcher) Close

func (w *Watcher) Close() error

func (*Watcher) Events

func (w *Watcher) Events() <-chan Event

func (*Watcher) RemoveFile

func (w *Watcher) RemoveFile(path string)

func (*Watcher) Watch

func (w *Watcher) Watch(ctx context.Context, basePath string) error