From 9630a2b277b33b2374e63cd43f12789c88c0f5fb Mon Sep 17 00:00:00 2001
From: sujit <s.baniya.np@gmail.com>
Date: Wed, 9 Oct 2024 00:08:21 +0545
Subject: [PATCH] feat: add example

---
 {v2 => dag}/dag.go          | 2 +-
 {v2 => dag}/task_manager.go | 2 +-
 examples/dag.go             | 7 ++++---
 3 files changed, 6 insertions(+), 5 deletions(-)
 rename {v2 => dag}/dag.go (99%)
 rename {v2 => dag}/task_manager.go (99%)

diff --git a/v2/dag.go b/dag/dag.go
similarity index 99%
rename from v2/dag.go
rename to dag/dag.go
index 2115ad4..224020d 100644
--- a/v2/dag.go
+++ b/dag/dag.go
@@ -1,4 +1,4 @@
-package v2
+package dag
 
 import (
 	"context"
diff --git a/v2/task_manager.go b/dag/task_manager.go
similarity index 99%
rename from v2/task_manager.go
rename to dag/task_manager.go
index 92f89c2..3a2347b 100644
--- a/v2/task_manager.go
+++ b/dag/task_manager.go
@@ -1,4 +1,4 @@
-package v2
+package dag
 
 import (
 	"context"
diff --git a/examples/dag.go b/examples/dag.go
index a228aea..c3fa15a 100644
--- a/examples/dag.go
+++ b/examples/dag.go
@@ -7,7 +7,7 @@ import (
 	"net/http"
 
 	"github.com/oarkflow/mq"
-	"github.com/oarkflow/mq/v2"
+	"github.com/oarkflow/mq/dag"
 )
 
 func handler1(ctx context.Context, task *mq.Task) mq.Result {
@@ -57,7 +57,8 @@ func handler6(ctx context.Context, task *mq.Task) mq.Result {
 }
 
 var (
-	d = v2.NewDAG(mq.WithSyncMode(true))
+	d = dag.NewDAG(mq.WithSyncMode(true))
+	// d = dag.NewDAG(mq.WithSyncMode(true), mq.WithTLS(true, "./certs/server.crt", "./certs/server.key"), mq.WithCAPath("./certs/ca.cert"))
 )
 
 func main() {
@@ -67,7 +68,7 @@ func main() {
 	d.AddNode("D", handler4)
 	d.AddNode("E", handler5)
 	d.AddNode("F", handler6)
-	d.AddEdge("A", "B", v2.LoopEdge)
+	d.AddEdge("A", "B", dag.LoopEdge)
 	d.AddCondition("C", map[string]string{"PASS": "D", "FAIL": "E"})
 	d.AddEdge("B", "C")
 	d.AddEdge("D", "F")