fifo

Documentation

Overview

Package fifo implements functions to create and open a fifo for inter-process communication in an OS agnostic way. A few assumptions should be made when using this package. First, New() must always be called before Open(). Second Open() returns an io.ReadWriteCloser that is only connected with the io.ReadWriteCloser returned from New().

Index

• Constants
• func CreateAndRead(path string) (func() (io.ReadCloser, error), error)
• func IsClosedErr(err error) bool
• func OpenWriter(path string) (io.WriteCloser, error)
• func Remove(path string) error

Constants

const PipeBufferSize = int32(^uint16(0))

PipeBufferSize is the size of the input and output buffers for the windows named pipe

Functions

func CreateAndRead

func CreateAndRead(path string) (func() (io.ReadCloser, error), error)

CreateAndRead creates a fifo at the given path and returns an io.ReadCloser open for it. The fifo must not already exist

func IsClosedErr

func IsClosedErr(err error) bool

func OpenWriter

func OpenWriter(path string) (io.WriteCloser, error)

OpenWriter opens a fifo that already exists and returns an io.WriteCloser for it

func Remove

func Remove(path string) error

Remove a fifo that already exists at a given path