MCPcopy Create free account

hub / github.com/badoo/thunder / functions

Functions724 in github.com/badoo/thunder

⨍ Functions 724◇ Types & classes 128
↓ 2 callersFunctionupdateHosts
()
jobgen/servers.go:78
↓ 1 callersMethodAddCommitCallback
(cb func())
db/db.go:151
↓ 1 callersFunctionDoInLazyTransactionWithTrx
(cb func(tx *LazyTrx) error, trx *LazyTrx)
db/db.go:125
↓ 1 callersMethodGetCycleMs
()
proto/thunder-config.pb.go:74
↓ 1 callersMethodGetDefault
()
proto/thunder-config.pb.go:67
↓ 1 callersMethodGetDsn
()
proto/thunder-config.pb.go:112
↓ 1 callersMethodGetFileStderrTemplate
()
go-proxyd/proto/phproxyd-config.pb.go:76
↓ 1 callersMethodGetFileStdoutTemplate
()
go-proxyd/proto/phproxyd-config.pb.go:69
↓ 1 callersMethodGetForce
()
go-proxyd/proto/phproxyd.pb.go:607
↓ 1 callersMethodGetFullTimetableReloadIntervalMs
()
proto/thunder-config.pb.go:81
↓ 1 callersMethodGetGenerationId
()
proto/thunder.pb.go:390
↓ 1 callersMethodGetHostSuffix
()
proto/thunder-config.pb.go:204
↓ 1 callersMethodGetIsDevel
()
proto/thunder-config.pb.go:95
↓ 1 callersMethodGetJobData
()
proto/thunder.pb.go:404
↓ 1 callersMethodGetLocation
()
proto/thunder.pb.go:418
↓ 1 callersMethodGetMaxConnections
()
proto/thunder-config.pb.go:119
↓ 1 callersMethodGetMaxMemory
()
proto/thunder-config.pb.go:178
↓ 1 callersMethodGetMaxrss
()
proto/phproxyd/phproxyd.pb.go:746
↓ 1 callersMethodGetMemStderrTemplate
()
go-proxyd/proto/phproxyd-config.pb.go:90
↓ 1 callersMethodGetMemStdoutTemplate
()
go-proxyd/proto/phproxyd-config.pb.go:83
↓ 1 callersMethodGetMethod
()
proto/thunder.pb.go:411
↓ 1 callersMethodGetMinIdleCpu
()
proto/thunder-config.pb.go:171
↓ 1 callersMethodGetMinMemory
()
proto/thunder-config.pb.go:157
↓ 1 callersMethodGetMinMemoryRatio
()
proto/thunder-config.pb.go:164
↓ 1 callersMethodGetMysql
()
proto/thunder-config.pb.go:46
↓ 1 callersMethodGetNextLaunchTs
()
proto/thunder.pb.go:425
↓ 1 callersMethodGetParams
()
go-proxyd/proto/phproxyd.pb.go:614
↓ 1 callersMethodGetParasiteMemory
()
proto/thunder-config.pb.go:150
↓ 1 callersMethodGetPhpBin
()
go-proxyd/proto/phproxyd-config.pb.go:55
↓ 1 callersMethodGetRqhLogFile
()
proto/thunder-config.pb.go:225
↓ 1 callersMethodGetRusage
()
proto/thunder-config.pb.go:185
↓ 1 callersMethodGetScript
()
go-proxyd/proto/phproxyd.pb.go:586
↓ 1 callersMethodGetSettingsId
()
proto/thunder.pb.go:439
↓ 1 callersMethodGetStatus
()
proto/thunder.pb.go:511
↓ 1 callersMethodGetStimeTvSec
()
proto/phproxyd/phproxyd.pb.go:444
↓ 1 callersMethodGetStimeTvUsec
()
proto/phproxyd/phproxyd.pb.go:451
↓ 1 callersMethodGetSuccess
()
proto/thunder.pb.go:551
↓ 1 callersMethodGetUtimeTvSec
()
proto/phproxyd/phproxyd.pb.go:430
↓ 1 callersMethodGetUtimeTvUsec
()
proto/phproxyd/phproxyd.pb.go:437
↓ 1 callersMethodGetValue
()
proto/thunder.pb.go:455
↓ 1 callersMethodKill
()
go-proxyd/vproc/vproc.go:61
↓ 1 callersMethodOK
(args ...interface{})
proto/thunder.gpbrpc.go:139
↓ 1 callersMethodPop
()
jobgen/dispatcher.go:756
↓ 1 callersMethodPush
(x interface{})
jobgen/dispatcher.go:749
↓ 1 callersFunctionReceiveMessage
(c io.Reader)
logs-collector/common/protocol.go:38
↓ 1 callersMethodRequestAddJobs
(rctx gpbrpc.RequestT, request *RequestAddJobs)
proto/thunder.gpbrpc.go:113
↓ 1 callersMethodRequestLogFinish
(rctx gpbrpc.RequestT, request *RequestLogFinish)
proto/thunder.gpbrpc.go:115
↓ 1 callersMethodRequestSoftCheck
(rctx gpbrpc.RequestT, request *RequestSoftCheck)
go-proxyd/proto/phproxyd.gpbrpc.go:187
↓ 1 callersMethodRequestSoftFree
(rctx gpbrpc.RequestT, request *RequestSoftFree)
go-proxyd/proto/phproxyd.gpbrpc.go:188
↓ 1 callersMethodRequestSoftRun
(rctx gpbrpc.RequestT, request *RequestSoftRun)
go-proxyd/proto/phproxyd.gpbrpc.go:186
↓ 1 callersMethodRequestStat
(rctx gpbrpc.RequestT, request *RequestStat)
proto/phproxyd/phproxyd.gpbrpc.go:151
↓ 1 callersMethodRequestStats
(rctx gpbrpc.RequestT, request *RequestStats)
go-proxyd/proto/phproxyd.gpbrpc.go:181
↓ 1 callersMethodRequestUpdateStatus
(rctx gpbrpc.RequestT, request *RequestUpdateStatus)
proto/thunder.gpbrpc.go:114
↓ 1 callersFunctionSelectRunQueue
()
jobgen/model.go:850
↓ 1 callersFunctionSendMessage
(c io.Writer, ln *LogLines)
logs-collector/common/protocol.go:10
↓ 1 callersMethodSet
(key uint64, value Value)
go-proxyd/vhash/vhach.go:48
↓ 1 callersMethodStart
()
go-proxyd/vproc/vproc.go:43
↓ 1 callersMethodWait
()
go-proxyd/vproc/vproc.go:52
↓ 1 callersMethodacceptWaiting
(jobs []*RunQueueEntry)
jobgen/launcher.go:113
↓ 1 callersFunctionaddJobInfo
(tx *db.LazyTrx, rows []*JobInfoEntry)
jobgen/model.go:521
↓ 1 callersMethodaddNew
(key uint64, value Value)
go-proxyd/vhash/vhach.go:78
↓ 1 callersFunctionaddToQueueAndDeleteExpired
(tx *db.LazyTrx, rows []*RunQueueEntry, toDelete []*TimetableEntry)
jobgen/model.go:578
↓ 1 callersFunctionbatchPrepareNextGeneration
(tx *db.LazyTrx, have_finish_jobs bool, className string, params []NextGenParams, settings *ScriptSettings)
jobgen/model.go:393
↓ 1 callersFunctionbatchSetNextGenerateJobTs
(tx *db.LazyTrx, className string, params []NextGenParams, settings *ScriptSettings)
jobgen/model.go:411
↓ 1 callersMethodcheckDeleted
()
jobgen/dispatcher.go:149
↓ 1 callersFunctioncheckSelect42
()
thunder.go:49
↓ 1 callersFunctionclearJobsResults
(tx *db.LazyTrx, className string)
jobgen/model.go:460
↓ 1 callersFunctionclearJobsResultsForLocations
(tx *db.LazyTrx, className string, locations []string)
jobgen/model.go:467
↓ 1 callersFunctionclearOldHeartbeats
()
jobgen/model.go:1130
↓ 1 callersFunctioncollectInitial
()
logs-collector/logscol/collector.go:406
↓ 1 callersFunctioncontinueDispatchAfterKill
(className string)
jobgen/killer.go:52
↓ 1 callersFunctioncopyTTEntries
(entries []*TimetableEntry)
jobgen/dispatcher.go:88
↓ 1 callersFunctioncopyTTEntriesMap
(entries map[uint64]*TimetableEntry)
jobgen/dispatcher.go:100
↓ 1 callersMethodcycle
()
jobgen/launcher.go:221
↓ 1 callersFunctiondeleteAddedFromTimetable
(tx *db.LazyTrx, ids []uint64)
jobgen/model.go:729
↓ 1 callersMethoddispatchThread
()
jobgen/dispatcher.go:112
↓ 1 callersFunctiondoCycle
()
jobgen/jobgen.go:427
↓ 1 callersFunctionforceCheckDeletedThread
()
jobgen/notifiers.go:13
↓ 1 callersFunctiongenerateJobs
haveTTRows must be nil if there are no timetable entries for any location otherwise it must have only true entries like map["location"] => true probab
jobgen/jobgen.go:190
↓ 1 callersFunctiongetAllInodes
(dir string)
logs-collector/logscol/collector.go:379
↓ 1 callersFunctiongetAutoIncrementIncrement
()
jobgen/jobgen.go:648
↓ 1 callersFunctiongetAvailableHosts
()
jobgen/model.go:1089
↓ 1 callersFunctiongetDispatcherDebugCh
(className, location string)
jobgen/notifiers.go:410
↓ 1 callersFunctiongetDispatcherJobsCountCh
(className, location string)
jobgen/notifiers.go:427
↓ 1 callersFunctiongetExistingTTIds
get existing ids from db for provided checkIds list
jobgen/model.go:662
↓ 1 callersFunctiongetFlags
()
jobgen/model.go:1012
↓ 1 callersFunctiongetGroupedJobInfo
return map[location][class_name]*JobInfoEntry
jobgen/model.go:978
↓ 1 callersFunctiongetGroupedScriptsForPlatform
()
jobgen/model.go:953
↓ 1 callersFunctiongetHostnameIdx
(hostname string)
jobgen/dispatcher.go:549
↓ 1 callersFunctiongetLauncherDebugCh
(hostname string)
jobgen/notifiers.go:444
↓ 1 callersFunctiongetLauncherLogFinishCh
(hostname string)
jobgen/notifiers.go:468
↓ 1 callersFunctiongetLauncherUpdateStatusCh
(hostname string)
jobgen/notifiers.go:456
↓ 1 callersFunctiongetLockName
()
jobgen/model.go:275
↓ 1 callersFunctiongetOrCreateLauncherThread
(hostname string)
jobgen/notifiers.go:118
↓ 1 callersFunctiongetParasiteMemory
(info *ServerInfo)
jobgen/common.go:14
↓ 1 callersFunctiongetRunningInfo
(run_id uint64)
jobgen/model.go:178
↓ 1 callersFunctiongetRunningInfos
(run_ids []uint64)
jobgen/model.go:198
↓ 1 callersFunctiongetScriptRusageStats
()
jobgen/model.go:1043
↓ 1 callersFunctiongetScriptSettings
(className string)
jobgen/settings.go:87
↓ 1 callersFunctiongetWaitingRQLen
(hostname string)
jobgen/notifiers.go:266
← previousnext →101–200 of 724, ranked by callers