Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/btccom/btcpool-go-modules-ABANDONED
/ functions
Functions
232 in github.com/btccom/btcpool-go-modules-ABANDONED
⨍
Functions
232
◇
Types & classes
84
↓ 69 callers
Method
Error
Error 实现StratumError的Error()接口以便其被当做error类型使用
stratumSwitcher/Errors.go:23
↓ 28 callers
Function
writeError
(w http.ResponseWriter, errNo int, errMsg string)
userChainAPIServer/switcherAPIServer/HTTPAPI.go:404
↓ 21 callers
Method
Error
()
userChainAPIServer/switcherAPIServer/APIError.go:20
↓ 19 callers
Function
notNullTrim
($envName)
install/cfg-generator/lib/functions.php:28
↓ 15 callers
Method
AllocSessionID
AllocSessionID 为调用者分配一个会话ID
stratumSwitcher/SessionIDManager.go:85
↓ 13 callers
Method
FreeSessionID
FreeSessionID 释放调用者持有的会话ID
stratumSwitcher/SessionIDManager.go:136
↓ 11 callers
Method
Create
Create 创建Zookeeper节点
stratumSwitcher/ZookeeperManager.go:156
↓ 11 callers
Method
Stop
Stop 停止一个 Stratum 会话
stratumSwitcher/StratumSession.go:316
↓ 11 callers
Function
optionalTrim
($envName, $defaultValue = '')
install/cfg-generator/lib/functions.php:49
↓ 10 callers
Function
fatal
($msg)
install/cfg-generator/lib/functions.php:8
↓ 9 callers
Method
Error
()
userChainAPIServer/initUserCoin/APIError.go:20
↓ 9 callers
Function
NewStratumError
NewStratumError 新建一个StratumError
stratumSwitcher/Errors.go:14
↓ 7 callers
Function
NewAPIError
NewAPIError 新建一个APIError
userChainAPIServer/switcherAPIServer/APIError.go:12
↓ 7 callers
Function
NewAPIError
NewAPIError 新建一个APIError
userChainAPIServer/initUserCoin/APIError.go:12
↓ 7 callers
Function
basicAuth
basicAuth 执行Basic认证
userChainAPIServer/switcherAPIServer/HTTPAPI.go:102
↓ 5 callers
Function
Uint32ToHex
Uint32ToHex unit32 转 hex
stratumSwitcher/Utils.go:36
↓ 5 callers
Function
errPuts
($msg)
install/cfg-generator/lib/functions.php:4
↓ 5 callers
Function
formatHashrate
(hashrate float64)
chainSwitcher/utils.go:40
↓ 5 callers
Method
writeJSONResponseToClient
(jsonData *JSONRPCResponse)
stratumSwitcher/StratumSession.go:1583
↓ 4 callers
Method
GetW
GetW 获取Zookeeper节点的值并设置监控
stratumSwitcher/ZookeeperManager.go:121
↓ 4 callers
Function
ParseAuxPowData
ParseAuxPowData 解析辅助工作量数据 * <https://en.bitcoin.it/wiki/Merged_mining_specification#Aux_proof-of-work_block> ? coinbase_txn txn
mergedMiningProxy/AuxPowData.go:40
↓ 4 callers
Method
ToJSONRPCArray
ToJSONRPCArray 转换为JSONRPCArray
stratumSwitcher/Errors.go:28
↓ 4 callers
Method
getReconnectCounter
getReconnectCounter 获取币种切换计数(线程安全)
stratumSwitcher/StratumSession.go:217
↓ 4 callers
Method
getVersionMaskStr
()
stratumSwitcher/StratumSession.go:1605
↓ 4 callers
Function
isTrue
($envName)
install/cfg-generator/lib/functions.php:60
↓ 4 callers
Function
writeError
writeError 输出JSON-RPC格式的错误信息
mergedMiningProxy/ProxyRPC.go:36
↓ 3 callers
Function
NewSessionIDManager
NewSessionIDManager 创建一个会话ID管理器实例
stratumSwitcher/SessionIDManager.go:38
↓ 3 callers
Function
ParseRPCResponse
ParseRPCResponse 将RPC响应的JSON字节数组转换为RPCResponse结构体
mergedMiningProxy/RPCCall.go:82
↓ 3 callers
Function
RPCCall
RPCCall 调用RPC方法
mergedMiningProxy/RPCCall.go:39
↓ 3 callers
Method
SetParam
SetParam 设置 JSONRPCRequest 对象的参数 传递给 SetParam 的参数列表将按顺序复制到 JSONRPCRequest.Params 中
stratumSwitcher/JSONRPC.go:91
↓ 3 callers
Function
TargetToBits
TargetToBits 将target的完整形式转换为压缩形式(bits)
mergedMiningProxy/Utils.go:94
↓ 3 callers
Method
ToHex
ToHex 把AuxPowData转换为十六进制字符串
mergedMiningProxy/AuxPowData.go:199
↓ 3 callers
Method
ToJSONBytes
ToJSONBytes 将 JSONRPCRequest 对象转换为 JSON 字节序列
stratumSwitcher/JSONRPC.go:96
↓ 3 callers
Function
changeMiningCoin
(puname string, coin string)
userChainAPIServer/switcherAPIServer/HTTPAPI.go:411
↓ 3 callers
Function
commaSplitTrim
($envName)
install/cfg-generator/lib/functions.php:89
↓ 3 callers
Function
createZookeeperPath
递归创建Zookeeper Node
userChainAPIServer/initUserCoin/Zookeeper.go:11
↓ 3 callers
Method
findMiningCoin
(autoReg bool)
stratumSwitcher/StratumSession.go:700
↓ 3 callers
Method
proxyStratum
()
stratumSwitcher/StratumSession.go:1212
↓ 3 callers
Function
sendCurrentChainToKafka
()
chainSwitcher/main.go:272
↓ 3 callers
Method
setStatNonLock
setStatNonLock 设置会话状态(
stratumSwitcher/StratumSession.go:199
↓ 3 callers
Method
stratumHandleRequest
(request *JSONRPCRequest, stat *AuthorizeStat)
stratumSwitcher/StratumSession.go:587
↓ 3 callers
Function
toJSON
($obj)
install/cfg-generator/lib/functions.php:81
↓ 3 callers
Method
tryStop
检查是否发生了重连,若未发生重连,则停止会话
stratumSwitcher/StratumSession.go:1359
↓ 3 callers
Method
writeJSONRequestToServer
(jsonData *JSONRPCRequest)
stratumSwitcher/StratumSession.go:1594
↓ 2 callers
Function
BitsToTarget
BitsToTarget 将target的压缩形式(bits)转换为完整形式
mergedMiningProxy/Utils.go:81
↓ 2 callers
Function
FilterWorkerName
FilterWorkerName 过滤矿工名
stratumSwitcher/Utils.go:131
↓ 2 callers
Method
GetRegularSubaccountName
GetRegularSubaccountName 获取规范化的(大小写敏感的)子账户名
stratumSwitcher/StratumSessionManager.go:333
↓ 2 callers
Function
HashSHA256
(input []byte)
mergedMiningProxy/LitecoinScrypt.go:10
↓ 2 callers
Function
IOCopyBuffer
IOCopyBuffer 在写入失败时还能拿到Buffer的IO拷贝函数
stratumSwitcher/Utils.go:82
↓ 2 callers
Function
IP2Long
IP2Long IP转整数 来自 <https://www.socketloop.com/tutorials/golang-convert-ip-address-string-to-long-unsigned-32-bit-integer>
stratumSwitcher/Utils.go:16
↓ 2 callers
Function
NewJSONRPCRequest
NewJSONRPCRequest 解析 JSON RPC 请求字符串并创建 JSONRPCRequest 对象
stratumSwitcher/JSONRPC.go:76
↓ 2 callers
Function
NewStratumSession
NewStratumSession 创建一个新的 Stratum 会话
stratumSwitcher/StratumSession.go:149
↓ 2 callers
Method
ReleaseW
ReleaseW 释放监控
stratumSwitcher/ZookeeperManager.go:162
↓ 2 callers
Function
Uint32ToHexLE
Uint32ToHexLE unit32 转 hex (小端字节序)
stratumSwitcher/Utils.go:43
↓ 2 callers
Method
connectStratumServer
()
stratumSwitcher/StratumSession.go:773
↓ 2 callers
Method
createAuxBlock
(response *RPCResponse)
mergedMiningProxy/ProxyRPC.go:144
↓ 2 callers
Function
fcntl
Zero Downtime upgrades of TCP servers in Go <http://blog.nella.org/?p=879> These are here because there is no API in syscall for turning OFF close-on-
stratumSwitcher/Utils_linux.go:23
↓ 2 callers
Function
getConnFd
(conn net.Conn)
stratumSwitcher/Utils_linux.go:58
↓ 2 callers
Method
getDefaultStratumProtocol
()
stratumSwitcher/StratumSession.go:369
↓ 2 callers
Method
getStat
getStat 获取会话状态(线程安全)
stratumSwitcher/StratumSession.go:204
↓ 2 callers
Method
isFullWithoutLock
isFull 判断会话ID是否已满(内部使用,不加锁)
stratumSwitcher/SessionIDManager.go:72
↓ 2 callers
Function
newConnFromFd
(fd uintptr)
stratumSwitcher/Utils_linux.go:88
↓ 2 callers
Function
outputConfigJSON
($json, $fileName = 'config.json')
install/cfg-generator/lib/functions.php:97
↓ 2 callers
Function
peekWithTimeout
(reader *bufio.Reader, len int, timeout time.Duration)
stratumSwitcher/StratumSession.go:1491
↓ 2 callers
Function
readByteWithTimeout
(reader *bufio.Reader, buffer []byte, timeout time.Duration)
stratumSwitcher/StratumSession.go:1518
↓ 2 callers
Function
readLineWithTimeout
(reader *bufio.Reader, timeout time.Duration)
stratumSwitcher/StratumSession.go:1537
↓ 2 callers
Method
reconnectStratumServer
reconnectStratumServer 重连服务器
stratumSwitcher/StratumSession.go:1436
↓ 2 callers
Method
sendMiningAuthorizeToServer
发送 mining.subscribe
stratumSwitcher/StratumSession.go:914
↓ 2 callers
Function
setCloseOnExec
(fd uintptr)
stratumSwitcher/Utils_linux.go:32
↓ 2 callers
Function
setMiningCoin
(puname string, coin string)
userChainAPIServer/initUserCoin/InitUserCoin.go:124
↓ 2 callers
Function
setNoCloseOnExec
(fd uintptr)
stratumSwitcher/Utils_linux.go:37
↓ 2 callers
Method
submitAuxBlock
(params []interface{}, response *RPCResponse)
mergedMiningProxy/ProxyRPC.go:175
↓ 2 callers
Method
tryReconnect
检查是否发生了重连,若未发生重连,则尝试重连
stratumSwitcher/StratumSession.go:1380
↓ 2 callers
Method
updateAuxBlock
updateAuxBlock 更新辅助区块
mergedMiningProxy/AuxJobMaker.go:129
↓ 2 callers
Function
write
write 输出JSON-RPC格式的信息
mergedMiningProxy/ProxyRPC.go:30
↓ 2 callers
Function
writeSuccess
(w http.ResponseWriter)
userChainAPIServer/switcherAPIServer/HTTPAPI.go:397
↓ 1 callers
Function
ArrayReverse
(input []byte)
mergedMiningProxy/LitecoinScrypt.go:28
↓ 1 callers
Method
AssignServerIDFromZK
AssignServerIDFromZK 从Zookeeper分配服务器ID
stratumSwitcher/StratumSessionManager.go:133
↓ 1 callers
Function
BigToCompact
BigToCompact 将大整数转换为target的压缩形式(bits) 拷贝自 <https://github.com/elastos/Elastos.ELA/blob/28be25a43f3befaa8bc7d7b77f8dfa8b48d43970/blockchain/difficulty.
mergedMiningProxy/Utils.go:42
↓ 1 callers
Method
Check
Check 检查配置的合法性
mergedMiningProxy/ConfigData.go:94
↓ 1 callers
Function
CompactToBig
CompactToBig 将target的压缩形式(bits)转换为大整数 拷贝自 <https://github.com/elastos/Elastos.ELA/blob/28be25a43f3befaa8bc7d7b77f8dfa8b48d43970/blockchain/blockchain.
mergedMiningProxy/Utils.go:12
↓ 1 callers
Function
DeepCopy
DeepCopy 深度拷贝map和切片 来自:https://studygolang.com/articles/8036
mergedMiningProxy/Utils.go:107
↓ 1 callers
Function
DoubleSHA256
(input []byte)
mergedMiningProxy/LitecoinScrypt.go:16
↓ 1 callers
Method
ExpandingBlockchainBranch
ExpandingBlockchainBranch 将特定币种的MerkleBranch添加到AuxPowData.blockchainBranch
mergedMiningProxy/AuxPowData.go:148
↓ 1 callers
Method
FindAuxJob
FindAuxJob 查找辅助挖矿任务
mergedMiningProxy/AuxJobMaker.go:120
↓ 1 callers
Method
GetAuxJob
GetAuxJob 获取辅助挖矿任务
mergedMiningProxy/AuxJobMaker.go:90
↓ 1 callers
Function
HTTPPost
HTTPPost 调用HTTP Post方法
userChainAPIServer/initUserCoin/UserAutoReg.go:100
↓ 1 callers
Function
HexToString
(input []byte)
mergedMiningProxy/LitecoinScrypt.go:24
↓ 1 callers
Method
InitDB
(conf DBConnectionInfo)
mergedMiningProxy/DbConnection.go:25
↓ 1 callers
Function
InitUserCoin
InitUserCoin 拉取用户id列表来初始化用户币种记录
userChainAPIServer/initUserCoin/InitUserCoin.go:35
↓ 1 callers
Method
InsertAuxBlock
(blockinfo SubmitAuxBlockInfo)
mergedMiningProxy/DbConnection.go:49
↓ 1 callers
Method
IsRunning
IsRunning 检查会话是否在运行(线程安全)
stratumSwitcher/StratumSession.go:184
↓ 1 callers
Method
LoadFromFile
LoadFromFile 从文件载入配置
stratumSwitcher/ConfigData.go:59
↓ 1 callers
Method
LoadFromFile
LoadFromFile 从文件载入配置
stratumSwitcher/ConfigData.go:135
↓ 1 callers
Method
LoadFromFile
LoadFromFile 从文件载入配置
mergedMiningProxy/ConfigData.go:171
↓ 1 callers
Function
NewAuxJobMaker
NewAuxJobMaker 创建辅助挖矿任务构造器
mergedMiningProxy/AuxJobMaker.go:63
↓ 1 callers
Function
NewJSONRPC2Error
NewJSONRPC2Error create json-rpc 2.0 error object from json-1.0 error object
stratumSwitcher/JSONRPC.go:32
↓ 1 callers
Function
NewJSONRPCResponse
NewJSONRPCResponse 解析 JSON RPC 响应字符串并创建 JSONRPCResponse 对象
stratumSwitcher/JSONRPC.go:101
↓ 1 callers
Function
NewNodeWatcher
NewNodeWatcher 新建节点监控器
stratumSwitcher/ZookeeperManager.go:37
↓ 1 callers
Function
NewProxyRPCHandle
NewProxyRPCHandle 创建代理RPC处理器
mergedMiningProxy/ProxyRPC.go:50
next →
1–100 of 232, ranked by callers