Compare commits
2 Commits
Author | SHA1 | Date | |
---|---|---|---|
|
728b34b684 | ||
|
8be663a0a0 |
@@ -12,6 +12,13 @@ const (
|
||||
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!
|
||||
func (rep *Replicator) Handle(w http.ResponseWriter, r *http.Request) {
|
||||
// We'll handle two types of requests: HTTP GET requests for JSON, or
|
||||
// streaming requets for state or wall.
|
||||
|
@@ -183,3 +183,7 @@ func (db *Database) addCollection(id uint64, c collection, collectionState any)
|
||||
func (db *Database) Handle(w http.ResponseWriter, r *http.Request) {
|
||||
db.rep.Handle(w, r)
|
||||
}
|
||||
|
||||
func (db *Database) RegisterHandlers(mux *http.ServeMux, rootPath string) {
|
||||
db.rep.RegisterHandlers(mux, rootPath)
|
||||
}
|
||||
|
Reference in New Issue
Block a user