feat: add service package

Makefile

@@ -47,3 +47,8 @@ rm-test-db:
 .PHONY: run-migration
 run-migration:
 	go run cmd/psqlqueue/main.go migrate
+
+.PHONY: create-mocks
+create-mocks:
+	@rm -rf mocks
+	mockery --all

domain/message.go

@@ -67,3 +67,11 @@ type MessageRepository interface {
 	Ack(ctx context.Context, id string) error
 	Nack(ctx context.Context, id string, visibilityTimeoutSeconds uint) error
 }
+
+// MessageService is the service interface for the Message entity.
+type MessageService interface {
+	Create(ctx context.Context, message *Message) error
+	List(ctx context.Context, queueID, label *string, limit uint) ([]*Message, error)
+	Ack(ctx context.Context, id string) error
+	Nack(ctx context.Context, id string, visibilityTimeoutSeconds uint) error
+}

domain/queue.go

@@ -47,3 +47,15 @@ type QueueRepository interface {
 	Purge(ctx context.Context, id string) error
 	Cleanup(ctx context.Context, id string) error
 }
+
+// QueueService is the service interface for the Queue entity.
+type QueueService interface {
+	Create(ctx context.Context, queue *Queue) error
+	Update(ctx context.Context, queue *Queue) error
+	Get(ctx context.Context, id string) (*Queue, error)
+	List(ctx context.Context, offset, limit int) ([]*Queue, error)
+	Delete(ctx context.Context, id string) error
+	Stats(ctx context.Context, id string) (*QueueStats, error)
+	Purge(ctx context.Context, id string) error
+	Cleanup(ctx context.Context, id string) error
+}

go.mod

@@ -35,6 +35,7 @@ require (
 	github.com/jackc/puddle/v2 v2.2.1 // indirect
 	github.com/pmezard/go-difflib v1.0.0 // indirect
 	github.com/russross/blackfriday/v2 v2.1.0 // indirect
+	github.com/stretchr/objx v0.5.0 // indirect
 	github.com/xrash/smetrics v0.0.0-20201216005158-039620a65673 // indirect
 	go.uber.org/atomic v1.7.0 // indirect
 	golang.org/x/crypto v0.17.0 // indirect