process

Documentation

Index

• Variables
• func NewSignal[T string | int](x T) (syscall.Signal, bool)
• func SignalIntoInt(s os.Signal) (int, bool)
• func SignalIntoString(s os.Signal) string
• type Process
  • func NewProcess(locker *lease.Locker, name string, arg ...string) *Process
  • func (p *Process) Run(ctx context.Context, opt ...lease.ConfigOption) error
  • func (p *Process) Validate() error

Variables

var ErrInvalidProcess = errors.New("InvalidProcess")

Functions

func NewSignal

func NewSignal[T string | int](x T) (syscall.Signal, bool)

NewSignal returns the Signal for signal named x or numbered x.

Examples:

• "INT" -> syscall.SIGINT
• 2 -> syscall.SIGINT
• "2" -> syscall.SIGINT

func SignalIntoInt

func SignalIntoInt(s os.Signal) (int, bool)

func SignalIntoString

func SignalIntoString(s os.Signal) string

Types

type Process

type Process struct {
	Stdin        io.Reader
	Stdout       io.Writer
	Stderr       io.Writer
	Args         []string
	CancelSignal os.Signal
	WaitDelay    time.Duration
	// contains filtered or unexported fields
}

Process is an external command executed under lock control.

func NewProcess

func NewProcess(locker *lease.Locker, name string, arg ...string) *Process

func (*Process) Run

func (p *Process) Run(ctx context.Context, opt ...lease.ConfigOption) error

Run starts the specified command and waits for it to complete with the lease lock.

Run supports the same options as lease.Locker.LockAndRun.

func (*Process) Validate

func (p *Process) Validate() error