scanner

package

v0.3.0 Latest Latest Go to latest Published: May 29, 2024 License: Apache-2.0 Imports: 14 Imported by: 0

Details

Package scanner parses log files

This section is empty.

This section is empty.

func New(
	cfg *server.Config, store store.Store, registry *prometheus.Registry, scheduler *gocron.Scheduler,
) server.Server

New returns a server that manages scanners.

type Config struct {
	Follow        bool
	FromBeginning bool
	Poll          bool
	Reopen        bool
}

Config defines the behavior of the scanner

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

Metric defines the prometheus counter to increment when a line matches the regular expression.

type Parse func(context.Context, *tail.Tail, map[string]*Metric) error

Parse implements the custom logic to parse a specific log file type.

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

Scanner scans a log file to extract the given metrics.

func FromConfig(
	scan *store.Scan, config *Config, registerer prometheus.Registerer,
) (*Scanner, error)

FromConfig creates a new scanner, based on the configuration provided.

func (s *Scanner) GetLastModified() time.Time

GetLastModified returns the last time the scanner configuration was updated.

func (s *Scanner) Start(ctx *stopper.Context) error

Start scanning the log

func (s *Scanner) Stop() error

Stop stops the scanning activity.