1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
|
package main
import (
"fmt"
"time"
"github.com/getsentry/sentry-go"
)
func runTask(monitorSlug string, duration time.Duration, shouldFail bool) {
checkinId := sentry.CaptureCheckIn(
&sentry.CheckIn{
MonitorSlug: monitorSlug,
Status: sentry.CheckInStatusInProgress,
},
&sentry.MonitorConfig{
Schedule: sentry.CrontabSchedule("* * * * *"),
MaxRuntime: 2,
CheckInMargin: 1,
},
)
task := fmt.Sprintf("Task[monitor_slug=%s,id=%s]", monitorSlug, *checkinId)
fmt.Printf("Task started: %s\n", task)
time.Sleep(duration)
var status sentry.CheckInStatus
if shouldFail {
status = sentry.CheckInStatusError
} else {
status = sentry.CheckInStatusOK
}
sentry.CaptureCheckIn(
&sentry.CheckIn{
ID: *checkinId,
MonitorSlug: monitorSlug,
Status: status,
},
nil,
)
fmt.Printf("Task finished: %s; Status: %s\n", task, status)
}
func main() {
_ = sentry.Init(sentry.ClientOptions{
Dsn: "",
Debug: true,
})
// Start a task that runs every minute and always succeeds
go func() {
for {
go runTask("sentry-go-periodic-task-success", time.Second, false)
time.Sleep(time.Minute)
}
}()
time.Sleep(3 * time.Second)
// Start a task that runs every minute and fails every second time
go func() {
shouldFail := true
for {
go runTask("sentry-go-periodic-task-sometimes-fail", 2*time.Second, shouldFail)
time.Sleep(time.Minute)
shouldFail = !shouldFail
}
}()
select {}
}
|
