github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-26 21:17:23 +00:00
Code Issues Projects Releases Wiki Activity

Fix formatting of API server diagram

Browse Source
This commit is contained in:
Nick Turner 2022-11-06 16:41:11 -08:00
parent 3efd107eb2
commit 02e3fbfeff
1 changed files with 34 additions and 38 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

56
staging/src/k8s.io/apiserver/pkg/server/genericapiserver.go
View File

@ -418,44 +418,40 @@ func (s *GenericAPIServer) PrepareRun() preparedGenericAPIServer {
// or the secure port cannot be listened on initially. // or the secure port cannot be listened on initially.
// This is the diagram of what channels/signals are dependent on each other: // This is the diagram of what channels/signals are dependent on each other:
// //
// stopCh // | stopCh
// |
// ---------------------------------------------------------
// | | // | |
// ShutdownInitiated (shutdownInitiatedCh) | // | ---------------------------------------------------------
// | | |
// | ShutdownInitiated (shutdownInitiatedCh) |
// | | |
// | (ShutdownDelayDuration) (PreShutdownHooks)
// | | |
// | AfterShutdownDelayDuration (delayedStopCh) PreShutdownHooksStopped (preShutdownHooksHasStoppedCh)
// | | |
// | |-------------------------------------------------------|
// | | // | |
//
// (ShutdownDelayDuration) (PreShutdownHooks)
//
// | | // | |
// AfterShutdownDelayDuration (delayedStopCh) PreShutdownHooksStopped (preShutdownHooksHasStoppedCh) // | NotAcceptingNewRequest (notAcceptingNewRequestCh)
// | | // | |
// |-------------------------------------------------------| // | |
// | // | |---------------------------------------------------------|
// | // | | | | |
// NotAcceptingNewRequest (notAcceptingNewRequestCh) // | [without [with | |
// | // | ShutdownSendRetryAfter] ShutdownSendRetryAfter] | |
// | // | | | | |
// |---------------------------------------------------------| // | | ---------------| |
// | | | | // | | | |
// [without [with | | // | | (HandlerChainWaitGroup::Wait) |
//
// ShutdownSendRetryAfter] ShutdownSendRetryAfter] | |
//
// | | | | // | | | |
// | ---------------| | // | | InFlightRequestsDrained (drainedCh) |
// | | | |
// | ----------------------------------------|-----------------|
// | | | // | | |
// | (HandlerChainWaitGroup::Wait) | // | stopHttpServerCh (AuditBackend::Shutdown())
// | | |
// | InFlightRequestsDrained (drainedCh) |
// | | |
// ----------------------------------------|-----------------|
// | | // | |
// stopHttpServerCh (AuditBackend::Shutdown()) // | listenerStoppedCh
// | // | |
// listenerStoppedCh // | HTTPServerStoppedListening (httpServerStoppedListeningCh)
// |
// HTTPServerStoppedListening (httpServerStoppedListeningCh)
func (s preparedGenericAPIServer) Run(stopCh <-chan struct{}) error { func (s preparedGenericAPIServer) Run(stopCh <-chan struct{}) error {
delayedStopCh := s.lifecycleSignals.AfterShutdownDelayDuration delayedStopCh := s.lifecycleSignals.AfterShutdownDelayDuration
shutdownInitiatedCh := s.lifecycleSignals.ShutdownInitiated shutdownInitiatedCh := s.lifecycleSignals.ShutdownInitiated