pipe

Documentation

Overview

Package pipe has functions for pipe channel handling.

Index

• func Close(pipe chan interface{}, err error)
• func New() chan interface{}
• func ReadErrors(pipe chan interface{}) []error
• func WaitAndRedirect(pipe, redirectPipe chan interface{}, interrupt chan os.Signal) (ok bool)

Functions

func Close

func Close(pipe chan interface{}, err error)

Close closes a pipe and optionally sends an error

func New

func New() chan interface{}

New creates a new pipe. A pipe is basically a channel.

func ReadErrors

func ReadErrors(pipe chan interface{}) []error

ReadErrors selects all received errors and returns them. This is helpful for synchronous migration functions.

func WaitAndRedirect

func WaitAndRedirect(pipe, redirectPipe chan interface{}, interrupt chan os.Signal) (ok bool)

WaitAndRedirect waits for pipe to be closed and redirects all messages from pipe to redirectPipe while it waits. It also checks if there was an interrupt send and will quit gracefully if yes.