bonanza_scheduler

package
v0.0.0-...-43ed5bc Latest Latest
Warning

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

Go to latest
Published: Feb 25, 2026 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var File_bonanza_build_pkg_proto_configuration_bonanza_scheduler_bonanza_scheduler_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"`
	ClientGrpcServers                 []*grpc.ServerConfiguration               `protobuf:"bytes,3,rep,name=client_grpc_servers,json=clientGrpcServers,proto3" json:"client_grpc_servers,omitempty"`
	WorkerGrpcServers                 []*grpc.ServerConfiguration               `protobuf:"bytes,4,rep,name=worker_grpc_servers,json=workerGrpcServers,proto3" json:"worker_grpc_servers,omitempty"`
	BuildQueueStateGrpcServers        []*grpc.ServerConfiguration               `` /* 145-byte string literal not displayed */
	PredeclaredPlatformQueues         []*PredeclaredPlatformQueueConfiguration  `` /* 138-byte string literal not displayed */
	ActionRouter                      *scheduler.ActionRouterConfiguration      `protobuf:"bytes,7,opt,name=action_router,json=actionRouter,proto3" json:"action_router,omitempty"`
	PreviousExecutionStatsStore       *PreviousExecutionStatsStoreConfiguration `` /* 146-byte string literal not displayed */
	PlatformQueueWithNoWorkersTimeout *durationpb.Duration                      `` /* 168-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) GetActionRouter

func (*ApplicationConfiguration) GetBuildQueueStateGrpcServers

func (x *ApplicationConfiguration) GetBuildQueueStateGrpcServers() []*grpc.ServerConfiguration

func (*ApplicationConfiguration) GetClientGrpcServers

func (x *ApplicationConfiguration) GetClientGrpcServers() []*grpc.ServerConfiguration

func (*ApplicationConfiguration) GetGlobal

func (*ApplicationConfiguration) GetPlatformQueueWithNoWorkersTimeout

func (x *ApplicationConfiguration) GetPlatformQueueWithNoWorkersTimeout() *durationpb.Duration

func (*ApplicationConfiguration) GetPredeclaredPlatformQueues

func (x *ApplicationConfiguration) GetPredeclaredPlatformQueues() []*PredeclaredPlatformQueueConfiguration

func (*ApplicationConfiguration) GetPreviousExecutionStatsStore

func (x *ApplicationConfiguration) GetPreviousExecutionStatsStore() *PreviousExecutionStatsStoreConfiguration

func (*ApplicationConfiguration) GetWorkerGrpcServers

func (x *ApplicationConfiguration) GetWorkerGrpcServers() []*grpc.ServerConfiguration

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 PredeclaredPlatformQueueConfiguration

type PredeclaredPlatformQueueConfiguration struct {
	PkixPublicKeys                            [][]byte               `protobuf:"bytes,1,rep,name=pkix_public_keys,json=pkixPublicKeys,proto3" json:"pkix_public_keys,omitempty"`
	SizeClasses                               []uint32               `protobuf:"varint,2,rep,packed,name=size_classes,json=sizeClasses,proto3" json:"size_classes,omitempty"`
	WorkerInvocationStickinessLimits          []*durationpb.Duration `` /* 161-byte string literal not displayed */
	MaximumQueuedBackgroundLearningOperations int32                  `` /* 191-byte string literal not displayed */
	BackgroundLearningOperationPriority       int32                  `` /* 171-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*PredeclaredPlatformQueueConfiguration) Descriptor deprecated

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

Deprecated: Use PredeclaredPlatformQueueConfiguration.ProtoReflect.Descriptor instead.

func (*PredeclaredPlatformQueueConfiguration) GetBackgroundLearningOperationPriority

func (x *PredeclaredPlatformQueueConfiguration) GetBackgroundLearningOperationPriority() int32

func (*PredeclaredPlatformQueueConfiguration) GetMaximumQueuedBackgroundLearningOperations

func (x *PredeclaredPlatformQueueConfiguration) GetMaximumQueuedBackgroundLearningOperations() int32

func (*PredeclaredPlatformQueueConfiguration) GetPkixPublicKeys

func (x *PredeclaredPlatformQueueConfiguration) GetPkixPublicKeys() [][]byte

func (*PredeclaredPlatformQueueConfiguration) GetSizeClasses

func (x *PredeclaredPlatformQueueConfiguration) GetSizeClasses() []uint32

func (*PredeclaredPlatformQueueConfiguration) GetWorkerInvocationStickinessLimits

func (x *PredeclaredPlatformQueueConfiguration) GetWorkerInvocationStickinessLimits() []*durationpb.Duration

func (*PredeclaredPlatformQueueConfiguration) ProtoMessage

func (*PredeclaredPlatformQueueConfiguration) ProtoMessage()

func (*PredeclaredPlatformQueueConfiguration) ProtoReflect

func (*PredeclaredPlatformQueueConfiguration) Reset

func (*PredeclaredPlatformQueueConfiguration) String

type PreviousExecutionStatsStoreConfiguration

type PreviousExecutionStatsStoreConfiguration struct {
	GrpcClient             *grpc.ClientConfiguration `protobuf:"bytes,1,opt,name=grpc_client,json=grpcClient,proto3" json:"grpc_client,omitempty"`
	Namespace              *object.Namespace         `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	TagSignaturePrivateKey string                    `` /* 131-byte string literal not displayed */
	ObjectEncoders         []*encoding.BinaryEncoder `protobuf:"bytes,4,rep,name=object_encoders,json=objectEncoders,proto3" json:"object_encoders,omitempty"`
	// contains filtered or unexported fields
}

func (*PreviousExecutionStatsStoreConfiguration) Descriptor deprecated

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

Deprecated: Use PreviousExecutionStatsStoreConfiguration.ProtoReflect.Descriptor instead.

func (*PreviousExecutionStatsStoreConfiguration) GetGrpcClient

func (*PreviousExecutionStatsStoreConfiguration) GetNamespace

func (*PreviousExecutionStatsStoreConfiguration) GetObjectEncoders

func (*PreviousExecutionStatsStoreConfiguration) GetTagSignaturePrivateKey

func (x *PreviousExecutionStatsStoreConfiguration) GetTagSignaturePrivateKey() string

func (*PreviousExecutionStatsStoreConfiguration) ProtoMessage

func (*PreviousExecutionStatsStoreConfiguration) ProtoReflect

func (*PreviousExecutionStatsStoreConfiguration) Reset

func (*PreviousExecutionStatsStoreConfiguration) String

Jump to

Keyboard shortcuts

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