package fifosync

import "github.com/containerd/containerd/pkg/fifosync"

Package fifosync provides a pattern on Unix-like operating systems for synchronizing across processes using Unix FIFOs (named pipes).

Index ¶

• type Trigger
• func NewTrigger(name string, mode uint32) (Trigger, error)
• type Waiter
• func NewWaiter(name string, mode uint32) (Waiter, error)

Types ¶

type Trigger ¶

type Trigger interface {
	// Name returns the name of the trigger
	Name() string
	// Trigger triggers another process to proceed.
	Trigger() error
}

Trigger is a FIFO which is used to signal another process to proceed.

func NewTrigger ¶

func NewTrigger(name string, mode uint32) (Trigger, error)

NewTrigger creates a new Trigger

type Waiter ¶

type Waiter interface {
	// Name returns the name of the waiter
	Name() string
	// Wait waits for a trigger from another process.
	Wait() error
}

Waiter is a FIFO which is used to wait for trigger provided by another process.

func NewWaiter ¶

func NewWaiter(name string, mode uint32) (Waiter, error)

NewWaiter creates a new Waiter

Source Files ¶

fifo_unix.go