Removed unneeded references to badger
parent
4dcba0b90a
commit
55d2f3da63
|
@ -15,7 +15,6 @@ Flags are supplied to the compiled go program in the form ```-flag=stuff```.
|
|||
| Flag | Description | Default |
|
||||
| ---- | ----------- | ------- |
|
||||
| listen | Port number to listen on | 8080 |
|
||||
| dbpath | File path to store DB data | /tmp/badger |
|
||||
| nats | URL of NATS | nats://localhost:4222 |
|
||||
|
||||
## API
|
||||
|
|
18
main.go
18
main.go
|
@ -7,38 +7,22 @@ import (
|
|||
"strconv"
|
||||
"time"
|
||||
|
||||
"github.com/dgraph-io/badger"
|
||||
"github.com/julienschmidt/httprouter"
|
||||
"github.com/julienschmidt/httprouter"
|
||||
"github.com/nats-io/go-nats"
|
||||
"github.com/golang/protobuf/proto"
|
||||
)
|
||||
|
||||
var listen string
|
||||
var dbPath string
|
||||
var natsHost string
|
||||
|
||||
var db *badger.DB
|
||||
var natsConn *nats.Conn
|
||||
|
||||
func main() {
|
||||
// Parse flags
|
||||
flag.StringVar(&listen, "listen", ":8080", "host and port to listen on")
|
||||
flag.StringVar(&dbPath, "dbpath", "/tmp/badger", "path to store data")
|
||||
flag.StringVar(&natsHost, "nats", "nats://localhost:4222", "host and port of NATS")
|
||||
flag.Parse()
|
||||
|
||||
// Open badger
|
||||
log.Printf("starting badger at %s", dbPath)
|
||||
opts := badger.DefaultOptions
|
||||
opts.Dir = dbPath
|
||||
opts.ValueDir = dbPath
|
||||
var err error
|
||||
db, err = badger.Open(opts)
|
||||
if err != nil {
|
||||
log.Fatal(err)
|
||||
}
|
||||
defer db.Close()
|
||||
|
||||
// NATS client
|
||||
nc, _ := nats.Connect(natsHost);
|
||||
nc.Subscribe("new_bite", NewBite);
|
||||
|
|
Loading…
Reference in New Issue