rollup

package
v1.0.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 6, 2022 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

View Source
const (
	Sum            Method = "sum"
	Unique                = "unique"
	Min                   = "min"
	Max                   = "max"
	Mean                  = "mean"
	Median                = "median"
	Entropy               = "entropy"
	Percentilerank        = "percentilerank"
	Percentile            = "entropy"

	KENTIK_EVENT_TYPE = "KFlow:%s:%s"
)
View Source
const (
	CHAN_SLACK = 10000
)

Variables

This section is empty.

Functions

This section is empty.

Types

type Method

type Method string

type Roller

type Roller interface {
	Add([]map[string]interface{})
	Export() []Rollup
}

func GetRollups

func GetRollups(log logger.Underlying) ([]Roller, error)

type Rollup

type Rollup struct {
	Dimension string        `json:"dimension"`
	Metric    float64       `json:"metric"`
	EventType string        `json:"eventType"`
	KeyJoin   string        `json:"keyJoin"`
	Interval  time.Duration `json:"interval"`

	Name     string
	Count    uint64
	Min      uint64
	Max      uint64
	Provider kt.Provider
	// contains filtered or unexported fields
}

func (*Rollup) GetDims

func (r *Rollup) GetDims() []string

type RollupDef

type RollupDef struct {
	Sample     bool
	Method     Method
	Metrics    []string
	Dimensions []string
	Name       string
}

func (*RollupDef) String

func (r *RollupDef) String() string

type RollupFlag

type RollupFlag []RollupDef

func (*RollupFlag) Set

func (i *RollupFlag) Set(value string) error

func (*RollupFlag) String

func (rf *RollupFlag) String() string

type StatsRollup

type StatsRollup struct {
	logger.ContextL
	// contains filtered or unexported fields
}

func (*StatsRollup) Add

func (r *StatsRollup) Add(in []map[string]interface{})

func (*StatsRollup) Export

func (r *StatsRollup) Export() []Rollup

type UniqueRollup

type UniqueRollup struct {
	logger.ContextL
	// contains filtered or unexported fields
}

func (*UniqueRollup) Add

func (r *UniqueRollup) Add(in []map[string]interface{})

func (*UniqueRollup) Export

func (r *UniqueRollup) Export() []Rollup

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL