Import path: gitlab.soludian.com/soludian/fountain/libs/base/syncs

syncs

import "gitlab.soludian.com/soludian/fountain/libs/base/syncs"

Package syncs provides synchronization primitives util functions.

Index

• func Go(f func() error) error
• func SignalHandler(ctx context.Context, signals ...os.Signal) (execute func() error, interrupt func(error))
• func WaitCloseSignals(onClose func(sig os.Signal))
• type SignalError
  • func (e SignalError) Error() string

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))

WaitCloseSignals for some huang program.

Usage:

... do something. eg: start a http server

	syncs.WaitCloseSignals(func(sig os.Signal) {
 ... do something
	})

type SignalError

SignalError is returned by the signal handler's execute function when it terminates due to a received signal.

type SignalError struct {
    Signal os.Signal
}

func (SignalError) Error

func (e SignalError) Error() string

Error implements the error interface.

Generated by gomarkdoc