analyze

Documentation

Index

• Constants
• type Analyze
  • func NewAnalyze(agt *agent.Agent) *Analyze
  • func (analyze *Analyze) CleanupJob(job *model.Job)
  • func (analyze *Analyze) GetDataEpoch() time.Time
  • func (analyze *Analyze) Init(cfg module.ModuleConfig) error
  • func (analyze *Analyze) IsRunning() bool
  • func (analyze *Analyze) PrerequisiteModules() []string
  • func (analyze *Analyze) ProcessJob(job *model.Job, reader io.ReadCloser) (io.ReadCloser, error)
  • func (analyze *Analyze) Start() error
  • func (analyze *Analyze) Stop() error

Constants

const DEFAULT_ANALYZERS_PATH = "/opt/sensoroni/analyzers"

const DEFAULT_ANALYZER_EXECUTABLE = "python"

const DEFAULT_ANALYZER_INSTALLER = "pip"

const DEFAULT_PARALLEL_LIMIT = 5

const DEFAULT_SUMMARY_LENGTH = 50

const DEFAULT_TIMEOUT_MS = 900000

Types

type Analyze

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

func NewAnalyze

func NewAnalyze(agt *agent.Agent) *Analyze

func (*Analyze) CleanupJob

func (analyze *Analyze) CleanupJob(job *model.Job)

func (*Analyze) GetDataEpoch

func (analyze *Analyze) GetDataEpoch() time.Time

func (*Analyze) Init

func (analyze *Analyze) Init(cfg module.ModuleConfig) error

func (*Analyze) IsRunning

func (analyze *Analyze) IsRunning() bool

func (*Analyze) PrerequisiteModules

func (analyze *Analyze) PrerequisiteModules() []string

func (*Analyze) ProcessJob

func (analyze *Analyze) ProcessJob(job *model.Job, reader io.ReadCloser) (io.ReadCloser, error)

func (*Analyze) Start

func (analyze *Analyze) Start() error

func (*Analyze) Stop

func (analyze *Analyze) Stop() error