Documentation ¶
Index ¶
- Constants
- type Importer
- func (importer *Importer) CleanupJob(job *model.Job)
- func (importer *Importer) GetDataEpoch() time.Time
- func (importer *Importer) Init(cfg module.ModuleConfig) error
- func (importer *Importer) IsRunning() bool
- func (lag *Importer) PrerequisiteModules() []string
- func (importer *Importer) ProcessJob(job *model.Job, reader io.ReadCloser) (io.ReadCloser, error)
- func (importer *Importer) Start() error
- func (importer *Importer) Stop() error
Constants ¶
View Source
const DEFAULT_EXECUTABLE_PATH = "tcpdump"
View Source
const DEFAULT_PCAP_INPUT_PATH = "/nsm/import"
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 Importer ¶
type Importer struct {
// contains filtered or unexported fields
}
func NewImporter ¶
func (*Importer) CleanupJob ¶
func (*Importer) GetDataEpoch ¶
func (*Importer) PrerequisiteModules ¶
func (*Importer) ProcessJob ¶
func (importer *Importer) ProcessJob(job *model.Job, reader io.ReadCloser) (io.ReadCloser, error)
Click to show internal directories.
Click to hide internal directories.