bb_worker

package
v0.0.0-...-ea22f37 Latest Latest
Warning

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

Go to latest
Published: Apr 1, 2024 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var File_pkg_proto_configuration_bb_worker_bb_worker_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type ApplicationConfiguration

type ApplicationConfiguration struct {
	Blobstore                      *blobstore.BlobstoreConfiguration         `protobuf:"bytes,1,opt,name=blobstore,proto3" json:"blobstore,omitempty"`
	BrowserUrl                     string                                    `protobuf:"bytes,2,opt,name=browser_url,json=browserUrl,proto3" json:"browser_url,omitempty"`
	MaximumMessageSizeBytes        int64                                     `` /* 135-byte string literal not displayed */
	Scheduler                      *grpc.ClientConfiguration                 `protobuf:"bytes,8,opt,name=scheduler,proto3" json:"scheduler,omitempty"`
	Global                         *global.Configuration                     `protobuf:"bytes,19,opt,name=global,proto3" json:"global,omitempty"`
	BuildDirectories               []*BuildDirectoryConfiguration            `protobuf:"bytes,20,rep,name=build_directories,json=buildDirectories,proto3" json:"build_directories,omitempty"`
	FilePool                       *filesystem.FilePoolConfiguration         `protobuf:"bytes,22,opt,name=file_pool,json=filePool,proto3" json:"file_pool,omitempty"`
	CompletedActionLoggers         []*CompletedActionLoggingConfiguration    `` /* 130-byte string literal not displayed */
	OutputUploadConcurrency        int64                                     `` /* 134-byte string literal not displayed */
	DirectoryCache                 *cas.CachingDirectoryFetcherConfiguration `protobuf:"bytes,25,opt,name=directory_cache,json=directoryCache,proto3" json:"directory_cache,omitempty"`
	Prefetching                    *PrefetchingConfiguration                 `protobuf:"bytes,26,opt,name=prefetching,proto3" json:"prefetching,omitempty"`
	ForceUploadTreesAndDirectories bool                                      `` /* 159-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ApplicationConfiguration) Descriptor deprecated

func (*ApplicationConfiguration) Descriptor() ([]byte, []int)

Deprecated: Use ApplicationConfiguration.ProtoReflect.Descriptor instead.

func (*ApplicationConfiguration) GetBlobstore

func (*ApplicationConfiguration) GetBrowserUrl

func (x *ApplicationConfiguration) GetBrowserUrl() string

func (*ApplicationConfiguration) GetBuildDirectories

func (x *ApplicationConfiguration) GetBuildDirectories() []*BuildDirectoryConfiguration

func (*ApplicationConfiguration) GetCompletedActionLoggers

func (x *ApplicationConfiguration) GetCompletedActionLoggers() []*CompletedActionLoggingConfiguration

func (*ApplicationConfiguration) GetDirectoryCache

func (*ApplicationConfiguration) GetFilePool

func (*ApplicationConfiguration) GetForceUploadTreesAndDirectories

func (x *ApplicationConfiguration) GetForceUploadTreesAndDirectories() bool

func (*ApplicationConfiguration) GetGlobal

func (*ApplicationConfiguration) GetMaximumMessageSizeBytes

func (x *ApplicationConfiguration) GetMaximumMessageSizeBytes() int64

func (*ApplicationConfiguration) GetOutputUploadConcurrency

func (x *ApplicationConfiguration) GetOutputUploadConcurrency() int64

func (*ApplicationConfiguration) GetPrefetching

func (*ApplicationConfiguration) GetScheduler

func (*ApplicationConfiguration) ProtoMessage

func (*ApplicationConfiguration) ProtoMessage()

func (*ApplicationConfiguration) ProtoReflect

func (x *ApplicationConfiguration) ProtoReflect() protoreflect.Message

func (*ApplicationConfiguration) Reset

func (x *ApplicationConfiguration) Reset()

func (*ApplicationConfiguration) String

func (x *ApplicationConfiguration) String() string

type BuildDirectoryConfiguration

type BuildDirectoryConfiguration struct {

	// Types that are assignable to Backend:
	//
	//	*BuildDirectoryConfiguration_Native
	//	*BuildDirectoryConfiguration_Virtual
	Backend isBuildDirectoryConfiguration_Backend `protobuf_oneof:"backend"`
	Runners []*RunnerConfiguration                `protobuf:"bytes,3,rep,name=runners,proto3" json:"runners,omitempty"`
	// contains filtered or unexported fields
}

func (*BuildDirectoryConfiguration) Descriptor deprecated

func (*BuildDirectoryConfiguration) Descriptor() ([]byte, []int)

Deprecated: Use BuildDirectoryConfiguration.ProtoReflect.Descriptor instead.

func (*BuildDirectoryConfiguration) GetBackend

func (m *BuildDirectoryConfiguration) GetBackend() isBuildDirectoryConfiguration_Backend

func (*BuildDirectoryConfiguration) GetNative

func (*BuildDirectoryConfiguration) GetRunners

func (*BuildDirectoryConfiguration) GetVirtual

func (*BuildDirectoryConfiguration) ProtoMessage

func (*BuildDirectoryConfiguration) ProtoMessage()

func (*BuildDirectoryConfiguration) ProtoReflect

func (*BuildDirectoryConfiguration) Reset

func (x *BuildDirectoryConfiguration) Reset()

func (*BuildDirectoryConfiguration) String

func (x *BuildDirectoryConfiguration) String() string

type BuildDirectoryConfiguration_Native

type BuildDirectoryConfiguration_Native struct {
	Native *NativeBuildDirectoryConfiguration `protobuf:"bytes,1,opt,name=native,proto3,oneof"`
}

type BuildDirectoryConfiguration_Virtual

type BuildDirectoryConfiguration_Virtual struct {
	Virtual *VirtualBuildDirectoryConfiguration `protobuf:"bytes,2,opt,name=virtual,proto3,oneof"`
}

type CompletedActionLoggingConfiguration

type CompletedActionLoggingConfiguration struct {
	Client                *grpc.ClientConfiguration `protobuf:"bytes,1,opt,name=client,proto3" json:"client,omitempty"`
	MaximumSendQueueSize  uint32                    `` /* 126-byte string literal not displayed */
	AddInstanceNamePrefix string                    `` /* 128-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CompletedActionLoggingConfiguration) Descriptor deprecated

func (*CompletedActionLoggingConfiguration) Descriptor() ([]byte, []int)

Deprecated: Use CompletedActionLoggingConfiguration.ProtoReflect.Descriptor instead.

func (*CompletedActionLoggingConfiguration) GetAddInstanceNamePrefix

func (x *CompletedActionLoggingConfiguration) GetAddInstanceNamePrefix() string

func (*CompletedActionLoggingConfiguration) GetClient

func (*CompletedActionLoggingConfiguration) GetMaximumSendQueueSize

func (x *CompletedActionLoggingConfiguration) GetMaximumSendQueueSize() uint32

func (*CompletedActionLoggingConfiguration) ProtoMessage

func (*CompletedActionLoggingConfiguration) ProtoMessage()

func (*CompletedActionLoggingConfiguration) ProtoReflect

func (*CompletedActionLoggingConfiguration) Reset

func (*CompletedActionLoggingConfiguration) String

type NativeBuildDirectoryConfiguration

type NativeBuildDirectoryConfiguration struct {
	BuildDirectoryPath     string                          `protobuf:"bytes,1,opt,name=build_directory_path,json=buildDirectoryPath,proto3" json:"build_directory_path,omitempty"`
	CacheDirectoryPath     string                          `protobuf:"bytes,2,opt,name=cache_directory_path,json=cacheDirectoryPath,proto3" json:"cache_directory_path,omitempty"`
	MaximumCacheFileCount  uint64                          `` /* 129-byte string literal not displayed */
	MaximumCacheSizeBytes  int64                           `` /* 129-byte string literal not displayed */
	CacheReplacementPolicy eviction.CacheReplacementPolicy `` /* 191-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*NativeBuildDirectoryConfiguration) Descriptor deprecated

func (*NativeBuildDirectoryConfiguration) Descriptor() ([]byte, []int)

Deprecated: Use NativeBuildDirectoryConfiguration.ProtoReflect.Descriptor instead.

func (*NativeBuildDirectoryConfiguration) GetBuildDirectoryPath

func (x *NativeBuildDirectoryConfiguration) GetBuildDirectoryPath() string

func (*NativeBuildDirectoryConfiguration) GetCacheDirectoryPath

func (x *NativeBuildDirectoryConfiguration) GetCacheDirectoryPath() string

func (*NativeBuildDirectoryConfiguration) GetCacheReplacementPolicy

func (x *NativeBuildDirectoryConfiguration) GetCacheReplacementPolicy() eviction.CacheReplacementPolicy

func (*NativeBuildDirectoryConfiguration) GetMaximumCacheFileCount

func (x *NativeBuildDirectoryConfiguration) GetMaximumCacheFileCount() uint64

func (*NativeBuildDirectoryConfiguration) GetMaximumCacheSizeBytes

func (x *NativeBuildDirectoryConfiguration) GetMaximumCacheSizeBytes() int64

func (*NativeBuildDirectoryConfiguration) ProtoMessage

func (*NativeBuildDirectoryConfiguration) ProtoMessage()

func (*NativeBuildDirectoryConfiguration) ProtoReflect

func (*NativeBuildDirectoryConfiguration) Reset

func (*NativeBuildDirectoryConfiguration) String

type PrefetchingConfiguration

type PrefetchingConfiguration struct {
	FileSystemAccessCache       *blobstore.BlobAccessConfiguration `` /* 128-byte string literal not displayed */
	BloomFilterBitsPerPath      uint32                             `` /* 134-byte string literal not displayed */
	BloomFilterMaximumSizeBytes uint32                             `` /* 149-byte string literal not displayed */
	DownloadConcurrency         int64                              `protobuf:"varint,4,opt,name=download_concurrency,json=downloadConcurrency,proto3" json:"download_concurrency,omitempty"`
	// contains filtered or unexported fields
}

