utils

func CopyAndCapture ¶

func CopyAndCapture(w io.Writer, r io.Reader) ([]byte, error)

func InitPool ¶

func InitPool()

func NewRabbitMQClient ¶

func NewRabbitMQClient(cfg config.RabbitmqConfig) *rabbitMQClient

func Pipeline ¶

func Pipeline(cmds ...*exec.Cmd) (pipeLineOutput, collectedStandardError []byte, pipeLineError error)

Pipeline strings together the given exec.Cmd commands in a similar fashion to the Unix pipeline. Each command's standard output is connected to the standard input of the next command, and the output of the final command in the pipeline is returned, along with the collected standard error of all commands and the first error found (if any).

To provide input to the pipeline, assign an io.Reader to the first's Stdin.

func VersionCompare ¶

func VersionCompare(v1, v2 string) (result int)