bonanza_worker

package
v0.0.0-...-929fcf4 Latest Latest
Warning

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

Go to latest
Published: Jan 15, 2026 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var File_bonanza_build_pkg_proto_configuration_bonanza_worker_bonanza_worker_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type ApplicationConfiguration

type ApplicationConfiguration struct {
	Global                 *global.Configuration             `protobuf:"bytes,1,opt,name=global,proto3" json:"global,omitempty"`
	StorageGrpcClient      *grpc.ClientConfiguration         `protobuf:"bytes,2,opt,name=storage_grpc_client,json=storageGrpcClient,proto3" json:"storage_grpc_client,omitempty"`
	SchedulerGrpcClient    *grpc.ClientConfiguration         `protobuf:"bytes,3,opt,name=scheduler_grpc_client,json=schedulerGrpcClient,proto3" json:"scheduler_grpc_client,omitempty"`
	BuildDirectories       []*BuildDirectoryConfiguration    `protobuf:"bytes,4,rep,name=build_directories,json=buildDirectories,proto3" json:"build_directories,omitempty"`
	FilePool               *filesystem.FilePoolConfiguration `protobuf:"bytes,5,opt,name=file_pool,json=filePool,proto3" json:"file_pool,omitempty"`
	LocalObjectStore       *local.StoreConfiguration         `protobuf:"bytes,7,opt,name=local_object_store,json=localObjectStore,proto3" json:"local_object_store,omitempty"`
	ParsedObjectPool       *parser.ParsedObjectPool          `protobuf:"bytes,6,opt,name=parsed_object_pool,json=parsedObjectPool,proto3" json:"parsed_object_pool,omitempty"`
	ObjectStoreConcurrency int64                             `` /* 130-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) GetBuildDirectories

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

func (*ApplicationConfiguration) GetFilePool

func (*ApplicationConfiguration) GetGlobal

func (*ApplicationConfiguration) GetLocalObjectStore

func (x *ApplicationConfiguration) GetLocalObjectStore() *local.StoreConfiguration

func (*ApplicationConfiguration) GetObjectStoreConcurrency

func (x *ApplicationConfiguration) GetObjectStoreConcurrency() int64

func (*ApplicationConfiguration) GetParsedObjectPool

func (x *ApplicationConfiguration) GetParsedObjectPool() *parser.ParsedObjectPool

func (*ApplicationConfiguration) GetSchedulerGrpcClient

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

func (*ApplicationConfiguration) GetStorageGrpcClient

func (x *ApplicationConfiguration) GetStorageGrpcClient() *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 {
	Runners []*RunnerConfiguration      `protobuf:"bytes,1,rep,name=runners,proto3" json:"runners,omitempty"`
	Mount   *virtual.MountConfiguration `protobuf:"bytes,2,opt,name=mount,proto3" json:"mount,omitempty"`
	// contains filtered or unexported fields
}

func (*BuildDirectoryConfiguration) Descriptor deprecated

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

Deprecated: Use BuildDirectoryConfiguration.ProtoReflect.Descriptor instead.

func (*BuildDirectoryConfiguration) GetMount

func (*BuildDirectoryConfiguration) GetRunners

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 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"`
	PlatformPrivateKeys                 []string                                     `protobuf:"bytes,3,rep,name=platform_private_keys,json=platformPrivateKeys,proto3" json:"platform_private_keys,omitempty"`
	ClientCertificateVerifier           *x509.ClientCertificateVerifierConfiguration `` /* 138-byte string literal not displayed */
	SizeClass                           uint32                                       `protobuf:"varint,5,opt,name=size_class,json=sizeClass,proto3" json:"size_class,omitempty"`
	IsLargestSizeClass                  bool                                         `protobuf:"varint,6,opt,name=is_largest_size_class,json=isLargestSizeClass,proto3" json:"is_largest_size_class,omitempty"`
	ShuffleDirectoryListings            bool                                         `` /* 136-byte string literal not displayed */
	HiddenFilesPattern                  string                                       `protobuf:"bytes,8,opt,name=hidden_files_pattern,json=hiddenFilesPattern,proto3" json:"hidden_files_pattern,omitempty"`
	MaximumExecutionTimeoutCompensation *durationpb.Duration                         `` /* 170-byte string literal not displayed */
	MaximumWritableFileUploadDelay      *durationpb.Duration                         `` /* 158-byte string literal not displayed */
	MaximumFilePoolFileCount            uint64                                       `` /* 141-byte string literal not displayed */
	MaximumFilePoolSizeBytes            uint64                                       `` /* 141-byte string literal not displayed */
	WorkerId                            map[string]string                            `` /* 160-byte string literal not displayed */
	EnvironmentVariables                map[string]string                            `` /* 196-byte string literal not displayed */
	BuildDirectoryOwnerUserId           uint32                                       `` /* 144-byte string literal not displayed */
	BuildDirectoryOwnerGroupId          uint32                                       `` /* 147-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) GetBuildDirectoryOwnerGroupId

func (x *RunnerConfiguration) GetBuildDirectoryOwnerGroupId() uint32

func (*RunnerConfiguration) GetBuildDirectoryOwnerUserId

func (x *RunnerConfiguration) GetBuildDirectoryOwnerUserId() uint32

func (*RunnerConfiguration) GetClientCertificateVerifier

func (x *RunnerConfiguration) GetClientCertificateVerifier() *x509.ClientCertificateVerifierConfiguration

func (*RunnerConfiguration) GetConcurrency

func (x *RunnerConfiguration) GetConcurrency() uint64

func (*RunnerConfiguration) GetEndpoint

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

func (*RunnerConfiguration) GetEnvironmentVariables

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

func (*RunnerConfiguration) GetHiddenFilesPattern

func (x *RunnerConfiguration) GetHiddenFilesPattern() string

func (*RunnerConfiguration) GetIsLargestSizeClass

func (x *RunnerConfiguration) GetIsLargestSizeClass() bool

func (*RunnerConfiguration) GetMaximumExecutionTimeoutCompensation

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

func (*RunnerConfiguration) GetMaximumFilePoolFileCount

func (x *RunnerConfiguration) GetMaximumFilePoolFileCount() uint64

func (*RunnerConfiguration) GetMaximumFilePoolSizeBytes

func (x *RunnerConfiguration) GetMaximumFilePoolSizeBytes() uint64

func (*RunnerConfiguration) GetMaximumWritableFileUploadDelay

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

func (*RunnerConfiguration) GetPlatformPrivateKeys

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

func (*RunnerConfiguration) GetShuffleDirectoryListings

func (x *RunnerConfiguration) GetShuffleDirectoryListings() bool

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

Jump to

Keyboard shortcuts

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