syncs

func ContextValue ¶ added in v0.7.2

func ContextValue(key, value any) context.Context

ContextValue create a new context with given value

func Go ¶

func Go(f func() error) error

Go is a basic promise implementation: it wraps calls a function in a goroutine and returns a channel which will later return the function's return value.

func SignalHandler ¶

func SignalHandler(ctx context.Context, signals ...os.Signal) (execute func() error, interrupt func(error))

SignalHandler returns an actor, i.e. an execute and interrupt func, that terminates with SignalError when the process receives one of the provided signals, or the parent context is canceled.

from https://github.com/oklog/run/blob/master/actors.go

func WaitCloseSignals ¶

func WaitCloseSignals(onClose func(sig os.Signal), sigCh ...chan os.Signal)

WaitCloseSignals for some huang program.

Usage:

// do something. eg: start a http server

syncs.WaitCloseSignals(func(sig os.Signal) {
	// do something on shutdown. eg: close db, flush logs
})