var ABORT_POLLING_INTERVAL = 500 * time.Millisecond
func SwallowSigQuit()
type InterruptCause uint
const (
InterruptCauseInvalid InterruptCause = iota
InterruptCauseSignal
InterruptCauseAbortByOtherProcess
)
func (ic InterruptCause) String() string
type InterruptHandler struct {
// contains filtered or unexported fields
}
func NewInterruptHandler(client parallel_support.Client, signals ...os.Signal) *InterruptHandler
func (handler *InterruptHandler) Status() InterruptStatus
func (handler *InterruptHandler) Stop()
type InterruptHandlerInterface interface {
Status() InterruptStatus
}
type InterruptLevel uint
const (
InterruptLevelUninterrupted InterruptLevel = iota
InterruptLevelCleanupAndReport
InterruptLevelReportOnly
InterruptLevelBailOut
)
type InterruptStatus struct {
Channel chan interface{}
Level InterruptLevel
Cause InterruptCause
}
func (s InterruptStatus) Interrupted() bool
func (s InterruptStatus) Message() string
func (s InterruptStatus) ShouldIncludeProgressReport() bool