mongodb

type Connector struct {
	DB     string // The MongoDB uri
	DBName string // Database name from MongoDB
	// contains filtered or unexported fields
}

type JobCollection struct {
	ID          primitive.ObjectID `bson:"_id"`
	JobName     string             `bson:"job_name"`
	FuncName    string             `bson:"func_name"`
	CronFormat  []string           `bson:"cron_format"`
	NextDate    time.Time          `bson:"next_date"`
	TotalTask   int                `bson:"total_task"`
	TotalRun    int                `bson:"total_run"`
	TotalError  int                `bson:"total_error"`
	SuccessRate float64            `bson:"success_rate"`
	ErrorRate   float64            `bson:"error_rate"`
}

type TaskCollection struct {
	JobId  primitive.ObjectID `bson:"job_id"`
	Params []interface{}      `bson:"params"`
}