processor

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

type DBProcessorInterface interface {
	ProcessorInterface
}

type DataSchema struct {
	Group []string    `json:"group"`
	Stat  []*StatData `json:"stat"`
}

type FilterProcessor struct {
	Processor
	// contains filtered or unexported fields
}

type JsonParseProcessor struct {
	Processor
	// contains filtered or unexported fields
}

type Processor struct {
}

type ProcessorInterface interface {
	// contains filtered or unexported methods
}

type RethinkDBProcessor struct {
	Processor
	// contains filtered or unexported fields
}

type RethinkDataSchema struct {
	UserId    string        `json:"_userId"`
	Interval  time.Duration `json:"interval"`
	StartTime string        `json:"starttime"`
	EndTime   string        `json:"endtime"`
	GroupBy   []string      `json:"groupBy"`
	Data      []DataSchema  `json:"Data"`
}

type StatData struct {
	Column    string `json:"column"`
	Operation string `json:"operation"`
	Value     int64  `json:"value"`
	// contains filtered or unexported fields
}

type StatTrieData struct {
	DataMap map[string]*StatData
}

type StatisticProcessor struct {
	Processor

	SelectQueryList  []query.SelectQueryItem
	GroupByQueryList []query.GroupByQueryItem

	HasGroupBy bool

	Interval time.Duration
	// contains filtered or unexported fields
}