bb_scheduler

package
v0.0.0-...-31d23d1 Latest Latest
Warning

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

 Go to latest Published: Feb 1, 2025 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_pkg_proto_configuration_bb_scheduler_bb_scheduler_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type ApplicationConfiguration 

type ApplicationConfiguration struct {
	AdminHttpServers                  []*http.ServerConfiguration              `protobuf:"bytes,19,rep,name=admin_http_servers,json=adminHttpServers,proto3" json:"admin_http_servers,omitempty"`
	AdminRoutePrefix                  string                                   `protobuf:"bytes,22,opt,name=admin_route_prefix,json=adminRoutePrefix,proto3" json:"admin_route_prefix,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"`
	BrowserUrl                        string                                   `protobuf:"bytes,5,opt,name=browser_url,json=browserUrl,proto3" json:"browser_url,omitempty"`
	ContentAddressableStorage         *blobstore.BlobAccessConfiguration       `` /* 138-byte string literal not displayed */
	MaximumMessageSizeBytes           int64                                    `` /* 135-byte string literal not displayed */
	Global                            *global.Configuration                    `protobuf:"bytes,8,opt,name=global,proto3" json:"global,omitempty"`
	BuildQueueStateGrpcServers        []*grpc.ServerConfiguration              `` /* 146-byte string literal not displayed */
	PredeclaredPlatformQueues         []*PredeclaredPlatformQueueConfiguration `` /* 139-byte string literal not displayed */
	ExecuteAuthorizer                 *auth.AuthorizerConfiguration            `protobuf:"bytes,15,opt,name=execute_authorizer,json=executeAuthorizer,proto3" json:"execute_authorizer,omitempty"`
	ModifyDrainsAuthorizer            *auth.AuthorizerConfiguration            `` /* 130-byte string literal not displayed */
	KillOperationsAuthorizer          *auth.AuthorizerConfiguration            `` /* 136-byte string literal not displayed */
	ActionRouter                      *scheduler.ActionRouterConfiguration     `protobuf:"bytes,16,opt,name=action_router,json=actionRouter,proto3" json:"action_router,omitempty"`
	InitialSizeClassCache             *blobstore.BlobAccessConfiguration       `` /* 129-byte string literal not displayed */
	PlatformQueueWithNoWorkersTimeout *durationpb.Duration                     `` /* 169-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 (x *ApplicationConfiguration) GetActionRouter() *scheduler.ActionRouterConfiguration

func (*ApplicationConfiguration) GetAdminHttpServers 

func (x *ApplicationConfiguration) GetAdminHttpServers() []*http.ServerConfiguration

func (*ApplicationConfiguration) GetAdminRoutePrefix 

func (x *ApplicationConfiguration) GetAdminRoutePrefix() string

func (*ApplicationConfiguration) GetBrowserUrl 

func (x *ApplicationConfiguration) GetBrowserUrl() string

func (*ApplicationConfiguration) GetBuildQueueStateGrpcServers 

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

func (*ApplicationConfiguration) GetClientGrpcServers 

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

func (*ApplicationConfiguration) GetContentAddressableStorage 

func (x *ApplicationConfiguration) GetContentAddressableStorage() *blobstore.BlobAccessConfiguration

func (*ApplicationConfiguration) GetExecuteAuthorizer 

func (x *ApplicationConfiguration) GetExecuteAuthorizer() *auth.AuthorizerConfiguration

func (*ApplicationConfiguration) GetGlobal 

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

func (*ApplicationConfiguration) GetInitialSizeClassCache 

func (x *ApplicationConfiguration) GetInitialSizeClassCache() *blobstore.BlobAccessConfiguration

func (*ApplicationConfiguration) GetKillOperationsAuthorizer 

func (x *ApplicationConfiguration) GetKillOperationsAuthorizer() *auth.AuthorizerConfiguration

func (*ApplicationConfiguration) GetMaximumMessageSizeBytes 

func (x *ApplicationConfiguration) GetMaximumMessageSizeBytes() int64

func (*ApplicationConfiguration) GetModifyDrainsAuthorizer 

func (x *ApplicationConfiguration) GetModifyDrainsAuthorizer() *auth.AuthorizerConfiguration

func (*ApplicationConfiguration) GetPlatformQueueWithNoWorkersTimeout 

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

func (*ApplicationConfiguration) GetPredeclaredPlatformQueues 

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

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 {
	InstanceNamePrefix                        string                 `protobuf:"bytes,1,opt,name=instance_name_prefix,json=instanceNamePrefix,proto3" json:"instance_name_prefix,omitempty"`
	Platform                                  *v2.Platform           `protobuf:"bytes,2,opt,name=platform,proto3" json:"platform,omitempty"`
	SizeClasses                               []uint32               `protobuf:"varint,3,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) GetInstanceNamePrefix 

func (x *PredeclaredPlatformQueueConfiguration) GetInstanceNamePrefix() string

func (*PredeclaredPlatformQueueConfiguration) GetMaximumQueuedBackgroundLearningOperations 

func (x *PredeclaredPlatformQueueConfiguration) GetMaximumQueuedBackgroundLearningOperations() int32

func (*PredeclaredPlatformQueueConfiguration) GetPlatform 

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

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 (x *PredeclaredPlatformQueueConfiguration) ProtoReflect() protoreflect.Message

func (*PredeclaredPlatformQueueConfiguration) Reset 

func (x *PredeclaredPlatformQueueConfiguration) Reset()

func (*PredeclaredPlatformQueueConfiguration) String 

func (x *PredeclaredPlatformQueueConfiguration) 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.