81
case enumsspb.CALLBACK_STATE_BACKING_OFF:
82
return []hsm.Task{BackoffTask{deadline: c.NextAttemptScheduleTime.AsTime()}}, nil
84
>
switch v := c.Callback.GetVariant().(type) {
85
>
case *persistencespb.Callback_Nexus_:
86
>
u, err := url.Parse(c.Callback.GetNexus().Url)
87
>
if err != nil {
88
return nil, fmt.Errorf("failed to parse URL: %v: %w", &c, err)
89
}
90
>
return []hsm.Task{InvocationTask{destination: u.Scheme + "://" + u.Host}}, nil
statemachine.go
91
case *persistencespb.Callback_Hsm:
92
// Destination is empty on the internal queue.