Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Calculation ¶
type Calculation struct {
// contains filtered or unexported fields
}
func NewCalculation ¶
func NewCalculation(src *lang2.Calculation) *Calculation
func (*Calculation) ID ¶
func (c *Calculation) ID() string
func (*Calculation) Src ¶
func (c *Calculation) Src() *lang2.Calculation
type CalculationValue ¶
type CalculationValue struct {
// contains filtered or unexported fields
}
type Calculator ¶
type Calculator struct { DatabaseBroker broker.DatabaseBroker `kernel:"inject"` Cron *cron.CronService `kernel:"inject"` Latest memory.Latest `kernel:"inject"` DBServer *string `kernel:"flag,metric-db,DB url"` // contains filtered or unexported fields }
Calculator is a service which accepts metrics and then performs any defined calculations. However, it only does the calculation once it gets all the values the calculation requires.
func (*Calculator) Accept ¶
func (calc *Calculator) Accept(metric api.Metric)
func (*Calculator) Script ¶
func (calc *Calculator) Script() *lang2.Script
func (*Calculator) Start ¶
func (calc *Calculator) Start() error
type Service ¶
type Service struct { Latest memory.Latest `kernel:"inject"` DatabaseBroker broker.DatabaseBroker `kernel:"inject"` Calculator *Calculator `kernel:"inject"` Daemon *kernel.Daemon `kernel:"inject"` QueueName *string `kernel:"flag,metric-queue,DB queue name,database.calc"` // contains filtered or unexported fields }
type StackEntry ¶
func (StackEntry) IsValid ¶
func (se StackEntry) IsValid() bool
Click to show internal directories.
Click to hide internal directories.