cron

cron

| | |

A simple tool that allows you to cron your jobs.

With support for modes

• from midnight
• recurring

Settings

Mode Year Month Day_of_week Day Hour Minute Second

0 1 1 1 0 0 0

Modes

• 0 - starts on midnight
• 1 - starts from now

Dependency Management

Dependency

Project dependencies are managed using Dependency. Read more about Dependency.

• Get dependency manager: go get github.com/joaosoft/dependency

• Install dependencies: dependency get
• Update dependencies: dependency update
• Reset dependencies: dependency reset
• Add dependencies: dependency add <dependency>
• Remove dependencies: dependency remove <dependency>

Go

go get github.com/joaosoft/cron

Configuration

{
  "cron": {
    "log": {
      "level": "debug"
    },
    "migration": {
      "path": {
        "database": "schema/db/postgres"
      },
      "db": {
        "schema": "cron",
        "driver": "postgres",
        "datasource": "postgres://user:password@localhost:7000/postgres?sslmode=disable&cron_path=cron"
      },
      "log": {
        "level": "info"
      }
    },
    "dbr": {
      "read_db": {
        "driver": "postgres",
        "datasource": "postgres://user:password@localhost:7000/postgres?sslmode=disable&cron_path=cron"
      },
      "write_db": {
        "driver": "postgres",
        "datasource": "postgres://user:password@localhost:7100/postgres?sslmode=disable&cron_path=cron"
      },
      "log": {
        "level": "debug"
      }
    }
  },
  "manager": {
    "log": {
      "level": "debug"
    }
  }
}

Usage

This examples are available in the project at cron/examples

func main() {
	// create cron
	myCron, err := cron.New()
	if err != nil {
		panic(err)
	}

	// add tasks to jobs
	myCron.
		AddJobTaskWithFuncs("teste1_key", canExecute, before, middle, after).
		AddJobTask("teste2_key", cron.NewTaskGeneric(canExecute, before, middle, after)).
		AddJobTaskWithFuncs("teste3_key", canExecute, before, middle, after)

	// wait
	myCron.Wait()
}

func canExecute() (bool, error) {
	logger.Info("executing can execute method")
	return true, nil
}

func before() error {
	logger.Info("executing before method")
	return nil
}

func middle() error {
	logger.Info("executing middle method")
	return nil
}

func after() error {
	logger.Info("executing after method")
	return nil
}

Result:

{"prefixes":{"level":"info","timestamp":"2019-06-14 19:04:29:19"},"tags":{"service":"manager"},"message":"config config_app added","sufixes":{"ip":"192.168.1.67"}}
{"prefixes":{"level":"info","timestamp":"2019-06-14 19:04:29:19"},"tags":{"service":"manager"},"message":"database db_postgres added","sufixes":{"ip":"192.168.1.67"}}
{"prefixes":{"level":"info","timestamp":"2019-06-14 19:04:29:19"},"tags":{"service":"manager"},"message":"database db-Read added","sufixes":{"ip":"192.168.1.67"}}
{"prefixes":{"level":"info","timestamp":"2019-06-14 19:04:29:19"},"tags":{"service":"manager"},"message":"database db-Write added","sufixes":{"ip":"192.168.1.67"}}
{"prefixes":{"level":"info","timestamp":"2019-06-14 19:04:29:19"},"tags":{"service":"cron"},"message":"scheduling job with name: teste1","sufixes":{"ip":"192.168.1.67"}}
{"prefixes":{"level":"info","timestamp":"2019-06-14 19:04:29:19"},"tags":{"service":"manager"},"message":"process teste1_key added","sufixes":{"ip":"192.168.1.67"}}
{"prefixes":{"level":"info","timestamp":"2019-06-14 19:04:29:19"},"tags":{"service":"cron"},"message":"scheduling job with name: teste2","sufixes":{"ip":"192.168.1.67"}}
{"prefixes":{"level":"info","timestamp":"2019-06-14 19:04:29:19"},"tags":{"service":"manager"},"message":"process teste2_key added","sufixes":{"ip":"192.168.1.67"}}
{"prefixes":{"level":"info","timestamp":"2019-06-14 19:04:29:19"},"tags":{"service":"manager"},"message":"starting...","sufixes":{"ip":"192.168.1.67"}}
{"prefixes":{"level":"info","timestamp":"2019-06-14 19:04:29:19"},"tags":{"service":"manager"},"message":"started [ process: teste1_key ]","sufixes":{"ip":"192.168.1.67"}}
{"prefixes":{"level":"info","timestamp":"2019-06-14 19:04:29:19"},"tags":{"service":"manager"},"message":"started [ process: teste2_key ]","sufixes":{"ip":"192.168.1.67"}}
{"prefixes":{"level":"info","timestamp":"2019-06-14 19:04:29:19"},"tags":{"service":"cron"},"message":"job teste2_key waiting next scheduled time 1m0s]","sufixes":{"ip":"192.168.1.67"}}
{"prefixes":{"level":"info","timestamp":"2019-06-14 19:04:29:19"},"tags":{"service":"cron"},"message":"job teste1_key waiting next scheduled time 23h41m30.132184s]","sufixes":{"ip":"192.168.1.67"}}
{"prefixes":{"level":"info","timestamp":"2019-06-14 19:04:29:19"},"tags":{"service":"manager"},"message":"started","sufixes":{"ip":"192.168.1.67"}}
{"prefixes":{"level":"info","timestamp":"2019-06-14 19:04:29:19"},"tags":{"service":"cron"},"message":"cron service started!","sufixes":{"ip":"192.168.1.67"}}
{"prefixes":{"level":"info","timestamp":"2019-06-14 19:04:29:19"},"tags":{"service":"cron"},"message":"waiting for quit signal...","sufixes":{"ip":"192.168.1.67"}}
{"prefixes":{"level":"info","timestamp":"2019-06-14 19:04:31:19"},"tags":{"service":"cron"},"message":"quitting cron","sufixes":{"ip":"192.168.1.67"}}

Known issues

Follow me at

Facebook: https://www.facebook.com/joaosoft

LinkedIn: https://www.linkedin.com/in/jo%C3%A3o-ribeiro-b2775438/