Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/AlloyTeam/alloy-worker
/ functions
Functions
107 in github.com/AlloyTeam/alloy-worker
⨍
Functions
107
◇
Types & classes
57
↓ 12 callers
Method
monitor
* 接收 Worker 线程的 monitor 并上报 * * @param payload 日志信息
src/worker/main-thread/worker-report.ts:51
↓ 8 callers
Function
isPromise
(obj: any)
src/worker/common/utils/index.ts:34
↓ 7 callers
Method
request
* 发送请求, 不等待响应 * * @param actionType 事务类型 * @param payload 负载
src/worker/common/channel.ts:61
↓ 7 callers
Method
weblog
* 接收 Worker 线程的 weblog 并上报 * * @param payload 日志信息
src/worker/main-thread/worker-report.ts:69
↓ 6 callers
Method
actionHandler
* 事务处理器, 提供给通信 Channel 调用 * * @param message 会话消息 * @returns
src/worker/common/base-controller.ts:90
↓ 6 callers
Method
addActionHandler
()
test/unit/worker/common/base-action.spec.ts:6
↓ 6 callers
Method
apply
(compiler)
src/plugin/index.js:14
↓ 6 callers
Method
getProxyFunction
* 获取上报的代理函数 * @param noCache 未加载真实上报模块前是否缓存上报数据
src/worker/external/report-proxy.ts:50
↓ 6 callers
Method
trigger
(actionType: string, response: any)
test/unit/worker/mock/mock-controller.ts:22
↓ 5 callers
Method
raven
* 接收 Worker 线程的 raven 并上报 * * @param payload 日志信息
src/worker/main-thread/worker-report.ts:60
↓ 4 callers
Method
requestPromise
()
test/unit/worker/mock/mock-controller.ts:34
↓ 4 callers
Method
start
* 开始心跳检测
src/worker/heart-beat-check.ts:38
↓ 3 callers
Function
addZero
(num)
script/build.js:7
↓ 3 callers
Method
eachLoad
* 遍历上报代理加载真实上报模块 * * @param module 真实上报模块
src/worker/external/report-proxy.ts:19
↓ 3 callers
Function
getWorkerUrl
(isDebugMode: boolean)
src/worker/index.ts:64
↓ 3 callers
Method
hasSessionHandler
* 判断是否有指定会话的处理器 * * @param sessionId 会话 Id * @returns {boolean} 判断结果
src/worker/common/channel.ts:253
↓ 3 callers
Method
postMessage
* 封装的 worker 原生 postMessage 接口 * 支持 structured clone 和 transfer 2种通信模式 * * @param message 会话消息
src/worker/common/channel.ts:166
↓ 3 callers
Method
report
* Worker 状态上报 * * @param [isTimeoutAndSuccess=false] 是否超时后通信成功 * @param [timeWorkerReplyMessage] 收到 Worker 线程回复的时刻; undefined 则是通信失败, 没
src/worker/worker-status-check.ts:95
↓ 3 callers
Method
requestDurationReport
(requestDuration: number, timeout: number, actionType: string)
src/worker/common/channel-report.ts:35
↓ 3 callers
Method
requestPromise
* 发送请求, 并等待响应 * * @param actionType 事务类型 * @param payload 负载 * @param timeout 响应超时 * @returns {Promise<IMessage>} 等待响应的 Promi
src/worker/common/channel.ts:82
↓ 3 callers
Method
stop
* 停止心跳检测
src/worker/heart-beat-check.ts:52
↓ 2 callers
Method
addOnmessageListener
* 添加 worker onmessage 事件的回调 * * @param {(event: any) => void} onmessage 回调函数 * @returns {() => void} 移除监听函数
src/worker/common/base-controller.ts:133
↓ 2 callers
Method
addSessionHandler
* 添加会话响应器 * * @param sessionId 会话 Id * @param handler 会话响应器
src/worker/common/channel.ts:216
↓ 2 callers
Method
communicationTest
* 通信能力检测
src/worker/main-thread/worker-ability-test.ts:15
↓ 2 callers
Function
createAlloyWorker
(options: Omit<IAlloyWorkerOptions, 'workerUrl'>)
src/worker/index.ts:31
↓ 2 callers
Function
generateFileFromTemplate
(originFilePath, targerFilePath)
src/command/one-script/generate-file.js:20
↓ 2 callers
Method
generateSessionId
* 生成每次独立会话的 Id * * @returns 会话 Id
src/worker/common/channel.ts:240
↓ 2 callers
Function
getBuildFinishTime
()
script/build.js:6
↓ 2 callers
Function
getDebugTimeStamp
()
src/worker/common/utils/index.ts:20
↓ 2 callers
Method
hasActionHandler
* 判断是否有指定事务的处理器 * * @param actionType 事务类型 * @returns {boolean}
src/worker/common/base-controller.ts:148
↓ 2 callers
Function
insertNewActionLine
(originStr)
src/command/one-script/insert-to-index.js:6
↓ 2 callers
Method
loadRealReport
* 将 reportProxy 替换为真实的上报实例, 上报实例的各种方法调用为发送数据到主线程上报.
src/worker/worker-thread/worker-report.ts:14
↓ 2 callers
Method
onmesssageDebugLog
* 对接收到的会话消息进行 Debug Log 输出 * * @param message 接收到的会话消息
src/worker/common/channel-report.ts:56
↓ 2 callers
Method
postMessageDebugLog
* 对发送的会话消息进行 Debug Log 输出 * * @param message 发送的会话消息
src/worker/common/channel-report.ts:84
↓ 2 callers
Method
reportActionHandlerError
* 上报事务处理器执行报错 * @description * 在各线程 Controller 中 override * * @param actionType 事务类型 * @param error 报错信息
src/worker/common/base-controller.ts:160
↓ 2 callers
Function
statFunc
(cb)
script/build.js:19
↓ 2 callers
Method
timeoutReport
* Worker 通信超时上报 * * @param actionType 事务类型
src/worker/common/channel-report.ts:20
↓ 1 callers
Function
actionExist
(actionName)
src/command/one-script/check-name.js:31
↓ 1 callers
Method
addActionHandler
* 添加事务处理器, 不允许重复添加 * * @param actionType 事务类型 * @param handler 事务处理器
src/worker/common/base-controller.ts:72
↓ 1 callers
Method
captureWorkerException
* 将 Worker 线程的报错堆栈发到主线程进行上报 * * @param payload 报错信息
src/worker/worker-thread/worker-report.ts:37
↓ 1 callers
Method
check
* 进行 worker 通信能力测试
src/worker/worker-status-check.ts:58
↓ 1 callers
Method
checkHealth
* 检查心跳是否健康
src/worker/heart-beat-check.ts:108
↓ 1 callers
Method
checkHeartBeat
* 检查一次心跳
src/worker/heart-beat-check.ts:63
↓ 1 callers
Function
checkIsInWorker
* 判断当前是否在 Worker 环境 * * @returns {boolean}
src/worker/common/utils/index.ts:6
↓ 1 callers
Function
checkName
(actionName)
src/command/one-script/check-name.js:8
↓ 1 callers
Method
deadReport
* Worker 线程死亡的上报
src/worker/heart-beat-check.ts:148
↓ 1 callers
Method
deleteSessionHandler
* 移除会话响应器 * * @param sessionId
src/worker/common/channel.ts:229
↓ 1 callers
Method
durationReport
* 心跳时长的上报 * * @param heartBeatDuration 心跳时长
src/worker/heart-beat-check.ts:132
↓ 1 callers
Method
getExecuteFunction
* 获取真实上报函数
src/worker/external/report-proxy.ts:89
↓ 1 callers
Method
heartBeatTest
* 心跳检测
src/worker/main-thread/worker-ability-test.ts:23
↓ 1 callers
Method
initLoad
* 加载真实上报模块 * @param module 真实上报模模块
src/worker/external/report-proxy.ts:119
↓ 1 callers
Function
insertToIndex
(actionName, pureActionName)
src/command/one-script/insert-to-index.js:5
↓ 1 callers
Function
insertType
(pureActionName)
src/command/one-script/insert-type.js:4
↓ 1 callers
Method
monitor
* 将 Worker 线程的 monitor 发到主线程进行上报 * * @param payload monitor 信息
src/worker/worker-thread/worker-report.ts:46
↓ 1 callers
Function
nameVeridate
(actionName)
src/command/one-script/check-name.js:15
↓ 1 callers
Method
newWorker
* 创建 Worker 线程实例
src/worker/main-thread/controller.ts:61
↓ 1 callers
Method
response
* 发送响应 * * @param sessionId 会话 Id * @param payload 负载
src/worker/common/channel.ts:46
↓ 1 callers
Method
showDeadTip
* Worker 线程死亡的 UI 提示
src/worker/heart-beat-check.ts:123
↓ 1 callers
Method
startHeartBeatCheck
* 开始进行心跳检查
src/worker/main-thread/index.ts:104
↓ 1 callers
Method
startWorkerStatusCheck
* 开始进行状态检查
src/worker/main-thread/index.ts:73
Method
PromiseFunction
(resolve: Function)
src/worker/common/channel.ts:105
Method
addActionHandler
(actionType: string, handler: (payload: any) => any)
test/unit/worker/mock/mock-controller.ts:17
Method
addActionHandler
()
src/worker/worker-thread/worker-ability-test.ts:12
Method
addActionHandler
()
src/worker/worker-thread/worker-report.ts:68
Method
addActionHandler
()
src/worker/worker-thread/cookie.ts:16
Method
addActionHandler
()
src/worker/main-thread/worker-ability-test.ts:29
Method
addActionHandler
()
src/worker/main-thread/worker-report.ts:11
Method
addActionHandler
()
src/worker/main-thread/cookie.ts:9
Method
captureWorkerException
* 接收 Worker 线程的报错堆栈并上报 * * @param payload 报错信息
src/worker/main-thread/worker-report.ts:27
Method
communicationTest
* 通信能力检测的处理器
src/worker/worker-thread/worker-ability-test.ts:23
Function
constructor
(controller: Controller, threadAction: any)
src/worker/common/base-action.ts:16
Method
constructor
(options)
src/plugin/index.js:10
Method
constructor
(controller: Controller, mainThreadWorker: MainThreadWorker)
src/worker/worker-status-check.ts:46
Method
constructor
(mainThreadWorker: MainThreadWorker)
src/worker/heart-beat-check.ts:31
Method
constructor
()
src/worker/worker-thread/index.ts:45
Method
constructor
(controller: Controller, threadAction: any)
src/worker/worker-thread/worker-report.ts:22
Method
constructor
()
src/worker/worker-thread/controller.ts:10
Method
constructor
(isDebugMode: boolean)
src/worker/common/channel-report.ts:11
Method
constructor
()
src/worker/common/base-controller.ts:30
Method
constructor
(worker: Worker, controller: IController)
src/worker/common/channel.ts:29
Method
constructor
(functionName: string)
src/worker/external/report-proxy.ts:39
Method
constructor
(options: IAlloyWorkerOptions)
src/worker/main-thread/index.ts:57
Method
constructor
(options: IAlloyWorkerOptions)
src/worker/main-thread/controller.ts:28
Function
data
()
test/unit/worker/mock/mock-controller.ts:4
Function
data
()
test/unit/worker/mock/mock-worker.ts:5
Method
execute
* 调用真实上报模块进行上报
src/worker/external/report-proxy.ts:73
Function
generateFiles
(actionName, pureActionName)
src/command/one-script/generate-file.js:9
Method
getCookie
* 到主线程获取 cookie
src/worker/worker-thread/cookie.ts:12
Method
getCookie
* 获取 cookie 处理器
src/worker/main-thread/cookie.ts:16
Method
heartBeatTest
* 心跳检测的处理器
src/worker/worker-thread/worker-ability-test.ts:40
Function
loader
()
src/plugin/worker-loader.js:14
Function
monitor
* 监控点上报 * * @param monitorId 监控点
src/worker/external/report.ts:14
Method
onmessage
* 收到会话消息的处理函数 * * 发现是请求, 调用通信控制器的事务处理器进行处理, 获取事务结果并响应; * 发现是响应,调用会话响应器 * @param event worker 通信事件
src/worker/common/channel.ts:134
Method
onmessageAsHealthHeartBeat
* 监听 worker 的 onmessage, 作为正常返回的心跳
src/worker/heart-beat-check.ts:95
Function
origin
()
test/any.ts:12
Function
raven
* 错误上报 * * @param error 报错信息
src/worker/external/report.ts:24
Method
raven
* 将 Worker 线程的 raven 发到主线程进行上报 * * @param payload raven 信息
src/worker/worker-thread/worker-report.ts:55
Method
reportActionHandlerError
(actionType: string, error: any)
src/worker/worker-thread/controller.ts:26
Method
reportActionHandlerError
(actionType: string, error: any)
src/worker/main-thread/controller.ts:48
Method
request
* 发送事务,不等待结果 * * @param actionType 事务类型 * @param payload 负载
src/worker/common/base-controller.ts:40
next →
1–100 of 107, ranked by callers