billing map-reduce test

main.go

@@ -0,0 +1,29 @@
package main

import (
	"fmt"
	"github.com/journeymidnight/yig-billing/helper"
	pb "github.com/journeymidnight/yig-billing/mapreduce/proto"
	"google.golang.org/grpc"
	"net"
)

func main() {
	helper.ReadConfig()
	helper.NewLogger()

	meepoConf := helper.Conf.Meepo
	tikvConf := helper.Conf.Tikv
	helper.Logger.Println(
		"Registry IP:", meepoConf.RegistryAddress, "port:", meepoConf.RegistryPort)

	listener, err := net.Listen("tcp",
		fmt.Sprintf("[::]:%d", meepoConf.RegistryPort))
	if err != nil {
		panic("net.Listen error: " + err.Error())
	}
	grpcServer := grpc.NewServer()
	pb.RegisterMeepoRegistryServer(grpcServer, NewRegistry(tikvConf.PdAddresses))
	err = grpcServer.Serve(listener)
	helper.Logger.Println("Server stopped with error:", err)
}