fifo by default

.gitignore

@@ -0,0 +1 @@
+.idea

enqueue.go

@@ -21,10 +21,16 @@ type EnqueueData struct {
 	EnqueueOptions
 }
 
+const (
+	fifo = iota + 1
+	lifo
+)
+
 type EnqueueOptions struct {
 	RetryCount int     `json:"retry_count,omitempty"`
 	Retry      bool    `json:"retry,omitempty"`
 	At         float64 `json:"at,omitempty"`
+	Policy	   int		`json:"policy,omitempty"`
 }
 
 func generateJid() string {
@@ -38,15 +44,15 @@ func generateJid() string {
 }
 
 func Enqueue(queue, class string, args interface{}) (string, error) {
-	return EnqueueWithOptions(queue, class, args, EnqueueOptions{At: nowToSecondsWithNanoPrecision()})
+	return EnqueueWithOptions(queue, class, args, EnqueueOptions{At: nowToSecondsWithNanoPrecision(),Policy: fifo})
 }
 
 func EnqueueIn(queue, class string, in float64, args interface{}) (string, error) {
-	return EnqueueWithOptions(queue, class, args, EnqueueOptions{At: nowToSecondsWithNanoPrecision() + in})
+	return EnqueueWithOptions(queue, class, args, EnqueueOptions{At: nowToSecondsWithNanoPrecision() + in,Policy: fifo})
 }
 
 func EnqueueAt(queue, class string, at time.Time, args interface{}) (string, error) {
-	return EnqueueWithOptions(queue, class, args, EnqueueOptions{At: timeToSecondsWithNanoPrecision(at)})
+	return EnqueueWithOptions(queue, class, args, EnqueueOptions{At: timeToSecondsWithNanoPrecision(at),Policy: fifo})
 }
 
 func EnqueueWithOptions(queue, class string, args interface{}, opts EnqueueOptions) (string, error) {
@@ -78,7 +84,11 @@ func EnqueueWithOptions(queue, class string, args interface{}, opts EnqueueOptio
 		return "", err
 	}
 	queue = Config.Namespace + "queue:" + queue
-	_, err = conn.Do("rpush", queue, bytes)
+	if opts.Policy == fifo {
+		_, err = conn.Do("lpush", queue, bytes)
+	} else{
+		_, err = conn.Do("rpush", queue, bytes)
+	}
 	if err != nil {
 		return "", err
 	}

go.mod

@@ -0,0 +1,3 @@
+module github.com/itering/go-workers
+
+go 1.14