lifecycle

type Lifecycle ¶

type Lifecycle struct {
	// contains filtered or unexported fields
}

Lifecycle formally manages various long-running goroutines for smooth cleanup when restarting major components (e.g. mediorum). This allows us to wait for all registered goroutines on a service to gracefully shut down before restarting the service.

func NewFromLifecycle(lc *Lifecycle, name string) *Lifecycle

func NewLifecycle(ctx context.Context, name string, z *zap.Logger) *Lifecycle

func (l *Lifecycle) AddManagedRoutine(name string, f func(context.Context) error)

func (l *Lifecycle) ShutdownWithTimeout(timeout time.Duration) error

func (l *Lifecycle) Wait()