func main() {
	logrus.SetLevel(logrus.InfoLevel)
	// Start a local cluster
	err := cluster.StartWith([]gubernator.PeerInfo{
		{GRPCAddress: "127.0.0.1:9990", HTTPAddress: "127.0.0.1:9980"},
		{GRPCAddress: "127.0.0.1:9991", HTTPAddress: "127.0.0.1:9981"},
		{GRPCAddress: "127.0.0.1:9992", HTTPAddress: "127.0.0.1:9982"},
		{GRPCAddress: "127.0.0.1:9993", HTTPAddress: "127.0.0.1:9983"},
		{GRPCAddress: "127.0.0.1:9994", HTTPAddress: "127.0.0.1:9984"},
		{GRPCAddress: "127.0.0.1:9995", HTTPAddress: "127.0.0.1:9985"},
	})
	if err != nil {
		panic(err)
	}

	fmt.Println("Running.....")

	// Wait until we get a INT signal then shutdown the cluster
	c := make(chan os.Signal, 1)
	signal.Notify(c, os.Interrupt)
	for sig := range c {
		if sig == os.Interrupt {
			cluster.Stop()
			os.Exit(0)
		}
	}
}
// Start a cluster of gubernator instances for use in testing clients
Start a cluster of gubernator instances for use in testing clients
// Start a cluster of gubernator instances for use in testing clients
func main() {
	logrus.SetLevel(logrus.InfoLevel)
	err := cluster.StartWith([]gubernator.PeerInfo{
		{GRPCAddress: "127.0.0.1:9990", HTTPAddress: "127.0.0.1:9980"},
		{GRPCAddress: "127.0.0.1:9991", HTTPAddress: "127.0.0.1:9981"},
		{GRPCAddress: "127.0.0.1:9992", HTTPAddress: "127.0.0.1:9982"},
		{GRPCAddress: "127.0.0.1:9993", HTTPAddress: "127.0.0.1:9983"},
		{GRPCAddress: "127.0.0.1:9994", HTTPAddress: "127.0.0.1:9984"},
		{GRPCAddress: "127.0.0.1:9995", HTTPAddress: "127.0.0.1:9985"},
	})
	if err != nil {
		panic(err)
	}
	fmt.Println("Running.....")
	c := make(chan os.Signal, 1)
	signal.Notify(c, os.Interrupt)
	for sig := range c {
		if sig == os.Interrupt {
			cluster.Stop()
			os.Exit(0)
		}
	}
}
func main ( ) { logrus . SetLevel ( logrus . InfoLevel ) err := cluster . StartWith ( [ ] gubernator . PeerInfo { { GRPCAddress : " " , HTTPAddress : " " } , { GRPCAddress : " " , HTTPAddress : " " } , { GRPCAddress : " " , HTTPAddress : " " } , { GRPCAddress : " " , HTTPAddress : " " } , { GRPCAddress : " " , HTTPAddress : " " } , { GRPCAddress : " " , HTTPAddress : " " } , } ) if err != nil { panic ( err ) } fmt . Println ( " " ) c := make ( chan os . Signal , 1 ) signal . Notify ( c , os . Interrupt ) for sig := range c { if sig == os . Interrupt { cluster . Stop ( ) os . Exit ( 0 ) } } }
Start a cluster of gubernator instances for use in testing clients
Start a cluster of gubernator instances for use in testing clients
// Start a local cluster // Wait until we get a INT signal then shutdown the cluster