o11y/pkg/query-service/app/infra.go at iam-datastore

mirror of https://github.com/hanzoai/o11y.git synced 2026-10-30 14:56:15 +00:00

Files

T

zeekay b9f9cdf918 feat: bump o11y fork to latest SigNoz — full re-sync, builds green (§4c retained)

Re-sync the entire SigNoz-derived Go tree to a clean fork of latest SigNoz
main (upstream 3e6339019), eliminating the version-skew that broke
`go build ./...` (mixed-era packages, ~14 imported-but-absent packages,
partial signoz->o11y / clickhouse->datastore rebrands, self-import cycle,
duplicate package decls).

- pkg/ + cmd/ wholesale replaced with latest SigNoz; imports rewritten
  github.com/SigNoz/signoz/ -> github.com/hanzoai/o11y/.
- Adopt SigNoz's CURRENT structure (resourcefilter->telemetryresourcefilter,
  integrationtypes->cloudintegrationtypes, roletypes/grammar/times folded in
  upstream); old paths dropped.
- Fork deps repathed to hanzoai + bumped: signoz-otel-collector v0.144.6,
  clickhouse-go-mock v0.14.1, govaluate v0.1.0; expr-lang/expr => hanzoai/expr
  v1.17.8 (replace). go.mod reconciled from latest SigNoz; go.sum re-tidied.
- ee/ + cmd/enterprise stripped — o11y stays MIT-only; community edition
  imports no ee packages.
- Preserved o11y additions: module path github.com/hanzoai/o11y, mount.go
  (cloud.Register/zip mount adapter, HIP-0106), NOTICE + LICENSE (SigNoz §4c
  attribution retained; upstream pkg files are headerless per SigNoz convention).
- Reverted o11y cosmetic renames (o11y*/datastore*) and experimental originals
  (authz/iamauthz, billing, zapreceiver, zapmetricreceiver) to SigNoz canonical
  to kill the skew; snapshots retained in git history for re-layering.

go build ./... = exit 0. go vet clean except benign "unreachable code" in
generated ANTLR parser files (inherited from upstream).

2026-07-02 14:20:32 -07:00

909 lines

22 KiB

Go

