...

Package fifo

import "github.com/containerd/fifo"
Overview
Index

Overview ▾

Constants

const O_PATH = 010000000

Variables

var (
    ErrClosed      = errors.New("fifo closed")
    ErrCtrlClosed  = errors.New("control of closed fifo")
    ErrRdFrmWRONLY = errors.New("reading from write-only fifo")
    ErrReadClosed  = errors.New("reading from a closed fifo")
    ErrWrToRDONLY  = errors.New("writing to read-only fifo")
    ErrWriteClosed = errors.New("writing to a closed fifo")
)

func IsFifo

func IsFifo(path string) (bool, error)

IsFifo checks if a file is a (named pipe) fifo if the file does not exist then it returns false

func OpenFifo

func OpenFifo(ctx context.Context, fn string, flag int, perm os.FileMode) (io.ReadWriteCloser, error)

OpenFifo opens a fifo. Returns io.ReadWriteCloser. Context can be used to cancel this function until open(2) has not returned. Accepted flags:

func OpenFifoDup2

func OpenFifoDup2(ctx context.Context, fn string, flag int, perm os.FileMode, fd int) (io.ReadWriteCloser, error)

OpenFifoDup2 is same as OpenFifo, but additionally creates a copy of the FIFO file descriptor with dup2 syscall.