MCPcopy Create free account

hub / github.com/badoo/thunder / functions

Functions724 in github.com/badoo/thunder

⨍ Functions 724◇ Types & classes 128
↓ 52 callersMethodUnlock
()
go-proxyd/vhash/vhach.go:36
↓ 49 callersMethodLock
()
go-proxyd/vhash/vhach.go:32
↓ 29 callersMethodString
()
go-proxyd/proto/phproxyd.pb.go:194
↓ 25 callersMethodGetHash
()
go-proxyd/proto/phproxyd.pb.go:593
↓ 24 callersMethodExec
(queryTpl string, args ...interface{})
db/db.go:231
↓ 21 callersMethodString
()
proto/thunder.pb.go:122
↓ 15 callersMethodQuery
(queryTpl string, args ...interface{})
db/db.go:222
↓ 12 callersMethodString
()
proto/phproxyd/phproxyd.pb.go:176
↓ 12 callersFunctiongetNextLaunchTsForCron
(ts, now uint64, secRnd int, cron string)
jobgen/cron.go:21
↓ 10 callersFunctioncronFindClosestNext
(value int, options cronRange)
jobgen/cron.go:145
↓ 9 callersFunctiontrigger
trigger a channel. do not block if channel is already full
jobgen/dispatcher.go:766
↓ 8 callersMethodcall
(req proto.Message)
jobgen/launcher.go:103
↓ 8 callersMethodprintTrace
()
jobgen/dispatcher.go:457
↓ 7 callersMethodGet
(key uint64)
go-proxyd/vhash/vhach.go:40
↓ 7 callersFunctionconvertTsIntToString
(ts sql.NullInt64)
jobgen/launcher.go:569
↓ 7 callersMethodlogIncorrectFinish
(resp *badoo_phproxyd.ResponseCheck, row *RunQueueEntry, prevStatus string)
jobgen/launcher.go:633
↓ 6 callersFunctionDebugPrintln
(localPrefix, str string)
db/db.go:203
↓ 6 callersMethodString
()
jobgen/notifiers.go:293
↓ 6 callersFunctionpNullInt64
(arg sql.NullInt64)
jobgen/notifiers.go:285
↓ 5 callersMethodErrorGeneric
(args ...interface{})
go-proxyd/proto/phproxyd.gpbrpc.go:241
↓ 5 callersMethodGetScripts
()
go-proxyd/proto/phproxyd-config.pb.go:34
↓ 5 callersMethodGetStore
()
go-proxyd/proto/phproxyd.pb.go:621
↓ 5 callersMethodaddToWaiting
(row *TimetableEntry)
jobgen/dispatcher.go:494
↓ 5 callersFunctioncronMakeRange
** * Convert "1-23/4" to array(1 => true, 5 => true, 9 => true, 13 => true, 17 => true, 21 => true) * * @param $col string crontab column * @
jobgen/cron.go:244
↓ 5 callersMethodgetCache
(key uint64)
go-proxyd/sharded_cache.go:25
↓ 4 callersMethodGetErrorCode
()
proto/thunder.pb.go:144
↓ 4 callersFunctionStdoutFile
(store badoo_phproxyd.StoreT, id uint64)
go-proxyd/go-proto.go:35
↓ 4 callersFunctioncopyRunQueueMap
(m map[uint64]*RunQueueEntry)
jobgen/launcher.go:93
↓ 4 callersMethodgetMapByStatus
(status string)
jobgen/launcher.go:519
↓ 4 callersFunctionlauncherPrint
(w io.Writer, idRows map[uint64]*jobgen.RunQueueEntry, m []*jobgen.RunQueueEntry, status string)
web.go:103
↓ 4 callersFunctionloadNewIds
(newIds map[uint64]bool)
jobgen/model.go:869
↓ 4 callersFunctionnotifyAboutNewTTRows
location = DEFAULT_LOCATION_IDX for location_type=any and hostname for location_type=each
jobgen/notifiers.go:96
↓ 4 callersMethodremoveFromAdded
(row *TimetableEntry)
jobgen/dispatcher.go:478
↓ 4 callersFunctionsaveOffsets
()
logs-collector/logscol/collector.go:336
↓ 4 callersMethodterminate
(row *RunQueueEntry, action string)
jobgen/launcher.go:785
↓ 4 callersMethodupdateStatus
(row *RunQueueEntry, newStatus string)
jobgen/launcher.go:533
↓ 3 callersMethodBegin
()
db/db.go:155
↓ 3 callersMethodErrorAlreadyRunning
(args ...interface{})
go-proxyd/proto/phproxyd.gpbrpc.go:251
↓ 3 callersMethodErrorGeneric
(args ...interface{})
proto/thunder.gpbrpc.go:147
↓ 3 callersMethodErrorNotFound
(args ...interface{})
go-proxyd/proto/phproxyd.gpbrpc.go:256
↓ 3 callersFunctionExec
(queryTpl string, args ...interface{})
db/db.go:300
↓ 3 callersMethodGetClassName
()
proto/thunder.pb.go:397
↓ 3 callersMethodOK
(args ...interface{})
go-proxyd/proto/phproxyd.gpbrpc.go:233
↓ 3 callersMethodRollback
()
db/db.go:188
↓ 3 callersFunctionStderrFile
(store badoo_phproxyd.StoreT, id uint64)
go-proxyd/go-proto.go:42
↓ 3 callersFunctionTplQuery
(query string, args ...interface{})
db/db.go:275
↓ 3 callersMethodaddToAdded
(row *TimetableEntry)
jobgen/dispatcher.go:463
↓ 3 callersMethoddelFromMaps
(id uint64)
jobgen/launcher.go:473
↓ 3 callersFunctiondeleteFromRunQueue
(tx *db.LazyTrx, ids []uint64, prevStatus string)
jobgen/model.go:222
↓ 3 callersFunctiongetLocationIdx
(locationType string, location string)
jobgen/common.go:53
↓ 3 callersFunctiongetNextJobGenerateTs
(className string, firstRun bool, prevTs uint64, settings *ScriptSettings)
jobgen/common.go:26
↓ 3 callersMethodprocessFinished
process finished: 1. send an error to ev.errorCh, nil if all is ok 2. restore state upon failure
jobgen/dispatcher.go:310
↓ 3 callersMethodremoveFromWaiting
(row *TimetableEntry)
jobgen/dispatcher.go:509
↓ 3 callersFunctionscanRqEntry
(rows *sql.Rows)
jobgen/model.go:823
↓ 2 callersMethodCommit
()
db/db.go:160
↓ 2 callersMethodDelete
(key uint64)
go-proxyd/vhash/vhach.go:56
↓ 2 callersMethodEnum
()
proto/thunder.pb.go:117
↓ 2 callersMethodErrorRunFailed
(args ...interface{})
go-proxyd/proto/phproxyd.gpbrpc.go:246
↓ 2 callersFunctionEscapeString
grabbed from mymysql examples
db/db.go:62
↓ 2 callersMethodGetErrorText
()
proto/thunder.pb.go:151
↓ 2 callersMethodGetHostname
()
proto/thunder.pb.go:172
↓ 2 callersMethodGetLauncher
()
proto/thunder-config.pb.go:88
↓ 2 callersMethodGetPrevStatus
()
proto/thunder.pb.go:544
↓ 2 callersMethodGetRunId
()
proto/thunder.pb.go:537
↓ 2 callersMethodLen
Timetable Priority Queue:
jobgen/dispatcher.go:737
↓ 2 callersMethodRequestCheck
(rctx gpbrpc.RequestT, request *RequestCheck)
go-proxyd/proto/phproxyd.gpbrpc.go:183
↓ 2 callersMethodRequestFree
(rctx gpbrpc.RequestT, request *RequestFree)
go-proxyd/proto/phproxyd.gpbrpc.go:184
↓ 2 callersMethodRequestPing
(rctx gpbrpc.RequestT, request *RequestPing)
go-proxyd/proto/phproxyd.gpbrpc.go:180
↓ 2 callersMethodRequestRrd
(rctx gpbrpc.RequestT, request *RequestRrd)
go-proxyd/proto/phproxyd.gpbrpc.go:179
↓ 2 callersMethodRequestRun
(rctx gpbrpc.RequestT, request *RequestRun)
go-proxyd/proto/phproxyd.gpbrpc.go:182
↓ 2 callersMethodRequestTerminate
(rctx gpbrpc.RequestT, request *RequestTerminate)
go-proxyd/proto/phproxyd.gpbrpc.go:185
↓ 2 callersMethodString
()
logs-collector/common/lines.pb.go:32
↓ 2 callersMethodacceptNewJobs
(jobs []*TimetableEntry)
jobgen/dispatcher.go:524
↓ 2 callersMethodaddToMaps
(row *RunQueueEntry)
jobgen/launcher.go:493
↓ 2 callersFunctionaddToTimetable
method inserts rows into timetable and sets insert id
jobgen/model.go:759
↓ 2 callersMethodcheckZero
(src string)
jobgen/dispatcher.go:443
↓ 2 callersMethodconvertRunQueueEntryToFinishInfo
(row *RunQueueEntry)
jobgen/launcher.go:603
↓ 2 callersFunctioncronGetDays
** * Get array(day => true) of days that match supplied days_of_month or days_of_week for a given month and year * * @param $month * @param $year
jobgen/cron.go:171
↓ 2 callersFunctioncronNextLaunchTime
** * Compute next launch timestamp based on cron settings * * @param $minutes array 1. Range for minute column (e.g. self::_cronMakeRange
jobgen/cron.go:55
↓ 2 callersFunctiondieWithUsage
()
logs-collector/main.go:19
↓ 2 callersFunctiondoRotate
(filename string, ino uint64)
logs-collector/logscol/collector.go:248
↓ 2 callersFunctiongenerationFinished
** * Whether or not current generation has properly finished (with finish_jobs applied). * * If location_type is not 'any', then just isset($timeta
jobgen/model.go:491
↓ 2 callersFunctiongetFreeMem
(info *ServerInfo)
jobgen/common.go:22
↓ 2 callersFunctiongetLocations
(settings *ScriptSettings)
jobgen/servers.go:100
↓ 2 callersFunctiongetOrCreateDispatcherThread
(className, location string)
jobgen/notifiers.go:41
↓ 2 callersFunctiongetScriptPath
(settings *ScriptSettings)
jobgen/launcher.go:245
↓ 2 callersFunctionlogFailedLocation
(settings *ScriptSettings, location, failureReason string)
jobgen/servers.go:133
↓ 2 callersFunctionnotifyAboutNewRQRows
(hostname string, rqRows []*RunQueueEntry, allJobs bool)
jobgen/notifiers.go:143
↓ 2 callersFunctionnotifyForFullTTSelect
select everything from timetable, notify dispatcher threads and start them if needed
jobgen/notifiers.go:178
↓ 2 callersFunctionopenFile
(filename string)
logs-collector/logsproc/processor.go:94
↓ 2 callersFunctionpNullFloat64
(arg sql.NullFloat64)
jobgen/notifiers.go:277
↓ 2 callersMethodpersistFinishAndNotify
(row *RunQueueEntry, success bool, prevStatus string)
jobgen/launcher.go:577
↓ 2 callersMethodprepareFirstQuery
(queryTpl string, args ...interface{})
db/db.go:207
↓ 2 callersFunctionprepareNextGeneration
(tx *db.LazyTrx, have_finish_jobs bool, className string, settings *ScriptSettings)
jobgen/model.go:374
↓ 2 callersMethodprocessWaiting
()
jobgen/launcher.go:255
↓ 2 callersMethodredispatch
()
jobgen/dispatcher.go:579
↓ 2 callersFunctionscanTimetableEntry
(rows *sql.Rows)
jobgen/model.go:279
↓ 2 callersFunctionselectRQAndNotify
select everything from timetable, notify dispatcher threads and start them if needed
jobgen/notifiers.go:234
↓ 2 callersFunctionselectTimetable
()
jobgen/model.go:306
↓ 2 callersFunctionshouldHaveFinished
We set alarm on the end host so that we can be sure that script is dead after created + max_time
jobgen/launcher.go:469
next →1–100 of 724, ranked by callers