public
/
jldb
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 17 Wiki Activity

Code cleanup / beta stuff

master v0.6.3
jdl 2023-12-03 20:38:45 +01:00
parent 728b34b684
commit 9785637b3b
2 changed files with 4 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
lib/rep/http-handler.go
View File

@ -12,12 +12,6 @@ const (
pathStreamWAL = "stream-wal" pathStreamWAL = "stream-wal"
) )
func (rep *Replicator) RegisterHandlers(mux *http.ServeMux, rootPath string) {
mux.HandleFunc(path.Join(rootPath, pathGetInfo), rep.handleGetInfo)
mux.HandleFunc(path.Join(rootPath, pathSendState), rep.handleSendState)
mux.HandleFunc(path.Join(rootPath, pathStreamWAL), rep.handleStreamWAL)
}
// TODO: Remove this! // TODO: Remove this!
func (rep *Replicator) Handle(w http.ResponseWriter, r *http.Request) { func (rep *Replicator) Handle(w http.ResponseWriter, r *http.Request) {
// We'll handle two types of requests: HTTP GET requests for JSON, or // We'll handle two types of requests: HTTP GET requests for JSON, or

8
mdb/db.go
View File

@ -73,6 +73,10 @@ type Database struct {
} }
func New(conf Config) *Database { func New(conf Config) *Database {
if conf.NetTimeout <= 0 {
conf.NetTimeout = time.Minute
}
if conf.MaxConcurrentUpdates <= 0 { if conf.MaxConcurrentUpdates <= 0 {
conf.MaxConcurrentUpdates = 32 conf.MaxConcurrentUpdates = 32
} }
@ -183,7 +187,3 @@ func (db *Database) addCollection(id uint64, c collection, collectionState any)
func (db *Database) Handle(w http.ResponseWriter, r *http.Request) { func (db *Database) Handle(w http.ResponseWriter, r *http.Request) {
db.rep.Handle(w, r) db.rep.Handle(w, r)
} }
func (db *Database) RegisterHandlers(mux *http.ServeMux, rootPath string) {
db.rep.RegisterHandlers(mux, rootPath)
}