Documentation
¶
Overview ¶
Package execution implements the REAPI Execution service.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Register ¶
func Register(s *grpc.Server, executor *Executor, ac *actioncache.ActionCache, cas *blobstore.ContentAddressableStorage) error
Register creates and registers a new Service with the given gRPC server.
Types ¶
type Service ¶
type Service struct {
remote.UnimplementedExecutionServer
// contains filtered or unexported fields
}
Service implements the REAPI Execution service.
func NewService ¶
func NewService(executor *Executor, ac *actioncache.ActionCache, cas *blobstore.ContentAddressableStorage) (Service, error)
NewService creates a new Service.
func (Service) Execute ¶
func (s Service) Execute(request *remote.ExecuteRequest, executeServer remote.Execution_ExecuteServer) error
Execute executes the given action and returns the result.
func (Service) WaitExecution ¶
func (s Service) WaitExecution(request *remote.WaitExecutionRequest, executionServer remote.Execution_WaitExecutionServer) error
WaitExecution waits for the specified execution to complete.
Source Files
Click to show internal directories.
Click to hide internal directories.