aalog

Documentation

Index

• type AaLog
  • func New(c config.AalogbeatConfig) (AaLog, error)
• type LogHeader
• type LogRecord
• type Record
  • func (r Record) ToEvent() beat.Event

Types

type AaLog

type AaLog interface {
	// Open the event log. state 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 AaLogState.
	Open(state checkpoint.AaLogState) error

	// Read records from the log. If io.EOF is returned you should stop reading
	// and close the log.
	Read() ([]Record, error)

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

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

	// State returns the most recent AaLogState.
	State() checkpoint.AaLogState
}

func New

func New(c config.AalogbeatConfig) (AaLog, error)

New creates and returns a new AaLog for reading logs

type LogHeader

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

type LogRecord

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

type Record

type Record struct {
	LogRecord
	Offset checkpoint.AaLogState // Position of the record within its source stream.
}

func (Record) ToEvent

func (r Record) ToEvent() beat.Event

ToEvent returns a new MapStr containing the data from this LogRecord