acquisition

Apr 11, 2024

Changes in this version

+ func GetMetricsLevelFromPromCfg(prom *csconfig.PrometheusCfg) int

Sep 18, 2023

Changes in this version

+ type DataSourceUnavailableError struct

+ Err error

+ Name string

+ func (e *DataSourceUnavailableError) Error() string

+ func (e *DataSourceUnavailableError) Unwrap() error

May 16, 2023

Changes in this version

type DataSource

+ GetUuid func() string

+ UnmarshalConfig func([]byte) error

Jul 5, 2021

Changes in this version

+ var AcquisitionSources = []struct{ ... }

+ func GetMetrics(sources []DataSource, aggregated bool) error

type DataSource

+ func GetDataSourceIface(dataSourceType string) DataSource

+ func LoadAcquisitionFromDSN(dsn string, label string) ([]DataSource, error)

+ CanRun func() error

+ ConfigureByDSN func(string, string, *log.Entry) error

+ Dump func() interface{}

+ GetAggregMetrics func() []prometheus.Collector

+ GetMetrics func() []prometheus.Collector

+ GetMode func() string

+ GetName func() string

+ OneShotAcquisition func(chan types.Event, *tomb.Tomb) error

+ StreamingAcquisition func(chan types.Event, *tomb.Tomb) error

Dec 7, 2020

Changes in this version

+ var CAT_MODE = "cat"

+ var JOURNALD_CMD = "journalctl"

+ var JOURNALD_DEFAULT_CAT_ARGS = []string

+ var JOURNALD_DEFAULT_TAIL_ARGS = []string

+ var TAIL_MODE = "tail"

+ func StartAcquisition(sources []DataSource, output chan types.Event, AcquisTomb *tomb.Tomb) error

+ type DataSource interface

+ Configure func(DataSourceCfg) error

+ Mode func() string

+ StartReading func(chan types.Event, *tomb.Tomb) error

+ func DataSourceConfigure(config DataSourceCfg) (DataSource, error)

+ func LoadAcquisitionFromFile(config *csconfig.CrowdsecServiceCfg) ([]DataSource, error)

+ type DataSourceCfg struct

+ Filename string

+ Filenames []string

+ JournalctlFilters []string

+ Labels map[string]string

+ Mode string

+ Profiling bool

+ type FileSource struct

+ Config DataSourceCfg

+ Files []string

+ func (f *FileSource) CatOneFile(output chan types.Event, AcquisTomb *tomb.Tomb, idx int) error

+ func (f *FileSource) Configure(Config DataSourceCfg) error

+ func (f *FileSource) Mode() string

+ func (f *FileSource) StartCat(output chan types.Event, AcquisTomb *tomb.Tomb) error

+ func (f *FileSource) StartReading(out chan types.Event, t *tomb.Tomb) error

+ func (f *FileSource) StartTail(output chan types.Event, AcquisTomb *tomb.Tomb) error

+ func (f *FileSource) TailOneFile(output chan types.Event, AcquisTomb *tomb.Tomb, idx int) error

+ type JournaldSource struct

+ Cmd *exec.Cmd

+ Config DataSourceCfg

+ Decoder *json.Decoder

+ SrcName string

+ Stderr io.ReadCloser

+ Stdout io.ReadCloser

+ func (j *JournaldSource) Configure(config DataSourceCfg) error

+ func (j *JournaldSource) Mode() string

+ func (j *JournaldSource) StartCat(out chan types.Event, t *tomb.Tomb) error

+ func (j *JournaldSource) StartReading(out chan types.Event, t *tomb.Tomb) error

+ func (j *JournaldSource) StartTail(out chan types.Event, t *tomb.Tomb) error

Jun 10, 2020

Changes in this version

type FileAcquisCtx

+ func LoadAcquisitionConfig(cConfig *csconfig.CrowdSec) (*FileAcquisCtx, error)

May 15, 2020

Changes in this version

+ const BINTYPE

+ const CATMODE

+ const FILETYPE

+ const TAILMODE

+ var ReaderHits = prometheus.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... })

+ func AcquisReadOneFile(ctx FileCtx, output chan types.Event, AcquisTomb *tomb.Tomb) error

+ func AcquisStartReading(ctx *FileAcquisCtx, output chan types.Event, AcquisTomb *tomb.Tomb)

+ func ReadAtOnce(ctx FileCtx, output chan types.Event, AcquisTomb *tomb.Tomb) error

+ type Acquisition interface

+ Init func(map[string]interface{}) (interface{}, error)

+ ReadOne func(interface{}) (string, error)

+ type FileAcquisCtx struct

+ Files []FileCtx

+ Profiling bool

+ func InitReader(cfg string) (*FileAcquisCtx, error)

+ func InitReaderFromFileCtx(files []FileCtx) (*FileAcquisCtx, error)

+ type FileCtx struct

+ Filename string

+ Filenames []string

+ Labels map[string]string

+ Mode string

+ Profiling bool

+ Type string