import "github.com/apache/beam/sdks/go/pkg/beam/x/hooks/perf"
Package perf is to add performance measuring hooks to a runner, such as cpu, heap, or trace profiles.
EnableHeapCaptureHook actives a registered heap profile capture hook for a given pipeline.
EnableProfCaptureHook actives a registered profile capture hook for a given pipeline.
EnableTraceCaptureHook actives a registered profile capture hook for a given pipeline.
func RegisterHeapCaptureHook(name string, c CaptureHookFactory)
RegisterHeapCaptureHook registers a CaptureHookFactory for the supplied identifier. It panics if the same identifier is registered twice.
func RegisterProfCaptureHook(name string, c CaptureHookFactory)
RegisterProfCaptureHook registers a CaptureHookFactory for the supplied identifier. It panics if the same identifier is registered twice.
func RegisterTraceCaptureHook(name string, c CaptureHookFactory)
RegisterTraceCaptureHook registers a CaptureHookFactory for the supplied identifier. It panics if the same identifier is registered twice.
CaptureHook is used by the harness to have the runner persist a trace record with the supplied name and comment. The type of trace can be determined by the prefix of the string.
* prof: A profile compatible with traces produced by runtime/pprof * trace: A trace compatible with traces produced by runtime/trace
type CaptureHookFactory func([]string) CaptureHook
CaptureHookFactory creates a CaptureHook from the supplied options.
Package perf imports 8 packages (graph) and is imported by 1 packages. Updated 2019-01-29. Refresh now. Tools for package owners.