server

package
v0.6.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 4, 2025 License: AGPL-3.0 Imports: 31 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// OpenAIRequestTimeout is the maximum time to wait for OpenAI to respond
	OpenAIRequestTimeout = 15 * time.Second
)

Added constant

Variables

View Source 
var (
	// Note: Some errors might overlap with core definitions but are kept here
	// for mapping purposes within redirectToFrontend.
	ErrSessionNotFound           = errors.New("session not found")
	ErrSessionExpired            = errors.New("session expired")
	ErrUserNotFound              = errors.New("user not found")
	ErrTeamNotFound              = errors.New("team not found")
	ErrUnauthorizedUser          = errors.New("unauthorized user")
	ErrUserInactive              = errors.New("user inactive")
	ErrOIDCProviderNotConfigured = errors.New("OIDC provider not configured") // This one might belong in auth/oidc.go
	ErrOIDCInvalidToken          = errors.New("invalid OIDC token")
	ErrOIDCEmailNotVerified      = errors.New("email not verified")
)

Define Auth/OIDC specific errors used within handlers, especially for redirect mapping.

Functions

func SendError 

func SendError(c *fiber.Ctx, status int, err interface{}) error

SendError is a helper function to easily send a JSON error response with the given HTTP status code and error message. It uses the GeneralErrorType by default.

func SendErrorWithType 

func SendErrorWithType(c *fiber.Ctx, status int, err interface{}, errorType models.ErrorType) error

SendErrorWithType is a helper function to easily send a JSON error response with the given HTTP status code, error message, and a specific application error type.

func SendSuccess 

func SendSuccess(c *fiber.Ctx, status int, data interface{}) error

SendSuccess is a helper function to easily send a successful JSON response with the given HTTP status code and data payload.

Types

type ActiveQuery added in v0.4.0 

type ActiveQuery struct {
	ID        string
	UserID    models.UserID
	SourceID  models.SourceID
	TeamID    models.TeamID
	StartTime time.Time
	SQL       string
	Cancel    context.CancelFunc
}

ActiveQuery represents an active query with its context for cancellation

type MetaResponse added in v0.2.2 

type MetaResponse struct {
	Version           string `json:"version"`
	HTTPServerTimeout string `json:"http_server_timeout"`
}

MetaResponse represents the server metadata response

type QueryTracker added in v0.4.0 

type QueryTracker struct {
	// contains filtered or unexported fields
}

QueryTracker manages active queries for cancellation support

func (*QueryTracker) AddQuery added in v0.4.0 

func (qt *QueryTracker) AddQuery(userID models.UserID, sourceID models.SourceID, teamID models.TeamID, sql string, cancel context.CancelFunc) string

AddQuery adds a new active query to the tracker

func (*QueryTracker) CancelQuery added in v0.4.0 

func (qt *QueryTracker) CancelQuery(queryID string, userID models.UserID) bool

CancelQuery cancels a query if it exists and belongs to the user

func (*QueryTracker) Cleanup added in v0.4.0 

func (qt *QueryTracker) Cleanup()

Cleanup removes queries that have been running for too long (over 1 hour)

func (*QueryTracker) GetUserQueries added in v0.4.0 

func (qt *QueryTracker) GetUserQueries(userID models.UserID) []*ActiveQuery

GetUserQueries returns all active queries for a user

func (*QueryTracker) RemoveQuery added in v0.4.0 

func (qt *QueryTracker) RemoveQuery(queryID string)

RemoveQuery removes a query from the tracker

type Response 

type Response struct {
	Status    string      `json:"status"` // "success" or "error"
	Data      interface{} `json:"data,omitempty"`
	Message   string      `json:"message,omitempty"`
	ErrorType string      `json:"error_type,omitempty"` // Application-specific error type code.
}

Response defines the standard JSON structure for API responses.

func NewErrorResponse 

func NewErrorResponse(err interface{}, errorType models.ErrorType) Response

NewErrorResponse creates a standard error response structure. It accepts various error types and maps them to a consistent JSON format.

func NewSuccessResponse 

func NewSuccessResponse(data interface{}) Response

NewSuccessResponse creates a standard success response structure.

type Server 

type Server struct {
	// contains filtered or unexported fields
}

Server represents the core HTTP server, encapsulating the Fiber app instance and necessary dependencies like database connections and configuration.

func New 

func New(opts ServerOptions) *Server

New creates, configures, and returns a new Server instance. It initializes the Fiber application, sets up middleware, injects dependencies, and registers all application routes.

func (*Server) Shutdown 

func (s *Server) Shutdown(ctx context.Context) error

Shutdown gracefully shuts down the Fiber server within the given context timeout.

func (*Server) Start 

func (s *Server) Start() error

Start binds the server to the configured host and port and begins listening.

type ServerOptions 

type ServerOptions struct {
	Config        *config.Config
	SQLite        *sqlite.DB
	ClickHouse    *clickhouse.Manager
	AlertsManager *alerts.Manager    // Alerts manager for manual resolution with Alertmanager notification.
	OIDCProvider  *auth.OIDCProvider // OIDC provider for authentication flows.
	FS            http.FileSystem    // Filesystem for serving static assets (frontend).
	Logger        *slog.Logger
	BuildInfo     string
	Version       string
}

ServerOptions holds the dependencies required to create a new Server instance. This structure reflects the refactored approach using direct dependencies instead of services.

type SettingsByCategoryResponse added in v0.6.0 

type SettingsByCategoryResponse struct {
	Category string                  `json:"category"`
	Settings []SystemSettingResponse `json:"settings"`
}

SettingsByCategoryResponse groups settings by category.

type SystemSettingResponse added in v0.6.0 

type SystemSettingResponse struct {
	Key         string `json:"key"`
	Value       string `json:"value"`
	ValueType   string `json:"value_type"`
	Category    string `json:"category"`
	Description string `json:"description,omitempty"`
	IsSensitive bool   `json:"is_sensitive"`
	MaskedValue string `json:"masked_value,omitempty"`
	CreatedAt   string `json:"created_at"`
	UpdatedAt   string `json:"updated_at"`
}

SystemSettingResponse represents a setting in API responses.

type TestAlertmanagerRequest added in v0.6.0 

type TestAlertmanagerRequest struct {
	URL                   string `json:"url"`
	TLSInsecureSkipVerify bool   `json:"tls_insecure_skip_verify"`
	Timeout               string `json:"timeout,omitempty"` // Duration string (e.g., "5s")
}

TestAlertmanagerRequest represents a request to test Alertmanager connection.

type UpdateSettingRequest added in v0.6.0 

type UpdateSettingRequest struct {
	Value       string `json:"value"`
	ValueType   string `json:"value_type"`
	Category    string `json:"category"`
	Description string `json:"description"`
	IsSensitive bool   `json:"is_sensitive"`
}

UpdateSettingRequest represents a request to update a setting.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.