MCPcopy Create free account

hub / github.com/jpillora/overseer / functions

Functions116 in github.com/jpillora/overseer

↓ 19 callersMethoddebugf
(f string, args ...interface{})
proc_master.go:641
↓ 17 callersMethodClose
()
graceful.go:94
↓ 14 callersMethodwarnf
(f string, args ...interface{})
proc_master.go:653
↓ 12 callersMethodtryRestart
tryRestart is the auto-restart path invoked from the fetch loop; it consults Config.ShouldRestart and defers if the predicate returns false.
proc_master.go:380
↓ 9 callersMethodinfo
info backs the exported MasterInfo() function.
proc_master.go:400
↓ 8 callersFunctionScan
Scan returns a goroutine snapshot if b contains a Go panic or runtime crash (e.g. SIGSEGV/SIGABRT with a goroutine dump). If logf is non-nil, parse er
opanic/opanic.go:97
↓ 7 callersMethodBytes
Bytes returns a copy of the bytes currently buffered, in write order.
opanic/opanic.go:77
↓ 6 callersMethodinfof
(f string, args ...interface{})
proc_master.go:647
↓ 5 callersFunctionNewTailWriter
NewTailWriter returns a TailWriter that retains the last `size` bytes. A non-positive size yields a no-op writer.
opanic/opanic.go:46
↓ 5 callersMethodWrite
(p []byte)
opanic/opanic.go:50
↓ 5 callersFunctionmove
(dst, src string)
sys_posix.go:25
↓ 3 callersMethodString
()
waitdelay_integration_test.go:30
↓ 3 callersMethodforceNextRestart
forceNextRestart marks the next restart attempt to skip ShouldRestart; backs the exported ForceNextRestart() function.
proc_master.go:392
↓ 3 callersMethodsendSignal
(s os.Signal)
proc_master.go:190
↓ 3 callersMethodtriggerRestart
triggerRestart is the manual-restart path invoked from the signal handler and the exported Restart() function; it bypasses Config.ShouldRestart.
proc_master.go:386
↓ 3 callersMethodupdateHash
()
fetcher/fetcher_file.go:84
↓ 2 callersFunctionbuildStderrLeaker
(t *testing.T)
waitdelay_integration_test.go:91
↓ 2 callersMethoddebugf
(f string, args ...interface{})
proc_worker.go:158
↓ 2 callersMethodfetch
()
proc_master.go:258
↓ 2 callersMethodforceNextRestart
()
proc_worker.go:149
↓ 2 callersMethodinfo
()
proc_worker.go:153
↓ 2 callersMethodinfof
(f string, args ...interface{})
proc_worker.go:164
↓ 2 callersFunctionkillGrandchildByStdout
Best-effort cleanup: the leaker prints the grandchild PID to its stdout before exec'ing into sleep, so we can target only the process this test actual
waitdelay_integration_test.go:108
↓ 2 callersFunctionrunErr
(c *Config)
overseer.go:199
↓ 2 callersFunctionsanityCheck
sanityCheck returns true if a check was performed
overseer.go:145
↓ 2 callersMethodstartRestart
startRestart atomically claims ownership of the restart and, if claimed, performs the graceful shutdown handshake. When checkShouldRestart is true the
proc_master.go:415
↓ 2 callersFunctiontoken
()
proc_master.go:659
↓ 1 callersMethodFetch
Fetch should check if there is an updated binary to fetch, and then stream it back the form of an io.Reader. If io.Reader is nil, then it is assumed t
fetcher/fetcher.go:18
↓ 1 callersMethodFile
()
graceful.go:80
↓ 1 callersFunctionForceNextRestart
ForceNextRestart marks the next restart attempt — typically the one following the next successful fetch — to proceed even if Config.ShouldRestart retu
overseer.go:235
↓ 1 callersFunctionGetWin32Proc
(pid int32)
proc_worker_windows.go:79
↓ 1 callersFunctionGetWin32ProcWithContext
(ctx context.Context, pid int32)
proc_worker_windows.go:83
↓ 1 callersMethodInit
Init should perform validation on fields. For example, ensure the appropriate URLs or keys are defined or ensure there is connectivity to the appropri
fetcher/fetcher.go:11
↓ 1 callersFunctionMasterInfo
MasterInfo returns a snapshot of the master's upgrade and restart state. Valid in the master process; in the worker (or before Run) it returns a zero
overseer.go:244
↓ 1 callersFunctionRun
Run executes overseer, if an error is encountered, overseer fallsback to running the program directly (unless Required is set).
overseer.go:130
↓ 1 callersFunctionWMIQueryWithContext
(ctx context.Context, query string, dst interface{}, connectServerArgs ...interface{})
proc_worker_windows.go:99
↓ 1 callersFunctionbuildPanicker
buildPanicker compiles testdata/panicker into the test's temp dir and returns the resulting binary path.
opanic/integration_test.go:15
↓ 1 callersMethodcheckBinary
()
proc_master.go:76
↓ 1 callersFunctionchmod
(f *os.File, perms os.FileMode)
sys_posix.go:44
↓ 1 callersFunctionchown
(f *os.File, uid, gid int)
sys_posix.go:47
↓ 1 callersFunctionextension
On Windows, include the .exe extension, noop otherwise.
proc_master.go:666
↓ 1 callersMethodfetchLoop
fetchLoop is run in a goroutine
proc_master.go:235
↓ 1 callersMethodfork
()
proc_master.go:467
↓ 1 callersMethodforkLoop
not a real fork
proc_master.go:458
↓ 1 callersMethodhandleSignal
(s os.Signal)
proc_master.go:128
↓ 1 callersMethodinitFileDescriptors
()
proc_worker.go:87
↓ 1 callersFunctionnewOverseerListener
(l net.Listener)
graceful.go:14
↓ 1 callersFunctionoverwrite
(dst, src string)
proc_worker_others.go:33
↓ 1 callersMethodrelease
non-blocking trigger close
graceful.go:55
↓ 1 callersMethodretreiveFileDescriptors
()
proc_master.go:211
↓ 1 callersMethodrun
()
proc_worker.go:58
↓ 1 callersMethodsetupSignalling
()
proc_master.go:112
↓ 1 callersFunctionsyncCmd
()
sys_posix.go:40
↓ 1 callersMethodtriggerRestart
()
proc_worker.go:143
↓ 1 callersFunctionvalidate
(c *Config)
overseer.go:93
↓ 1 callersMethodwatchParent
()
proc_worker_others.go:13
↓ 1 callersMethodwatchSignal
()
proc_worker.go:111
MethodAccept
()
graceful.go:29
MethodClose
blocking wait for close
graceful.go:75
MethodFetch
Fetch the binary from S3
fetcher/fetcher_s3.go:75
MethodFetch
()
fetcher/fetcher.go:34
MethodFetch
Fetch the binary from the provided URL
fetcher/fetcher_http.go:45
MethodFetch
Fetch the binary from the provided Repository
fetcher/fetcher_github.go:67
MethodFetch
Fetch file from the specified Path
fetcher/fetcher_file.go:38
FunctionFunc
Func converts a fetch function into the fetcher interface
fetcher/fetcher.go:22
MethodInit
Init validates the provided config
fetcher/fetcher_s3.go:43
MethodInit
()
fetcher/fetcher.go:30
MethodInit
Init validates the provided config
fetcher/fetcher_http.go:29
MethodInit
Init validates the provided config
fetcher/fetcher_github.go:46
MethodInit
Init sets the Path and Interval options
fetcher/fetcher_file.go:24
FunctionIsSupported
IsSupported returns whether overseer is supported on the current OS.
overseer.go:252
FunctionRestart
Restart programmatically triggers a graceful restart. If NoRestart is enabled, then this will essentially be a graceful shutdown.
overseer.go:223
FunctionRunErr
RunErr allows manual handling of any overseer errors.
overseer.go:123
FunctionSanityCheck
SanityCheck manually runs the check to ensure this binary is compatible with overseer. This tries to ensure that a restart is never performed against
overseer.go:165
FunctionTestCmdWait_StderrLeak_WithWaitDelay
Reproduces the master-hang bug: a worker subprocess inherits the worker's fd 2 (the pipe to its MultiWriter parent) and outlives the worker. Without W
waitdelay_integration_test.go:41
FunctionTestCmdWait_StderrLeak_WithoutWaitDelay_Hangs
Same scenario without WaitDelay: cmd.Wait blocks past a short timeout, proving the bug is real before the fix. We don't wait long — just enough to ver
waitdelay_integration_test.go:72
FunctionTestForceInfo_ConcurrentRaceFree
Exercises the new force/info paths from many goroutines so `go test -race` catches any regression in their locking.
proc_master_test.go:266
FunctionTestForceNextRestart_BypassesShouldRestart
forceNextRestart makes the next auto-restart attempt skip ShouldRestart; the mark is consumed by the attempt.
proc_master_test.go:169
FunctionTestForceNextRestart_ReleasesPendingRestart
a force latched while ShouldRestart is deferring must release the already-pending restart on the next retry tick.
proc_master_test.go:192
FunctionTestForkNotifyRestart_NoReceiver_DoesNotBlock
Regression: when startRestart times out, mp.restarting stays true, so the next fork()'s "notify success" path tried to send on the unbuffered mp.resta
proc_master_test.go:83
FunctionTestForkNotifyRestart_Receiver_GetsNotified
When startRestart is actually parked on its receive, the send must reach the receiver — non-blocking is for the timeout-path-receiver-gone case only.
proc_master_test.go:118
FunctionTestMasterInfo_Fields
(t *testing.T)
proc_master_test.go:230
FunctionTestMasterInfo_UpgradeStaged
(t *testing.T)
proc_master_test.go:210
FunctionTestPackageFuncs_NoProcess
(t *testing.T)
proc_master_test.go:246
FunctionTestRestart_ConcurrentRaceFree
Exercises the mutex-guarded state transitions from many goroutines so `go test -race` catches any regression in pendingRestart/restarting.
proc_master_test.go:58
FunctionTestScan_Detects
(t *testing.T)
opanic/opanic_test.go:48
FunctionTestScan_DetectsSIGABRT
(t *testing.T)
opanic/sigabrt_test.go:11
FunctionTestScan_EmptyInput
(t *testing.T)
opanic/opanic_test.go:65
FunctionTestScan_FromPanickingChild
Exercises the end-to-end pipeline: a real child process panics, its stderr flows through TailWriter, and Scan extracts a snapshot.
opanic/integration_test.go:31
FunctionTestScan_NoPanic
(t *testing.T)
opanic/opanic_test.go:58
FunctionTestScan_TruncatedTail
(t *testing.T)
opanic/opanic_test.go:74
FunctionTestTailWriter_BelowCapacity
(t *testing.T)
opanic/opanic_test.go:27
FunctionTestTailWriter_KeepsTail
(t *testing.T)
opanic/opanic_test.go:18
FunctionTestTailWriter_MultipleWrites
(t *testing.T)
opanic/opanic_test.go:35
FunctionTestTriggerRestart_BypassesShouldRestart
triggerRestart is the manual path; it must bypass ShouldRestart and must never leave pendingRestart set.
proc_master_test.go:152
FunctionTestTryRestart_ShouldRestartFalse_Defers
(t *testing.T)
proc_master_test.go:19
FunctionTestTryRestart_ShouldRestartNil_TriggersRestart
(t *testing.T)
proc_master_test.go:9
FunctionTestTryRestart_ShouldRestartTrue_ClearsPending
(t *testing.T)
proc_master_test.go:29
FunctionTestTryRestart_TransitionFromFalseToTrue
(t *testing.T)
proc_master_test.go:40
FunctionTestWorker_InfoAndForceAreNoops
(t *testing.T)
proc_master_test.go:256
next →1–100 of 116, ranked by callers