( index int, designation contract.TaskFanOutRunDesignationRequest, )
| 3291 | } |
| 3292 | |
| 3293 | func nativeFanOutDesignationMetadata( |
| 3294 | index int, |
| 3295 | designation contract.TaskFanOutRunDesignationRequest, |
| 3296 | ) (json.RawMessage, error) { |
| 3297 | brief := strings.TrimSpace(designation.Brief) |
| 3298 | if brief == "" { |
| 3299 | return nil, fmt.Errorf("designations[%d].brief is required", index) |
| 3300 | } |
| 3301 | metadata := cloneJSON(designation.Metadata) |
| 3302 | if len(metadata) > 0 && !json.Valid(metadata) { |
| 3303 | return nil, fmt.Errorf("designations[%d].metadata must be valid JSON", index) |
| 3304 | } |
| 3305 | encoded, err := json.Marshal(nativeFanOutDesignationMetadataPayload{ |
| 3306 | Designation: nativeFanOutDesignationMetadataDetail{Index: index, Brief: brief}, |
| 3307 | Metadata: metadata, |
| 3308 | }) |
| 3309 | if err != nil { |
| 3310 | return nil, fmt.Errorf("task fan-out metadata: %w", err) |
| 3311 | } |
| 3312 | return encoded, nil |
| 3313 | } |
| 3314 | |
| 3315 | func nativeFanOutDesignationIdempotencyKey( |
| 3316 | requestKey string, |
no test coverage detected