Documentation ¶
Index ¶
Constants ¶
View Source
const Version = "2.0.0"
Variables ¶
View Source
var DefaultConfig = Config{
Jobs: jobsConfig{
RetryInterval: 60,
},
MySQL: mysqlConfig{
Host: "127.0.0.1",
Port: 3306,
DB: "test",
Table: "dalga",
User: "root",
Password: "",
MaxOpenConns: 50,
},
Listen: listenConfig{
Host: "127.0.0.1",
Port: 34006,
},
Endpoint: endpointConfig{
BaseURL: "http://127.0.0.1:5000/",
Timeout: 10,
},
}
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct { Jobs jobsConfig MySQL mysqlConfig Listen listenConfig Endpoint endpointConfig }
func (*Config) LoadFromFile ¶
type Dalga ¶
type Dalga struct { Jobs *jobmanager.JobManager // contains filtered or unexported fields }
Dalga is a job scheduler.
func (*Dalga) CreateTable ¶
CreateTable creates the table for storing jobs on database.
func (*Dalga) NotifyDone ¶
func (d *Dalga) NotifyDone() chan struct{}
NotifyDone returns a channel that will be closed when Run method returns.
Click to show internal directories.
Click to hide internal directories.