task

func DistriTaskBootstrap ¶

func DistriTaskBootstrap(rail miso.Rail) error

func IsTaskMaster ¶

func IsTaskMaster(rail miso.Rail) bool

Check if current node is master

func IsTaskSchedulingDisabled ¶

func IsTaskSchedulingDisabled() bool

Check if it's disabled (based on configuration, doesn't affect method call)

func ScheduleDistributedTask ¶

func ScheduleDistributedTask(t miso.Job) error

Schedule a named distributed task

Applications are grouped together as a cluster (each cluster is differentiated by its group name), only the master node can run the Scheduled tasks.

Tasks are pending until StartTaskSchedulerAsync() is called.

E.g.,

job := miso.Job{
	Name:            "Very important task",
	Cron:            "0/1 * * * * ?",
	CronWithSeconds: true,
	Run: MyTask,
}
ScheduleDistributedTask(job)

func SetScheduleGroup ¶

func SetScheduleGroup(groupName string)

Set the schedule group for current node, by default it's 'default'

func StartTaskSchedulerAsync ¶

func StartTaskSchedulerAsync(rail miso.Rail) error

Start distributed scheduler asynchronously

func StartTaskSchedulerBlocking ¶

func StartTaskSchedulerBlocking(rail miso.Rail) error

Start distributed scheduler, current routine is blocked

func StopTaskScheduler ¶

func StopTaskScheduler()

Shutdown distributed job scheduling