Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Params ¶
type Params struct { Persister types.Persister // Persister to load and store state with. Reader types.Reader // Reader to read logs from. Logger log.Logger // Logger to use. InitialState types.State }
Params contains parameters for NewWatcher.
type Watcher ¶
type Watcher struct {
// contains filtered or unexported fields
}
Watcher is a component that wraps a Reader and takes care of loading and storing state before an after calling Reader.ReadLogs. It ensures that each Reader never reads the same messages that were previously read.
Click to show internal directories.
Click to hide internal directories.