connections

type InfluxConnectionParams struct {
	Server      string
	Username    string
	Password    string
	Database    string
	UnsafeHTTPS bool
}

type InfluxConnectionService interface {
	NewConnection(*InfluxConnectionParams) (influx.Client, error)
}

type MockPgxW struct {
	ExecRes         []pgx.CommandTag
	ExecErrs        []error
	CurrentExec     int
	QueryRes        []*pgx.Rows
	QueryErrs       []error
	CurrentQ        int
	ExpQ            []string
	ExpQArgs        [][]interface{}
	ExpExec         []string
	ExpExecArgs     [][]interface{}
	BeginRes        []*pgx.Tx
	BeginErr        []error
	CurrentBegin    int
	CopyFromErr     []error
	CurrentCopyFrom int
	ExpCopyFromTab  []pgx.Identifier
	ExpCopyFromCol  [][]string
}

type PgxWrap interface {
	Begin() (*pgx.Tx, error)
	CopyFrom(tableName pgx.Identifier, columnNames []string, rowSrc pgx.CopyFromSource) (int, error)
	Exec(sql string, arguments ...interface{}) (commandTag pgx.CommandTag, err error)
	Query(sql string, args ...interface{}) (*pgx.Rows, error)
	Close() error
}

type TSConnectionService interface {
	NewConnection(connectionString string) (PgxWrap, error)
}