serve

package
v1.2.0 Latest Latest
Warning

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

Go to latest
Published: Jul 6, 2026 License: MIT Imports: 24 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewProxy

func NewProxy()

NewProxy 初始化代理

func WebsocketCapture added in v1.1.0

func WebsocketCapture(c *gin.Context)

WebsocketCapture Websocket 连接(抓包)

Types

type CaptureHub added in v1.1.0

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

CaptureHub 管理抓包任务

func GetCaptureHub added in v1.1.0

func GetCaptureHub() *CaptureHub

GetCaptureHub 获取全局唯一的抓包实例

func (*CaptureHub) Broadcast added in v1.1.0

func (h *CaptureHub) Broadcast(taskUuid string, data PacketData)

Broadcast 将数据推送给客户端

func (*CaptureHub) CloseTask added in v1.1.0

func (h *CaptureHub) CloseTask(taskUuid string)

func (*CaptureHub) IsCapturing added in v1.1.0

func (h *CaptureHub) IsCapturing(taskUuid string) bool

IsCapturing 检查是否有任务在抓包

func (*CaptureHub) Publish added in v1.1.0

func (h *CaptureHub) Publish(taskUuid string, direction string, protocol string, payload []byte)

type PacketData added in v1.1.0

type PacketData struct {
	TaskUuid  string `json:"task_uuid"` // 代理唯一标识
	Timestamp int64  `json:"timestamp"` // 时间戳,毫秒
	Direction string `json:"direction"` // IN-入站 OUT-出站
	Protocol  string `json:"protocol"`  // TCP\UDP\HTTP
	Payload   string `json:"payload"`   // Hex-encoded data
}

PacketData 推送的数据包

type ProxyTask

type ProxyTask struct {
	models.ProxyBasic

	TrafficIn  int64 `json:"traffic_in"`
	TrafficOut int64 `json:"traffic_out"`
	// contains filtered or unexported fields
}

func (*ProxyTask) ActiveConnections added in v1.1.0

func (task *ProxyTask) ActiveConnections() int64

func (*ProxyTask) Remove

func (task *ProxyTask) Remove()

Remove 移除任务

func (*ProxyTask) Restart

func (task *ProxyTask) Restart() error

Restart 重启任务

func (*ProxyTask) Snapshot added in v1.1.0

func (task *ProxyTask) Snapshot() *TaskSnapshot

func (*ProxyTask) Start

func (task *ProxyTask) Start() error

Start 启动任务

func (*ProxyTask) Status

func (task *ProxyTask) Status() ([]*ProxyTask, error)

Status 获取任务状态

func (*ProxyTask) Stop

func (task *ProxyTask) Stop() error

Stop 停止代理

type TaskSnapshot added in v1.1.0

type TaskSnapshot struct {
	models.ProxyBasic
	TrafficIn         int64 `json:"traffic_in"`
	TrafficOut        int64 `json:"traffic_out"`
	ActiveConnections int64 `json:"active_connections"`
}

func ProxyTaskSnapshots added in v1.1.0

func ProxyTaskSnapshots() []*TaskSnapshot

Jump to

Keyboard shortcuts

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