weathercalc

package
v0.0.0-...-d8ac9bd Latest Latest
Warning

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

Go to latest
Published: May 18, 2024 License: Apache-2.0 Imports: 21 Imported by: 0

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

func (c *Calculation) Accept(metric api.Metric) bool

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
}

func (*Service) Start

func (s *Service) Start() error

type StackEntry

type StackEntry struct {
	Time  time.Time
	Value value.Value
}

func (StackEntry) IsValid

func (se StackEntry) IsValid() bool

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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