Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/jpillora/overseer
/ functions
Functions
116 in github.com/jpillora/overseer
⨍
Functions
116
◇
Types & classes
16
↓ 19 callers
Method
debugf
(f string, args ...interface{})
proc_master.go:641
↓ 17 callers
Method
Close
()
graceful.go:94
↓ 14 callers
Method
warnf
(f string, args ...interface{})
proc_master.go:653
↓ 12 callers
Method
tryRestart
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 callers
Method
info
info backs the exported MasterInfo() function.
proc_master.go:400
↓ 8 callers
Function
Scan
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 callers
Method
Bytes
Bytes returns a copy of the bytes currently buffered, in write order.
opanic/opanic.go:77
↓ 6 callers
Method
infof
(f string, args ...interface{})
proc_master.go:647
↓ 5 callers
Function
NewTailWriter
NewTailWriter returns a TailWriter that retains the last `size` bytes. A non-positive size yields a no-op writer.
opanic/opanic.go:46
↓ 5 callers
Method
Write
(p []byte)
opanic/opanic.go:50
↓ 5 callers
Function
move
(dst, src string)
sys_posix.go:25
↓ 3 callers
Method
String
()
waitdelay_integration_test.go:30
↓ 3 callers
Method
forceNextRestart
forceNextRestart marks the next restart attempt to skip ShouldRestart; backs the exported ForceNextRestart() function.
proc_master.go:392
↓ 3 callers
Method
sendSignal
(s os.Signal)
proc_master.go:190
↓ 3 callers
Method
triggerRestart
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 callers
Method
updateHash
()
fetcher/fetcher_file.go:84
↓ 2 callers
Function
buildStderrLeaker
(t *testing.T)
waitdelay_integration_test.go:91
↓ 2 callers
Method
debugf
(f string, args ...interface{})
proc_worker.go:158
↓ 2 callers
Method
fetch
()
proc_master.go:258
↓ 2 callers
Method
forceNextRestart
()
proc_worker.go:149
↓ 2 callers
Method
info
()
proc_worker.go:153
↓ 2 callers
Method
infof
(f string, args ...interface{})
proc_worker.go:164
↓ 2 callers
Function
killGrandchildByStdout
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 callers
Function
runErr
(c *Config)
overseer.go:199
↓ 2 callers
Function
sanityCheck
sanityCheck returns true if a check was performed
overseer.go:145
↓ 2 callers
Method
startRestart
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 callers
Function
token
()
proc_master.go:659
↓ 1 callers
Method
Fetch
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 callers
Method
File
()
graceful.go:80
↓ 1 callers
Function
ForceNextRestart
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 callers
Function
GetWin32Proc
(pid int32)
proc_worker_windows.go:79
↓ 1 callers
Function
GetWin32ProcWithContext
(ctx context.Context, pid int32)
proc_worker_windows.go:83
↓ 1 callers
Method
Init
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 callers
Function
MasterInfo
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 callers
Function
Run
Run executes overseer, if an error is encountered, overseer fallsback to running the program directly (unless Required is set).
overseer.go:130
↓ 1 callers
Function
WMIQueryWithContext
(ctx context.Context, query string, dst interface{}, connectServerArgs ...interface{})
proc_worker_windows.go:99
↓ 1 callers
Function
buildPanicker
buildPanicker compiles testdata/panicker into the test's temp dir and returns the resulting binary path.
opanic/integration_test.go:15
↓ 1 callers
Method
checkBinary
()
proc_master.go:76
↓ 1 callers
Function
chmod
(f *os.File, perms os.FileMode)
sys_posix.go:44
↓ 1 callers
Function
chown
(f *os.File, uid, gid int)
sys_posix.go:47
↓ 1 callers
Function
extension
On Windows, include the .exe extension, noop otherwise.
proc_master.go:666
↓ 1 callers
Method
fetchLoop
fetchLoop is run in a goroutine
proc_master.go:235
↓ 1 callers
Method
fork
()
proc_master.go:467
↓ 1 callers
Method
forkLoop
not a real fork
proc_master.go:458
↓ 1 callers
Method
handleSignal
(s os.Signal)
proc_master.go:128
↓ 1 callers
Method
initFileDescriptors
()
proc_worker.go:87
↓ 1 callers
Function
newOverseerListener
(l net.Listener)
graceful.go:14
↓ 1 callers
Function
overwrite
(dst, src string)
proc_worker_others.go:33
↓ 1 callers
Method
release
non-blocking trigger close
graceful.go:55
↓ 1 callers
Method
retreiveFileDescriptors
()
proc_master.go:211
↓ 1 callers
Method
run
()
proc_worker.go:58
↓ 1 callers
Method
setupSignalling
()
proc_master.go:112
↓ 1 callers
Function
syncCmd
()
sys_posix.go:40
↓ 1 callers
Method
triggerRestart
()
proc_worker.go:143
↓ 1 callers
Function
validate
(c *Config)
overseer.go:93
↓ 1 callers
Method
watchParent
()
proc_worker_others.go:13
↓ 1 callers
Method
watchSignal
()
proc_worker.go:111
Method
Accept
()
graceful.go:29
Method
Close
blocking wait for close
graceful.go:75
Method
Fetch
Fetch the binary from S3
fetcher/fetcher_s3.go:75
Method
Fetch
()
fetcher/fetcher.go:34
Method
Fetch
Fetch the binary from the provided URL
fetcher/fetcher_http.go:45
Method
Fetch
Fetch the binary from the provided Repository
fetcher/fetcher_github.go:67
Method
Fetch
Fetch file from the specified Path
fetcher/fetcher_file.go:38
Function
Func
Func converts a fetch function into the fetcher interface
fetcher/fetcher.go:22
Method
Init
Init validates the provided config
fetcher/fetcher_s3.go:43
Method
Init
()
fetcher/fetcher.go:30
Method
Init
Init validates the provided config
fetcher/fetcher_http.go:29
Method
Init
Init validates the provided config
fetcher/fetcher_github.go:46
Method
Init
Init sets the Path and Interval options
fetcher/fetcher_file.go:24
Function
IsSupported
IsSupported returns whether overseer is supported on the current OS.
overseer.go:252
Function
Restart
Restart programmatically triggers a graceful restart. If NoRestart is enabled, then this will essentially be a graceful shutdown.
overseer.go:223
Function
RunErr
RunErr allows manual handling of any overseer errors.
overseer.go:123
Function
SanityCheck
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
Function
TestCmdWait_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
Function
TestCmdWait_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
Function
TestForceInfo_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
Function
TestForceNextRestart_BypassesShouldRestart
forceNextRestart makes the next auto-restart attempt skip ShouldRestart; the mark is consumed by the attempt.
proc_master_test.go:169
Function
TestForceNextRestart_ReleasesPendingRestart
a force latched while ShouldRestart is deferring must release the already-pending restart on the next retry tick.
proc_master_test.go:192
Function
TestForkNotifyRestart_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
Function
TestForkNotifyRestart_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
Function
TestMasterInfo_Fields
(t *testing.T)
proc_master_test.go:230
Function
TestMasterInfo_UpgradeStaged
(t *testing.T)
proc_master_test.go:210
Function
TestPackageFuncs_NoProcess
(t *testing.T)
proc_master_test.go:246
Function
TestRestart_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
Function
TestScan_Detects
(t *testing.T)
opanic/opanic_test.go:48
Function
TestScan_DetectsSIGABRT
(t *testing.T)
opanic/sigabrt_test.go:11
Function
TestScan_EmptyInput
(t *testing.T)
opanic/opanic_test.go:65
Function
TestScan_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
Function
TestScan_NoPanic
(t *testing.T)
opanic/opanic_test.go:58
Function
TestScan_TruncatedTail
(t *testing.T)
opanic/opanic_test.go:74
Function
TestTailWriter_BelowCapacity
(t *testing.T)
opanic/opanic_test.go:27
Function
TestTailWriter_KeepsTail
(t *testing.T)
opanic/opanic_test.go:18
Function
TestTailWriter_MultipleWrites
(t *testing.T)
opanic/opanic_test.go:35
Function
TestTriggerRestart_BypassesShouldRestart
triggerRestart is the manual path; it must bypass ShouldRestart and must never leave pendingRestart set.
proc_master_test.go:152
Function
TestTryRestart_ShouldRestartFalse_Defers
(t *testing.T)
proc_master_test.go:19
Function
TestTryRestart_ShouldRestartNil_TriggersRestart
(t *testing.T)
proc_master_test.go:9
Function
TestTryRestart_ShouldRestartTrue_ClearsPending
(t *testing.T)
proc_master_test.go:29
Function
TestTryRestart_TransitionFromFalseToTrue
(t *testing.T)
proc_master_test.go:40
Function
TestWorker_InfoAndForceAreNoops
(t *testing.T)
proc_master_test.go:256
next →
1–100 of 116, ranked by callers