tailer

Jun 28, 2019

Changes in this version

+ func InitWebhookTailer(inputConfig *v2.InputConfig) fswatcher.FileTailer

+ func NewLineBuffer() lineBuffer

+ func WebhookHandler() http.Handler

+ func WebhookProcessBody(c *v2.InputConfig, b []byte) []string

type BufferLoadMetric

+ Dec func()

+ Inc func()

+ Set func(value int64)

+ Start func()

+ Stop func()

+ type WebhookTailer struct

+ func (t *WebhookTailer) Close()

+ func (t *WebhookTailer) Errors() chan fswatcher.Error

+ func (t *WebhookTailer) Lines() chan *fswatcher.Line

+ func (t WebhookTailer) ServeHTTP(w http.ResponseWriter, r *http.Request)

Apr 8, 2019

Changes in this version

+ func BufferedTailer(orig fswatcher.FileTailer) fswatcher.FileTailer

+ func BufferedTailerWithMetrics(orig fswatcher.FileTailer, bufferLoadMetric BufferLoadMetric) fswatcher.FileTailer

+ type BufferLoadMetric interface

+ Observe func(currentLoad float64)

+ Register func()

+ Unregister func()

Oct 8, 2018

Changes in this version

+ type Error interface

+ Cause func() error

Sep 22, 2017

Changes in this version

+ type EventLoop interface

+ Errors func() chan error

+ Events func() chan Events

+ type Events interface

+ Process func(fileBefore *File, reader *bufferedLineReader, abspath string, ...) (file *File, lines []string, err error)

+ type File struct

+ func (f *File) CheckMoved() (bool, error)

+ func (f *File) CheckTruncated() (bool, error)

+ func (f *File) Close() error

+ func (f *File) Name() string

+ func (f *File) Read(b []byte) (int, error)

+ func (f *File) Seek(offset int64, whence int) (int64, error)

+ func (file *File) CheckMoved() (bool, error)

+ func (file *File) CheckTruncated() (bool, error)

type Tailer

+ func RunFseventFileTailer(path string, readall bool, logger simpleLogger) Tailer

+ func RunPollingFileTailer(path string, readall bool, pollIntervall time.Duration, logger simpleLogger) Tailer

+ type Watcher interface

+ StartEventLoop func() EventLoop

+ func NewFseventWatcher(abspath string, _ *File) (Watcher, error)

+ func NewFseventWatcher(abspath string, file *File) (Watcher, error)

+ func NewPollingWatcher(abspath string, timeInterval time.Duration) (Watcher, error)

Sep 2, 2016

Changes in this version

+ func NewBufferedLineReader() *bufferedLineReader

+ type Tailer interface

+ Close func()

+ Errors func() chan error

+ Lines func() chan string

+ func RunFileTailer(path string, readall bool, logger simpleLogger) Tailer

+ func RunStdinTailer() Tailer