Introduction

The project is a distributed task scheduling service, which is mainly used to schedule and execute Linux crontab tasks. Store crontab tasks through etcd and provide distributed locks for multiple workers. The master module is responsible for the addition, deletion, modification and query of tasks on the HTTP interface. The worker node is responsible for monitoring etcd changes and maintaining a scheduling table in memory. Multiple worker nodes can execute tasks concurrently.

Start

The service depends on etcd and mongodb. Please configure the environment first.

Start the master and start only one instance.

cd master/main
go run main. go

Start worker to start multiple instances.

cd worker/main
go run worker. go

Api

Save job interface:
POST /job/save
{
    "name":"test",   
    "command":"echo hello",
    "express":"*/5 * * * * * *"
}

Delete job interface:
GET /job/delete/{name}

Query job interface:
GET /job/list

Interrupt job interface:
GET /job/interrupt/{name}

Query job log interface:
GET /log/list/{name}?skip={0}&limit={20}

Query worker node interface:
GET /worker/list