series

Documentation

Overview

Package series contains the logic that manages the datasets used for machine learning

Index

• func Consumer(consumer *kafka.Reader, tServ chan types.TrainRequest, conf config.Config) (e error)
• func ProcessUpdate(event event.Event, ps pointstores.PointStore, tServ chan types.TrainRequest, ...) error

Functions

func Consumer

func Consumer(consumer *kafka.Reader, tServ chan types.TrainRequest, conf config.Config) (e error)

Consumer starts a Kafka consumer that'll ingest metrics updates

func ProcessUpdate

func ProcessUpdate(event event.Event, ps pointstores.PointStore, tServ chan types.TrainRequest, conf config.Config) error

ProcessUpdate serves to separate the cloud event processing logic from that which is Kafka specific, that way allowing for training data to be ingested into the system through other channels