wakemutation

package

v0.77.1 Latest Latest Go to latest Published: Sep 4, 2026 License: MIT Imports: 6 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/avivsinai/agent-message-queue

Links

Open Source Insights

Documentation ¶

Rendered for

Constants ¶

This section is empty.

Variables ¶

View Source

var ErrClosed = errors.New("wake mutation lease is closed")

Functions ¶

func ProcessAlive ¶

func ProcessAlive(pid int) bool

Types ¶

type Lease ¶

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

Lease is a capability for effects that must finish before its authority is released. Close prevents new effects, waits for admitted effects, and then calls the backing release function.

func New ¶

func New(release ReleaseFunc) *Lease

func (*Lease) Active ¶

func (lease *Lease) Active() bool

func (*Lease) Close ¶

func (lease *Lease) Close() error

func (*Lease) KillProcess ¶

func (lease *Lease) KillProcess(process *os.Process) error

func (*Lease) LinkAt ¶

func (lease *Lease) LinkAt(
	fromDirFD int,
	from string,
	toDirFD int,
	to string,
	flags int,
) error

func (*Lease) LinkAtWith ¶

func (lease *Lease) LinkAtWith(
	link LinkAtFunc,
	fromDirFD int,
	from string,
	toDirFD int,
	to string,
	flags int,
) error

func (*Lease) QueueRestart ¶

func (lease *Lease) QueueRestart(
	restartSignals chan<- os.Signal,
	signal os.Signal,
) error

func (*Lease) QueueStop ¶

func (lease *Lease) QueueStop(stopRequest chan<- struct{}) error

func (*Lease) RenameAt ¶

func (lease *Lease) RenameAt(
	fromDirFD int,
	from string,
	toDirFD int,
	to string,
) error

func (*Lease) RenameAtWith ¶

func (lease *Lease) RenameAtWith(
	rename RenameAtFunc,
	fromDirFD int,
	from string,
	toDirFD int,
	to string,
) error

func (*Lease) RenameNoReplaceAt ¶

func (lease *Lease) RenameNoReplaceAt(
	fromDirFD int,
	from string,
	toDirFD int,
	to string,
) error

func (*Lease) RenameNoReplaceAtWith ¶

func (lease *Lease) RenameNoReplaceAtWith(
	rename RenameNoReplaceAtFunc,
	fromDirFD int,
	from string,
	toDirFD int,
	to string,
) error

func (*Lease) SendPidfdSignal ¶

func (lease *Lease) SendPidfdSignal(pidfd int, signal unix.Signal) error

func (*Lease) SendPidfdSignalWith ¶

func (lease *Lease) SendPidfdSignalWith(
	send PidfdSenderFunc,
	pidfd int,
	signal unix.Signal,
) error

func (*Lease) UnlinkAt ¶

func (lease *Lease) UnlinkAt(dirfd int, name string, flags int) error

func (*Lease) UnlinkAtWith ¶

func (lease *Lease) UnlinkAtWith(
	unlink UnlinkAtFunc,
	dirfd int,
	name string,
	flags int,
) error

type LinkAtFunc ¶

type LinkAtFunc func(fromDirFD int, from string, toDirFD int, to string, flags int) error

type PidfdSenderFunc ¶

type PidfdSenderFunc func(pidfd int, signal unix.Signal, info *unix.Siginfo, flags int) error

type ReleaseFunc ¶

type ReleaseFunc func() error

ReleaseFunc releases the lifecycle authority that backs a Lease.

type RenameAtFunc ¶

type RenameAtFunc func(fromDirFD int, from string, toDirFD int, to string) error

type RenameNoReplaceAtFunc ¶

type RenameNoReplaceAtFunc func(fromDirFD int, from string, toDirFD int, to string) error

type UnlinkAtFunc ¶

type UnlinkAtFunc func(dirfd int, name string, flags int) error

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL