series

package
Version: v0.4.0 Latest Latest
Warning

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

Go to latest
Published: Feb 21, 2021 License: BSD-3-Clause Imports: 14 Imported by: 0

Documentation

Overview

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

Index

Constants

This section is empty.

Variables

This section is empty.

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

Types

This section is empty.

Directories

Path Synopsis
Package pointstores contains the implementation of all the supported storage adapters for the series
Package pointstores contains the implementation of all the supported storage adapters for the series

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
t or T : Toggle theme light dark auto
y or Y : Canonical URL