eventlog

type Checkpoint struct {
	Name         string
	RecordNumber uint64
	Timestamp    time.Time
	Bookmark     string
}

type EventLog interface {
	// Open the event log. checkpoint points to the last successfully read event
	// in this event log. Read will resume from the next record. To start reading
	// from the first event specify a zero-valued Checkpoint.
	Open(checkpoint Checkpoint) error

	// Read records from the event log.
	Read() ([]Record, error)

	// Close the event log. It should not be re-opened after closing.
	Close() error

	// Name returns the event log's name.
	Name() string
}

type EventLogConfig struct {
	Context     pipeline.Context
	Name        string
	IgnoreOlder time.Duration
	EventID     string
	Level       string
	Provider    []string
}

type Record struct {
	sys.Event
	API    string     // The event log API type used to read the record.
	XML    string     // XML representation of the event.
	Offset Checkpoint // Position of the record within its source stream.
}