22
//
23
// Cancelation is asynchronous and may be not be respected by the operation's implementation.
24
>
func (h *OperationHandle[T]) Cancel(ctx context.Context, options nexus.CancelOperationOptions) error {
handle.go
25
>
u := h.client.serviceBaseURL.JoinPath(url.PathEscape(h.client.service), url.PathEscape(h.Operation), "cancel")
26
>
request, err := http.NewRequestWithContext(ctx, "POST", u.String(), nil)
27
>
if err != nil {
28
return err
29
}
30
>
request.Header.Set(nexus.HeaderOperationToken, h.Token)
handle.go
31
>
addContextTimeoutToHTTPHeader(ctx, request.Header)
32
>
request.Header.Set(headerUserAgent, userAgent)
33
>
addNexusHeaderToHTTPHeader(options.Header, request.Header)
34
>
response, err := h.client.httpCaller(request)
35
>
if err != nil {
36
return err
37
}