connector

Documentation

Index

• func GetStudyConfs(pool *pgxpool.Pool, dataSource string) ([]*Source, error)
• func LastEvent(pool *pgxpool.Pool, source *Source, orderBy string) (*InferenceDataEvent, bool, error)
• func LoadEvents(connector Connector, dataSource string, orderColumn string)
• func WriteEvents(pool *pgxpool.Pool, study string, events <-chan *InferenceDataEvent) (int, error)
• type Config
• type Connector

Functions

func GetStudyConfs

func GetStudyConfs(pool *pgxpool.Pool, dataSource string) ([]*Source, error)

func LastEvent

func LastEvent(pool *pgxpool.Pool, source *Source, orderBy string) (*InferenceDataEvent, bool, error)

func LoadEvents

func LoadEvents(connector Connector, dataSource string, orderColumn string)

func WriteEvents

func WriteEvents(pool *pgxpool.Pool, study string, events <-chan *InferenceDataEvent) (int, error)

Types

type Config

type Config struct {
	DB string `env:"PG_URL,required"` // postgres://user:password@host:port/db

}

type Connector

type Connector interface {
	Handler(source *Source, lastEvent *InferenceDataEvent) <-chan *InferenceDataEvent
}