rollup

Documentation

Index

• Constants
• type Method
• type Roller
  • func GetRollups(log logger.Underlying, cfg *ktranslate.RollupConfig) ([]Roller, error)
• type Rollup
  • func (r *Rollup) GetDims() []string
• type RollupDef
  • func (r *RollupDef) String() string
• type RollupDefs
  • func (i *RollupDefs) Set(value string) error
  • func (rf *RollupDefs) String() string
• type RollupFlag
  • func (ff *RollupFlag) Set(val string) error
  • func (ff *RollupFlag) String() string
• type StatsRollup
  • func (r *StatsRollup) Add(in []map[string]interface{})
  • func (r *StatsRollup) Export() []Rollup
• type UniqueRollup
  • func (r *UniqueRollup) Add(in []map[string]interface{})
  • func (r *UniqueRollup) Export() []Rollup

Constants

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"
)

const (
	CHAN_SLACK = 10000
)

Types

type Method

type Method string

type Roller

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

func GetRollups

func GetRollups(log logger.Underlying, cfg *ktranslate.RollupConfig) ([]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 RollupDefs

type RollupDefs []RollupDef

func (*RollupDefs) Set

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

func (*RollupDefs) String

func (rf *RollupDefs) String() string

type RollupFlag

type RollupFlag []string

func (*RollupFlag) Set

func (ff *RollupFlag) Set(val string) error

func (*RollupFlag) String

func (ff *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