chore: golangci

Author: zenghur

.golangci.yml

@@ -0,0 +1,62 @@
+linters-settings:
+  govet:
+    check-shadowing: true
+    settings:
+      printf:
+        funcs:
+          - (github.com/golangci/golangci-lint/pkg/logutils.Log).Infof
+          - (github.com/golangci/golangci-lint/pkg/logutils.Log).Warnf
+          - (github.com/golangci/golangci-lint/pkg/logutils.Log).Errorf
+          - (github.com/golangci/golangci-lint/pkg/logutils.Log).Fatalf
+  golint:
+    min-confidence: 0
+  gocyclo:
+    min-complexity: 10
+  maligned:
+    suggest-new: true
+  dupl:
+    threshold: 100
+  goconst:
+    min-len: 2
+    min-occurrences: 2
+  depguard:
+    list-type: blacklist
+    packages:
+      # logging is allowed only by logutils.Log, logrus
+      # is allowed to use only in logutils package
+      - github.com/sirupsen/logrus
+  misspell:
+    locale: US
+  lll:
+    line-length: 140
+  goimports:
+    local-prefixes: github.com/golangci/golangci-lint
+  gocritic:
+    enabled-tags:
+      - performance
+      - style
+      - experimental
+    disabled-checks:
+      - wrapperFunc
+      - dupImport # https://github.com/go-critic/go-critic/issues/845
+
+linters:
+  enable-all: true
+  disable:
+    - maligned
+    - prealloc
+    - gochecknoglobals
+
+run:
+  skip-dirs:
+    - test/testdata_etc
+    - pkg/golinters/goanalysis/(checker|passes)
+
+issues:
+  exclude-rules:
+    - text: "weak cryptographic primitive"
+      linters:
+        - gosec
+
+
+

Gopkg.lock

@@ -27,7 +27,7 @@
 
 [[constraint]]
   name = "github.com/xiaojiaoyu100/curlew"
-  version = "0.0.1"
+  version = "0.1.0"
 
 [prune]
   unused-packages = true

Gopkg.toml

@@ -3,8 +3,9 @@ package roc
 import (
 	"container/list"
 	"context"
-	"github.com/xiaojiaoyu100/curlew"
 	"time"
+
+	"github.com/xiaojiaoyu100/curlew"
 )
 
 type Cache struct {
@@ -16,7 +17,6 @@ type Cache struct {
 }
 
 func New(setters ...Setter) (*Cache, error) {
-	var err error
 	c := new(Cache)
 	c.GCInterval = 60 * time.Second
 	c.BucketNum = 16
@@ -41,7 +41,10 @@ func New(setters ...Setter) (*Cache, error) {
 		c.buckets = append(c.buckets, bucket)
 	}
 
-	c.dispatcher, err = curlew.New()
+	monitor := func(err error) {}
+
+	var err error
+	c.dispatcher, err = curlew.New(curlew.WithMonitor(monitor))
 	if err != nil {
 		return nil, err
 	}
@@ -58,17 +61,15 @@ func (c *Cache) gc() {
 		for {
 			select {
 			case <-ticker.C:
-				{
-					for _, bucket := range c.buckets {
-						j := curlew.NewJob()
-						j.Fn = func(_ context.Context, arg interface{}) error {
-							b := arg.(*Bucket)
-							b.gc()
-							return nil
-						}
-						j.Arg = bucket
-						c.dispatcher.SubmitAsync(j)
+				for _, bucket := range c.buckets {
+					j := curlew.NewJob()
+					j.Fn = func(_ context.Context, arg interface{}) error {
+						b := arg.(*Bucket)
+						b.gc()
+						return nil
 					}
+					j.Arg = bucket
+					c.dispatcher.SubmitAsync(j)
 				}
 			case <-c.close:
 				return

cache.go

@@ -10,13 +10,15 @@ func isPowerOfTwo(num int) bool {
 	return (num != 0) && ((num & (num - 1)) == 0)
 }
 
+// WithBucketNum set the number of buckets
 func WithBucketNum(num int) Setter {
 	return func(c *Cache) error {
 		c.BucketNum = num
 		return nil
 	}
 }
 
+// WithGCInterval sets the gc cycle.
 func WithGCInterval(interval time.Duration) Setter {
 	return func(c *Cache) error {
 		c.GCInterval = interval

setter.go

@@ -2,12 +2,14 @@ package roc
 
 import "time"
 
+// Unit represents a store unit
 type Unit struct {
 	Key            string
 	Data           interface{}
 	ExpirationTime time.Time
 }
 
+// Expire returns true when unit has expired.
 func (u *Unit) Expire() bool {
 	return u.ExpirationTime.Before(time.Now().UTC())
 }