event-driven

event-driven

A robust Go library designed to simplify distributed transactions in microservices architecture. It provides:

• Saga Pattern implementation with orchestrator
• Message queue integration
• Transaction monitoring and tracking
• Automatic cleanup of old transactions
• Built-in Grafana dashboards
• Easy-to-use SDK for producers and consumers

INSTALL

go get -u github.com/IsaacDSC/event-driven

Functionalities

Dashboard

• SERVER HTTP
  • Save transactions on database
  • Dashboard to monitor transactions
  • Removed transaction every (30 Days)

SAGA PATTERN - ORCHESTRATOR

Use Repository to monitoring queues

Init project

go mod init eventdrivenexample

touch main.go

go get -u github.com/IsaacDSC/event-driven

Create tables on pgDatabase

• 1.1 Download this schema and running in to database

wget https://github.com/IsaacDSC/event-driven/blob/main/internal/sqlc/schema.sql

Create instance repository main.go

package main

import (
	"context"
	"event-driven/SDK"
	"event-driven/internal/example/checkout/domains"
	"event-driven/repository"
	"event-driven/types"
	"time"
)

const connectionString = "user=root password=root dbname=event-driven sslmode=disable"

func main() {
	repo, err := repository.NewPgAdapter(connectionString)
	if err != nil {
		panic(err)
	}

	defer repo.Close()
}

Producer message example

Create file producer.go

mkdir producer && touch producer/producer.go

Add code this file producer.go

package producer

import (
	"context"
	"event-driven/SDK"
	"event-driven/internal/example/checkout/domains"
	"event-driven/repository"
	"event-driven/types"
	"time"
)

func producer(repo types.Repository) {
	pd := SDK.NewProducer(rdAddr, repo, &types.Opts{
		MaxRetry: 5,
		DeadLine: time.Now().Add(15 * time.Minute),
	})

	input := map[string]any{
		"order_id":     "79a369da-0d71-4e3f-b504-e1f793220e60",
		"client":       "John Doe",
		"client_email": "[email protected]",
		"products": []map[string]any{
			{
				"product_id": "79a369da-0d71-4e3f-b504-e1f793220e60",
				"quantity":   1,
				"price":      100.00,
			},
			{
				"product_id": "79a369da-0d71-4e3f-b504-e1f793220e60",
				"quantity":   3,
				"price":      400.00,
			},
		},
		"total":  500.00,
		"status": "pending",
	}

	if err := pd.SagaProducer(context.Background(), EventCheckoutCreated, input); err != nil {
		return err
	}

}

Consumers message example

Create file consumer.go

mkdir consumer && touch consumer/consumer.go

Add code this file consumer.go

package consumer

import (
	"context"
	"event-driven/SDK"
	"event-driven/internal/example/checkout/domains"
	"event-driven/repository"
	"event-driven/types"
	"time"
)

const rdAddr = "localhost:6379"

func consumer(repo types.Repository) error {
	sgPayment := domains.NewPayment()
	sgStock := domains.NewStock()
	sgDelivery := domains.NewDelivery()
	sgNotify := domains.NewNotify()

	sp := SDK.NewSagaPattern(rdAddr, repo, []types.ConsumerInput{
		sgPayment,
		sgStock,
		sgDelivery,
		sgNotify,
	}, types.Opts{
		MaxRetry: 3,
	}, false)

	if err := sp.WithConsumerServer(rdAddr, repo).AddHandlers(map[string]types.ConsumerFn{
		EventCheckoutCreated: sp.Consumer,
	}).Start(); err != nil {
		return err
	}

	return nil
}

Contributing

We welcome contributions to make this library even better! Please read our Contributing Guidelines to get started.

The project follows a trunk-based development model, and all contributions should be made through pull requests targeting the main branch.