bb_worker

package
v0.0.0-...-d03d5e3 Latest Latest
Warning

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

 Go to latest Published: Dec 15, 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 */
	InputDownloadConcurrency       int64                                     `` /* 137-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 (x *ApplicationConfiguration) GetBlobstore() *blobstore.BlobstoreConfiguration

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 (x *ApplicationConfiguration) GetDirectoryCache() *cas.CachingDirectoryFetcherConfiguration

func (*ApplicationConfiguration) GetFilePool 

func (x *ApplicationConfiguration) GetFilePool() *filesystem.FilePoolConfiguration

func (*ApplicationConfiguration) GetForceUploadTreesAndDirectories 

func (x *ApplicationConfiguration) GetForceUploadTreesAndDirectories() bool

func (*ApplicationConfiguration) GetGlobal 

func (x *ApplicationConfiguration) GetGlobal() *global.Configuration

func (*ApplicationConfiguration) GetInputDownloadConcurrency 

func (x *ApplicationConfiguration) GetInputDownloadConcurrency() int64

func (*ApplicationConfiguration) GetMaximumMessageSizeBytes 

func (x *ApplicationConfiguration) GetMaximumMessageSizeBytes() int64

func (*ApplicationConfiguration) GetOutputUploadConcurrency 

func (x *ApplicationConfiguration) GetOutputUploadConcurrency() int64

func (*ApplicationConfiguration) GetPrefetching 

func (x *ApplicationConfiguration) GetPrefetching() *PrefetchingConfiguration

func (*ApplicationConfiguration) GetScheduler 

func (x *ApplicationConfiguration) GetScheduler() *grpc.ClientConfiguration

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 (x *BuildDirectoryConfiguration) GetNative() *NativeBuildDirectoryConfiguration

func (*BuildDirectoryConfiguration) GetRunners 

func (x *BuildDirectoryConfiguration) GetRunners() []*RunnerConfiguration

func (*BuildDirectoryConfiguration) GetVirtual 

func (x *BuildDirectoryConfiguration) GetVirtual() *VirtualBuildDirectoryConfiguration

func (*BuildDirectoryConfiguration) ProtoMessage 

func (*BuildDirectoryConfiguration) ProtoMessage()

func (*BuildDirectoryConfiguration) ProtoReflect 

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

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 (x *CompletedActionLoggingConfiguration) GetClient() *grpc.ClientConfiguration

func (*CompletedActionLoggingConfiguration) GetMaximumSendQueueSize 

func (x *CompletedActionLoggingConfiguration) GetMaximumSendQueueSize() uint32

func (*CompletedActionLoggingConfiguration) ProtoMessage 

func (*CompletedActionLoggingConfiguration) ProtoMessage()

func (*CompletedActionLoggingConfiguration) ProtoReflect 

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

func (*CompletedActionLoggingConfiguration) Reset 

func (x *CompletedActionLoggingConfiguration) Reset()

func (*CompletedActionLoggingConfiguration) String 

func (x *CompletedActionLoggingConfiguration) String() 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 (x *NativeBuildDirectoryConfiguration) ProtoReflect() protoreflect.Message

func (*NativeBuildDirectoryConfiguration) Reset 

func (x *NativeBuildDirectoryConfiguration) Reset()

func (*NativeBuildDirectoryConfiguration) String 

func (x *NativeBuildDirectoryConfiguration) String() 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 */
	// 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) 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 (x *RunnerConfiguration) GetCostsPerSecond() map[string]*resourceusage.MonetaryResourceUsage_Expense

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 (x *VirtualBuildDirectoryConfiguration) GetMount() *virtual.MountConfiguration

func (*VirtualBuildDirectoryConfiguration) GetShuffleDirectoryListings 

func (x *VirtualBuildDirectoryConfiguration) GetShuffleDirectoryListings() bool

func (*VirtualBuildDirectoryConfiguration) ProtoMessage 

func (*VirtualBuildDirectoryConfiguration) ProtoMessage()

func (*VirtualBuildDirectoryConfiguration) ProtoReflect 

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

func (*VirtualBuildDirectoryConfiguration) Reset 

func (x *VirtualBuildDirectoryConfiguration) Reset()

func (*VirtualBuildDirectoryConfiguration) String 

func (x *VirtualBuildDirectoryConfiguration) String() string

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.