Microservice framework with kafka example

Author: nmalhotra

Gopkg.lock

@@ -0,0 +1,42 @@
+# Gopkg.toml example
+#
+# Refer to https://github.com/golang/dep/blob/master/docs/Gopkg.toml.md
+# for detailed Gopkg.toml documentation.
+#
+# required = ["github.com/user/thing/cmd/thing"]
+# ignored = ["github.com/user/project/pkgX", "bitbucket.org/user/project/pkgA/pkgY"]
+#
+# [[constraint]]
+#   name = "github.com/user/project"
+#   version = "1.0.0"
+#
+# [[constraint]]
+#   name = "github.com/user/project2"
+#   branch = "dev"
+#   source = "github.com/myfork/project2"
+#
+# [[override]]
+#   name = "github.com/x/y"
+#   version = "2.4.0"
+#
+# [prune]
+#   non-go = false
+#   go-tests = true
+#   unused-packages = true
+
+
+[[constraint]]
+  name = "github.com/Shopify/sarama"
+  version = "1.16.0"
+
+[[constraint]]
+  name = "github.com/sirupsen/logrus"
+  version = "1.0.5"
+
+[prune]
+  go-tests = true
+  unused-packages = true
+
+[[constraint]]
+  name = "github.com/spf13/viper"
+  version = "1.0.2"

Gopkg.toml

@@ -0,0 +1,8 @@
+{
+    "config": {
+        "brokers": ["0.0.0.0:9092"],
+        "group": 0,
+        "offset": -1,
+        "partition": 0
+    }
+}

examples/kafka.json

@@ -0,0 +1,40 @@
+package main
+
+import (
+	"go-micro-framework/microservice/configuration"
+	"go-micro-framework/microservice/server"
+	"log"
+)
+
+func main() {
+	kafkacfg := configuration.MyKafkaConfig()
+	err := kafkacfg.LoadConfig("kafka.config")
+	if err != nil {
+		log.Fatal("Failed to LoadConfig - %#v\n", err)
+		return
+	}
+
+	kp, err := server.MyKafkaProducer(kafkacfg)
+	if err != nil {
+		log.Fatal("Failed to MyKafkaProducer")
+		return
+	}
+
+	err = kp.Start()
+	if err != nil {
+		log.Fatal("Failed to Start Kafka Producer")
+		return
+	}
+	defer kp.Stop()
+
+	msg := server.Message{
+		Service:        server.Service("hello"),
+		ServiceMessage: "Nitish Malhotra",
+	}
+
+	err = kp.Produce("greeter", msg)
+	if err != nil {
+		log.Fatal("Failed to Produce")
+		return
+	}
+}

examples/producer.go

@@ -0,0 +1,8 @@
+{
+    "config": {
+        "brokers": ["0.0.0.0:9092"],
+        "group": 0,
+        "offset": -1,
+        "partition": 0
+    }
+}

examples/simple-microservice/kafka.json

@@ -0,0 +1,81 @@
+package main
+
+import (
+	"flag"
+	"fmt"
+	"go-micro-framework/examples/simple-microservice/server"
+	"go-micro-framework/examples/simple-microservice/service"
+	"os"
+
+	log "github.com/sirupsen/logrus"
+)
+
+var debug = flag.String("debug", "debug", "Debug levels : panic,fatal,error,warn,info,debug")
+
+func blockForever() {
+	c := make(chan struct{})
+	<-c
+}
+
+func init() {
+	//--- Setup the logrus logger ---
+	log.SetFormatter(&log.TextFormatter{})
+	log.SetOutput(os.Stdout)
+	log.SetLevel(log.DebugLevel)
+}
+
+func setLogLevel() {
+	flag.Parse()
+	switch *debug {
+	case "panic":
+		log.SetLevel(log.PanicLevel)
+		break
+	case "fatal":
+		log.SetLevel(log.FatalLevel)
+		break
+	case "error":
+		log.SetLevel(log.ErrorLevel)
+		break
+	case "warn":
+		log.SetLevel(log.WarnLevel)
+		break
+	case "info":
+		log.SetLevel(log.InfoLevel)
+		break
+	case "debug":
+		log.SetLevel(log.DebugLevel)
+		break
+	default:
+		fmt.Printf("Level %s not supported.", *debug)
+	}
+	fmt.Printf("=============================\n")
+	fmt.Printf("CURRENT LOG LEVEL : %s\n", log.GetLevel().String())
+	fmt.Printf("=============================\n")
+}
+
+func main() {
+	setLogLevel()
+
+	// Instantiate the ServiceMgr
+	ServiceMgr, err := service.MyServiceMgr()
+	if err != nil {
+		log.Fatalf("Failed MyServiceMgr - %v", err.Error())
+		return
+	}
+
+	// Register your server with the microservice
+	err = server.Register(ServiceMgr)
+	if err != nil {
+		log.Fatalf("Failed server Registration - %v", err.Error())
+		return
+	}
+
+	// Start all your servers registered with the microservice
+	err = ServiceMgr.Start()
+	if err != nil {
+		log.Fatalf("Failed Start - %v", err.Error())
+		return
+	}
+
+	blockForever()
+}

examples/simple-microservice/main

@@ -0,0 +1,32 @@
+package server
+
+import (
+	"go-micro-framework/microservice"
+	"go-micro-framework/microservice/configuration"
+	"go-micro-framework/microservice/server"
+)
+
+// Register your server here. Server options are available in SDS_common
+// microservice/server package.
+func Register(ms microservice.Microservice) (err error) {
+	kafkacfg := configuration.MyKafkaConfig()
+	err = kafkacfg.LoadConfig("kafka.json")
+	if err != nil {
+		return
+	}
+
+	// Instantiate the kafka server
+	kafkaserver, err := server.MyKafkaConsumer(kafkacfg)
+	if err != nil {
+		return
+	}
+
+	// Register the server with the microservice.
+	// Microservice.Start() walks through all the servers registered with the microservice
+	// and call their respective Start() routines.
+	err = ms.RegisterServer(server.ServerType("kafka"), kafkaserver)
+	if err != nil {
+		return
+	}
+	return
+}