interrupt_handler

Documentation

Index

• Constants
• func SwallowSigQuit()
• type InterruptCause
  • func (ic InterruptCause) String() string
• type InterruptHandler
  • func NewInterruptHandler(timeout time.Duration, client parallel_support.Client) *InterruptHandler
  • func (handler *InterruptHandler) ClearInterruptPlaceholderMessage()
  • func (handler *InterruptHandler) InterruptMessageWithStackTraces() string
  • func (handler *InterruptHandler) SetInterruptPlaceholderMessage(message string)
  • func (handler *InterruptHandler) Status() InterruptStatus
  • func (handler *InterruptHandler) Stop()
• type InterruptHandlerInterface
• type InterruptStatus

Constants

const ABORT_POLLING_INTERVAL = 500 * time.Millisecond

const ABORT_REPEAT_INTERRUPT_DURATION = 30 * time.Second

const TIMEOUT_REPEAT_INTERRUPT_FRACTION_OF_TIMEOUT = 10

const TIMEOUT_REPEAT_INTERRUPT_MAXIMUM_DURATION = 30 * time.Second

Functions

func SwallowSigQuit

func SwallowSigQuit()

Types

type InterruptCause

type InterruptCause uint

const (
	InterruptCauseInvalid InterruptCause = iota

	InterruptCauseSignal
	InterruptCauseTimeout
	InterruptCauseAbortByOtherProcess
)

func (InterruptCause) String

func (ic InterruptCause) String() string

type InterruptHandler

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

func NewInterruptHandler

func NewInterruptHandler(timeout time.Duration, client parallel_support.Client) *InterruptHandler

func (*InterruptHandler) ClearInterruptPlaceholderMessage

func (handler *InterruptHandler) ClearInterruptPlaceholderMessage()

func (*InterruptHandler) InterruptMessageWithStackTraces

func (handler *InterruptHandler) InterruptMessageWithStackTraces() string

func (*InterruptHandler) SetInterruptPlaceholderMessage

func (handler *InterruptHandler) SetInterruptPlaceholderMessage(message string)

func (*InterruptHandler) Status

func (handler *InterruptHandler) Status() InterruptStatus

func (*InterruptHandler) Stop

func (handler *InterruptHandler) Stop()

type InterruptHandlerInterface

type InterruptHandlerInterface interface {
	Status() InterruptStatus
	SetInterruptPlaceholderMessage(string)
	ClearInterruptPlaceholderMessage()
	InterruptMessageWithStackTraces() string
}

type InterruptStatus

type InterruptStatus struct {
	Interrupted bool
	Channel     chan interface{}
	Cause       InterruptCause
}