Versions in this module Expand all Collapse all v0 v0.0.2 Oct 15, 2021 v0.0.1 Oct 14, 2021 Changes in this version + func ImportSegments(log *log.Logger, loader Loader, storer Storer) + func NewLogger(maxAge time.Duration) (*log.Logger, error) + type Config struct + LoaderArgs ConnArgs + Log Logger + StorerArgs DbConnection + func LoadConfig() (*Config, error) + type ConnArgs struct + AuthLoginPwd string + ConnectTimeout time.Duration + ImportBatchSize int + Interval time.Duration + Uri string + UserAgent string + type DbConnection struct + DbName string + Host string + Password string + Port int + User string + type HTTPLoader struct + func NewHTTPLoader(log *log.Logger, args *ConnArgs) (*HTTPLoader, error) + func (hi *HTTPLoader) LoadNext() ([]model.Segmentation, error) + type Loader interface + LoadNext func() ([]model.Segmentation, error) + type Logger struct + CleanupMaxAgeDays int + type PGStorer struct + func NewPGStorer(cfg *DbConnection) (*PGStorer, error) + func (s *PGStorer) Store(segs []model.Segmentation) error + type Storer interface + Store func(segs []model.Segmentation) error
Go to main page