Method close

status_manager.go:159–195

()

}

func (sm *StatusManager) close() error {
	sm.cancel()

	componentNames := sm.getAllComponents()

	for i, j := 0, len(componentNames)-1; i < j; i, j = i+1, j-1 {
		componentNames[i], componentNames[j] = componentNames[j], componentNames[i]
	}

	shutdownCtx, shutdownCancel := context.WithTimeout(context.Background(), sm.config.ShutdownTimeout)
	deadline, _ := shutdownCtx.Deadline()

	doneCh := make(chan struct{})
	go func() {
		sm.shutdownComponents(shutdownCtx, componentNames)
		close(doneCh)
	}()

	var shutdownErr error
	select {
	case <-doneCh:
	case <-shutdownCtx.Done():
		shutdownErr = fmt.Errorf("timeout stopping components")
	}

	shutdownCancel()

	if err := sm.waitForGoroutines(deadline); err != nil {
		if shutdownErr != nil {
			shutdownErr = fmt.Errorf("%v; %w", shutdownErr, err)
		} else {
			shutdownErr = err
		}
	}

	return shutdownErr
}

func (sm *StatusManager) shutdownComponents(ctx context.Context, order []string) {
	if len(order) == 0 {