main.go

package main

import (
	"log"
	"os"

	"github.com/kelseyhightower/journal-2-logentries/journal"
	"github.com/kelseyhightower/journal-2-logentries/logentries"
)

func main() {
	socket := os.Getenv("LOGENTRIES_JOURNAL_SOCKET")
	if socket == "" {
		socket = journal.DefaultSocket
	}
	url := os.Getenv("LOGENTRIES_URL")
	if url == "" {
		url = logentries.DefaultUrl
	}
	token := os.Getenv("LOGENTRIES_TOKEN")
	if token == "" {
		log.Fatal("non-empty input token (LOGENTRIES_TOKEN) is required. See https://logentries.com/doc/input-token")
	}
	logs, err := journal.Follow(socket)
	if err != nil {
		log.Fatal(err.Error())
	}
	le, err := logentries.New(url, token)
	if err != nil {
		log.Fatal(err.Error())
	}
	for {
		select {
		case data := <-logs:
			if _, err := le.Write(data); err != nil {
				log.Print(err.Error())
			}
		}
	}
}