34 lines
886 B
Go
34 lines
886 B
Go
|
package app
|
||
|
|
|
||
|
|
import (
|
||
|
|
"context"
|
||
|
|
"net/http"
|
||
|
|
|
||
|
|
"go.signoz.io/signoz/pkg/query-service/dao"
|
||
|
|
"go.signoz.io/signoz/pkg/query-service/model"
|
||
|
|
)
|
||
|
|
|
||
|
|
func (aH *APIHandler) insertIngestionKey(w http.ResponseWriter, r *http.Request) {
|
||
|
|
req, err := parseInsertIngestionKeyRequest(r)
|
||
|
|
if aH.HandleError(w, err, http.StatusBadRequest) {
|
||
|
|
return
|
||
|
|
}
|
||
|
|
|
||
|
|
if err := dao.DB().InsertIngestionKey(context.Background(), req); err != nil {
|
||
|
|
RespondError(w, &model.ApiError{Err: err, Typ: model.ErrorInternal}, nil)
|
||
|
|
return
|
||
|
|
}
|
||
|
|
|
||
|
|
aH.WriteJSON(w, r, map[string]string{"data": "ingestion key added successfully"})
|
||
|
|
}
|
||
|
|
|
||
|
|
func (aH *APIHandler) getIngestionKeys(w http.ResponseWriter, r *http.Request) {
|
||
|
|
ingestionKeys, err := dao.DB().GetIngestionKeys(context.Background())
|
||
|
|
if err != nil {
|
||
|
|
RespondError(w, &model.ApiError{Err: err, Typ: model.ErrorInternal}, nil)
|
||
|
|
return
|
||
|
|
}
|
||
|
|
|
||
|
|
aH.WriteJSON(w, r, ingestionKeys)
|
||
|
|
}
|