execution

Documentation

Overview

Bazel Remote Execution API gRPC server Contains limited implementation of the Execution API interface

Index

• Constants
• func CancelOperation(r dialer.Resolver, name string) (*empty.Empty, error)
• func Execute(r dialer.Resolver, actionDigest *remoteexecution.Digest, skipCache bool) (*longrunning.Operation, error)
• func ExecuteOperationToStr(op *longrunning.Operation) string
• func ExtractOpFromJson(opBytes []byte) (*longrunning.Operation, error)
• func GetOperation(r dialer.Resolver, name string) (*longrunning.Operation, error)
• func MakeExecutionServer(gc *bazel.GRPCConfig, s server.Scheduler, stat stats.StatsReceiver) *executionServer
• func OperationToJson(op *longrunning.Operation) ([]byte, error)
• func ParseExecuteOperation(op *longrunning.Operation) (*remoteexecution.ExecuteOperationMetadata, *status.Status, ...)

Constants

const (
	TaskIDPrefix   = "Bazel_ExecuteRequest"
	CommandDefault = "BZ_PLACEHOLDER"
)

Functions

func CancelOperation

func CancelOperation(r dialer.Resolver, name string) (*empty.Empty, error)

Make a CancelOperation request against a server support the google.longrunning.operations API Takes a Resolver and name of the Operation to Cancel

func Execute

func Execute(r dialer.Resolver, actionDigest *remoteexecution.Digest, skipCache bool) (*longrunning.Operation, error)

Makes an Execute request against a server supporting the google.devtools.remoteexecution API Takes a Resolver and ExecuteRequest data. Currently supported: * ActionDigest * SkipCache TBD support for: * Misc specs: InstanceName, Policies

func ExecuteOperationToStr

func ExecuteOperationToStr(op *longrunning.Operation) string

String conversion for human consumption of Operation's nested data

func ExtractOpFromJson

func ExtractOpFromJson(opBytes []byte) (*longrunning.Operation, error)

TODO - used by bazel-integration, may be possible to replace with OperationToJson via bzutil and remove this JSON unmarshalling doesn't work for Operations with nested Results, as they're of unexported type isOperation_Result. Thus, we need custom unmarshalling logic.

func GetOperation

func GetOperation(r dialer.Resolver, name string) (*longrunning.Operation, error)

Make a GetOperation request against a server supporting the google.longrunning.operations API Takes a Resolver and name of the Operation to Get

func MakeExecutionServer

func MakeExecutionServer(gc *bazel.GRPCConfig, s server.Scheduler, stat stats.StatsReceiver) *executionServer

Creates a new GRPCServer (executionServer) based on a GRPC config, scheduler, and stats, and preregisters the service

func OperationToJson

func OperationToJson(op *longrunning.Operation) ([]byte, error)

Converts a longrunning.Operation to a Json-encoded []byte. Because an Operation's Result field is not natively compatible with json.Marshal, this does the minimum necessary extraction of nested data and wrapping with custom types so that it can be used with Marshal.

func ParseExecuteOperation

func ParseExecuteOperation(op *longrunning.Operation) (*remoteexecution.ExecuteOperationMetadata,
	*status.Status, *remoteexecution.ExecuteResponse, error)

Parse a generic longrunning.Operation structure into expected Execution API components. Deserializes Operation.Metadata as an ExecuteOperationMetadata always. Checks for Operation.Result as a Response and if found deserializes as an ExecuteResponse. Per Bazel API, does not check for Operation.Result as a GRPC Status/Error - not allowed.