stopapp

package

v1.0.247 Latest Latest Go to latest Published: Dec 18, 2025 License: MIT Imports: 10 Imported by: 3

Details

View Source

const SecondsWaitTotalMessagesSendingNow = 10

SecondsWaitTotalMessagesSendingNow - количество секунд ожидания для отправки последнего сообщения

View Source

var OrderedMapConnections *ordered_map.Map[string, WaitGroupContext]

OrderedMapConnections - содержит все WaitGroup от разных компонент, в порядке подключения компонентов

View Source

var SignalInterrupt chan os.Signal

SignalInterrupt - канал для ожидания сигнала остановки приложения

View Source

var TotalMessagesSendingNow int32

TotalMessagesSendingNow - количество сообщений отправляющихся прям сейчас

func GetWaitGroup_Main() *sync.WaitGroup

GetWaitGroup_Main - возвращает группу ожидания завершения всех частей программы

func SetWaitGroup_Main(wg *sync.WaitGroup)

SetWaitGroup_Main - присваивает внешний WaitGroup

func StartWaitStop()

StartWaitStop - запускает ожидание сигнала завершения приложения

func StopApp()

StopApp - отмена глобального контекста для остановки работы приложения

func StopAppAndWait()

StopApp - отмена глобального контекста для остановки работы приложения

func WaitStop()

WaitStop - ожидает отмену глобального контекста или сигнала завершения приложения

func WaitTotalMessagesSendingNow(filename string)

ожидает чтоб прям щас ничего не отправлялось

func Wait_GracefulShutdown()

Wait_GracefulShutdown - ожидает завершения всех горутин программы, а потом ожидает закрытие всех подключений

type KeyValueWaitGroupContext struct {
	Key   string
	Value WaitGroupContext
}

KeyValueWaitGroupContext - структура ключ-значение

type WaitGroupContext struct {
	WaitGroup     *sync.WaitGroup
	Ctx           *context.Context
	CancelCtxFunc func()
}

WaitGroupContext - структура для хранения WaitGroup и контекста