Functions — github.com/badoo/thunder

hub / github.com/badoo/thunder / functions

Functions724 in github.com/badoo/thunder

⨍ Functions 724◇ Types & classes 128

↓ 1 callersFunctionhandleConnection

(conn net.Conn)

logs-collector/logsproc/processor.go:71

↓ 1 callersMethodinit

()

jobgen/launcher.go:816

↓ 1 callersMethodinit

()

jobgen/dispatcher.go:721

↓ 1 callersFunctioninotifyEvSender

goroutine that starts to watch directory "sourceDir" and sends file names of changed files to "fsNotifyEvChan" chan

logs-collector/logscol/collector.go:66

↓ 1 callersFunctioninotifyRouter

()

logs-collector/logscol/collector.go:263

↓ 1 callersFunctionlauncherJobsDebugPage

(w io.Writer, hostname string)

web.go:127

↓ 1 callersFunctionloadFullState

(funcs ...*LoadStateFunc)

jobgen/jobgen.go:171

↓ 1 callersFunctionloadSettingsFromRows

(jiRows map[string]map[string]*JobInfoEntry, scripts map[string]*ScriptEntry)

jobgen/settings.go:48

↓ 1 callersFunctionlogTTFinish

(tx *db.LazyTrx, row *TimetableEntry, haveOldFinishCount bool, oldFinishCount uint)

jobgen/model.go:689

↓ 1 callersMethodmainThread

()

jobgen/launcher.go:183

↓ 1 callersFunctionmakeJobsList

(jobs Jobs, instanceCount int, className string)

jobgen/model.go:804

↓ 1 callersFunctionmemoryThresholdExceeded

(info *ServerInfo)

jobgen/servers.go:244

↓ 1 callersFunctionnewShardedCache

(shards int)

go-proxyd/sharded_cache.go:13

↓ 1 callersFunctionnotifyTTFinished

(className, location string, timetable_id, run_id uint64, success, deleteRq bool, prevStatus string)

jobgen/notifiers.go:79

↓ 1 callersFunctionoffsetsSaver

()

logs-collector/logscol/collector.go:366

↓ 1 callersFunctionparseJobs

(jobsStr string)

jobgen/common.go:65

↓ 1 callersFunctionparseNextTsCallback

(nextTsCallbackStr string)

jobgen/common.go:70

↓ 1 callersMethodprocessAllJobs

(jobs []*TimetableEntry)

jobgen/dispatcher.go:253

↓ 1 callersMethodprocessAllRows

(rows []*RunQueueEntry)

jobgen/launcher.go:401

↓ 1 callersMethodprocessDebugEvent

(ev *LauncherDebugPrintRequest)

jobgen/launcher.go:143

↓ 1 callersMethodprocessDebugEvent

(ev *DebugPrintRequest)

jobgen/dispatcher.go:212

↓ 1 callersMethodprocessFinished

()

jobgen/launcher.go:437

↓ 1 callersMethodprocessLogFinishRequest

(req *LauncherLogFinishRequest)

jobgen/launcher.go:370

↓ 1 callersMethodprocessNewJobsEv

(ev *NewJobs)

jobgen/dispatcher.go:181

↓ 1 callersMethodprocessRunningTooLong

()

jobgen/launcher.go:745

↓ 1 callersMethodprocessUpdateStatusRequest

(req *LauncherUpdateStatusRequest)

jobgen/launcher.go:342

↓ 1 callersFunctionprocessWait

(p *vproc.Vproc)

go-proxyd/go-proto.go:183

↓ 1 callersMethodprocessWaitingInInit

()

jobgen/launcher.go:686

↓ 1 callersFunctionrequestRotate

(filename string)

logs-collector/logscol/collector.go:190

↓ 1 callersFunctionresetRunRequest

(tx *db.LazyTrx, className string)

jobgen/model.go:748

↓ 1 callersFunctionrunqueuePeriodicSelectThread

()

jobgen/notifiers.go:165

↓ 1 callersFunctionselectHostname

(location, locationType string, cpuUsage float64, maxMemory int64)

jobgen/servers.go:152

↓ 1 callersFunctionselectTimetableByIds

(ids []uint64)

jobgen/model.go:337

↓ 1 callersFunctionsendChanges

(filename string, r *bufio.Reader, ino uint64, offset *int64)

logs-collector/logscol/collector.go:157

↓ 1 callersFunctionsetFinishJobsTs

(tx *db.LazyTrx, className string, locations []string)

jobgen/model.go:542

↓ 1 callersFunctionsetInitJobsTs

(tx *db.LazyTrx, className string, locations []string)

jobgen/model.go:554

↓ 1 callersFunctionsetJobsGeneratedTs

(tx *db.LazyTrx, className string, locations []string)

jobgen/model.go:566

↓ 1 callersFunctionsetKilledFlag

(tx *db.LazyTrx, className string)

jobgen/model.go:360

↓ 1 callersFunctionsetMaxFinishedTs

(tx *db.LazyTrx, className string, employeeId int64, ts int64)

jobgen/model.go:451

↓ 1 callersFunctionsetNextGenerateJobTs

(tx *db.LazyTrx, className string, settings *ScriptSettings)

jobgen/model.go:440

↓ 1 callersFunctionsetPausedFlag

(tx *db.LazyTrx, className string)

jobgen/model.go:367

↓ 1 callersFunctionsetRunAccepted

(tx *db.LazyTrx, className string)

jobgen/model.go:753

↓ 1 callersFunctionsetRunStatusToInit

(tx *db.LazyTrx, run_id uint64, max_time int)

jobgen/model.go:267

↓ 1 callersFunctionsetupAndCheckMysql

()

thunder.go:72

↓ 1 callersFunctionstartKilling

