Documentation
¶
Index ¶
- func DialCloudWorkflowsExecutionService(ctx context.Context) (*workflowexecutions.Service, error)
- func DialRBECAS(ctx context.Context, dialOpts ...grpc.DialOption) (map[string]*rbeclient.Client, error)
- func DialSwarming(ctx context.Context) (swarmingv2.SwarmingV2Client, error)
- func FetchBenchmarkJSON(ctx context.Context, c *rbeclient.Client, rootDigest string) (map[string]perfresults.PerfResults, error)
- func FetchBenchmarkJSONRaw(ctx context.Context, c *rbeclient.Client, rootDigest string) (map[string][]byte, error)
- type CASResultReader
- type SwarmingTaskReader
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DialCloudWorkflowsExecutionService ¶
DialCloudWorkflowsExecutionService returns a google cloud workflows 'Executions' service client.
func DialRBECAS ¶
func DialRBECAS(ctx context.Context, dialOpts ...grpc.DialOption) (map[string]*rbeclient.Client, error)
DialRBECAS will attempt to dial a set of RBE-CAS service backends for CABE. We create one Client for each RBE-CAS instance we need to connect to, each of which is Dialed separately. Returns either a map of CAS instance name to Client, or an error if any of the Clients could not be Dialed.
func DialSwarming ¶
func DialSwarming(ctx context.Context) (swarmingv2.SwarmingV2Client, error)
func FetchBenchmarkJSON ¶
func FetchBenchmarkJSON(ctx context.Context, c *rbeclient.Client, rootDigest string) (map[string]perfresults.PerfResults, error)
FetchBenchmarkJSON fetches the benchmark results json files from the CAS root at rootDigest. It returns a map of benchmark name to perfresults.PerfResults parsed from the json bytes.
Types ¶
type CASResultReader ¶
type CASResultReader func(context.Context, string, string) (map[string]perfresults.PerfResults, error)
CASResultReader is an interface for getting PerfResults for CAS instance and root digest values.
type SwarmingTaskReader ¶
SwarmingTaskReader is an interface for getting Swarming task metadata associated with a pinpoint job.
Source Files