ingester

Documentation

Index

• func HandleAggregates(aggregates []scheduler.ExternalAggregate) error
• type AggregateIngester
  • func NewAggregateIngester() *AggregateIngester
  • func (ai *AggregateIngester) Ingest(aggregates []scheduler.ExternalAggregate) error
  • func (ai *AggregateIngester) Run()

Functions

func HandleAggregates

func HandleAggregates(aggregates []scheduler.ExternalAggregate) error

HandleAggregates process a slice of ExternalAggregates and trigger all standard fact-situation-rule process

Types

type AggregateIngester

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

AggregateIngester is a component which process scheduler.ExternalAggregate

func NewAggregateIngester

func NewAggregateIngester() *AggregateIngester

NewAggregateIngester returns a pointer to a new AggregateIngester instance

func (*AggregateIngester) Ingest

func (ai *AggregateIngester) Ingest(aggregates []scheduler.ExternalAggregate) error

Ingest process an array of scheduler.ExternalAggregate

func (*AggregateIngester) Run

func (ai *AggregateIngester) Run()

Run is the main routine of a TypeIngester instance