Raw Permalink Blame History

 package app
 import (
 	"encoding/json"
 	"net/http"
 	"github.com/hanzoai/o11y/pkg/http/render"
 	"github.com/hanzoai/o11y/pkg/query-service/model"
 	"github.com/hanzoai/o11y/pkg/types/authtypes"
 	"github.com/hanzoai/o11y/pkg/valuer"
 )
 func (aH *APIHandler) getHostAttributeKeys(w http.ResponseWriter, r *http.Request) {
 	ctx := r.Context()
 	req, err := parseFilterAttributeKeyRequest(r)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	// get attribute keys
 	claims, err := authtypes.ClaimsFromContext(r.Context())
 	if err != nil {
 		render.Error(w, err)
 		return
 	}
 	orgID := valuer.MustNewUUID(claims.OrgID)
 	keys, err := aH.hostsRepo.GetHostAttributeKeys(ctx, orgID, *req)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	// write response
 	aH.Respond(w, keys)
 }
 func (aH *APIHandler) getHostAttributeValues(w http.ResponseWriter, r *http.Request) {
 	ctx := r.Context()
 	// parse request
 	req, err := parseFilterAttributeValueRequest(r)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	// get attribute values
 	claims, err := authtypes.ClaimsFromContext(r.Context())
 	if err != nil {
 		render.Error(w, err)
 		return
 	}
 	orgID := valuer.MustNewUUID(claims.OrgID)
 	values, err := aH.hostsRepo.GetHostAttributeValues(ctx, orgID, *req)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	// write response
 	aH.Respond(w, values)
 }
 func (aH *APIHandler) getHostList(w http.ResponseWriter, r *http.Request) {
 	ctx := r.Context()
 	claims, err := authtypes.ClaimsFromContext(r.Context())
 	if err != nil {
 		render.Error(w, err)
 		return
 	}
 	orgID, err := valuer.NewUUID(claims.OrgID)
 	if err != nil {
 		render.Error(w, err)
 		return
 	}
 	req := model.HostListRequest{}
 	// parse request
 	err = json.NewDecoder(r.Body).Decode(&req)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	// get host list
 	hostList, err := aH.hostsRepo.GetHostList(ctx, orgID, req)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	// write response
 	aH.Respond(w, hostList)
 }
 func (aH *APIHandler) getProcessAttributeKeys(w http.ResponseWriter, r *http.Request) {
 	ctx := r.Context()
 	req, err := parseFilterAttributeKeyRequest(r)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	claims, err := authtypes.ClaimsFromContext(r.Context())
 	if err != nil {
 		render.Error(w, err)
 		return
 	}
 	orgID := valuer.MustNewUUID(claims.OrgID)
 	keys, err := aH.processesRepo.GetProcessAttributeKeys(ctx, orgID, *req)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	aH.Respond(w, keys)
 }
 func (aH *APIHandler) getProcessAttributeValues(w http.ResponseWriter, r *http.Request) {
 	ctx := r.Context()
 	req, err := parseFilterAttributeValueRequest(r)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	claims, err := authtypes.ClaimsFromContext(r.Context())
 	if err != nil {
 		render.Error(w, err)
 		return
 	}
 	orgID := valuer.MustNewUUID(claims.OrgID)
 	values, err := aH.processesRepo.GetProcessAttributeValues(ctx, orgID, *req)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	aH.Respond(w, values)
 }
 func (aH *APIHandler) getProcessList(w http.ResponseWriter, r *http.Request) {
 	ctx := r.Context()
 	claims, err := authtypes.ClaimsFromContext(r.Context())
 	if err != nil {
 		render.Error(w, err)
 		return
 	}
 	orgID, err := valuer.NewUUID(claims.OrgID)
 	if err != nil {
 		render.Error(w, err)
 		return
 	}
 	req := model.ProcessListRequest{}
 	err = json.NewDecoder(r.Body).Decode(&req)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	hostList, err := aH.processesRepo.GetProcessList(ctx, orgID, req)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	aH.Respond(w, hostList)
 }
 func (aH *APIHandler) getPodAttributeKeys(w http.ResponseWriter, r *http.Request) {
 	ctx := r.Context()
 	req, err := parseFilterAttributeKeyRequest(r)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	claims, err := authtypes.ClaimsFromContext(r.Context())
 	if err != nil {
 		render.Error(w, err)
 		return
 	}
 	orgID := valuer.MustNewUUID(claims.OrgID)
 	keys, err := aH.podsRepo.GetPodAttributeKeys(ctx, orgID, *req)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	aH.Respond(w, keys)
 }
 func (aH *APIHandler) getPodAttributeValues(w http.ResponseWriter, r *http.Request) {
 	ctx := r.Context()
 	req, err := parseFilterAttributeValueRequest(r)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	claims, err := authtypes.ClaimsFromContext(r.Context())
 	if err != nil {
 		render.Error(w, err)
 		return
 	}
 	orgID := valuer.MustNewUUID(claims.OrgID)
 	values, err := aH.podsRepo.GetPodAttributeValues(ctx, orgID, *req)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	aH.Respond(w, values)
 }
 func (aH *APIHandler) getPodList(w http.ResponseWriter, r *http.Request) {
 	ctx := r.Context()
 	claims, err := authtypes.ClaimsFromContext(r.Context())
 	if err != nil {
 		render.Error(w, err)
 		return
 	}
 	orgID, err := valuer.NewUUID(claims.OrgID)
 	if err != nil {
 		render.Error(w, err)
 		return
 	}
 	req := model.PodListRequest{}
 	err = json.NewDecoder(r.Body).Decode(&req)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	podList, err := aH.podsRepo.GetPodList(ctx, orgID, req)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	aH.Respond(w, podList)
 }
 func (aH *APIHandler) getNodeAttributeKeys(w http.ResponseWriter, r *http.Request) {
 	ctx := r.Context()
 	req, err := parseFilterAttributeKeyRequest(r)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	claims, err := authtypes.ClaimsFromContext(r.Context())
 	if err != nil {
 		render.Error(w, err)
 		return
 	}
 	orgID := valuer.MustNewUUID(claims.OrgID)
 	keys, err := aH.nodesRepo.GetNodeAttributeKeys(ctx, orgID, *req)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	aH.Respond(w, keys)
 }
 func (aH *APIHandler) getNodeAttributeValues(w http.ResponseWriter, r *http.Request) {
 	ctx := r.Context()
 	req, err := parseFilterAttributeValueRequest(r)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	claims, err := authtypes.ClaimsFromContext(r.Context())
 	if err != nil {
 		render.Error(w, err)
 		return
 	}
 	orgID := valuer.MustNewUUID(claims.OrgID)
 	values, err := aH.nodesRepo.GetNodeAttributeValues(ctx, orgID, *req)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	aH.Respond(w, values)
 }
 func (aH *APIHandler) getNodeList(w http.ResponseWriter, r *http.Request) {
 	ctx := r.Context()
 	claims, err := authtypes.ClaimsFromContext(r.Context())
 	if err != nil {
 		render.Error(w, err)
 		return
 	}
 	orgID, err := valuer.NewUUID(claims.OrgID)
 	if err != nil {
 		render.Error(w, err)
 		return
 	}
 	req := model.NodeListRequest{}
 	err = json.NewDecoder(r.Body).Decode(&req)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	nodeList, err := aH.nodesRepo.GetNodeList(ctx, orgID, req)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	aH.Respond(w, nodeList)
 }
 func (aH *APIHandler) getNamespaceAttributeKeys(w http.ResponseWriter, r *http.Request) {
 	ctx := r.Context()
 	req, err := parseFilterAttributeKeyRequest(r)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	keys, err := aH.namespacesRepo.GetNamespaceAttributeKeys(ctx, *req)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	aH.Respond(w, keys)
 }
 func (aH *APIHandler) getNamespaceAttributeValues(w http.ResponseWriter, r *http.Request) {
 	ctx := r.Context()
 	req, err := parseFilterAttributeValueRequest(r)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	claims, err := authtypes.ClaimsFromContext(r.Context())
 	if err != nil {
 		render.Error(w, err)
 		return
 	}
 	orgID := valuer.MustNewUUID(claims.OrgID)
 	values, err := aH.namespacesRepo.GetNamespaceAttributeValues(ctx, orgID, *req)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	aH.Respond(w, values)
 }
 func (aH *APIHandler) getNamespaceList(w http.ResponseWriter, r *http.Request) {
 	ctx := r.Context()
 	claims, err := authtypes.ClaimsFromContext(r.Context())
 	if err != nil {
 		render.Error(w, err)
 		return
 	}
 	orgID, err := valuer.NewUUID(claims.OrgID)
 	if err != nil {
 		render.Error(w, err)
 		return
 	}
 	req := model.NamespaceListRequest{}
 	err = json.NewDecoder(r.Body).Decode(&req)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	namespaceList, err := aH.namespacesRepo.GetNamespaceList(ctx, orgID, req)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	aH.Respond(w, namespaceList)
 }
 func (aH *APIHandler) getClusterAttributeKeys(w http.ResponseWriter, r *http.Request) {
 	ctx := r.Context()
 	req, err := parseFilterAttributeKeyRequest(r)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	claims, err := authtypes.ClaimsFromContext(r.Context())
 	if err != nil {
 		render.Error(w, err)
 		return
 	}
 	orgID := valuer.MustNewUUID(claims.OrgID)
 	keys, err := aH.clustersRepo.GetClusterAttributeKeys(ctx, orgID, *req)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	aH.Respond(w, keys)
 }
 func (aH *APIHandler) getClusterAttributeValues(w http.ResponseWriter, r *http.Request) {
 	ctx := r.Context()
 	req, err := parseFilterAttributeValueRequest(r)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	claims, err := authtypes.ClaimsFromContext(r.Context())
 	if err != nil {
 		render.Error(w, err)
 		return
 	}
 	orgID := valuer.MustNewUUID(claims.OrgID)
 	values, err := aH.clustersRepo.GetClusterAttributeValues(ctx, orgID, *req)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	aH.Respond(w, values)
 }
 func (aH *APIHandler) getClusterList(w http.ResponseWriter, r *http.Request) {
 	ctx := r.Context()
 	claims, err := authtypes.ClaimsFromContext(r.Context())
 	if err != nil {
 		render.Error(w, err)
 		return
 	}
 	orgID, err := valuer.NewUUID(claims.OrgID)
 	if err != nil {
 		render.Error(w, err)
 		return
 	}
 	req := model.ClusterListRequest{}
 	err = json.NewDecoder(r.Body).Decode(&req)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	clusterList, err := aH.clustersRepo.GetClusterList(ctx, orgID, req)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	aH.Respond(w, clusterList)
 }
 func (aH *APIHandler) getDeploymentAttributeKeys(w http.ResponseWriter, r *http.Request) {
 	ctx := r.Context()
 	req, err := parseFilterAttributeKeyRequest(r)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	claims, err := authtypes.ClaimsFromContext(r.Context())
 	if err != nil {
 		render.Error(w, err)
 		return
 	}
 	orgID := valuer.MustNewUUID(claims.OrgID)
 	keys, err := aH.deploymentsRepo.GetDeploymentAttributeKeys(ctx, orgID, *req)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	aH.Respond(w, keys)
 }
 func (aH *APIHandler) getDeploymentAttributeValues(w http.ResponseWriter, r *http.Request) {
 	ctx := r.Context()
 	req, err := parseFilterAttributeValueRequest(r)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	claims, err := authtypes.ClaimsFromContext(r.Context())
 	if err != nil {
 		render.Error(w, err)
 		return
 	}
 	orgID := valuer.MustNewUUID(claims.OrgID)
 	values, err := aH.deploymentsRepo.GetDeploymentAttributeValues(ctx, orgID, *req)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	aH.Respond(w, values)
 }
 func (aH *APIHandler) getDeploymentList(w http.ResponseWriter, r *http.Request) {
 	ctx := r.Context()
 	claims, err := authtypes.ClaimsFromContext(r.Context())
 	if err != nil {
 		render.Error(w, err)
 		return
 	}
 	orgID, err := valuer.NewUUID(claims.OrgID)
 	if err != nil {
 		render.Error(w, err)
 		return
 	}
 	req := model.DeploymentListRequest{}
 	err = json.NewDecoder(r.Body).Decode(&req)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	deploymentList, err := aH.deploymentsRepo.GetDeploymentList(ctx, orgID, req)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	aH.Respond(w, deploymentList)
 }
 func (aH *APIHandler) getDaemonSetAttributeKeys(w http.ResponseWriter, r *http.Request) {
 	ctx := r.Context()
 	req, err := parseFilterAttributeKeyRequest(r)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	claims, err := authtypes.ClaimsFromContext(r.Context())
 	if err != nil {
 		render.Error(w, err)
 		return
 	}
 	orgID := valuer.MustNewUUID(claims.OrgID)
 	keys, err := aH.daemonsetsRepo.GetDaemonSetAttributeKeys(ctx, orgID, *req)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	aH.Respond(w, keys)
 }
 func (aH *APIHandler) getDaemonSetAttributeValues(w http.ResponseWriter, r *http.Request) {
 	ctx := r.Context()
 	req, err := parseFilterAttributeValueRequest(r)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	claims, err := authtypes.ClaimsFromContext(r.Context())
 	if err != nil {
 		render.Error(w, err)
 		return
 	}
 	orgID := valuer.MustNewUUID(claims.OrgID)
 	values, err := aH.daemonsetsRepo.GetDaemonSetAttributeValues(ctx, orgID, *req)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	aH.Respond(w, values)
 }
 func (aH *APIHandler) getDaemonSetList(w http.ResponseWriter, r *http.Request) {
 	ctx := r.Context()
 	claims, err := authtypes.ClaimsFromContext(r.Context())
 	if err != nil {
 		render.Error(w, err)
 		return
 	}
 	orgID, err := valuer.NewUUID(claims.OrgID)
 	if err != nil {
 		render.Error(w, err)
 		return
 	}
 	req := model.DaemonSetListRequest{}
 	err = json.NewDecoder(r.Body).Decode(&req)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	daemonSetList, err := aH.daemonsetsRepo.GetDaemonSetList(ctx, orgID, req)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	aH.Respond(w, daemonSetList)
 }
 func (aH *APIHandler) getStatefulSetAttributeKeys(w http.ResponseWriter, r *http.Request) {
 	ctx := r.Context()
 	req, err := parseFilterAttributeKeyRequest(r)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	claims, err := authtypes.ClaimsFromContext(r.Context())
 	if err != nil {
 		render.Error(w, err)
 		return
 	}
 	orgID := valuer.MustNewUUID(claims.OrgID)
 	keys, err := aH.statefulsetsRepo.GetStatefulSetAttributeKeys(ctx, orgID, *req)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	aH.Respond(w, keys)
 }
 func (aH *APIHandler) getStatefulSetAttributeValues(w http.ResponseWriter, r *http.Request) {
 	ctx := r.Context()
 	req, err := parseFilterAttributeValueRequest(r)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	claims, err := authtypes.ClaimsFromContext(r.Context())
 	if err != nil {
 		render.Error(w, err)
 		return
 	}
 	orgID := valuer.MustNewUUID(claims.OrgID)
 	values, err := aH.statefulsetsRepo.GetStatefulSetAttributeValues(ctx, orgID, *req)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	aH.Respond(w, values)
 }
 func (aH *APIHandler) getStatefulSetList(w http.ResponseWriter, r *http.Request) {
 	ctx := r.Context()
 	claims, err := authtypes.ClaimsFromContext(r.Context())
 	if err != nil {
 		render.Error(w, err)
 		return
 	}
 	orgID, err := valuer.NewUUID(claims.OrgID)
 	if err != nil {
 		render.Error(w, err)
 		return
 	}
 	req := model.StatefulSetListRequest{}
 	err = json.NewDecoder(r.Body).Decode(&req)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	statefulSetList, err := aH.statefulsetsRepo.GetStatefulSetList(ctx, orgID, req)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	aH.Respond(w, statefulSetList)
 }
 func (aH *APIHandler) getJobAttributeKeys(w http.ResponseWriter, r *http.Request) {
 	ctx := r.Context()
 	req, err := parseFilterAttributeKeyRequest(r)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	claims, err := authtypes.ClaimsFromContext(r.Context())
 	if err != nil {
 		render.Error(w, err)
 		return
 	}
 	orgID := valuer.MustNewUUID(claims.OrgID)
 	keys, err := aH.jobsRepo.GetJobAttributeKeys(ctx, orgID, *req)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	aH.Respond(w, keys)
 }
 func (aH *APIHandler) getJobAttributeValues(w http.ResponseWriter, r *http.Request) {
 	ctx := r.Context()
 	req, err := parseFilterAttributeValueRequest(r)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	claims, err := authtypes.ClaimsFromContext(r.Context())
 	if err != nil {
 		render.Error(w, err)
 		return
 	}
 	orgID := valuer.MustNewUUID(claims.OrgID)
 	values, err := aH.jobsRepo.GetJobAttributeValues(ctx, orgID, *req)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	aH.Respond(w, values)
 }
 func (aH *APIHandler) getJobList(w http.ResponseWriter, r *http.Request) {
 	ctx := r.Context()
 	claims, err := authtypes.ClaimsFromContext(r.Context())
 	if err != nil {
 		render.Error(w, err)
 		return
 	}
 	orgID, err := valuer.NewUUID(claims.OrgID)
 	if err != nil {
 		render.Error(w, err)
 		return
 	}
 	req := model.JobListRequest{}
 	err = json.NewDecoder(r.Body).Decode(&req)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	jobList, err := aH.jobsRepo.GetJobList(ctx, orgID, req)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	aH.Respond(w, jobList)
 }
 func (aH *APIHandler) getPvcList(w http.ResponseWriter, r *http.Request) {
 	ctx := r.Context()
 	claims, err := authtypes.ClaimsFromContext(r.Context())
 	if err != nil {
 		render.Error(w, err)
 		return
 	}
 	orgID, err := valuer.NewUUID(claims.OrgID)
 	if err != nil {
 		render.Error(w, err)
 		return
 	}
 	req := model.VolumeListRequest{}
 	err = json.NewDecoder(r.Body).Decode(&req)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	pvcList, err := aH.pvcsRepo.GetPvcList(ctx, orgID, req)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	aH.Respond(w, pvcList)
 }
 func (aH *APIHandler) getPvcAttributeKeys(w http.ResponseWriter, r *http.Request) {
 	ctx := r.Context()
 	req, err := parseFilterAttributeKeyRequest(r)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	claims, err := authtypes.ClaimsFromContext(r.Context())
 	if err != nil {
 		render.Error(w, err)
 		return
 	}
 	orgID := valuer.MustNewUUID(claims.OrgID)
 	keys, err := aH.pvcsRepo.GetPvcAttributeKeys(ctx, orgID, *req)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	aH.Respond(w, keys)
 }
 func (aH *APIHandler) getPvcAttributeValues(w http.ResponseWriter, r *http.Request) {
 	ctx := r.Context()
 	req, err := parseFilterAttributeValueRequest(r)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	claims, err := authtypes.ClaimsFromContext(r.Context())
 	if err != nil {
 		render.Error(w, err)
 		return
 	}
 	orgID := valuer.MustNewUUID(claims.OrgID)
 	values, err := aH.pvcsRepo.GetPvcAttributeValues(ctx, orgID, *req)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	aH.Respond(w, values)
 }
 func (aH *APIHandler) getK8sInfraOnboardingStatus(w http.ResponseWriter, r *http.Request) {
 	ctx := r.Context()
 	status := model.OnboardingStatus{}
 	didSendPodMetrics, err := aH.podsRepo.DidSendPodMetrics(ctx)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	if !didSendPodMetrics {
 		aH.Respond(w, status)
 		return
 	}
 	didSendClusterMetrics, err := aH.podsRepo.DidSendClusterMetrics(ctx)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	didSendNodeMetrics, err := aH.nodesRepo.DidSendNodeMetrics(ctx)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	didSendOptionalPodMetrics, err := aH.podsRepo.IsSendingOptionalPodMetrics(ctx)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	requiredMetadata, err := aH.podsRepo.SendingRequiredMetadata(ctx)
 	if err != nil {
 		RespondError(w, &model.ApiError{Typ: model.ErrorInternal, Err: err}, nil)
 		return
 	}
 	status.DidSendPodMetrics = didSendPodMetrics
 	status.DidSendClusterMetrics = didSendClusterMetrics
 	status.DidSendNodeMetrics = didSendNodeMetrics
 	status.IsSendingOptionalPodMetrics = didSendOptionalPodMetrics
 	status.IsSendingRequiredMetadata = requiredMetadata
 	aH.Respond(w, status)
 }

909 lines 22 KiB Go Raw Permalink Blame History

909 lines

22 KiB

Go

Raw Permalink Blame History