(reqMetadata, optsMetadata map[string]any)
| 2089 | } |
| 2090 | |
| 2091 | func mergeExecutorMetadata(reqMetadata, optsMetadata map[string]any) map[string]any { |
| 2092 | if len(reqMetadata) == 0 && len(optsMetadata) == 0 { |
| 2093 | return nil |
| 2094 | } |
| 2095 | merged := make(map[string]any, len(reqMetadata)+len(optsMetadata)) |
| 2096 | for key, value := range reqMetadata { |
| 2097 | merged[key] = value |
| 2098 | } |
| 2099 | for key, value := range optsMetadata { |
| 2100 | merged[key] = value |
| 2101 | } |
| 2102 | return merged |
| 2103 | } |
| 2104 | |
| 2105 | func mapExecutorStreamChunks(ctx context.Context, in <-chan pluginapi.ExecutorStreamChunk) <-chan coreexecutor.StreamChunk { |
| 2106 | if ctx == nil { |
no outgoing calls
no test coverage detected