107
}
108
109
>
func (l *Library) Tasks() []*chasm.RegistrableTask {
library.go
110
>
return []*chasm.RegistrableTask{
111
>
chasm.NewRegistrableSideEffectTask(
112
>
"invocation",
113
>
l.operationInvocationTaskHandler,
114
>
chasm.WithTaskGroup(TaskGroupName),
115
>
),
116
>
chasm.NewRegistrablePureTask("invocationBackoff", l.operationBackoffTaskHandler),
117
>
chasm.NewRegistrablePureTask("scheduleToStartTimeout", l.operationScheduleToStartTimeoutTaskHandler),
118
>
chasm.NewRegistrablePureTask("startToCloseTimeout", l.operationStartToCloseTimeoutTaskHandler),
119
>
chasm.NewRegistrablePureTask("scheduleToCloseTimeout", l.operationScheduleToCloseTimeoutTaskHandler),
120
>
chasm.NewRegistrableSideEffectTask(
121
>
"cancellation",
122
>
l.cancellationInvocationTaskHandler,
123
>
chasm.WithTaskGroup(TaskGroupName),
124
>
),
125
>
chasm.NewRegistrablePureTask("cancellationBackoff", l.cancellationBackoffTaskHandler),
126
>
}
127
>
}
128
129
func (l *Library) RegisterServices(server *grpc.Server) {