bb_scheduler

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: 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 (*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 (*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"`
	MaximumSizeClass                          uint32                 `protobuf:"varint,3,opt,name=maximum_size_class,json=maximumSizeClass,proto3" json:"maximum_size_class,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) GetMaximumSizeClass

func (x *PredeclaredPlatformQueueConfiguration) GetMaximumSizeClass() uint32

func (*PredeclaredPlatformQueueConfiguration) GetPlatform

func (*PredeclaredPlatformQueueConfiguration) GetWorkerInvocationStickinessLimits

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

func (*PredeclaredPlatformQueueConfiguration) ProtoMessage

func (*PredeclaredPlatformQueueConfiguration) ProtoMessage()

func (*PredeclaredPlatformQueueConfiguration) ProtoReflect

func (*PredeclaredPlatformQueueConfiguration) Reset

func (*PredeclaredPlatformQueueConfiguration) String

Jump to

Keyboard shortcuts

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