tasks

Documentation

Index

• Variables
• type AggregationTask
  • func (a *AggregationTask) Group() string
  • func (a *AggregationTask) Raw() ([]byte, error)
• type CommonTask
  • func (c *CommonTask) Tid() string
• type DataItem
• type DataType
• type FetcherTask
• type ParsingResultCollector
  • func NewParsingResultCollector(capacity int) *ParsingResultCollector
  • func (p *ParsingResultCollector) Data() map[string]TaskResult
  • func (p *ParsingResultCollector) Put(name string, res TaskResult)
• type ParsingTask
  • func (p *ParsingTask) Group() string
  • func (p *ParsingTask) Raw() ([]byte, error)
• type Task
• type TaskResult

Variables

var (
	EmptyCommonTask = CommonTask{
		Id:       "",
		PrevTime: -1,
		CurrTime: -1}
)

Types

type AggregationTask

type AggregationTask struct {
	CommonTask
	// Name of the current aggregation config
	Config string
	// Name of handled parsing config
	ParsingConfigName string
	// Content of the current parsing config
	ParsingConfig configs.ParsingConfig
	// Current aggregation config
	AggregationConfig configs.AggregationConfig
	// Hosts
	Hosts hosts.Hosts
	// Parsing results
	Results map[string]TaskResult
}

func (*AggregationTask) Group

func (a *AggregationTask) Group() string

func (*AggregationTask) Raw

func (a *AggregationTask) Raw() ([]byte, error)

type CommonTask

type CommonTask struct {
	Id       string `codec:"Id"`
	PrevTime int64  `codec:"PrevTime"`
	CurrTime int64  `codec:"CurrTime"`
}

func (*CommonTask) Tid

func (c *CommonTask) Tid() string

type DataItem

type DataItem map[string]interface{}

For senders

type DataType

type DataType map[string]DataItem

type FetcherTask

type FetcherTask struct {
	CommonTask
	Target string `codec:"Target"`
}

type ParsingResultCollector

type ParsingResultCollector struct {
	// contains filtered or unexported fields
}

func NewParsingResultCollector

func NewParsingResultCollector(capacity int) *ParsingResultCollector

func (*ParsingResultCollector) Data

func (p *ParsingResultCollector) Data() map[string]TaskResult

func (*ParsingResultCollector) Put

func (p *ParsingResultCollector) Put(name string, res TaskResult)

type ParsingTask

type ParsingTask struct {
	CommonTask
	// Hostname of target
	Host string
	// Name of handled parsing config
	ParsingConfigName string
	// Content of the current parsing config
	ParsingConfig configs.ParsingConfig
	// Content of aggreagtion configs
	// related to the current parsing config
	AggregationConfigs map[string]configs.AggregationConfig
}

func (*ParsingTask) Group

func (p *ParsingTask) Group() string

func (*ParsingTask) Raw

func (p *ParsingTask) Raw() ([]byte, error)

type Task

type Task interface {
	Tid() string
	Raw() ([]byte, error)
	Group() string
}

type TaskResult

type TaskResult string