Documentation
¶
Index ¶
- func Register(area string, method string, route string, actionFunc any, ...) *context.HttpRoute
- func SocketHandler(route *context.HttpRoute) websocket.Handler
- type BaseContext
- func (receiver *BaseContext) Close()
- func (receiver *BaseContext) ForReceiverFunc(f func(message string))
- func (receiver *BaseContext) GetHeader(key string) string
- func (receiver *BaseContext) GetParam(key string) any
- func (receiver *BaseContext) IsClose() bool
- func (receiver *BaseContext) ReceiverMessage() string
- func (receiver *BaseContext) ReceiverMessageFunc(d time.Duration, f func(message string))
- func (receiver *BaseContext) Send(msg any) error
- type Context
- type HandleMiddleware
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type BaseContext ¶
type BaseContext struct {
Ctx ctx.Context // 用于通知应用端是否断开连接
AutoExit bool // 当断开连接时，自动退出
HttpContext *context.HttpContext // 上下文
// contains filtered or unexported fields
}
func (*BaseContext) ForReceiverFunc ¶
func (receiver *BaseContext) ForReceiverFunc(f func(message string))
ForReceiverFunc 持续接收消息然后执行f()，然后再接收
func (*BaseContext) GetHeader ¶
func (receiver *BaseContext) GetHeader(key string) string
GetHeader 获取头部
func (*BaseContext) GetParam ¶
func (receiver *BaseContext) GetParam(key string) any
GetParam 获取来自URL的参数
func (*BaseContext) ReceiverMessage ¶
func (receiver *BaseContext) ReceiverMessage() string
ReceiverMessage 接收消息
func (*BaseContext) ReceiverMessageFunc ¶
func (receiver *BaseContext) ReceiverMessageFunc(d time.Duration, f func(message string))
ReceiverMessageFunc 接收消息。当收到消息后，会执行f()
func (*BaseContext) Send ¶
func (receiver *BaseContext) Send(msg any) error
Send 发送消息，如果msg不是go的基础类型，则会自动序列化成json
type Context ¶
type Context[T any] struct { *BaseContext // contains filtered or unexported fields }
Context websocket上下文
func (*Context[T]) ForReceiverFunc ¶
func (receiver *Context[T]) ForReceiverFunc(f func(message *T))
ForReceiverFunc 持续接收消息然后执行f()，然后再接收
func (*Context[T]) ReceiverFunc ¶
ReceiverFunc 当收到下一条消息时，会停止上一条消息的f()执行，然后再执行下一条消息的f()。如果没有收到消息，则会一直定时间隔执行f()
func (*Context[T]) SetContext ¶
func (receiver *Context[T]) SetContext(httpContext *context.HttpContext)
SetContext 收到请求时，设置上下文（webapi使用）
type HandleMiddleware ¶
type HandleMiddleware struct {
}
func (HandleMiddleware) Invoke ¶
func (receiver HandleMiddleware) Invoke(httpContext *context.HttpContext)
Source Files
Click to show internal directories.
Click to hide internal directories.