bazeldaemon

package
v0.1.23-oss Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 3, 2026 License: Apache-2.0 Imports: 33 Imported by: 0

README

Building using remote execution

  1. Start the server:

    $ MNT= $ go run ./cmd/abfs-bazel-daemon $MNT

  2. Build hello:

    $ cd test $ bazel clean # force build $ bazel --batch --digest_function=BLAKE3 build
    --remote_executor grpc://localhost:5823
    --experimental_remote_output_service grpc://localhost:5823
    --verbose_failures
    --experimental_remote_output_service_output_path_prefix=$MNT/output
    hello

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetArtifactLocator 

func GetArtifactLocator(pbLocator *anypb.Any) (*outputservice.FileArtifactLocator, error)

func HashFromResourceName 

func HashFromResourceName(resource string) (entities.Hash, int64, error)

Types

type Build 

type Build struct {
	Start        time.Time
	Duration     time.Duration
	BuildID      string
	OutputBaseID string
	OutputPath   string
}

type BuildExec 

type BuildExec struct {
	// contains filtered or unexported fields
}

type Server 

type Server struct {
	outputservice.UnimplementedBazelOutputServiceServer
	// contains filtered or unexported fields
}

func NewServer 

func NewServer(store entities.CASStore, client *binding.Client, root, buildOut string, nsjail bool, forceRun bool) *Server

func (*Server) BatchReadBlobs 

func (s *Server) BatchReadBlobs(context.Context, *re.BatchReadBlobsRequest) (*re.BatchReadBlobsResponse, error)

func (*Server) BatchStat 

func (s *Server) BatchStat(ctx context.Context, req *outputservice.BatchStatRequest) (*outputservice.BatchStatResponse, error)

BatchStat implements outputservice.BazelOutputServiceServer.

func (*Server) BatchUpdateBlobs 

func (s *Server) BatchUpdateBlobs(context.Context, *re.BatchUpdateBlobsRequest) (*re.BatchUpdateBlobsResponse, error)

func (*Server) Clean 

func (s *Server) Clean(ctx context.Context, req *outputservice.CleanRequest) (*outputservice.CleanResponse, error)

Clean implements outputservice.BazelOutputServiceServer.

func (*Server) Execute 

func (s *Server) Execute(in *re.ExecuteRequest, out re.Execution_ExecuteServer) error

Methods for Execution service.

func (*Server) FinalizeArtifacts 

func (s *Server) FinalizeArtifacts(ctx context.Context, req *outputservice.FinalizeArtifactsRequest) (*outputservice.FinalizeArtifactsResponse, error)

FinalizeArtifacts implements outputservice.BazelOutputServiceServer.

func (*Server) FinalizeBuild 

func (s *Server) FinalizeBuild(ctx context.Context, req *outputservice.FinalizeBuildRequest) (*outputservice.FinalizeBuildResponse, error)

FinalizeBuild implements outputservice.BazelOutputServiceServer.

func (*Server) FindMissingBlobs 

func (s *Server) FindMissingBlobs(ctx context.Context, req *re.FindMissingBlobsRequest) (*re.FindMissingBlobsResponse, error)

FindMissingBlobs parallelizes the checking of blob existence to improve performance. It uses a worker pool pattern to limit the number of concurrent operations and ensures thread-safe collection of missing digests and error handling.

func (*Server) GetActionResult 

func (s *Server) GetActionResult(ctx context.Context, in *re.GetActionResultRequest) (*re.ActionResult, error)

func (*Server) GetCapabilities 

func (s *Server) GetCapabilities(ctx context.Context, in *re.GetCapabilitiesRequest) (*re.ServerCapabilities, error)

Methods for Capabilities service.

func (*Server) GetTree 

func (s *Server) GetTree(*re.GetTreeRequest, re.ContentAddressableStorage_GetTreeServer) error

func (*Server) QueryWriteStatus 

func (s *Server) QueryWriteStatus(ctx context.Context, req *bytestream.QueryWriteStatusRequest) (*bytestream.QueryWriteStatusResponse, error)

func (*Server) Read 

func (s *Server) Read(req *bytestream.ReadRequest, resp bytestream.ByteStream_ReadServer) (retErr error)

Methods for ByteStream service.

func (*Server) Register 

func (s *Server) Register(grpcServer *grpc.Server)

func (*Server) SpliceBlob 

func (s *Server) SpliceBlob(context.Context, *re.SpliceBlobRequest) (*re.SpliceBlobResponse, error)

func (*Server) SplitBlob 

func (s *Server) SplitBlob(context.Context, *re.SplitBlobRequest) (*re.SplitBlobResponse, error)

func (*Server) StageArtifacts 

func (s *Server) StageArtifacts(ctx context.Context, req *outputservice.StageArtifactsRequest) (*outputservice.StageArtifactsResponse, error)

StageArtifacts implements outputservice.BazelOutputServiceServer.

func (*Server) StartBuild 

func (s *Server) StartBuild(ctx context.Context, req *outputservice.StartBuildRequest) (*outputservice.StartBuildResponse, error)

StartBuild implements outputservice.BazelOutputServiceServer.

func (*Server) UpdateActionResult 

func (s *Server) UpdateActionResult(ctx context.Context, in *re.UpdateActionResultRequest) (*re.ActionResult, error)

func (*Server) WaitExecution 

func (s *Server) WaitExecution(in *re.WaitExecutionRequest, out re.Execution_WaitExecutionServer) error

func (*Server) Write 

func (s *Server) Write(srv bytestream.ByteStream_WriteServer) error

type Span 

type Span struct {
	// contains filtered or unexported fields
}

func NewSpan 

func NewSpan(format string, v ...any) *Span

func (*Span) End 

func (s *Span) End()

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.