mirror of
https://github.com/VictoriaMetrics/VictoriaMetrics.git
synced 2024-11-21 14:44:00 +00:00
35 lines
701 B
Go
35 lines
701 B
Go
|
package vlinsert
|
||
|
|
|
||
|
|
import (
|
||
|
|
"net/http"
|
||
|
|
"strings"
|
||
|
|
|
||
|
|
"github.com/VictoriaMetrics/VictoriaMetrics/app/vlinsert/elasticsearch"
|
||
|
|
)
|
||
|
|
|
||
|
|
// Init initializes vlinsert
|
||
|
|
func Init() {
|
||
|
|
}
|
||
|
|
|
||
|
|
// Stop stops vlinsert
|
||
|
|
func Stop() {
|
||
|
|
}
|
||
|
|
|
||
|
|
// RequestHandler handles insert requests for VictoriaLogs
|
||
|
|
func RequestHandler(w http.ResponseWriter, r *http.Request) bool {
|
||
|
|
path := r.URL.Path
|
||
|
|
if !strings.HasPrefix(path, "/insert/") {
|
||
|
|
return false
|
||
|
|
}
|
||
|
|
path = strings.TrimPrefix(path, "/insert")
|
||
|
|
path = strings.ReplaceAll(path, "//", "/")
|
||
|
|
|
||
|
|
switch {
|
||
|
|
case strings.HasPrefix(path, "/elasticsearch/"):
|
||
|
|
path = strings.TrimPrefix(path, "/elasticsearch")
|
||
|
|
return elasticsearch.RequestHandler(path, w, r)
|
||
|
|
default:
|
||
|
|
return false
|
||
|
|
}
|
||
|
|
}
|