Function main

ch6/log_processing/main.go:22–53

()

}

func main() {
	pipePath := "/tmp/my_log_pipe"
	if err := os.RemoveAll(pipePath); err != nil {
		panic(err)
	}
	if err := syscall.Mkfifo(pipePath, 0600); err != nil {
		panic(err)
	}
	defer os.RemoveAll(pipePath)

	pipeFile, err := os.OpenFile(pipePath, os.O_RDONLY|os.O_CREATE, os.ModeNamedPipe)
	if err != nil {
		panic(err)
	}
	defer pipeFile.Close()

	go func() {
		writer, err := os.OpenFile(pipePath, os.O_WRONLY, os.ModeNamedPipe)
		if err != nil {
			panic(err)
		}
		defer writer.Close()

		for {
			writer.WriteString("INFO: All systems operational\n")
			writer.WriteString("ERROR: An error occurred\n")
			time.Sleep(1 * time.Second)
		}
	}()

	filterLogs(pipeFile, os.Stdout)
}