config

Documentation

Index

• Constants
• Variables
• func Merge(prefix string, conf *Config)
• type Config
  • func Load(cfgFile string) (*Config, error)
  • func (c *Config) Update(cfgFile string)
• type FactoryConfig
  • func DefaultFactory() FactoryConfig
• type PipeConfig
  • func DefaultPipe() PipeConfig
• type Postgres
  • func DefaultPostgres() Postgres
  • func DefaultTimescale() Postgres
  • func (p *Postgres) Connect() *pgxpool.Pool
  • func (p *Postgres) CreateTables(pool *pgxpool.Pool, schema string)

Constants

const (
	TypePostgres         = "postgres"
	TypeTimescale        = "timescale"
	DefaultPostgresPort  = 5432
	DefaultTimescalePort = 5432
	DefaultMaxConn       = 5000
)

Variables

var ErrConfigRead = errors.New("failed to read/write config")

var POSTGRES string

var TIMESCALE string

Functions

func Merge

func Merge(prefix string, conf *Config)

Merge command line flags and environment variables with config.

Types

type Config

type Config struct {
	Port      int
	Postgres  Postgres
	Timescale Postgres
	Factory   FactoryConfig
	Pipe      PipeConfig
}

func Load

func Load(cfgFile string) (*Config, error)

func (*Config) Update

func (c *Config) Update(cfgFile string)

Update config on filesystem.

type FactoryConfig

type FactoryConfig struct {
	MaxLimit                   uint
	ErrorRate                  float64
	MaxTry, IDSize, CookieSize int
	BackupPath                 string
}

func DefaultFactory

func DefaultFactory() FactoryConfig

type PipeConfig

type PipeConfig struct {
	Streams   int
	BatchSize int
}

func DefaultPipe

func DefaultPipe() PipeConfig

type Postgres

type Postgres struct {
	DBType   string
	Username string
	Password string
	Host     string
	Database string
	Port     int
}

Postgres connection.

func DefaultPostgres

func DefaultPostgres() Postgres

func DefaultTimescale

func DefaultTimescale() Postgres

func (*Postgres) Connect

func (p *Postgres) Connect() *pgxpool.Pool

func (*Postgres) CreateTables

func (p *Postgres) CreateTables(pool *pgxpool.Pool, schema string)