36
[]callbackspb.CallbackStatus{callbackspb.CALLBACK_STATUS_BACKING_OFF},
37
callbackspb.CALLBACK_STATUS_SCHEDULED,
38
>
func(cb *Callback, ctx chasm.MutableContext, event EventRescheduled) error {
statemachine.go
39
>
cb.NextAttemptScheduleTime = nil
40
>
u, err := url.Parse(cb.Callback.GetNexus().Url)
41
>
if err != nil {
42
return fmt.Errorf("failed to parse URL: %v: %w", cb.Callback, err)
43
}
45
>
cb,
46
>
chasm.TaskAttributes{Destination: u.Scheme + "://" + u.Host},
47
>
&callbackspb.InvocationTask{Attempt: cb.Attempt},
48
>
)
49
>
return nil
50
},
51
)