Merge pull request #1 from golang-queue/github

chore(CI): Add github actions

Author: appleboy

.github/workflows/lint.yml

@@ -0,0 +1,31 @@
+name: Run CI Lint
+on: push
+
+jobs:
+  test:
+    strategy:
+      matrix:
+        os: [ubuntu-latest, macos-latest]
+        go: [1.16, 1.17]
+    name: ${{ matrix.os }} @ Go ${{ matrix.go }}
+    runs-on: ${{ matrix.os }}
+
+    env:
+      GO111MODULE: on
+      TESTTAGS: ${{ matrix.test-tags }}
+      GOPROXY: https://proxy.golang.org
+    steps:
+      - name: Set up Go ${{ matrix.go }}
+        uses: actions/setup-go@v2
+        with:
+          go-version: ${{ matrix.go }}
+
+      - name: Checkout Code
+        uses: actions/checkout@v2
+        with:
+          ref: ${{ github.ref }}
+
+      - name: golangci-lint
+        uses: golangci/golangci-lint-action@v2
+        with:
+          version: v1.42.0

.github/workflows/testing.yml

@@ -0,0 +1,42 @@
+name: Run Testing
+on: push
+
+jobs:
+  # Label of the container job
+  runner-job:
+    # You must use a Linux environment when using service containers or container jobs
+    runs-on: ubuntu-latest
+
+    # Service containers to run with `container-job`
+    services:
+      # Label used to access the service container
+      redis:
+        # Docker Hub image
+        image: redis
+        # Set health checks to wait until redis has started
+        options: >-
+          --health-cmd "redis-cli ping"
+          --health-interval 10s
+          --health-timeout 5s
+          --health-retries 5
+        ports:
+          - 6379:6379
+
+    env:
+      GO111MODULE: on
+      GOPROXY: https://proxy.golang.org
+    steps:
+      - name: Set up Go ${{ matrix.go }}
+        uses: actions/setup-go@v2
+
+      - name: Checkout Code
+        uses: actions/checkout@v2
+        with:
+          ref: ${{ github.ref }}
+
+      - name: Run Tests
+        run: |
+          go test -v -covermode=atomic -coverprofile=coverage.out .
+
+      - name: Upload coverage to Codecov
+        uses: codecov/codecov-action@v1

redis.go

@@ -30,12 +30,11 @@ type Worker struct {
 	channel          string
 	channelSize      int
 
-	stopOnce  sync.Once
-	stop      chan struct{}
-	runFunc   func(context.Context, queue.QueuedMessage) error
-	logger    queue.Logger
-	stopFlag  int32
-	startFlag int32
+	stopOnce sync.Once
+	stop     chan struct{}
+	runFunc  func(context.Context, queue.QueuedMessage) error
+	logger   queue.Logger
+	stopFlag int32
 }
 
 // WithAddr setup the addr of NSQ