Documentation
¶
Index ¶
- Variables
- type ApplicationConfiguration
- func (*ApplicationConfiguration) Descriptor() ([]byte, []int)deprecated
- func (x *ApplicationConfiguration) GetActionRouter() *scheduler.ActionRouterConfiguration
- func (x *ApplicationConfiguration) GetBuildQueueStateGrpcServers() []*grpc.ServerConfiguration
- func (x *ApplicationConfiguration) GetClientGrpcServers() []*grpc.ServerConfiguration
- func (x *ApplicationConfiguration) GetGlobal() *global.Configuration
- func (x *ApplicationConfiguration) GetPlatformQueueWithNoWorkersTimeout() *durationpb.Duration
- func (x *ApplicationConfiguration) GetPredeclaredPlatformQueues() []*PredeclaredPlatformQueueConfiguration
- func (x *ApplicationConfiguration) GetPreviousExecutionStatsStore() *PreviousExecutionStatsStoreConfiguration
- func (x *ApplicationConfiguration) GetWorkerGrpcServers() []*grpc.ServerConfiguration
- func (*ApplicationConfiguration) ProtoMessage()
- func (x *ApplicationConfiguration) ProtoReflect() protoreflect.Message
- func (x *ApplicationConfiguration) Reset()
- func (x *ApplicationConfiguration) String() string
- type PredeclaredPlatformQueueConfiguration
- func (*PredeclaredPlatformQueueConfiguration) Descriptor() ([]byte, []int)deprecated
- func (x *PredeclaredPlatformQueueConfiguration) GetBackgroundLearningOperationPriority() int32
- func (x *PredeclaredPlatformQueueConfiguration) GetMaximumQueuedBackgroundLearningOperations() int32
- func (x *PredeclaredPlatformQueueConfiguration) GetPkixPublicKeys() [][]byte
- func (x *PredeclaredPlatformQueueConfiguration) GetSizeClasses() []uint32
- func (x *PredeclaredPlatformQueueConfiguration) GetWorkerInvocationStickinessLimits() []*durationpb.Duration
- func (*PredeclaredPlatformQueueConfiguration) ProtoMessage()
- func (x *PredeclaredPlatformQueueConfiguration) ProtoReflect() protoreflect.Message
- func (x *PredeclaredPlatformQueueConfiguration) Reset()
- func (x *PredeclaredPlatformQueueConfiguration) String() string
- type PreviousExecutionStatsStoreConfiguration
- func (*PreviousExecutionStatsStoreConfiguration) Descriptor() ([]byte, []int)deprecated
- func (x *PreviousExecutionStatsStoreConfiguration) GetGrpcClient() *grpc.ClientConfiguration
- func (x *PreviousExecutionStatsStoreConfiguration) GetNamespace() *object.Namespace
- func (x *PreviousExecutionStatsStoreConfiguration) GetObjectEncoders() []*encoding.BinaryEncoder
- func (x *PreviousExecutionStatsStoreConfiguration) GetTagSignaturePrivateKey() string
- func (*PreviousExecutionStatsStoreConfiguration) ProtoMessage()
- func (x *PreviousExecutionStatsStoreConfiguration) ProtoReflect() protoreflect.Message
- func (x *PreviousExecutionStatsStoreConfiguration) Reset()
- func (x *PreviousExecutionStatsStoreConfiguration) String() string
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 (x *ApplicationConfiguration) GetActionRouter() *scheduler.ActionRouterConfiguration
func (*ApplicationConfiguration) GetBuildQueueStateGrpcServers ¶
func (x *ApplicationConfiguration) GetBuildQueueStateGrpcServers() []*grpc.ServerConfiguration
func (*ApplicationConfiguration) GetClientGrpcServers ¶
func (x *ApplicationConfiguration) GetClientGrpcServers() []*grpc.ServerConfiguration
func (*ApplicationConfiguration) GetGlobal ¶
func (x *ApplicationConfiguration) GetGlobal() *global.Configuration
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 (x *PredeclaredPlatformQueueConfiguration) ProtoReflect() protoreflect.Message
func (*PredeclaredPlatformQueueConfiguration) Reset ¶
func (x *PredeclaredPlatformQueueConfiguration) Reset()
func (*PredeclaredPlatformQueueConfiguration) String ¶
func (x *PredeclaredPlatformQueueConfiguration) String() 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 (x *PreviousExecutionStatsStoreConfiguration) GetGrpcClient() *grpc.ClientConfiguration
func (*PreviousExecutionStatsStoreConfiguration) GetNamespace ¶
func (x *PreviousExecutionStatsStoreConfiguration) GetNamespace() *object.Namespace
func (*PreviousExecutionStatsStoreConfiguration) GetObjectEncoders ¶
func (x *PreviousExecutionStatsStoreConfiguration) GetObjectEncoders() []*encoding.BinaryEncoder
func (*PreviousExecutionStatsStoreConfiguration) GetTagSignaturePrivateKey ¶
func (x *PreviousExecutionStatsStoreConfiguration) GetTagSignaturePrivateKey() string
func (*PreviousExecutionStatsStoreConfiguration) ProtoMessage ¶
func (*PreviousExecutionStatsStoreConfiguration) ProtoMessage()
func (*PreviousExecutionStatsStoreConfiguration) ProtoReflect ¶
func (x *PreviousExecutionStatsStoreConfiguration) ProtoReflect() protoreflect.Message
func (*PreviousExecutionStatsStoreConfiguration) Reset ¶
func (x *PreviousExecutionStatsStoreConfiguration) Reset()
func (*PreviousExecutionStatsStoreConfiguration) String ¶
func (x *PreviousExecutionStatsStoreConfiguration) String() string
Click to show internal directories.
Click to hide internal directories.