exporter

package module

v0.0.0-...-ef58b52 Latest Latest Go to latest Published: Dec 7, 2019 License: MIT Imports: 7 Imported by: 0

Details

A pet project for exporting csv data from IQControls Mass controller logs to timescale DB.

##Enviroments

BASE_URI Host for importing the data - usually mass server ip like http://10.0.0.150
START_OFFSET How far from now to start getting readings, if no readings in database time.Duration, eg.: 1h
IMPORT_PERIOD The import period - shouldn't be less than 1 min
IMPORT_ONLY_ONCE Import the data only once and die - mostly for testing

This section is empty.

This section is empty.

This section is empty.

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

func NewApplication(importer Importer, exporter Exporter, db *gorm.DB) *App

NewApplication creates App

func (a App) Export(ctx context.Context, imp []*sink.Reading) error

Export exports data

func (a App) Import(ctx context.Context) ([]*sink.Reading, error)

Import imports data

func (a App) IsHealthy() error

type Application interface {
	Importer
	Exporter
}

Application is the App

type Exporter interface {
	Export(ctx context.Context, imp []*sink.Reading) error
}

Exporter is a data exporter

type Importer interface {
	Import(ctx context.Context) ([]*sink.Reading, error)
}

Importer is a data importer

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

func NewMigrator(db *sql.DB) *Migrator

func (m *Migrator) IsHealthy() error

func (m *Migrator) MigrateDown() error

func (m *Migrator) MigrateUp() error

type Schema struct{}