processor

Documentation

Index

• type YamlProcessor
  • func NewYamlProcessor(y *model.YamlMapping, filename string) YamlProcessor
  • func (y YamlProcessor) RunParallel(ch chan [][]string, done chan bool)
  • func (y YamlProcessor) RunSync() error
  • func (y YamlProcessor) Validate(filename string) (out [][]string, err error)

Types

type YamlProcessor

type YamlProcessor struct {
	Yaml    *model.YamlMapping
	CsvFile string
}

func NewYamlProcessor

func NewYamlProcessor(y *model.YamlMapping, filename string) YamlProcessor

func (YamlProcessor) RunParallel

func (y YamlProcessor) RunParallel(ch chan [][]string, done chan bool)

run the datadog downloader in parallel based on query util all logs are downloaded

func (YamlProcessor) RunSync

func (y YamlProcessor) RunSync() error

run the datadog downloader sequentially based on query util all logs are downloaded

func (YamlProcessor) Validate

func (y YamlProcessor) Validate(filename string) (out [][]string, err error)

validate if the given yaml configuration is mapped to correct logs in datadog it will download just 10 records for validation