api

package
v0.0.0-0d51025 Latest Latest
Warning

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

Go to latest
Published: Jul 3, 2026 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func HandleWebSocket

func HandleWebSocket(hub *WSHub) gin.HandlerFunc

HandleWebSocket upgrades the HTTP connection to WebSocket.

Types

type AuditLog

type AuditLog struct {
	AuditLogBIZ *biz.AuditLog
}

AuditLog management

func (*AuditLog) Get

func (a *AuditLog) Get(c *gin.Context)

@Tags AuditLogAPI @Security ApiKeyAuth @Summary Get audit log by ID @Param id path string true "Audit log ID" @Success 200 {object} util.ResponseResult{data=schema.AuditLog} @Failure 401 {object} util.ResponseResult @Failure 500 {object} util.ResponseResult @Router /api/v1/audit-logs/{id} [get]

func (*AuditLog) Query

func (a *AuditLog) Query(c *gin.Context)

@Tags AuditLogAPI @Security ApiKeyAuth @Summary Query audit logs @Param current query int true "pagination index" default(1) @Param pageSize query int true "pagination size" default(10) @Param tenant_code query string false "Tenant code" @Param actor_user_id query string false "Actor user ID" @Param action query string false "Action" @Param resource_type query string false "Resource type" @Param resource_id query string false "Resource ID" @Param trace_id query string false "Trace ID" @Param start_time query string false "Start time" @Param end_time query string false "End time" @Success 200 {object} util.ResponseResult{data=[]schema.AuditLog} @Failure 401 {object} util.ResponseResult @Failure 500 {object} util.ResponseResult @Router /api/v1/audit-logs [get]

type EventAPI

type EventAPI struct {
	EventBIZ *biz.EventBiz
	Hub      *WSHub
}

EventAPI handles HTTP requests for event operations.

func (*EventAPI) GetStatistics

func (a *EventAPI) GetStatistics(c *gin.Context)

@Tags EventAPI @Security ApiKeyAuth @Summary Get event statistics (counts, trend, rankings) @Param time_range query string false "Time range" Enums(1h, 6h, 24h, 7d, today) default(24h) @Success 200 {object} util.ResponseResult{data=schema.EventStatistics} @Router /api/v1/ops/events/statistics [get]

func (*EventAPI) HandleWebSocket

func (a *EventAPI) HandleWebSocket(c *gin.Context)

@Tags EventAPI @Security ApiKeyAuth @Summary WebSocket endpoint for real-time event push @Router /api/v1/ops/events/ws [get]

func (*EventAPI) Query

func (a *EventAPI) Query(c *gin.Context)

@Tags EventAPI @Security ApiKeyAuth @Summary Query event logs with pagination and filtering @Param current query int false "Page number" default(1) @Param pageSize query int false "Page size" default(20) @Param event_type query string false "Event type filter" @Param tenant_code query string false "Tenant code filter" @Param model_code query string false "Model code filter" @Param endpoint_id query string false "Endpoint ID filter" @Param policy_id query string false "Policy ID filter" @Param start_time query string false "Start time (ISO 8601)" @Param end_time query string false "End time (ISO 8601)" @Success 200 {object} util.ResponseResult{data=schema.EventLogs} @Router /api/v1/ops/events [get]

type PortalUserAPI

type PortalUserAPI struct {
	PortalUserBIZ *biz.PortalUser
}

func (*PortalUserAPI) ListWorkspaceAPIKeys

func (a *PortalUserAPI) ListWorkspaceAPIKeys(c *gin.Context)

@Tags PortalUserAPI @Security ApiKeyAuth @Summary List portal workspace API keys @Param workspace_id path string true "workspace ID" @Success 200 {object} util.ResponseResult{data=[]biz.PortalWorkspaceAPIKey} @Failure 401 {object} util.ResponseResult @Failure 500 {object} util.ResponseResult @Router /api/v1/ops/portal/workspaces/{workspace_id}/api-keys [get]

func (*PortalUserAPI) Query

func (a *PortalUserAPI) Query(c *gin.Context)

@Tags PortalUserAPI @Security ApiKeyAuth @Summary Search portal users @Param keyword query string false "search keyword" @Param limit query int false "limit" default(20) @Success 200 {object} util.ResponseResult{data=[]biz.PortalUserResult} @Failure 401 {object} util.ResponseResult @Failure 500 {object} util.ResponseResult @Router /api/v1/ops/portal/users [get]

func (*PortalUserAPI) SyncWorkspaceRuntime

func (a *PortalUserAPI) SyncWorkspaceRuntime(c *gin.Context)

@Tags PortalUserAPI @Security ApiKeyAuth @Summary Sync portal workspace API keys to gateway runtime @Param workspace_id path string true "workspace ID" @Success 200 {object} util.ResponseResult @Failure 401 {object} util.ResponseResult @Failure 500 {object} util.ResponseResult @Router /api/v1/ops/portal/workspaces/{workspace_id}/runtime-sync [post]

type WSClient

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

WSClient represents a single WebSocket client connection.

type WSHub

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

WSHub manages WebSocket client connections and broadcasts.

func NewWSHub

func NewWSHub() *WSHub

NewWSHub creates a new WSHub instance.

func (*WSHub) Broadcast

func (h *WSHub) Broadcast(data []byte)

Broadcast sends a message to all connected clients.

func (*WSHub) ClientCount

func (h *WSHub) ClientCount() int

ClientCount returns the number of connected clients.

func (*WSHub) Run

func (h *WSHub) Run()

Run starts the hub's main loop. Should be called as a goroutine.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL