Documentation
¶
Overview ¶
Package concurrentxcom holds the pull_xcoms_concurrently task in its own package, so main.go can register tasks defined across packages with one RegisterDags.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func PullXComsConcurrently ¶
PullXComsConcurrently pulls a batch of XComs sequentially then concurrently (one goroutine per item), exercising concurrent reads of the injected sdk.Client, and returns both timings.
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.