(ingress TaskIngressContext)
| 505 | } |
| 506 | |
| 507 | func networkTaskOriginRef(ingress TaskIngressContext) string { |
| 508 | return fmt.Sprintf( |
| 509 | "workspace:%s/channel:%s/peer:%s", |
| 510 | strings.TrimSpace(ingress.WorkspaceID), |
| 511 | strings.TrimSpace(ingress.Channel), |
| 512 | strings.TrimSpace(ingress.PeerID), |
| 513 | ) |
| 514 | } |
| 515 | |
| 516 | func withNetworkRunMetadata(spec taskpkg.EnqueueRun, ingress TaskIngressContext) (taskpkg.EnqueueRun, error) { |
| 517 | values, err := networkRunMetadataValues(ingress) |
no outgoing calls
no test coverage detected