shijuvar

func init() {
	grpcLog = grpclog.NewLoggerV2(os.Stdout, os.Stderr, os.Stderr)
	grpclog.SetLoggerV2(grpcLog)
}
func main() {
	lis, err := net.Listen("tcp", port)
	if err != nil {
		grpcLog.Fatalf("failed to listen: %v", err)
	}
	// Creates a new gRPC server with UnaryInterceptor

shijuvar

// Authorization unary interceptor function to handle authorize per RPC call
func serverInterceptor(ctx context.Context,
	req interface{},
	info *grpc.UnaryServerInfo,
	handler grpc.UnaryHandler) (interface{}, error) {
	start := time.Now()
	// Skip authorize when GetJWT is requested
	if info.FullMethod != "/proto.EventStoreService/GetJWT" {
		if err := authorize(ctx); err != nil {
			return nil, err

shijuvar

package main

import (
	"encoding/json"
	"log"
	"runtime"

	stan "github.com/nats-io/go-nats-streaming"

	"github.com/shijuvar/gokit/examples/nats-streaming/pb"

shijuvar

package main

import (
	"encoding/json"
	"log"
	"runtime"
	"time"

	stan "github.com/nats-io/go-nats-streaming"

shijuvar

ackHandler := func(ackedNuid string, err error) {
        if err != nil {
            log.Printf("Error publishing message id %s: %v\n", ackedNuid, err.Error())
        } else {
            log.Printf("Received ACK for message id %s\n", ackedNuid)
        }
    }
	
 channel := event.Channel
 eventMsg := []byte(event.EventData)

shijuvar

package main

import (
	"context"
	"log"
	"net"

	stan "github.com/nats-io/go-nats-streaming"
	"google.golang.org/grpc"

shijuvar

const (
	queue   = "Order.OrdersCreatedQueue"
	subject = "Order.OrderCreated"
)

func main() {

	// Create server connection
	natsConnection, _ := nats.Connect(nats.DefaultURL)
	log.Println("Connected to " + nats.DefaultURL)

shijuvar

const subject = "Order.>"

func main() {

	// Create server connection
	natsConnection, _ := nats.Connect(nats.DefaultURL)
	log.Println("Connected to " + nats.DefaultURL)
	// Subscribe to subject
	natsConnection.Subscribe(subject, func(msg *nats.Msg) {
		eventStore := pb.EventStore{}

shijuvar

const (
	aggregate = "Order"
	event     = "OrderCreated"
)

// publishOrderCreated publish an event via NATS server
func publishOrderCreated(order *pb.Order) {
	// Connect to NATS server
	natsConnection, _ := nats.Connect(nats.DefaultURL)
	log.Println("Connected to " + nats.DefaultURL)

shijuvar

var orderServiceUri string
orderServiceUri = viper.GetString("discovery.orderservice")

func main() {
	// Create server connection
	natsConnection, _ := nats.Connect(nats.DefaultURL)
	log.Println("Connected to " + nats.DefaultURL)

	natsConnection.Subscribe("Discovery.OrderService", func(m *nats.Msg) {
		orderServiceDiscovery := pb.ServiceDiscovery{OrderServiceUri: orderServiceUri}