pdk

type Node struct {
	ID         string   `yaml:"id"`
	Group      string   `yaml:"group"`
	Search     string   `yaml:"search"`
	Attributes []string `yaml:"attributes"`
	VarTypes   []*struct {
		Regex         string         `yaml:"regex"`
		RegexCompiled *regexp.Regexp `yaml:"-"`
		Group         string         `yaml:"group"`
		Search        string         `yaml:"search"`
		Label         string         `yaml:"label"`
	} `yaml:"varTypes"`
}

type Processor struct {
	Name    string                 `yaml:"name"`
	Plugin  string                 `yaml:"plugin"`
	Timeout time.Duration          `yaml:"timeout"`
	Data    map[string]interface{} `yaml:"data"`
}

type ProcessorPlugin interface {
	// Return instance configuration
	Conf() *Processor

	// Set specific parameters for the instance,
	// establish connection, etc.
	Setup(*Processor) error

	// Process data source's received data in a background
	Process([]map[string]interface{}) ([]map[string]interface{}, error)

	// Stop the processor when the core service stops,
	// gracefully disconnect if needed
	Stop() error
}

type Relation struct {
	From *Node `yaml:"from"`
	To   *Node `yaml:"to"`
	Edge *struct {
		Label      string   `yaml:"label"`
		Attributes []string `yaml:"attributes"`
	} `yaml:"edge"`
}

type Source struct {
	Name            string            `yaml:"name"`
	Label           string            `yaml:"label"`
	Icon            string            `yaml:"icon"`
	Plugin          string            `yaml:"plugin"`
	InGlobal        bool              `yaml:"inGlobal"`
	IncludeDatetime bool              `yaml:"includeDatetime"`
	SupportsSQL     bool              `yaml:"supportsSQL"`
	Timeout         time.Duration     `yaml:"timeout"`
	Access          map[string]string `yaml:"access"`
	QueryFields     []string          `yaml:"queryFields"`
	IncludeFields   []string          `yaml:"includeFields"`
	StatsFields     []string          `yaml:"statsFields"`
	ReplaceFields   map[string]string `yaml:"replaceFields"`
	Relations       []*Relation       `yaml:"relations"`
}

type SourcePlugin interface {
	// Return data source instance configuration
	Conf() *Source

	// Set specific parameters for the data source instance,
	// establish connection, etc.
	Setup(*Source, int) error

	// Get a list of all known data source's fields
	// for the Web GUI autocomplete
	Fields() ([]string, error)

	// Execute the given query.
	// Returns results, statistics, debug info & error
	Search(*sqlparser.Select) ([]map[string]interface{}, map[string]interface{}, map[string]interface{}, error)

	// Stop the collector when the core service stops,
	// gracefully disconnect from the data source if needed
	Stop() error
}

type Stats struct {
	Fields map[string]*sortedmap.SortedMap
	// contains filtered or unexported fields
}