diff --git a/cmd/dqlite-demo/dqlite-demo.go b/cmd/dqlite-demo/dqlite-demo.go index ee69d8c4..b0e9d3d2 100644 --- a/cmd/dqlite-demo/dqlite-demo.go +++ b/cmd/dqlite-demo/dqlite-demo.go @@ -5,7 +5,7 @@ import ( "crypto/tls" "crypto/x509" "fmt" - "io/ioutil" + "io" "log" "net" "net/http" @@ -14,6 +14,7 @@ import ( "path/filepath" "strings" + "github.com/canonical/go-dqlite/v3" "github.com/canonical/go-dqlite/v3/app" "github.com/canonical/go-dqlite/v3/client" "github.com/pkg/errors" @@ -65,7 +66,7 @@ Complete documentation is available at https://github.com/canonical/go-dqlite`, if err != nil { return err } - data, err := ioutil.ReadFile(crt) + data, err := os.ReadFile(crt) if err != nil { return err } @@ -104,7 +105,7 @@ Complete documentation is available at https://github.com/canonical/go-dqlite`, err = row.Scan(&result) case "PUT": result = "done" - value, _ := ioutil.ReadAll(r.Body) + value, _ := io.ReadAll(r.Body) _, err = db.Exec(update, key, string(value[:])) default: err = fmt.Errorf("unsupported method") @@ -138,6 +139,13 @@ Complete documentation is available at https://github.com/canonical/go-dqlite`, app.Handover(context.Background()) app.Close() + lastEntry, err := dqlite.ReadLastEntryInfo(dir) + if err != nil { + return nil + } + + fmt.Printf("dqlite-demo: last entry had term=%d index=%d", lastEntry.Term, lastEntry.Index) + return nil }, } diff --git a/cmd/dqlite/dqlite.go b/cmd/dqlite/dqlite.go index 5bb74e01..48840287 100644 --- a/cmd/dqlite/dqlite.go +++ b/cmd/dqlite/dqlite.go @@ -6,7 +6,6 @@ import ( "crypto/x509" "fmt" "io" - "io/ioutil" "os" "strings" "time" @@ -72,7 +71,7 @@ func main() { return err } - data, err := ioutil.ReadFile(crt) + data, err := os.ReadFile(crt) if err != nil { return err }