Documentation
¶
Index ¶
- Constants
- type 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 ¶
View Source
const DEFAULT_DATA_LAG_MS = 120000
View Source
const DEFAULT_EPOCH_REFRESH_MS = 120000
View Source
const DEFAULT_EXECUTABLE_PATH = "stenoread"
View Source
const DEFAULT_PCAP_INPUT_PATH = "/nsm/pcap"
View Source
const DEFAULT_PCAP_OUTPUT_PATH = "/nsm/pcapout"
View Source
const DEFAULT_TIMEOUT_MS = 1200000
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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
Source Files
Click to show internal directories.
Click to hide internal directories.