mirror of
https://github.com/hanzoai/o11y.git
synced 2026-10-15 12:58:33 +00:00
zeekay
b36a8788a5
Full rebrand of the SigNoz observability platform: - Go module: github.com/SigNoz/signoz → github.com/hanzoai/o11y - Frontend: @signozhq/* → @hanzo/o11y-*, posthog-js → @hanzo/insights - Docker: signoz/* → ghcr.io/hanzoai/o11y* - ClickHouse → Hanzo Datastore (hanzoai/datastore) - Env vars: SIGNOZ_* → HANZO_* - DB tables: signoz_* → o11y_* - All branding, URLs, docs updated - 2172 files changed
61 lines
2.3 KiB
Go
61 lines
2.3 KiB
Go
package gateway
|
|
|
|
import (
|
|
"context"
|
|
"net/http"
|
|
"time"
|
|
|
|
"github.com/hanzoai/o11y/pkg/errors"
|
|
"github.com/hanzoai/o11y/pkg/types/gatewaytypes"
|
|
"github.com/hanzoai/o11y/pkg/valuer"
|
|
)
|
|
|
|
var (
|
|
ErrCodeGatewayUnsupported = errors.MustNewCode("gateway_unsupported")
|
|
ErrCodeInvalidGatewayConfig = errors.MustNewCode("invalid_gateway_config")
|
|
)
|
|
|
|
type Gateway interface {
|
|
// Get Ingestions Keys (this is supposed to be for the current user but for now in gateway code this is ignoring the consumer user)
|
|
GetIngestionKeys(ctx context.Context, orgID valuer.UUID, page, perPage int) (*gatewaytypes.GettableIngestionKeys, error)
|
|
|
|
// Search Ingestion Keys by Name (this is supposed to be for the current user but for now in gateway code this is ignoring the consumer user)
|
|
SearchIngestionKeysByName(ctx context.Context, orgID valuer.UUID, name string, page, perPage int) (*gatewaytypes.GettableIngestionKeys, error)
|
|
|
|
// Create Ingestion Key
|
|
CreateIngestionKey(ctx context.Context, orgID valuer.UUID, name string, tags []string, expiresAt time.Time) (*gatewaytypes.GettableCreatedIngestionKey, error)
|
|
|
|
// Update Ingestion Key
|
|
UpdateIngestionKey(ctx context.Context, orgID valuer.UUID, keyID string, name string, tags []string, expiresAt time.Time) error
|
|
|
|
// Delete Ingestion Key
|
|
DeleteIngestionKey(ctx context.Context, orgID valuer.UUID, keyID string) error
|
|
|
|
// Create Ingestion Key Limit
|
|
CreateIngestionKeyLimit(ctx context.Context, orgID valuer.UUID, keyID string, signal string, limitConfig gatewaytypes.LimitConfig, tags []string) (*gatewaytypes.GettableCreatedIngestionKeyLimit, error)
|
|
|
|
// Update Ingestion Key Limit
|
|
UpdateIngestionKeyLimit(ctx context.Context, orgID valuer.UUID, limitID string, limitConfig gatewaytypes.LimitConfig, tags []string) error
|
|
|
|
// Delete Ingestion Key Limit
|
|
DeleteIngestionKeyLimit(ctx context.Context, orgID valuer.UUID, limitID string) error
|
|
}
|
|
|
|
type Handler interface {
|
|
GetIngestionKeys(http.ResponseWriter, *http.Request)
|
|
|
|
SearchIngestionKeys(http.ResponseWriter, *http.Request)
|
|
|
|
CreateIngestionKey(http.ResponseWriter, *http.Request)
|
|
|
|
UpdateIngestionKey(http.ResponseWriter, *http.Request)
|
|
|
|
DeleteIngestionKey(http.ResponseWriter, *http.Request)
|
|
|
|
CreateIngestionKeyLimit(http.ResponseWriter, *http.Request)
|
|
|
|
UpdateIngestionKeyLimit(http.ResponseWriter, *http.Request)
|
|
|
|
DeleteIngestionKeyLimit(http.ResponseWriter, *http.Request)
|
|
}
|