server

Documentation

Index

• Constants
• func GetIDHandler(c *gin.Context)
• func WsHandlerWithDependencies(Token string, BaseUrl string, p *Processor.Processors) gin.HandlerFunc
• type RateLimiter
  • func NewRateLimiter() *RateLimiter
  • func (rl *RateLimiter) CheckAndUpdateRateLimit(ipAddress string) bool
• type WebSocketServerClient
  • func (client *WebSocketServerClient) Close() error
  • func (c *WebSocketServerClient) SendMessage(message map[string]interface{}) error

Constants

const (
	MaximumImageSize        = 10 * 1024 * 1024
	AllowedUploadsPerMinute = 100
	RequestInterval         = time.Minute
)

Functions

func GetIDHandler

func GetIDHandler(c *gin.Context)

func WsHandlerWithDependencies

func WsHandlerWithDependencies(Token string, BaseUrl string, p *Processor.Processors) gin.HandlerFunc

使用闭包结构 因为gin需要c *gin.Context固定签名

Types

type RateLimiter

type RateLimiter struct {
	Counts map[string][]time.Time
}

func NewRateLimiter

func NewRateLimiter() *RateLimiter

频率限制器

func (*RateLimiter) CheckAndUpdateRateLimit

func (rl *RateLimiter) CheckAndUpdateRateLimit(ipAddress string) bool

检查是否超过调用频率限制

type WebSocketServerClient

type WebSocketServerClient struct {
	Conn    *websocket.Conn
	Token   string
	BaseUrl string
}

func (*WebSocketServerClient) Close

func (client *WebSocketServerClient) Close() error

func (*WebSocketServerClient) SendMessage

func (c *WebSocketServerClient) SendMessage(message map[string]interface{}) error

发信息给client