(className string)

jobgen/killer.go:15

↓ 1 callersFunctionstreamLogs

(filename string, chEvs chan bool, rotEvs chan *rotateEvent)

logs-collector/logscol/collector.go:89

↓ 1 callersFunctionthrottleThread

()

jobgen/jobgen.go:672

↓ 1 callersFunctionupdateHostsThread

()

jobgen/servers.go:93

↓ 1 callersMethodupdateInplace

(element *Item, value Value)

go-proxyd/vhash/vhach.go:74

↓ 1 callersFunctionupdateLoadEstimates

assumes that rusageInfo.Lock() is held

jobgen/servers.go:367

↓ 1 callersFunctionupdateRunStatus

(tx *db.LazyTrx, run_id uint64, status, prevStatus string)

jobgen/model.go:244

↓ 1 callersFunctionwriteLines

(ln *common.LogLines)

logs-collector/logsproc/processor.go:150

↓ 1 callersFunctionwriteThread

(filename string, ch chan *msg)

logs-collector/logsproc/processor.go:105

FunctionAPIAcceptTTJobs

(jobs []*thunder.RequestAddJobsJobT)

jobgen/api.go:14

FunctionAPILogFinish

string is json-encode'd run queue entry row

jobgen/api.go:190

FunctionAPIUpdateRunStatus

(hostname string, runId uint64, prevStatus, status string)

jobgen/api.go:170

MethodClear

()

go-proxyd/vhash/vhach.go:67

MethodDelete

(key uint64)

go-proxyd/sharded_cache.go:40

MethodDispatch

(rctx gpbrpc.RequestT, abstract_service interface{})

proto/thunder.gpbrpc.go:118

MethodDispatch

(rctx gpbrpc.RequestT, abstract_service interface{})

proto/phproxyd/phproxyd.gpbrpc.go:158

MethodDispatch

(rctx gpbrpc.RequestT, abstract_service interface{})

go-proxyd/proto/phproxyd.gpbrpc.go:191

FunctionDoInLazyTransaction

(cb func(tx *LazyTrx) error)

db/db.go:121

MethodEnum

()

proto/thunder.pb.go:51

MethodEnum

()

proto/thunder.pb.go:87

MethodEnum

()

proto/phproxyd/phproxyd.pb.go:69

MethodEnum

()

proto/phproxyd/phproxyd.pb.go:111

MethodEnum

()

proto/phproxyd/phproxyd.pb.go:171

MethodEnum

()

proto/phproxyd/phproxyd.pb.go:204

MethodEnum

()

proto/phproxyd/phproxyd.pb.go:237

MethodEnum

()

go-proxyd/proto/phproxyd.pb.go:84

MethodEnum

()

go-proxyd/proto/phproxyd.pb.go:132

MethodEnum

()

go-proxyd/proto/phproxyd.pb.go:189

MethodEnum

()

go-proxyd/proto/phproxyd.pb.go:222

MethodEnum

()

go-proxyd/proto/phproxyd.pb.go:255

MethodErrorAlreadyRunning

(args ...interface{})

proto/phproxyd/phproxyd.gpbrpc.go:209

MethodErrorFailedFinished

(args ...interface{})

proto/phproxyd/phproxyd.gpbrpc.go:234

MethodErrorFailedFinished

(args ...interface{})

go-proxyd/proto/phproxyd.gpbrpc.go:276

MethodErrorGeneric

(args ...interface{})

proto/phproxyd/phproxyd.gpbrpc.go:199

MethodErrorNoMemory

(args ...interface{})

proto/phproxyd/phproxyd.gpbrpc.go:224

MethodErrorNoMemory

(args ...interface{})

go-proxyd/proto/phproxyd.gpbrpc.go:266

MethodErrorNotFound

(args ...interface{})

proto/phproxyd/phproxyd.gpbrpc.go:214

MethodErrorRunFailed

(args ...interface{})

proto/phproxyd/phproxyd.gpbrpc.go:204

MethodErrorStartChildFailed

(args ...interface{})

proto/phproxyd/phproxyd.gpbrpc.go:244

MethodErrorStartChildFailed

(args ...interface{})

go-proxyd/proto/phproxyd.gpbrpc.go:286

MethodErrorSuccessFinished

(args ...interface{})

proto/phproxyd/phproxyd.gpbrpc.go:229

MethodErrorSuccessFinished

(args ...interface{})

go-proxyd/proto/phproxyd.gpbrpc.go:271

MethodErrorTooBusy

(args ...interface{})

proto/phproxyd/phproxyd.gpbrpc.go:249

MethodErrorWaitForFree

(args ...interface{})

proto/phproxyd/phproxyd.gpbrpc.go:239

MethodErrorWaitForFree

(args ...interface{})

go-proxyd/proto/phproxyd.gpbrpc.go:281

MethodErrorWorking

(args ...interface{})

proto/phproxyd/phproxyd.gpbrpc.go:219

MethodErrorWorking

(args ...interface{})

go-proxyd/proto/phproxyd.gpbrpc.go:261

FunctionGenerateJobsCycle

go-proxyd/sharded_cache.go:29

MethodGetBaseDir

()

proto/thunder-config.pb.go:211

MethodGetBuffers

()

proto/thunder.pb.go:314

MethodGetCached

()

proto/thunder.pb.go:307

MethodGetClean

()

proto/phproxyd/phproxyd.pb.go:375

MethodGetClean

()

go-proxyd/proto/phproxyd.pb.go:393

MethodGetCommandsCnt

()

proto/phproxyd/phproxyd.pb.go:458

MethodGetCommandsCnt

()

proto/phproxyd/phproxyd.pb.go:539

← previous next →201–300 of 724, ranked by callers