func (*PrefetchingConfiguration) Descriptor deprecated

func (*PrefetchingConfiguration) Descriptor() ([]byte, []int)

Deprecated: Use PrefetchingConfiguration.ProtoReflect.Descriptor instead.

func (*PrefetchingConfiguration) GetBloomFilterBitsPerPath

func (x *PrefetchingConfiguration) GetBloomFilterBitsPerPath() uint32

func (*PrefetchingConfiguration) GetBloomFilterMaximumSizeBytes

func (x *PrefetchingConfiguration) GetBloomFilterMaximumSizeBytes() uint32

func (*PrefetchingConfiguration) GetDownloadConcurrency

func (x *PrefetchingConfiguration) GetDownloadConcurrency() int64

func (*PrefetchingConfiguration) GetFileSystemAccessCache

func (x *PrefetchingConfiguration) GetFileSystemAccessCache() *blobstore.BlobAccessConfiguration

func (*PrefetchingConfiguration) ProtoMessage

func (*PrefetchingConfiguration) ProtoMessage()

func (*PrefetchingConfiguration) ProtoReflect

func (x *PrefetchingConfiguration) ProtoReflect() protoreflect.Message

func (*PrefetchingConfiguration) Reset

func (x *PrefetchingConfiguration) Reset()

func (*PrefetchingConfiguration) String

