add a simple entrypoint

executor.go → crony/executor.go

@@ -1,4 +1,4 @@
-package cron
+package crony
 
 type Executor interface {
  Execute(command string) error

job.go → crony/job.go

@@ -1,4 +1,4 @@
-package cron
+package crony
 
 type Job struct {
  Schedule Schedule

pattern.go → crony/pattern.go

@@ -1,4 +1,4 @@
-package cron
+package crony
 
 import(
  "fmt"

pattern_test.go → crony/pattern_test.go

@@ -1,4 +1,4 @@
-package cron
+package crony
 
 import(
  "testing"

main.go

@@ -0,0 +1,23 @@
+package main
+
+import (
+ "fmt"
+ "github.com/pitluga/crony/crony"
+ "github.com/pitluga/crony/server"
+ "time"
+)
+
+func main() {
+ done := make(chan string)
+ server.Start(
+ crony.CreateFakeExecutor(),
+ []crony.Job{
+ crony.Job{crony.Parse("* * * * * *"), "echo hi"},
+ },
+ time.Minute,
+ )
+
+ fmt.Print("Server Started...\n")
+
+ fmt.Print(<-done)
+}

server.go → server/server.go

@@ -1,25 +1,26 @@
-package cron
+package server
 
-import(
+import (
+ "github.com/pitluga/crony/crony"
  "time"
 )
 
 type Server struct {
- executor Executor
- ticker *time.Ticker
- jobs []Job
+ executor crony.Executor
+ ticker  *time.Ticker
+ jobs  []crony.Job
 }
 
-func Start(executor Executor, jobs []Job, interval time.Duration) *Server {
+func Start(executor crony.Executor, jobs []crony.Job, interval time.Duration) *Server {
  ticker := time.NewTicker(interval)
 
  server := &Server{
  executor: executor,
- jobs: jobs,
- ticker: ticker,
+ jobs:  jobs,
+ ticker:  ticker,
  }
 
- go func () {
+ go func() {
  for now := range ticker.C {
  server.Once(now)
  }

server_test.go → server/server_test.go

@@ -1,16 +1,16 @@
-package cron
+package server
 
-import(
+import (
+ "github.com/pitluga/crony/crony"
  "testing"
  "time"
 )
 
-
 func TestOnceWithNoJobsDoesNothing(t *testing.T) {
- executor := CreateFakeExecutor()
+ executor := crony.CreateFakeExecutor()
  server := &Server{
  executor: executor,
- jobs: make([]Job, 0),
+ jobs:  make([]crony.Job, 0),
  }
 
  server.Once(time.Now())
@@ -21,11 +21,11 @@ func TestOnceWithNoJobsDoesNothing(t *testing.T) {
 }
 
 func TestOnceWithAWildcardJobRunsIt(t *testing.T) {
- executor := CreateFakeExecutor()
+ executor := crony.CreateFakeExecutor()
  server := &Server{
  executor: executor,
- jobs: []Job{
- Job{Parse("* * * * * *"), "echo hi"},
+ jobs: []crony.Job{
+ crony.Job{crony.Parse("* * * * * *"), "echo hi"},
  },
  }
 
@@ -41,11 +41,11 @@ func TestOnceWithAWildcardJobRunsIt(t *testing.T) {
 }
 
 func TestStartStopWithSingleJob(t *testing.T) {
- executor := CreateFakeExecutor()
+ executor := crony.CreateFakeExecutor()
  server := Start(
  executor,
- []Job{Job{Parse("* * * * * *"), "echo hi"}},
- time.Millisecond * 10,
+ []crony.Job{crony.Job{crony.Parse("* * * * * *"), "echo hi"}},
+ time.Millisecond*10,
  )
 
  timer := time.NewTimer(time.Millisecond * 12)