You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by po...@apache.org on 2021/09/22 11:22:32 UTC
[airflow-pgbouncer-exporter] 23/27: Update CHANGELOG for v0.10.0.
This is an automated email from the ASF dual-hosted git repository.
potiuk pushed a commit to branch migrate-to-latest-pgbouncer-exported
in repository https://gitbox.apache.org/repos/asf/airflow-pgbouncer-exporter.git
commit 5a6902b1e833a736f5d92b21cd20ac55bb53a4ef
Author: Juraj Bubniak <ju...@gmail.com>
AuthorDate: Mon Jun 21 14:21:38 2021 +0200
Update CHANGELOG for v0.10.0.
---
CHANGELOG.md | 5 +++++
cmd/health.go | 6 +++---
cmd/server.go | 8 ++++----
3 files changed, 12 insertions(+), 7 deletions(-)
diff --git a/CHANGELOG.md b/CHANGELOG.md
index fb4acbf..d99ae99 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -1,3 +1,8 @@
+## 0.10.0
+
+* Drop sqlx, use stdlib database.
+* Add Makefile.
+
## 0.9.2
* Fix docker image templates.
diff --git a/cmd/health.go b/cmd/health.go
index 2904383..edf758b 100644
--- a/cmd/health.go
+++ b/cmd/health.go
@@ -23,16 +23,16 @@ func checkHealth(ctx *cli.Context) error {
db, err := sql.Open("postgres", cfg.DatabaseURL)
if err != nil {
- return fmt.Errorf("could not initialize store: %v", err)
+ return fmt.Errorf("could not open db: %v", err)
}
defer db.Close()
- st := sqlstore.New(db)
+ store := sqlstore.New(db)
checkCtx, cancel := context.WithTimeout(context.Background(), cfg.StoreTimeout)
defer cancel()
- if err := st.Check(checkCtx); err != nil {
+ if err := store.Check(checkCtx); err != nil {
return fmt.Errorf("store health check failed: %v", err)
}
return nil
diff --git a/cmd/server.go b/cmd/server.go
index ed4eae1..71502bf 100644
--- a/cmd/server.go
+++ b/cmd/server.go
@@ -27,20 +27,20 @@ func runServer(ctx *cli.Context) error {
db, err := sql.Open("postgres", cfg.DatabaseURL)
if err != nil {
- return fmt.Errorf("could not initialize store: %v", err)
+ return fmt.Errorf("could not open db: %v", err)
}
defer db.Close()
- st := sqlstore.New(db)
+ store := sqlstore.New(db)
checkCtx, cancel := context.WithTimeout(context.Background(), cfg.StoreTimeout)
defer cancel()
- if err := st.Check(checkCtx); err != nil {
+ if err := store.Check(checkCtx); err != nil {
return fmt.Errorf("could not check store: %v", err)
}
- exp := collector.New(cfg, st)
+ exp := collector.New(cfg, store)
srv := server.New(cfg, exp)
log.Println("Starting ", collector.Name, version.Info())