mirror of
https://github.com/VictoriaMetrics/VictoriaMetrics.git
synced 2025-03-21 15:45:01 +00:00
7a1c84b6ec
### Describe Your Changes related issue https://github.com/VictoriaMetrics/VictoriaMetrics/issues/8353 ### Checklist The following checks are **mandatory**: - [ ] My change adheres [VictoriaMetrics contributing guidelines](https://docs.victoriametrics.com/contributing/). --------- Signed-off-by: hagen1778 <roman@victoriametrics.com> Co-authored-by: hagen1778 <roman@victoriametrics.com>
69 lines
2.1 KiB
Go
69 lines
2.1 KiB
Go
package vlinsert
|
|
|
|
import (
|
|
"fmt"
|
|
"net/http"
|
|
"strings"
|
|
|
|
"github.com/VictoriaMetrics/VictoriaMetrics/app/vlinsert/datadog"
|
|
"github.com/VictoriaMetrics/VictoriaMetrics/app/vlinsert/elasticsearch"
|
|
"github.com/VictoriaMetrics/VictoriaMetrics/app/vlinsert/journald"
|
|
"github.com/VictoriaMetrics/VictoriaMetrics/app/vlinsert/jsonline"
|
|
"github.com/VictoriaMetrics/VictoriaMetrics/app/vlinsert/loki"
|
|
"github.com/VictoriaMetrics/VictoriaMetrics/app/vlinsert/opentelemetry"
|
|
"github.com/VictoriaMetrics/VictoriaMetrics/app/vlinsert/syslog"
|
|
)
|
|
|
|
// Init initializes vlinsert
|
|
func Init() {
|
|
syslog.MustInit()
|
|
}
|
|
|
|
// Stop stops vlinsert
|
|
func Stop() {
|
|
syslog.MustStop()
|
|
}
|
|
|
|
// RequestHandler handles insert requests for VictoriaLogs
|
|
func RequestHandler(w http.ResponseWriter, r *http.Request) bool {
|
|
path := r.URL.Path
|
|
|
|
if !strings.HasPrefix(path, "/insert/") {
|
|
// Skip requests, which do not start with /insert/, since these aren't our requests.
|
|
return false
|
|
}
|
|
path = strings.TrimPrefix(path, "/insert")
|
|
path = strings.ReplaceAll(path, "//", "/")
|
|
|
|
switch path {
|
|
case "/jsonline":
|
|
jsonline.RequestHandler(w, r)
|
|
return true
|
|
case "/ready":
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.WriteHeader(200)
|
|
fmt.Fprintf(w, `{"status":"ok"}`)
|
|
return true
|
|
}
|
|
switch {
|
|
case strings.HasPrefix(path, "/elasticsearch"):
|
|
// some clients may omit trailing slash
|
|
// see https://github.com/VictoriaMetrics/VictoriaMetrics/issues/8353
|
|
path = strings.TrimPrefix(path, "/elasticsearch")
|
|
return elasticsearch.RequestHandler(path, w, r)
|
|
case strings.HasPrefix(path, "/loki/"):
|
|
path = strings.TrimPrefix(path, "/loki")
|
|
return loki.RequestHandler(path, w, r)
|
|
case strings.HasPrefix(path, "/opentelemetry/"):
|
|
path = strings.TrimPrefix(path, "/opentelemetry")
|
|
return opentelemetry.RequestHandler(path, w, r)
|
|
case strings.HasPrefix(path, "/journald/"):
|
|
path = strings.TrimPrefix(path, "/journald")
|
|
return journald.RequestHandler(path, w, r)
|
|
case strings.HasPrefix(path, "/datadog/"):
|
|
path = strings.TrimPrefix(path, "/datadog")
|
|
return datadog.RequestHandler(path, w, r)
|
|
default:
|
|
return false
|
|
}
|
|
}
|