Add go mod

core-go · Jul 27, 2024 · 058db31 · 058db31
1 parent ce3f9e5
commit 058db31
Show file tree

Hide file tree

Showing 7 changed files with 32 additions and 4 deletions.
diff --git a/consumer/consumer.go b/consumer/consumer.go
@@ -2,10 +2,15 @@ package consumer
 
 import "context"
 
+type SimpleConsumer struct {
+	Consume func(ctx context.Context, handle func(context.Context, []byte)
+	Handle  func(context.Context, []byte)
+}
+
 type Consumer struct {
-	Consume func(ctx context.Context, handle func(ctx context.Context, data []byte, header map[string]string, err error) error)
-	Handle func(ctx context.Context, data []byte, header map[string]string, err error) error
+	Consume func(ctx context.Context, handle func(context.Context, []byte, map[string]string))
+	Handle  func(context.Context, []byte, map[string]string)
 }
 
-type Handle func(ctx context.Context, data []byte, header map[string]string, err error) error
-type Consume func(ctx context.Context, handle func(ctx context.Context, data []byte, header map[string]string, err error) error)
+type Handle func(context.Context, []byte, map[string]string)
+type Consume func(context.Context, func(context.Context, []byte, map[string]string))
diff --git a/getter/getter.go b/getter/getter.go
@@ -2,6 +2,11 @@ package getter
 
 import "context"
 
+type SimpleGetter struct {
+	Get    func(ctx context.Context, handle func(context.Context, []byte)
+	Handle func(context.Context, []byte)
+}
+
 type Getter struct {
 	Get    func(ctx context.Context, handle func(context.Context, []byte, map[string]string))
 	Handle func(context.Context, []byte, map[string]string)

diff --git a/go.mod b/go.mod
@@ -0,0 +1,3 @@
+module github.com/core-go/mq
+
+go 1.18
diff --git a/go.sum b/go.sum
diff --git a/reader/reader.go b/reader/reader.go
@@ -2,6 +2,11 @@ package reader
 
 import "context"
 
+type SimpleReader struct {
+	Read   func(ctx context.Context, handle func(context.Context, []byte)
+	Handle func(context.Context, []byte)
+}
+
 type Reader struct {
 	Read   func(ctx context.Context, handle func(context.Context, []byte, map[string]string))
 	Handle func(context.Context, []byte, map[string]string)

diff --git a/receiver/receiver.go b/receiver/receiver.go
@@ -2,6 +2,11 @@ package receiver
 
 import "context"
 
+type SimpleReceiver struct {
+	Receive func(ctx context.Context, handle func(context.Context, []byte))
+	Handle  func(context.Context, []byte)
+}
+
 type Receiver struct {
 	Receive func(ctx context.Context, handle func(context.Context, []byte, map[string]string))
 	Handle  func(context.Context, []byte, map[string]string)

diff --git a/subscriber/subscriber.go b/subscriber/subscriber.go
@@ -2,6 +2,11 @@ package subscriber
 
 import "context"
 
+type SimpleSubscriber struct {
+	Subscribe func(ctx context.Context, handle func(context.Context, []byte))
+	Handle    func(context.Context, []byte)
+}
+
 type Subscriber struct {
 	Subscribe func(ctx context.Context, handle func(context.Context, []byte, map[string]string))
 	Handle    func(context.Context, []byte, map[string]string)