package main

import (
	"flag"
	"log_storage/logparse"
	"log_storage/logstorage"
	logreids "log_storage/redis"
	"strconv"

	"github.com/go-redis/redis"
	_ "github.com/lib/pq"
)

func main() {

	redisAddr := flag.String("RedisAddr", "", "reids server ip地址")
	redisPort := flag.Int("RedisPort", 6379, "redis端口号")
	redisPassword := flag.String("RedisPwd", "", "redis密码")
	pgsqlConn := flag.String("PgsqlConn", "", "pgsql连接字符串（host=192.168.1.245 port=5432 user=postgres password=123456 dbname=log）")

	flag.Parse()

	redisClient := redis.NewClient(&redis.Options{
		Addr:     *redisAddr + ":" + strconv.Itoa(*redisPort),
		Password: *redisPassword,
		DB:       14,
	})

	parseChan := make(chan *string)
	dbChan := make(chan *logparse.Log)

	go logstorage.PgsqlStorageStart(dbChan, *pgsqlConn)
	go logparse.LogParseStart(parseChan, dbChan)
	go logreids.RedisPullStart(parseChan, redisClient)

	waiting := make(chan interface{})

	<-waiting

}