func (x *PrefetchingConfiguration) String() string

type RunnerConfiguration

type RunnerConfiguration struct {
	Endpoint                                     *grpc.ClientConfiguration                               `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	Concurrency                                  uint64                                                  `protobuf:"varint,2,opt,name=concurrency,proto3" json:"concurrency,omitempty"`
	InstanceNamePrefix                           string                                                  `protobuf:"bytes,13,opt,name=instance_name_prefix,json=instanceNamePrefix,proto3" json:"instance_name_prefix,omitempty"`
	Platform                                     *v2.Platform                                            `protobuf:"bytes,3,opt,name=platform,proto3" json:"platform,omitempty"`
	SizeClass                                    uint32                                                  `protobuf:"varint,12,opt,name=size_class,json=sizeClass,proto3" json:"size_class,omitempty"`
	MaximumFilePoolFileCount                     int64                                                   `` /* 140-byte string literal not displayed */
	MaximumFilePoolSizeBytes                     int64                                                   `` /* 140-byte string literal not displayed */
	WorkerId                                     map[string]string                                       `` /* 173-byte string literal not displayed */
	InputRootCharacterDeviceNodes                []string                                                `` /* 154-byte string literal not displayed */
	CostsPerSecond                               map[string]*resourceusage.MonetaryResourceUsage_Expense `` /* 194-byte string literal not displayed */
	EnvironmentVariables                         map[string]string                                       `` /* 210-byte string literal not displayed */
	MaximumConsecutiveTestInfrastructureFailures uint32                                                  `` /* 201-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*RunnerConfiguration) Descriptor deprecated

func (*RunnerConfiguration) Descriptor() ([]byte, []int)

Deprecated: Use RunnerConfiguration.ProtoReflect.Descriptor instead.

func (*RunnerConfiguration) GetConcurrency

func (x *RunnerConfiguration) GetConcurrency() uint64

func (*RunnerConfiguration) GetCostsPerSecond

func (*RunnerConfiguration) GetEndpoint

func (x *RunnerConfiguration) GetEndpoint() *grpc.ClientConfiguration

func (*RunnerConfiguration) GetEnvironmentVariables

func (x *RunnerConfiguration) GetEnvironmentVariables() map[string]string

func (*RunnerConfiguration) GetInputRootCharacterDeviceNodes

func (x *RunnerConfiguration) GetInputRootCharacterDeviceNodes() []string

func (*RunnerConfiguration) GetInstanceNamePrefix

func (x *RunnerConfiguration) GetInstanceNamePrefix() string

func (*RunnerConfiguration) GetMaximumConsecutiveTestInfrastructureFailures

func (x *RunnerConfiguration) GetMaximumConsecutiveTestInfrastructureFailures() uint32

func (*RunnerConfiguration) GetMaximumFilePoolFileCount

func (x *RunnerConfiguration) GetMaximumFilePoolFileCount() int64

func (*RunnerConfiguration) GetMaximumFilePoolSizeBytes

func (x *RunnerConfiguration) GetMaximumFilePoolSizeBytes() int64

func (*RunnerConfiguration) GetPlatform

func (x *RunnerConfiguration) GetPlatform() *v2.Platform

func (*RunnerConfiguration) GetSizeClass

func (x *RunnerConfiguration) GetSizeClass() uint32

func (*RunnerConfiguration) GetWorkerId

func (x *RunnerConfiguration) GetWorkerId() map[string]string

func (*RunnerConfiguration) ProtoMessage

func (*RunnerConfiguration) ProtoMessage()

func (*RunnerConfiguration) ProtoReflect

func (x *RunnerConfiguration) ProtoReflect() protoreflect.Message

func (*RunnerConfiguration) Reset

func (x *RunnerConfiguration) Reset()

func (*RunnerConfiguration) String

func (x *RunnerConfiguration) String() string

type VirtualBuildDirectoryConfiguration

type VirtualBuildDirectoryConfiguration struct {
	Mount                               *virtual.MountConfiguration `protobuf:"bytes,1,opt,name=mount,proto3" json:"mount,omitempty"`
	MaximumExecutionTimeoutCompensation *durationpb.Duration        `` /* 170-byte string literal not displayed */
	ShuffleDirectoryListings            bool                        `` /* 136-byte string literal not displayed */
	HiddenFilesPattern                  string                      `protobuf:"bytes,4,opt,name=hidden_files_pattern,json=hiddenFilesPattern,proto3" json:"hidden_files_pattern,omitempty"`
	MaximumWritableFileUploadDelay      *durationpb.Duration        `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*VirtualBuildDirectoryConfiguration) Descriptor deprecated

