stenoquery

Documentation

Index

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

Constants

const DEFAULT_DATA_LAG_MS = 120000

const DEFAULT_EPOCH_REFRESH_MS = 120000

const DEFAULT_EXECUTABLE_PATH = "stenoread"

const DEFAULT_PCAP_INPUT_PATH = "/nsm/pcap"

const DEFAULT_PCAP_OUTPUT_PATH = "/nsm/pcapout"

const DEFAULT_TIMEOUT_MS = 1200000

Types

type StenoQuery

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

func NewStenoQuery

func NewStenoQuery(agt *agent.Agent) *StenoQuery

func (*StenoQuery) CleanupJob

func (steno *StenoQuery) CleanupJob(job *model.Job)

func (*StenoQuery) CreateQuery

func (steno *StenoQuery) CreateQuery(job *model.Job) string

func (*StenoQuery) GetDataEpoch

func (steno *StenoQuery) GetDataEpoch() time.Time

func (*StenoQuery) Init

func (steno *StenoQuery) Init(cfg module.ModuleConfig) error

func (*StenoQuery) IsRunning

func (steno *StenoQuery) IsRunning() bool

func (*StenoQuery) PrerequisiteModules

func (lag *StenoQuery) PrerequisiteModules() []string

func (*StenoQuery) ProcessJob

func (steno *StenoQuery) ProcessJob(job *model.Job, reader io.ReadCloser) (io.ReadCloser, error)

func (*StenoQuery) Start

func (steno *StenoQuery) Start() error

func (*StenoQuery) Stop

func (steno *StenoQuery) Stop() error