command

package
v0.0.0-...-1b293c9 Latest Latest
Warning

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

Go to latest
Published: Sep 3, 2025 License: Apache-2.0 Imports: 44 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetPathPatternWithChildren

func GetPathPatternWithChildren[TMetadata model_core.ReferenceMetadata](
	children model_core.PatchedMessage[*model_command_pb.PathPattern_Children, TMetadata],
	externalObject *model_core.Decodable[model_core.CreatedObject[TMetadata]],
	patcher *model_core.ReferenceMessagePatcher[TMetadata],
	objectCapturer model_core.CreatedObjectCapturer[TMetadata],
) *model_command_pb.PathPattern

func NewLocalExecutor

func NewLocalExecutor(
	objectDownloader object.Downloader[object.GlobalReference],
	parsedObjectPool *model_parser.ParsedObjectPool,
	dagUploaderClient dag_pb.UploaderClient,
	objectContentsWalkerSemaphore *semaphore.Weighted,
	topLevelDirectory TopLevelDirectory,
	handleAllocator virtual.StatefulHandleAllocator,
	filePool pool.FilePool,
	symlinkFactory virtual.SymlinkFactory,
	initialContentsSorter virtual.Sorter,
	hiddenFilesMatcher virtual.StringMatcher,
	runner runner_pb.RunnerClient,
	clock clock.Clock,
	uuidGenerator util.UUIDGenerator,
	maximumWritableFileUploadDelay time.Duration,
	environmentVariables map[string]string,
	buildDirectoryOwnerUserID uint32,
	buildDirectoryOwnerGroupID uint32,
	maximumExecutionTimeoutCompensation time.Duration,
) remoteworker.Executor[*model_executewithstorage.Action[object.GlobalReference], model_core.Decodable[object.LocalReference], model_core.Decodable[object.LocalReference]]

func PathPatternGetChildren

func PathPatternGetChildren[TReference any](
	ctx context.Context,
	reader model_parser.ParsedObjectReader[model_core.Decodable[TReference], model_core.Message[*model_command_pb.PathPattern_Children, TReference]],
	pathPattern model_core.Message[*model_command_pb.PathPattern, TReference],
) (model_core.Message[*model_command_pb.PathPattern_Children, TReference], error)

PathPatternGetChildren returns the list of children contained in a PathPattern entry. This either causes it to return children that are inlined or stored externally.

func PrependDirectoryToPathPatternChildren

func PrependDirectoryToPathPatternChildren[TMetadata model_core.ReferenceMetadata](name string, grandChildren model_core.PatchedMessage[*model_command_pb.PathPattern_Children, TMetadata], encoder model_encoding.BinaryEncoder, inlinedTreeOptions *inlinedtree.Options, objectCapturer model_core.CreatedObjectCapturer[TMetadata]) (model_core.PatchedMessage[*model_command_pb.PathPattern_Children, TMetadata], error)

Types

type PathPatternSet

type PathPatternSet[TMetadata model_core.ReferenceMetadata] struct {
	// contains filtered or unexported fields
}

PathPatternSet is a set of relative pathname strings that should be captured by a remote worker after execution of an action completes.

func (*PathPatternSet[TMetadata]) Add

func (s *PathPatternSet[TMetadata]) Add(path iter.Seq[string])

func (*PathPatternSet[TMetadata]) ToProto

func (s *PathPatternSet[TMetadata]) ToProto(encoder model_encoding.BinaryEncoder, inlinedTreeOptions *inlinedtree.Options, objectCapturer model_core.CreatedObjectCapturer[TMetadata]) (model_core.PatchedMessage[*model_command_pb.PathPattern_Children, TMetadata], error)

ToProto converts the set of relative pathname strings contained in the set to a PathPattern message that can be embedded in a Command message, which is to be processed by a remote worker.

type TopLevelDirectory

type TopLevelDirectory interface {
	AddChild(ctx context.Context, name path.Component, child virtual.DirectoryChild) error
	RemoveChild(name path.Component)
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL