weatheregress

Documentation

Index

• type Egress
  • func (s *Egress) Start() error
• type Processor
  • func (s *Processor) ProcessMetric(metric api.Metric)
  • func (s *Processor) Start() error

Types

type Egress

type Egress struct {
	Amqp           amqp2.Pool            `kernel:"inject"`
	Mqtt           mqtt.Pool             `kernel:"inject"`
	DatabaseBroker broker.DatabaseBroker `kernel:"inject"`
	Processor      *Processor            `kernel:"inject"`
	Daemon         *kernel.Daemon        `kernel:"inject"`
	QueueName      *string               `kernel:"flag,metric-queue,DB queue name,database.calc"`
	// contains filtered or unexported fields
}

func (*Egress) Start

func (s *Egress) Start() error

type Processor

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

func (*Processor) ProcessMetric

func (s *Processor) ProcessMetric(metric api.Metric)

ProcessMetric accepts a metric, checks to see if it's one we are interested in and if so places it into the work queue

func (*Processor) Start

func (s *Processor) Start() error