.gitignore

@@ -1,2 +1,4 @@
 *.db
-*.out
+*.out
+vendor
+coverage.txt

.travis.yml

@@ -1,4 +1,5 @@
 language: go
+services: mongodb
 before_install:
   - go get github.com/rakanalh/scheduler
 script:

Gopkg.toml

@@ -0,0 +1,7 @@
+[[constraint]]
+  name = "github.com/mattn/go-sqlite3"
+  version = "1.4.0"
+
+[[constraint]]
+  name = "github.com/stretchr/testify"
+  version = "1.1.4"

LICENSE.md

@@ -0,0 +1,21 @@
+The MIT License (MIT)
+
+Copyright (c) 2015 Rakan Alhneiti
+
+Permission is hereby granted, free of charge, to any person obtaining a copy
+of this software and associated documentation files (the "Software"), to deal
+in the Software without restriction, including without limitation the rights
+to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+copies of the Software, and to permit persons to whom the Software is
+furnished to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in all
+copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+SOFTWARE

README.org

@@ -60,7 +60,7 @@ and then pass it to the scheduler.
 
 Scheduling tasks can be done in 3 ways:
 
-** Execute a task which after 5 seconds.
+** Execute a task after 5 seconds.
 #+BEGIN_SRC go
 func MyFunc(arg1 string, arg2 string)
 taskID := s.RunAfter(5*time.Second, MyFunc, "Hello", "World")
@@ -69,7 +69,7 @@ taskID := s.RunAfter(5*time.Second, MyFunc, "Hello", "World")
 ** Execute a task at a specific time.
 #+BEGIN_SRC go
 func MyFunc(arg1 string, arg2 string)
-taskID := s.RunAt(Time.Now.Add(24 * time.Hour, MyFunc, "Hello", "World")
+taskID := s.RunAt(time.Now().Add(24 * time.Hour), MyFunc, "Hello", "World")
 #+END_SRC
 
 ** Execute a task every 1 minute.

_example/mongo/main.go

@@ -0,0 +1,53 @@
+package main
+
+import (
+	"log"
+	"time"
+
+	"github.com/rakanalh/scheduler"
+	"github.com/rakanalh/scheduler/storage"
+)
+
+func TaskWithoutArgs() {
+	log.Println("TaskWithoutArgs is executed")
+}
+
+func TaskWithArgs(message string) {
+	log.Println("TaskWithArgs is executed. message:", message)
+}
+
+func main() {
+	storage := storage.NewMongoDBStorage(
+		storage.MongoDBConfig{
+			ConnectionUrl: "mongodb://localhost/example",
+			Db:            "example",
+		},
+	)
+
+	if err := storage.Connect(); err != nil {
+		log.Fatal("Could not connect to db", err)
+	}
+
+	if err := storage.Initialize(); err != nil {
+		log.Fatal("Could not intialize database", err)
+	}
+
+	s := scheduler.New(storage)
+
+	// Start a task without arguments
+	if _, err := s.RunAfter(30*time.Second, TaskWithoutArgs); err != nil {
+		log.Fatal(err)
+	}
+
+	// Start a task with arguments
+	if _, err := s.RunEvery(5*time.Second, TaskWithArgs, "Hello from recurring task 1"); err != nil {
+		log.Fatal(err)
+	}
+
+	// Start the same task as above with a different argument
+	if _, err := s.RunEvery(10*time.Second, TaskWithArgs, "Hello from recurring task 2"); err != nil {
+		log.Fatal(err)
+	}
+	s.Start()
+	s.Wait()
+}

_example/postgres/main.go

@@ -0,0 +1,53 @@
+package main
+
+import (
+	"io"
+	"log"
+	"time"
+
+	"github.com/rakanalh/scheduler"
+	"github.com/rakanalh/scheduler/storage"
+)
+
+func TaskWithoutArgs() {
+	log.Println("TaskWithoutArgs is executed")
+}
+
+func TaskWithArgs(message string) {
+	log.Println("TaskWithArgs is executed. message:", message)
+}
+
+func main() {
+	storage, err := storage.NewPostgresStorage(
+		storage.PostgresDBConfig{
+			DbURL: "postgresql://<db-username>:<db-password>@localhost:5432/scheduler?sslmode=disable",
+		},
+	)
+	if err != nil {
+		log.Fatalf("Couldn't create scheduler storage : %v", err)
+	}
+
+	s := scheduler.New(storage)
+
+	go func(s scheduler.Scheduler, store io.Closer) {
+		time.Sleep(time.Second * 10)
+		// store.Close()
+		s.Stop()
+	}(s, storage)
+	// Start a task without arguments
+	if _, err := s.RunAfter(60*time.Second, TaskWithoutArgs); err != nil {
+		log.Fatal(err)
+	}
+
+	// Start a task with arguments
+	if _, err := s.RunEvery(5*time.Second, TaskWithArgs, "Hello from recurring task 1"); err != nil {
+		log.Fatal(err)
+	}
+
+	// Start the same task as above with a different argument
+	if _, err := s.RunEvery(10*time.Second, TaskWithArgs, "Hello from recurring task 2"); err != nil {
+		log.Fatal(err)
+	}
+	s.Start()
+	s.Wait()
+}

mock.go

@@ -90,7 +90,9 @@ func (s *storeMock) Fetch() ([]storage.TaskAttributes, error) {
 func (s *storeMock) Remove(task storage.TaskAttributes) error {
 	return nil
 }
-
+func (s *storeMock) Close() error {
+	return nil
+}
 func mockFunction(a string, b int) {
 
 }