func (*VirtualBuildDirectoryConfiguration) Descriptor() ([]byte, []int)

Deprecated: Use VirtualBuildDirectoryConfiguration.ProtoReflect.Descriptor instead.

func (*VirtualBuildDirectoryConfiguration) GetHiddenFilesPattern

func (x *VirtualBuildDirectoryConfiguration) GetHiddenFilesPattern() string

func (*VirtualBuildDirectoryConfiguration) GetMaximumExecutionTimeoutCompensation

func (x *VirtualBuildDirectoryConfiguration) GetMaximumExecutionTimeoutCompensation() *durationpb.Duration

func (*VirtualBuildDirectoryConfiguration) GetMaximumWritableFileUploadDelay

func (x *VirtualBuildDirectoryConfiguration) GetMaximumWritableFileUploadDelay() *durationpb.Duration

func (*VirtualBuildDirectoryConfiguration) GetMount

func (*VirtualBuildDirectoryConfiguration) GetShuffleDirectoryListings

func (x *VirtualBuildDirectoryConfiguration) GetShuffleDirectoryListings() bool

func (*VirtualBuildDirectoryConfiguration) ProtoMessage

func (*VirtualBuildDirectoryConfiguration) ProtoMessage()

func (*VirtualBuildDirectoryConfiguration) ProtoReflect

func (*VirtualBuildDirectoryConfiguration) Reset

func (*VirtualBuildDirectoryConfiguration) String

Jump to

Keyboard shortcuts

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