prospector

Documentation

Index

• type Prospector
  • func NewProspector(cfg *common.Config, states file.States, spoolerChan chan *input.FileEvent) (*Prospector, error)
  • func (p *Prospector) Init() error
  • func (p *Prospector) Run()
  • func (p *Prospector) Stop()
• type ProspectorLog
  • func NewProspectorLog(p *Prospector) (*ProspectorLog, error)
  • func (p *ProspectorLog) Init()
  • func (p *ProspectorLog) Run()
• type ProspectorStdin
  • func NewProspectorStdin(p *Prospector) (*ProspectorStdin, error)
  • func (p *ProspectorStdin) Init()
  • func (p *ProspectorStdin) Run()
• type Prospectorer

Types

type Prospector

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

func NewProspector

func NewProspector(cfg *common.Config, states file.States, spoolerChan chan *input.FileEvent) (*Prospector, error)

func (*Prospector) Init

func (p *Prospector) Init() error

Init sets up default config for prospector

func (*Prospector) Run

func (p *Prospector) Run()

Starts scanning through all the file paths and fetch the related files. Start a harvester for each file

func (*Prospector) Stop

func (p *Prospector) Stop()

type ProspectorLog

type ProspectorLog struct {
	Prospector *Prospector
	// contains filtered or unexported fields
}

func NewProspectorLog

func NewProspectorLog(p *Prospector) (*ProspectorLog, error)

func (*ProspectorLog) Init

func (p *ProspectorLog) Init()

func (*ProspectorLog) Run

func (p *ProspectorLog) Run()

type ProspectorStdin

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

func NewProspectorStdin

func NewProspectorStdin(p *Prospector) (*ProspectorStdin, error)

NewProspectorStdin creates a new stdin prospector This prospector contains one harvester which is reading from stdin

func (*ProspectorStdin) Init

func (p *ProspectorStdin) Init()

func (*ProspectorStdin) Run

func (p *ProspectorStdin) Run()

type Prospectorer

type Prospectorer interface {
	Init()
	Run()
}