From a943bbfd5bef61b8c3e2b602d2806524916bb413 Mon Sep 17 00:00:00 2001
From: Yudha Subki <yudhasubki@gmail.com>
Date: Thu, 1 Feb 2024 06:05:58 +0700
Subject: [PATCH] docs: add example using in Go Program

---
 example/basic/main.go | 80 +++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 80 insertions(+)
 create mode 100644 example/basic/main.go

diff --git a/example/basic/main.go b/example/basic/main.go
new file mode 100644
index 0000000..07bb626
--- /dev/null
+++ b/example/basic/main.go
@@ -0,0 +1,80 @@
+package main
+
+import (
+	"context"
+	"fmt"
+	"log"
+	"time"
+
+	"github.com/yudhasubki/blockqueue"
+	"github.com/yudhasubki/blockqueue/pkg/etcd"
+	"github.com/yudhasubki/blockqueue/pkg/io"
+	"github.com/yudhasubki/blockqueue/pkg/sqlite"
+)
+
+func main() {
+	db, err := sqlite.New("example", sqlite.Config{
+		BusyTimeout: 5,
+	})
+	if err != nil {
+		panic(err)
+	}
+
+	etcd, err := etcd.New("etcdb")
+	if err != nil {
+		panic(err)
+	}
+
+	ctx := context.Background()
+	stream := blockqueue.New(db, etcd)
+
+	err = stream.Run(ctx)
+	if err != nil {
+		panic(err)
+	}
+
+	request := io.Topic{
+		Name: "test",
+		Subscribers: io.Subscribers{
+			{
+				Name: "test_subscriber",
+			},
+		},
+	}
+
+	topic := request.Topic()
+
+	err = stream.AddJob(ctx, topic, request.Subscriber(topic.Id))
+	if err != nil {
+		panic(err)
+	}
+
+	go func() {
+		for {
+			response, err := stream.Read(context.Background(), topic, "test_subscriber")
+			if err != nil {
+				log.Printf("error %v", err)
+				continue
+			}
+
+			for _, r := range response {
+				log.Println("Response Message : ", r.Message)
+				err = stream.Ack(context.Background(), topic, "test_subscriber", r.Id)
+				if err != nil {
+					log.Printf("error ack message : %v", err)
+					continue
+				}
+
+				log.Println("success ack message")
+			}
+		}
+	}()
+
+	for i := 0; i < 10; i++ {
+		stream.Publish(ctx, topic, io.Publish{
+			Message: fmt.Sprintf("Test %v", i),
+		})
+	}
+
+	time.Sleep(5 * time.Second)
+}