Standard library implementation of gocron function (testable)

王林
Release: 2024-02-15 12:51:08
forward
1046 people have browsed it

Standard library implementation of gocron function (testable)

php editor Baicao introduces you to a function called gocron, which is a standard library implementation and has testable features. The gocron function is designed to provide an easy way to create and manage scheduled tasks. It can help developers easily write and schedule multiple scheduled tasks, and also provides flexible testing functions to facilitate developers to conduct unit testing and functional verification. Whether in a development environment or a production environment, the gocron function is a powerful and reliable tool that can be used to implement various complex timing task requirements.

Question content

I need to run a job at certain intervals (hit the rest endpoint and then send a message to the queue). Currently I have this function which uses gocron - https://github.com/go-co-op/gocron

But there is currently no mechanism to stop this feature, so I can't test it cleanly.

func RunSchedule(cronExpression string, myFunction func()) error {
    scheduler := gocron.NewScheduler(time.UTC)
    _, err := scheduler.Cron(cronExpression).StartImmediately().Do(myFunction)
    if err != nil {
        return err
    }
    scheduler.StartBlocking()
    return nil
}
Copy after login

It does what is asked and runs the parameterized function at the required intervals, but I'm sure there must be a cleaner solution - probably the standard library.

Solution

You can just return the .stop function:

func runschedule(cronexpression string, myfunction func()) (stop func(), err error) {
    scheduler := gocron.newscheduler(time.utc)
    _, err = scheduler.cron(cronexpression).startimmediately().do(myfunction)
    if err != nil {
        return nil, err
    }
    go func() {
        scheduler.startblocking()
    }()

    return scheduler.stop, nil
}
Copy after login

Then in your test you can do the following:

called := 0
stop, err := RunSchedule("some-schedule", func() {
    called++
})
time.Sleep(time.Second * 1) // whatever you need to do 
stop()
if called != 1 {
    t.Fail("called should be 1")
}
Copy after login

The above is the detailed content of Standard library implementation of gocron function (testable). For more information, please follow other related articles on the PHP Chinese website!

Related labels:
source:stackoverflow.com
Statement of this Website
The content of this article is voluntarily contributed by netizens, and the copyright belongs to the original author. This site does not assume corresponding legal responsibility. If you find any content suspected of plagiarism or infringement, please contact admin@php.cn
Popular Tutorials
More>
Latest Downloads
More>
Web Effects
Website Source Code
Website Materials
Front End Template