This is an automated email from the ASF dual-hosted git repository.
ccondit pushed a commit to branch master
in repository
https://gitbox.apache.org/repos/asf/yunikorn-scheduler-interface.git
The following commit(s) were added to refs/heads/master by this push:
new 4513ff3 [YUNIKORN-3040] SI: Update dependencies for CVE fixes (#146)
4513ff3 is described below
commit 4513ff3a692d37ea081a9d640aad6bbf1ced307d
Author: Craig Condit <ccon...@apache.org>
AuthorDate: Tue Mar 4 15:48:37 2025 -0600
[YUNIKORN-3040] SI: Update dependencies for CVE fixes (#146)
Closes: #146
---
go.mod | 24 +-
go.sum | 42 ++-
lib/go/si/si.pb.go | 927 ++++++++++++++---------------------------------------
3 files changed, 280 insertions(+), 713 deletions(-)
diff --git a/go.mod b/go.mod
index fb47a4e..257dcf9 100644
--- a/go.mod
+++ b/go.mod
@@ -19,24 +19,24 @@
module github.com/apache/yunikorn-scheduler-interface
-go 1.21
+go 1.23.0
+
+toolchain go1.23.7
require (
- google.golang.org/grpc v1.65.0
- google.golang.org/protobuf v1.34.2
+ google.golang.org/grpc v1.70.0
+ google.golang.org/protobuf v1.36.5
)
require (
- golang.org/x/net v0.25.0 // indirect
- golang.org/x/sys v0.20.0 // indirect
- golang.org/x/text v0.15.0 // indirect
- google.golang.org/genproto/googleapis/rpc
v0.0.0-20240528184218-531527333157 // indirect
+ golang.org/x/net v0.32.0 // indirect
+ golang.org/x/sys v0.30.0 // indirect
+ golang.org/x/text v0.22.0 // indirect
+ google.golang.org/genproto/googleapis/rpc
v0.0.0-20241202173237-19429a94021a // indirect
)
replace (
- golang.org/x/crypto => golang.org/x/crypto v0.21.0
- golang.org/x/net => golang.org/x/net v0.23.0
- golang.org/x/sys => golang.org/x/sys v0.18.0
- golang.org/x/text => golang.org/x/text v0.14.0
- golang.org/x/tools => golang.org/x/tools v0.17.0
+ golang.org/x/net => golang.org/x/net v0.36.0
+ golang.org/x/sys => golang.org/x/sys v0.30.0
+ golang.org/x/text => golang.org/x/text v0.22.0
)
diff --git a/go.sum b/go.sum
index 21696de..c021a2a 100644
--- a/go.sum
+++ b/go.sum
@@ -1,14 +1,32 @@
+github.com/go-logr/logr v1.4.2 h1:6pFjapn8bFcIbiKo3XT4j/BhANplGihG6tvd+8rYgrY=
+github.com/go-logr/logr v1.4.2/go.mod
h1:9T104GzyrTigFIr8wt5mBrctHMim0Nb2HLGrmQ40KvY=
+github.com/go-logr/stdr v1.2.2 h1:hSWxHoqTgW2S2qGc0LTAI563KZ5YKYRhT3MFKZMbjag=
+github.com/go-logr/stdr v1.2.2/go.mod
h1:mMo/vtBO5dYbehREoey6XUKy/eSumjCCveDpRre4VKE=
+github.com/golang/protobuf v1.5.4
h1:i7eJL8qZTpSEXOPTxNKhASYpMn+8e5Q6AdndVa1dWek=
+github.com/golang/protobuf v1.5.4/go.mod
h1:lnTiLA8Wa4RWRcIUkrtSVa5nRhsEGBg48fD6rSs7xps=
github.com/google/go-cmp v0.6.0 h1:ofyhxvXcZhMsU5ulbFiLKl/XBFqE1GSq7atu8tAmTRI=
github.com/google/go-cmp v0.6.0/go.mod
h1:17dUlkBOakJ0+DkrSSNjCkIjxS6bF9zb3elmeNGIjoY=
-golang.org/x/net v0.23.0 h1:7EYJ93RZ9vYSZAIb2x3lnuvqO5zneoD6IvWjuhfxjTs=
-golang.org/x/net v0.23.0/go.mod h1:JKghWKKOSdJwpW2GEx0Ja7fmaKnMsbu+MWVZTokSYmg=
-golang.org/x/sys v0.18.0 h1:DBdB3niSjOA/O0blCZBqDefyWNYveAYMNF1Wum0DYQ4=
-golang.org/x/sys v0.18.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
-golang.org/x/text v0.14.0 h1:ScX5w1eTa3QqT8oi6+ziP7dTV1S2+ALU0bI+0zXKWiQ=
-golang.org/x/text v0.14.0/go.mod
h1:18ZOQIKpY8NJVqYksKHtTdi31H5itFRjB5/qKTNYzSU=
-google.golang.org/genproto/googleapis/rpc v0.0.0-20240528184218-531527333157
h1:Zy9XzmMEflZ/MAaA7vNcoebnRAld7FsPW1EeBB7V0m8=
-google.golang.org/genproto/googleapis/rpc
v0.0.0-20240528184218-531527333157/go.mod
h1:EfXuqaE1J41VCDicxHzUDm+8rk+7ZdXzHV0IhO/I6s0=
-google.golang.org/grpc v1.65.0 h1:bs/cUb4lp1G5iImFFd3u5ixQzweKizoZJAwBNLR42lc=
-google.golang.org/grpc v1.65.0/go.mod
h1:WgYC2ypjlB0EiQi6wdKixMqukr6lBc0Vo+oOgjrM5ZQ=
-google.golang.org/protobuf v1.34.2
h1:6xV6lTsCfpGD21XK49h7MhtcApnLqkfYgPcdHftf6hg=
-google.golang.org/protobuf v1.34.2/go.mod
h1:qYOHts0dSfpeUzUFpOMr/WGzszTmLH+DiWniOlNbLDw=
+github.com/google/uuid v1.6.0 h1:NIvaJDMOsjHA8n1jAhLSgzrAzy1Hgr+hNrb57e+94F0=
+github.com/google/uuid v1.6.0/go.mod
h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
+go.opentelemetry.io/otel v1.32.0
h1:WnBN+Xjcteh0zdk01SVqV55d/m62NJLJdIyb4y/WO5U=
+go.opentelemetry.io/otel v1.32.0/go.mod
h1:00DCVSB0RQcnzlwyTfqtxSm+DRr9hpYrHjNGiBHVQIg=
+go.opentelemetry.io/otel/metric v1.32.0
h1:xV2umtmNcThh2/a/aCP+h64Xx5wsj8qqnkYZktzNa0M=
+go.opentelemetry.io/otel/metric v1.32.0/go.mod
h1:jH7CIbbK6SH2V2wE16W05BHCtIDzauciCRLoc/SyMv8=
+go.opentelemetry.io/otel/sdk v1.32.0
h1:RNxepc9vK59A8XsgZQouW8ue8Gkb4jpWtJm9ge5lEG4=
+go.opentelemetry.io/otel/sdk v1.32.0/go.mod
h1:LqgegDBjKMmb2GC6/PrTnteJG39I8/vJCAP9LlJXEjU=
+go.opentelemetry.io/otel/sdk/metric v1.32.0
h1:rZvFnvmvawYb0alrYkjraqJq0Z4ZUJAiyYCU9snn1CU=
+go.opentelemetry.io/otel/sdk/metric v1.32.0/go.mod
h1:PWeZlq0zt9YkYAp3gjKZ0eicRYvOh1Gd+X99x6GHpCQ=
+go.opentelemetry.io/otel/trace v1.32.0
h1:WIC9mYrXf8TmY/EXuULKc8hR17vE+Hjv2cssQDe03fM=
+go.opentelemetry.io/otel/trace v1.32.0/go.mod
h1:+i4rkvCraA+tG6AzwloGaCtkx53Fa+L+V8e9a7YvhT8=
+golang.org/x/net v0.36.0 h1:vWF2fRbw4qslQsQzgFqZff+BItCvGFQqKzKIzx1rmoA=
+golang.org/x/net v0.36.0/go.mod h1:bFmbeoIPfrw4sMHNhb4J9f6+tPziuGjq7Jk/38fxi1I=
+golang.org/x/sys v0.30.0 h1:QjkSwP/36a20jFYWkSue1YwXzLmsV5Gfq7Eiy72C1uc=
+golang.org/x/sys v0.30.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
+golang.org/x/text v0.22.0 h1:bofq7m3/HAFvbF51jz3Q9wLg3jkvSPuiZu/pD1XwgtM=
+golang.org/x/text v0.22.0/go.mod
h1:YRoo4H8PVmsu+E3Ou7cqLVH8oXWIHVoX0jqUWALQhfY=
+google.golang.org/genproto/googleapis/rpc v0.0.0-20241202173237-19429a94021a
h1:hgh8P4EuoxpsuKMXX/To36nOFD7vixReXgn8lPGnt+o=
+google.golang.org/genproto/googleapis/rpc
v0.0.0-20241202173237-19429a94021a/go.mod
h1:5uTbfoYQed2U9p3KIj2/Zzm02PYhndfdmML0qC3q3FU=
+google.golang.org/grpc v1.70.0 h1:pWFv03aZoHzlRKHWicjsZytKAiYCtNS0dHbXnIdq7jQ=
+google.golang.org/grpc v1.70.0/go.mod
h1:ofIJqVKDXx/JiXrwr2IG4/zwdH9txy3IlF40RmcJSQw=
+google.golang.org/protobuf v1.36.5
h1:tPhr+woSbjfYvY6/GPufUoYizxw1cF/yFoxJ2fmpwlM=
+google.golang.org/protobuf v1.36.5/go.mod
h1:9fA7Ob0pmnwhb644+1+CVWFRbNajQ6iRojtC/QF5bRE=
diff --git a/lib/go/si/si.pb.go b/lib/go/si/si.pb.go
index eb9033e..b99e135 100644
--- a/lib/go/si/si.pb.go
+++ b/lib/go/si/si.pb.go
@@ -16,7 +16,7 @@
// Code generated by protoc-gen-go. DO NOT EDIT.
// versions:
-// protoc-gen-go v1.34.2
+// protoc-gen-go v1.36.5
// protoc v4.23.2
// source: yunikorn-scheduler-interface/si.proto
@@ -28,6 +28,7 @@ import (
descriptorpb "google.golang.org/protobuf/types/descriptorpb"
reflect "reflect"
sync "sync"
+ unsafe "unsafe"
)
const (
@@ -507,10 +508,7 @@ func (EventRecord_ChangeDetail) EnumDescriptor() ([]byte,
[]int) {
}
type RegisterResourceManagerRequest struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
+ state protoimpl.MessageState `protogen:"open.v1"`
// An ID which can uniquely identify a RM **cluster**. (For example, if
a RM cluster has multiple manager instances for HA purpose, they should use the
same information when do registration).
// If RM register with the same ID, all previous scheduling state in
memory will be cleaned up, and expect RM report full scheduling state after
registration.
RmID string `protobuf:"bytes,1,opt,name=rmID,proto3"
json:"rmID,omitempty"`
@@ -521,20 +519,20 @@ type RegisterResourceManagerRequest struct {
// Different RMs can refer to the same policyGroup if their static
configuration is identical.
PolicyGroup string `protobuf:"bytes,3,opt,name=policyGroup,proto3"
json:"policyGroup,omitempty"`
// Pass the build information of k8shim to core.
- BuildInfo map[string]string
`protobuf:"bytes,4,rep,name=buildInfo,proto3" json:"buildInfo,omitempty"
protobuf_key:"bytes,1,opt,name=key,proto3"
protobuf_val:"bytes,2,opt,name=value,proto3"`
+ BuildInfo map[string]string
`protobuf:"bytes,4,rep,name=buildInfo,proto3" json:"buildInfo,omitempty"
protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
// Pass the serialized configuration for this policyGroup to core.
Config string `protobuf:"bytes,5,opt,name=config,proto3"
json:"config,omitempty"`
// Additional configuration key/value pairs for configuration not
related to the policyGroup.
- ExtraConfig map[string]string
`protobuf:"bytes,6,rep,name=extraConfig,proto3" json:"extraConfig,omitempty"
protobuf_key:"bytes,1,opt,name=key,proto3"
protobuf_val:"bytes,2,opt,name=value,proto3"`
+ ExtraConfig map[string]string
`protobuf:"bytes,6,rep,name=extraConfig,proto3" json:"extraConfig,omitempty"
protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *RegisterResourceManagerRequest) Reset() {
*x = RegisterResourceManagerRequest{}
- if protoimpl.UnsafeEnabled {
- mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[0]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[0]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *RegisterResourceManagerRequest) String() string {
@@ -545,7 +543,7 @@ func (*RegisterResourceManagerRequest) ProtoMessage() {}
func (x *RegisterResourceManagerRequest) ProtoReflect() protoreflect.Message {
mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[0]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -604,18 +602,16 @@ func (x *RegisterResourceManagerRequest) GetExtraConfig()
map[string]string {
// Upon success, scheduler returns RegisterResourceManagerResponse to RM,
otherwise RM receives exception.
type RegisterResourceManagerResponse struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
+ state protoimpl.MessageState `protogen:"open.v1"`
unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *RegisterResourceManagerResponse) Reset() {
*x = RegisterResourceManagerResponse{}
- if protoimpl.UnsafeEnabled {
- mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[1]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[1]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *RegisterResourceManagerResponse) String() string {
@@ -626,7 +622,7 @@ func (*RegisterResourceManagerResponse) ProtoMessage() {}
func (x *RegisterResourceManagerResponse) ProtoReflect() protoreflect.Message {
mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[1]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -642,25 +638,22 @@ func (*RegisterResourceManagerResponse) Descriptor()
([]byte, []int) {
}
type AllocationRequest struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
+ state protoimpl.MessageState `protogen:"open.v1"`
// Allocations can be released.
Releases *AllocationReleasesRequest
`protobuf:"bytes,2,opt,name=releases,proto3" json:"releases,omitempty"`
// ID of RM, this will be used to identify which RM of the request
comes from.
RmID string `protobuf:"bytes,3,opt,name=rmID,proto3"
json:"rmID,omitempty"`
// Allocation to add or update.
- Allocations []*Allocation
`protobuf:"bytes,4,rep,name=allocations,proto3" json:"allocations,omitempty"`
+ Allocations []*Allocation
`protobuf:"bytes,4,rep,name=allocations,proto3" json:"allocations,omitempty"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *AllocationRequest) Reset() {
*x = AllocationRequest{}
- if protoimpl.UnsafeEnabled {
- mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[2]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[2]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *AllocationRequest) String() string {
@@ -671,7 +664,7 @@ func (*AllocationRequest) ProtoMessage() {}
func (x *AllocationRequest) ProtoReflect() protoreflect.Message {
mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[2]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -708,26 +701,23 @@ func (x *AllocationRequest) GetAllocations()
[]*Allocation {
}
type ApplicationRequest struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
+ state protoimpl.MessageState `protogen:"open.v1"`
// RM should explicitly add application when allocation request also
explictly belongs to application.
// This is optional if allocation request doesn't belong to a
application. (Independent allocation)
New []*AddApplicationRequest `protobuf:"bytes,1,rep,name=new,proto3"
json:"new,omitempty"`
// RM can also remove applications, all allocation/allocation requests
associated with the application will be removed
Remove []*RemoveApplicationRequest
`protobuf:"bytes,2,rep,name=remove,proto3" json:"remove,omitempty"`
// ID of RM, this will be used to identify which RM of the request
comes from.
- RmID string `protobuf:"bytes,3,opt,name=rmID,proto3"
json:"rmID,omitempty"`
+ RmID string `protobuf:"bytes,3,opt,name=rmID,proto3"
json:"rmID,omitempty"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *ApplicationRequest) Reset() {
*x = ApplicationRequest{}
- if protoimpl.UnsafeEnabled {
- mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[3]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[3]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *ApplicationRequest) String() string {
@@ -738,7 +728,7 @@ func (*ApplicationRequest) ProtoMessage() {}
func (x *ApplicationRequest) ProtoReflect() protoreflect.Message {
mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[3]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -775,23 +765,20 @@ func (x *ApplicationRequest) GetRmID() string {
}
type NodeRequest struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
+ state protoimpl.MessageState `protogen:"open.v1"`
// New node can be scheduled. If a node is notified to be
"unscheduable", it needs to be part of this field as well.
Nodes []*NodeInfo `protobuf:"bytes,1,rep,name=nodes,proto3"
json:"nodes,omitempty"`
// ID of RM, this will be used to identify which RM of the request
comes from.
- RmID string `protobuf:"bytes,2,opt,name=rmID,proto3"
json:"rmID,omitempty"`
+ RmID string `protobuf:"bytes,2,opt,name=rmID,proto3"
json:"rmID,omitempty"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *NodeRequest) Reset() {
*x = NodeRequest{}
- if protoimpl.UnsafeEnabled {
- mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[4]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[4]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *NodeRequest) String() string {
@@ -802,7 +789,7 @@ func (*NodeRequest) ProtoMessage() {}
func (x *NodeRequest) ProtoReflect() protoreflect.Message {
mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[4]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -832,10 +819,7 @@ func (x *NodeRequest) GetRmID() string {
}
type AllocationResponse struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
+ state protoimpl.MessageState `protogen:"open.v1"`
// New allocations
New []*Allocation `protobuf:"bytes,1,rep,name=new,proto3"
json:"new,omitempty"`
// Released allocations, this could be either ack from scheduler when
RM asks to terminate some allocations.
@@ -843,15 +827,15 @@ type AllocationResponse struct {
Released []*AllocationRelease
`protobuf:"bytes,2,rep,name=released,proto3" json:"released,omitempty"`
// Rejected allocations
RejectedAllocations []*RejectedAllocation
`protobuf:"bytes,5,rep,name=rejectedAllocations,proto3"
json:"rejectedAllocations,omitempty"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *AllocationResponse) Reset() {
*x = AllocationResponse{}
- if protoimpl.UnsafeEnabled {
- mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[5]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[5]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *AllocationResponse) String() string {
@@ -862,7 +846,7 @@ func (*AllocationResponse) ProtoMessage() {}
func (x *AllocationResponse) ProtoReflect() protoreflect.Message {
mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[5]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -899,25 +883,22 @@ func (x *AllocationResponse) GetRejectedAllocations()
[]*RejectedAllocation {
}
type ApplicationResponse struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
+ state protoimpl.MessageState `protogen:"open.v1"`
// Rejected Applications
Rejected []*RejectedApplication
`protobuf:"bytes,1,rep,name=rejected,proto3" json:"rejected,omitempty"`
// Accepted Applications
Accepted []*AcceptedApplication
`protobuf:"bytes,2,rep,name=accepted,proto3" json:"accepted,omitempty"`
// Updated Applications
- Updated []*UpdatedApplication
`protobuf:"bytes,3,rep,name=updated,proto3" json:"updated,omitempty"`
+ Updated []*UpdatedApplication
`protobuf:"bytes,3,rep,name=updated,proto3" json:"updated,omitempty"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *ApplicationResponse) Reset() {
*x = ApplicationResponse{}
- if protoimpl.UnsafeEnabled {
- mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[6]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[6]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *ApplicationResponse) String() string {
@@ -928,7 +909,7 @@ func (*ApplicationResponse) ProtoMessage() {}
func (x *ApplicationResponse) ProtoReflect() protoreflect.Message {
mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[6]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -965,23 +946,20 @@ func (x *ApplicationResponse) GetUpdated()
[]*UpdatedApplication {
}
type NodeResponse struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
+ state protoimpl.MessageState `protogen:"open.v1"`
// Rejected Node Registrations
Rejected []*RejectedNode `protobuf:"bytes,1,rep,name=rejected,proto3"
json:"rejected,omitempty"`
// Accepted Node Registrations
- Accepted []*AcceptedNode `protobuf:"bytes,2,rep,name=accepted,proto3"
json:"accepted,omitempty"`
+ Accepted []*AcceptedNode
`protobuf:"bytes,2,rep,name=accepted,proto3" json:"accepted,omitempty"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *NodeResponse) Reset() {
*x = NodeResponse{}
- if protoimpl.UnsafeEnabled {
- mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[7]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[7]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *NodeResponse) String() string {
@@ -992,7 +970,7 @@ func (*NodeResponse) ProtoMessage() {}
func (x *NodeResponse) ProtoReflect() protoreflect.Message {
mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[7]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -1022,10 +1000,7 @@ func (x *NodeResponse) GetAccepted() []*AcceptedNode {
}
type UpdatedApplication struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
+ state protoimpl.MessageState `protogen:"open.v1"`
// The application ID that was updated
ApplicationID string `protobuf:"bytes,1,opt,name=applicationID,proto3"
json:"applicationID,omitempty"`
// State of the application
@@ -1033,16 +1008,16 @@ type UpdatedApplication struct {
// Timestamp of the state transition
StateTransitionTimestamp int64
`protobuf:"varint,3,opt,name=stateTransitionTimestamp,proto3"
json:"stateTransitionTimestamp,omitempty"`
// Detailed message
- Message string `protobuf:"bytes,4,opt,name=message,proto3"
json:"message,omitempty"`
+ Message string `protobuf:"bytes,4,opt,name=message,proto3"
json:"message,omitempty"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *UpdatedApplication) Reset() {
*x = UpdatedApplication{}
- if protoimpl.UnsafeEnabled {
- mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[8]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[8]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *UpdatedApplication) String() string {
@@ -1053,7 +1028,7 @@ func (*UpdatedApplication) ProtoMessage() {}
func (x *UpdatedApplication) ProtoReflect() protoreflect.Message {
mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[8]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -1097,23 +1072,20 @@ func (x *UpdatedApplication) GetMessage() string {
}
type RejectedApplication struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
+ state protoimpl.MessageState `protogen:"open.v1"`
// The application ID that was rejected
ApplicationID string `protobuf:"bytes,1,opt,name=applicationID,proto3"
json:"applicationID,omitempty"`
// A human-readable reason message
- Reason string `protobuf:"bytes,2,opt,name=reason,proto3"
json:"reason,omitempty"`
+ Reason string `protobuf:"bytes,2,opt,name=reason,proto3"
json:"reason,omitempty"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *RejectedApplication) Reset() {
*x = RejectedApplication{}
- if protoimpl.UnsafeEnabled {
- mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[9]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[9]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *RejectedApplication) String() string {
@@ -1124,7 +1096,7 @@ func (*RejectedApplication) ProtoMessage() {}
func (x *RejectedApplication) ProtoReflect() protoreflect.Message {
mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[9]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -1154,21 +1126,18 @@ func (x *RejectedApplication) GetReason() string {
}
type AcceptedApplication struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
+ state protoimpl.MessageState `protogen:"open.v1"`
// The application ID that was accepted
ApplicationID string `protobuf:"bytes,1,opt,name=applicationID,proto3"
json:"applicationID,omitempty"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *AcceptedApplication) Reset() {
*x = AcceptedApplication{}
- if protoimpl.UnsafeEnabled {
- mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[10]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[10]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *AcceptedApplication) String() string {
@@ -1179,7 +1148,7 @@ func (*AcceptedApplication) ProtoMessage() {}
func (x *AcceptedApplication) ProtoReflect() protoreflect.Message {
mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[10]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -1202,23 +1171,20 @@ func (x *AcceptedApplication) GetApplicationID() string
{
}
type RejectedNode struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
+ state protoimpl.MessageState `protogen:"open.v1"`
// The node ID that was rejected
NodeID string `protobuf:"bytes,1,opt,name=nodeID,proto3"
json:"nodeID,omitempty"`
// A human-readable reason message
- Reason string `protobuf:"bytes,2,opt,name=reason,proto3"
json:"reason,omitempty"`
+ Reason string `protobuf:"bytes,2,opt,name=reason,proto3"
json:"reason,omitempty"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *RejectedNode) Reset() {
*x = RejectedNode{}
- if protoimpl.UnsafeEnabled {
- mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[11]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[11]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *RejectedNode) String() string {
@@ -1229,7 +1195,7 @@ func (*RejectedNode) ProtoMessage() {}
func (x *RejectedNode) ProtoReflect() protoreflect.Message {
mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[11]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -1259,21 +1225,18 @@ func (x *RejectedNode) GetReason() string {
}
type AcceptedNode struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
+ state protoimpl.MessageState `protogen:"open.v1"`
// The node ID that was accepted
- NodeID string `protobuf:"bytes,1,opt,name=nodeID,proto3"
json:"nodeID,omitempty"`
+ NodeID string `protobuf:"bytes,1,opt,name=nodeID,proto3"
json:"nodeID,omitempty"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *AcceptedNode) Reset() {
*x = AcceptedNode{}
- if protoimpl.UnsafeEnabled {
- mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[12]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[12]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *AcceptedNode) String() string {
@@ -1284,7 +1247,7 @@ func (*AcceptedNode) ProtoMessage() {}
func (x *AcceptedNode) ProtoReflect() protoreflect.Message {
mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[12]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -1308,20 +1271,17 @@ func (x *AcceptedNode) GetNodeID() string {
// A sparse map of resource to Quantity.
type Resource struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
+ state protoimpl.MessageState `protogen:"open.v1"`
+ Resources map[string]*Quantity
`protobuf:"bytes,1,rep,name=resources,proto3" json:"resources,omitempty"
protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
unknownFields protoimpl.UnknownFields
-
- Resources map[string]*Quantity
`protobuf:"bytes,1,rep,name=resources,proto3" json:"resources,omitempty"
protobuf_key:"bytes,1,opt,name=key,proto3"
protobuf_val:"bytes,2,opt,name=value,proto3"`
+ sizeCache protoimpl.SizeCache
}
func (x *Resource) Reset() {
*x = Resource{}
- if protoimpl.UnsafeEnabled {
- mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[13]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[13]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *Resource) String() string {
@@ -1332,7 +1292,7 @@ func (*Resource) ProtoMessage() {}
func (x *Resource) ProtoReflect() protoreflect.Message {
mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[13]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -1356,20 +1316,17 @@ func (x *Resource) GetResources() map[string]*Quantity {
// Quantity includes a single int64 value
type Quantity struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
+ state protoimpl.MessageState `protogen:"open.v1"`
+ Value int64
`protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
unknownFields protoimpl.UnknownFields
-
- Value int64 `protobuf:"varint,1,opt,name=value,proto3"
json:"value,omitempty"`
+ sizeCache protoimpl.SizeCache
}
func (x *Quantity) Reset() {
*x = Quantity{}
- if protoimpl.UnsafeEnabled {
- mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[14]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[14]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *Quantity) String() string {
@@ -1380,7 +1337,7 @@ func (*Quantity) ProtoMessage() {}
func (x *Quantity) ProtoReflect() protoreflect.Message {
mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[14]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -1403,23 +1360,20 @@ func (x *Quantity) GetValue() int64 {
}
type PreemptionPolicy struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
+ state protoimpl.MessageState `protogen:"open.v1"`
// Opt-out from preemption
AllowPreemptSelf bool
`protobuf:"varint,1,opt,name=allowPreemptSelf,proto3"
json:"allowPreemptSelf,omitempty"`
// Allow preemption of other tasks with same or lower priority
AllowPreemptOther bool
`protobuf:"varint,2,opt,name=allowPreemptOther,proto3"
json:"allowPreemptOther,omitempty"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *PreemptionPolicy) Reset() {
*x = PreemptionPolicy{}
- if protoimpl.UnsafeEnabled {
- mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[15]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[15]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *PreemptionPolicy) String() string {
@@ -1430,7 +1384,7 @@ func (*PreemptionPolicy) ProtoMessage() {}
func (x *PreemptionPolicy) ProtoReflect() protoreflect.Message {
mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[15]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -1460,10 +1414,7 @@ func (x *PreemptionPolicy) GetAllowPreemptOther() bool {
}
type AddApplicationRequest struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
+ state protoimpl.MessageState `protogen:"open.v1"`
// The ID of the application, must be unique
ApplicationID string `protobuf:"bytes,1,opt,name=applicationID,proto3"
json:"applicationID,omitempty"`
// The queue this application is requesting. The scheduler will place
the application into a
@@ -1475,7 +1426,7 @@ type AddApplicationRequest struct {
Ugi *UserGroupInformation `protobuf:"bytes,4,opt,name=ugi,proto3"
json:"ugi,omitempty"`
// A set of tags for the application. These tags provide application
level generic information.
// The tags are optional and are used in placing an application or
scheduling.
- Tags map[string]string `protobuf:"bytes,5,rep,name=tags,proto3"
json:"tags,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3"
protobuf_val:"bytes,2,opt,name=value,proto3"`
+ Tags map[string]string `protobuf:"bytes,5,rep,name=tags,proto3"
json:"tags,omitempty" protobuf_key:"bytes,1,opt,name=key"
protobuf_val:"bytes,2,opt,name=value"`
// Execution timeout: How long this application can be in a running
state
// 0 or negative value means never expire.
ExecutionTimeoutMilliSeconds int64
`protobuf:"varint,6,opt,name=executionTimeoutMilliSeconds,proto3"
json:"executionTimeoutMilliSeconds,omitempty"`
@@ -1484,15 +1435,15 @@ type AddApplicationRequest struct {
// Gang scheduling style can be hard (the application will fail after
placeholder timeout)
// or soft (after the timeout the application will be scheduled as a
normal application)
GangSchedulingStyle string
`protobuf:"bytes,8,opt,name=gangSchedulingStyle,proto3"
json:"gangSchedulingStyle,omitempty"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *AddApplicationRequest) Reset() {
*x = AddApplicationRequest{}
- if protoimpl.UnsafeEnabled {
- mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[16]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[16]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *AddApplicationRequest) String() string {
@@ -1503,7 +1454,7 @@ func (*AddApplicationRequest) ProtoMessage() {}
func (x *AddApplicationRequest) ProtoReflect() protoreflect.Message {
mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[16]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -1575,23 +1526,20 @@ func (x *AddApplicationRequest)
GetGangSchedulingStyle() string {
}
type RemoveApplicationRequest struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
+ state protoimpl.MessageState `protogen:"open.v1"`
// The ID of the application to remove
ApplicationID string `protobuf:"bytes,1,opt,name=applicationID,proto3"
json:"applicationID,omitempty"`
// The partition the application belongs to
PartitionName string `protobuf:"bytes,2,opt,name=partitionName,proto3"
json:"partitionName,omitempty"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *RemoveApplicationRequest) Reset() {
*x = RemoveApplicationRequest{}
- if protoimpl.UnsafeEnabled {
- mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[17]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[17]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *RemoveApplicationRequest) String() string {
@@ -1602,7 +1550,7 @@ func (*RemoveApplicationRequest) ProtoMessage() {}
func (x *RemoveApplicationRequest) ProtoReflect() protoreflect.Message {
mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[17]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -1632,23 +1580,20 @@ func (x *RemoveApplicationRequest) GetPartitionName()
string {
}
type UserGroupInformation struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
+ state protoimpl.MessageState `protogen:"open.v1"`
// the user name
User string `protobuf:"bytes,1,opt,name=user,proto3"
json:"user,omitempty"`
// the list of groups of the user, can be empty
- Groups []string `protobuf:"bytes,2,rep,name=groups,proto3"
json:"groups,omitempty"`
+ Groups []string `protobuf:"bytes,2,rep,name=groups,proto3"
json:"groups,omitempty"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *UserGroupInformation) Reset() {
*x = UserGroupInformation{}
- if protoimpl.UnsafeEnabled {
- mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[18]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[18]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *UserGroupInformation) String() string {
@@ -1659,7 +1604,7 @@ func (*UserGroupInformation) ProtoMessage() {}
func (x *UserGroupInformation) ProtoReflect() protoreflect.Message {
mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[18]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -1689,14 +1634,11 @@ func (x *UserGroupInformation) GetGroups() []string {
}
type Allocation struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
+ state protoimpl.MessageState `protogen:"open.v1"`
// Allocation key
AllocationKey string `protobuf:"bytes,1,opt,name=allocationKey,proto3"
json:"allocationKey,omitempty"`
// Allocation tags
- AllocationTags map[string]string
`protobuf:"bytes,2,rep,name=allocationTags,proto3"
json:"allocationTags,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3"
protobuf_val:"bytes,2,opt,name=value,proto3"`
+ AllocationTags map[string]string
`protobuf:"bytes,2,rep,name=allocationTags,proto3"
json:"allocationTags,omitempty" protobuf_key:"bytes,1,opt,name=key"
protobuf_val:"bytes,2,opt,name=value"`
// Resource for each allocation
ResourcePerAlloc *Resource
`protobuf:"bytes,5,opt,name=resourcePerAlloc,proto3"
json:"resourcePerAlloc,omitempty"`
// Priority of allocation
@@ -1716,15 +1658,15 @@ type Allocation struct {
Originator bool `protobuf:"varint,14,opt,name=originator,proto3"
json:"originator,omitempty"`
// The preemption policy for this allocation
PreemptionPolicy *PreemptionPolicy
`protobuf:"bytes,15,opt,name=preemptionPolicy,proto3"
json:"preemptionPolicy,omitempty"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *Allocation) Reset() {
*x = Allocation{}
- if protoimpl.UnsafeEnabled {
- mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[19]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[19]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *Allocation) String() string {
@@ -1735,7 +1677,7 @@ func (*Allocation) ProtoMessage() {}
func (x *Allocation) ProtoReflect() protoreflect.Message {
mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[19]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -1828,21 +1770,18 @@ func (x *Allocation) GetPreemptionPolicy()
*PreemptionPolicy {
}
type AllocationReleasesRequest struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
+ state protoimpl.MessageState `protogen:"open.v1"`
// The allocations to release
AllocationsToRelease []*AllocationRelease
`protobuf:"bytes,1,rep,name=allocationsToRelease,proto3"
json:"allocationsToRelease,omitempty"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *AllocationReleasesRequest) Reset() {
*x = AllocationReleasesRequest{}
- if protoimpl.UnsafeEnabled {
- mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[20]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[20]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *AllocationReleasesRequest) String() string {
@@ -1853,7 +1792,7 @@ func (*AllocationReleasesRequest) ProtoMessage() {}
func (x *AllocationReleasesRequest) ProtoReflect() protoreflect.Message {
mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[20]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -1879,10 +1818,7 @@ func (x *AllocationReleasesRequest)
GetAllocationsToRelease() []*AllocationRelea
// as per the comment. The confirmation or response from the receiver is the
same message with the same
// termination type set.
type AllocationRelease struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
+ state protoimpl.MessageState `protogen:"open.v1"`
// The name of the partition the allocation belongs to
PartitionName string `protobuf:"bytes,1,opt,name=partitionName,proto3"
json:"partitionName,omitempty"`
// The application the allocation belongs to
@@ -1893,15 +1829,15 @@ type AllocationRelease struct {
Message string `protobuf:"bytes,5,opt,name=message,proto3"
json:"message,omitempty"`
// AllocationKey of the allocation to release, if not set all
allocations are released for the applicationID
AllocationKey string `protobuf:"bytes,6,opt,name=allocationKey,proto3"
json:"allocationKey,omitempty"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *AllocationRelease) Reset() {
*x = AllocationRelease{}
- if protoimpl.UnsafeEnabled {
- mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[21]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[21]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *AllocationRelease) String() string {
@@ -1912,7 +1848,7 @@ func (*AllocationRelease) ProtoMessage() {}
func (x *AllocationRelease) ProtoReflect() protoreflect.Message {
mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[21]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -1963,28 +1899,25 @@ func (x *AllocationRelease) GetAllocationKey() string {
}
type NodeInfo struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
+ state protoimpl.MessageState `protogen:"open.v1"`
// ID of node, the node must exist to be updated
NodeID string `protobuf:"bytes,1,opt,name=nodeID,proto3"
json:"nodeID,omitempty"`
// Action to perform by the scheduler
Action NodeInfo_ActionFromRM
`protobuf:"varint,2,opt,name=action,proto3,enum=si.v1.NodeInfo_ActionFromRM"
json:"action,omitempty"`
// New attributes of node, which will replace previously reported
attribute.
- Attributes map[string]string
`protobuf:"bytes,3,rep,name=attributes,proto3" json:"attributes,omitempty"
protobuf_key:"bytes,1,opt,name=key,proto3"
protobuf_val:"bytes,2,opt,name=value,proto3"`
+ Attributes map[string]string
`protobuf:"bytes,3,rep,name=attributes,proto3" json:"attributes,omitempty"
protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
// new schedulable resource, scheduler may preempt allocations on the
// node or schedule more allocations accordingly.
SchedulableResource *Resource
`protobuf:"bytes,4,opt,name=schedulableResource,proto3"
json:"schedulableResource,omitempty"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *NodeInfo) Reset() {
*x = NodeInfo{}
- if protoimpl.UnsafeEnabled {
- mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[22]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[22]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *NodeInfo) String() string {
@@ -1995,7 +1928,7 @@ func (*NodeInfo) ProtoMessage() {}
func (x *NodeInfo) ProtoReflect() protoreflect.Message {
mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[22]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -2039,25 +1972,22 @@ func (x *NodeInfo) GetSchedulableResource() *Resource {
}
type RejectedAllocation struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
+ state protoimpl.MessageState `protogen:"open.v1"`
// the ID of the allocation
AllocationKey string `protobuf:"bytes,1,opt,name=allocationKey,proto3"
json:"allocationKey,omitempty"`
// The ID of the application
ApplicationID string `protobuf:"bytes,2,opt,name=applicationID,proto3"
json:"applicationID,omitempty"`
// A human-readable reason message
- Reason string `protobuf:"bytes,3,opt,name=reason,proto3"
json:"reason,omitempty"`
+ Reason string `protobuf:"bytes,3,opt,name=reason,proto3"
json:"reason,omitempty"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *RejectedAllocation) Reset() {
*x = RejectedAllocation{}
- if protoimpl.UnsafeEnabled {
- mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[23]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[23]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *RejectedAllocation) String() string {
@@ -2068,7 +1998,7 @@ func (*RejectedAllocation) ProtoMessage() {}
func (x *RejectedAllocation) ProtoReflect() protoreflect.Message {
mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[23]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -2105,26 +2035,23 @@ func (x *RejectedAllocation) GetReason() string {
}
type PredicatesArgs struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
+ state protoimpl.MessageState `protogen:"open.v1"`
// allocation key identifies a container, the predicates function is
going to check
// if this container is eligible to be placed ont to a node.
AllocationKey string `protobuf:"bytes,1,opt,name=allocationKey,proto3"
json:"allocationKey,omitempty"`
// the node ID the container is assigned to.
NodeID string `protobuf:"bytes,2,opt,name=nodeID,proto3"
json:"nodeID,omitempty"`
// run the predicates for alloactions (true) or reservations (false)
- Allocate bool `protobuf:"varint,3,opt,name=allocate,proto3"
json:"allocate,omitempty"`
+ Allocate bool `protobuf:"varint,3,opt,name=allocate,proto3"
json:"allocate,omitempty"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *PredicatesArgs) Reset() {
*x = PredicatesArgs{}
- if protoimpl.UnsafeEnabled {
- mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[24]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[24]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *PredicatesArgs) String() string {
@@ -2135,7 +2062,7 @@ func (*PredicatesArgs) ProtoMessage() {}
func (x *PredicatesArgs) ProtoReflect() protoreflect.Message {
mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[24]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -2172,10 +2099,7 @@ func (x *PredicatesArgs) GetAllocate() bool {
}
type PreemptionPredicatesArgs struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
+ state protoimpl.MessageState `protogen:"open.v1"`
// the allocation key of the container to check
AllocationKey string `protobuf:"bytes,1,opt,name=allocationKey,proto3"
json:"allocationKey,omitempty"`
// the node ID the container should be attempted to be scheduled on
@@ -2183,16 +2107,16 @@ type PreemptionPredicatesArgs struct {
// a list of existing allocations that should be tentatively removed
before checking
PreemptAllocationKeys []string
`protobuf:"bytes,3,rep,name=preemptAllocationKeys,proto3"
json:"preemptAllocationKeys,omitempty"`
// index of last allocation in starting attempt (first attempt should
be 0..startIndex)
- StartIndex int32 `protobuf:"varint,4,opt,name=startIndex,proto3"
json:"startIndex,omitempty"`
+ StartIndex int32 `protobuf:"varint,4,opt,name=startIndex,proto3"
json:"startIndex,omitempty"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *PreemptionPredicatesArgs) Reset() {
*x = PreemptionPredicatesArgs{}
- if protoimpl.UnsafeEnabled {
- mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[25]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[25]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *PreemptionPredicatesArgs) String() string {
@@ -2203,7 +2127,7 @@ func (*PreemptionPredicatesArgs) ProtoMessage() {}
func (x *PreemptionPredicatesArgs) ProtoReflect() protoreflect.Message {
mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[25]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -2247,23 +2171,20 @@ func (x *PreemptionPredicatesArgs) GetStartIndex()
int32 {
}
type PreemptionPredicatesResponse struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
+ state protoimpl.MessageState `protogen:"open.v1"`
// whether or not container will schedule on the node
Success bool `protobuf:"varint,1,opt,name=success,proto3"
json:"success,omitempty"`
// index of last allocation which was removed before success (ignored
during failure)
- Index int32 `protobuf:"varint,2,opt,name=index,proto3"
json:"index,omitempty"`
+ Index int32 `protobuf:"varint,2,opt,name=index,proto3"
json:"index,omitempty"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *PreemptionPredicatesResponse) Reset() {
*x = PreemptionPredicatesResponse{}
- if protoimpl.UnsafeEnabled {
- mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[26]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[26]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *PreemptionPredicatesResponse) String() string {
@@ -2274,7 +2195,7 @@ func (*PreemptionPredicatesResponse) ProtoMessage() {}
func (x *PreemptionPredicatesResponse) ProtoReflect() protoreflect.Message {
mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[26]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -2304,10 +2225,7 @@ func (x *PreemptionPredicatesResponse) GetIndex() int32 {
}
type UpdateContainerSchedulingStateRequest struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
+ state protoimpl.MessageState `protogen:"open.v1"`
// application ID
ApplicationID string `protobuf:"bytes,1,opt,name=applicationID,proto3"
json:"applicationID,omitempty"`
// allocation key used to identify a container.
@@ -2315,16 +2233,16 @@ type UpdateContainerSchedulingStateRequest struct {
// container scheduling state
State UpdateContainerSchedulingStateRequest_SchedulingState
`protobuf:"varint,3,opt,name=state,proto3,enum=si.v1.UpdateContainerSchedulingStateRequest_SchedulingState"
json:"state,omitempty"`
// an optional plain message to explain why it is in such state
- Reason string `protobuf:"bytes,4,opt,name=reason,proto3"
json:"reason,omitempty"`
+ Reason string `protobuf:"bytes,4,opt,name=reason,proto3"
json:"reason,omitempty"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *UpdateContainerSchedulingStateRequest) Reset() {
*x = UpdateContainerSchedulingStateRequest{}
- if protoimpl.UnsafeEnabled {
- mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[27]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[27]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *UpdateContainerSchedulingStateRequest) String() string {
@@ -2335,7 +2253,7 @@ func (*UpdateContainerSchedulingStateRequest)
ProtoMessage() {}
func (x *UpdateContainerSchedulingStateRequest) ProtoReflect()
protoreflect.Message {
mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[27]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -2379,10 +2297,7 @@ func (x *UpdateContainerSchedulingStateRequest)
GetReason() string {
}
type UpdateConfigurationRequest struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
+ state protoimpl.MessageState `protogen:"open.v1"`
// RM ID to update
RmID string `protobuf:"bytes,2,opt,name=rmID,proto3"
json:"rmID,omitempty"`
// PolicyGroup to update
@@ -2390,16 +2305,16 @@ type UpdateConfigurationRequest struct {
// New configuration to update
Config string `protobuf:"bytes,4,opt,name=config,proto3"
json:"config,omitempty"`
// Additional configuration key/value pairs for configuration not
related to the policyGroup.
- ExtraConfig map[string]string
`protobuf:"bytes,5,rep,name=extraConfig,proto3" json:"extraConfig,omitempty"
protobuf_key:"bytes,1,opt,name=key,proto3"
protobuf_val:"bytes,2,opt,name=value,proto3"`
+ ExtraConfig map[string]string
`protobuf:"bytes,5,rep,name=extraConfig,proto3" json:"extraConfig,omitempty"
protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *UpdateConfigurationRequest) Reset() {
*x = UpdateConfigurationRequest{}
- if protoimpl.UnsafeEnabled {
- mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[28]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[28]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *UpdateConfigurationRequest) String() string {
@@ -2410,7 +2325,7 @@ func (*UpdateConfigurationRequest) ProtoMessage() {}
func (x *UpdateConfigurationRequest) ProtoReflect() protoreflect.Message {
mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[28]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -2454,10 +2369,7 @@ func (x *UpdateConfigurationRequest) GetExtraConfig()
map[string]string {
}
type EventRecord struct {
- state protoimpl.MessageState
- sizeCache protoimpl.SizeCache
- unknownFields protoimpl.UnknownFields
-
+ state protoimpl.MessageState `protogen:"open.v1"`
// the type of the object associated with the event
Type EventRecord_Type
`protobuf:"varint,1,opt,name=type,proto3,enum=si.v1.EventRecord_Type"
json:"type,omitempty"`
// ID of the object associated with the event
@@ -2473,16 +2385,16 @@ type EventRecord struct {
// the secondary object in the event (eg. allocation ID, request ID)
ReferenceID string `protobuf:"bytes,9,opt,name=referenceID,proto3"
json:"referenceID,omitempty"`
// the resource value if the change involves setting/modifying a
resource
- Resource *Resource `protobuf:"bytes,10,opt,name=resource,proto3"
json:"resource,omitempty"`
+ Resource *Resource `protobuf:"bytes,10,opt,name=resource,proto3"
json:"resource,omitempty"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
}
func (x *EventRecord) Reset() {
*x = EventRecord{}
- if protoimpl.UnsafeEnabled {
- mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[29]
- ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
- ms.StoreMessageInfo(mi)
- }
+ mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[29]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
}
func (x *EventRecord) String() string {
@@ -2493,7 +2405,7 @@ func (*EventRecord) ProtoMessage() {}
func (x *EventRecord) ProtoReflect() protoreflect.Message {
mi := &file_yunikorn_scheduler_interface_si_proto_msgTypes[29]
- if protoimpl.UnsafeEnabled && x != nil {
+ if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
@@ -2586,7 +2498,7 @@ var (
var File_yunikorn_scheduler_interface_si_proto protoreflect.FileDescriptor
-var file_yunikorn_scheduler_interface_si_proto_rawDesc = []byte{
+var file_yunikorn_scheduler_interface_si_proto_rawDesc = string([]byte{
0x0a, 0x25, 0x79, 0x75, 0x6e, 0x69, 0x6b, 0x6f, 0x72, 0x6e, 0x2d, 0x73,
0x63, 0x68, 0x65, 0x64,
0x75, 0x6c, 0x65, 0x72, 0x2d, 0x69, 0x6e, 0x74, 0x65, 0x72, 0x66, 0x61,
0x63, 0x65, 0x2f, 0x73,
0x69, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x05, 0x73, 0x69, 0x2e,
0x76, 0x31, 0x1a, 0x20,
@@ -3054,16 +2966,16 @@ var file_yunikorn_scheduler_interface_si_proto_rawDesc
= []byte{
0xa3, 0x08, 0x20, 0x01, 0x28, 0x08, 0x52, 0x08, 0x73, 0x69, 0x53, 0x65,
0x63, 0x72, 0x65, 0x74,
0x42, 0x0b, 0x5a, 0x09, 0x6c, 0x69, 0x62, 0x2f, 0x67, 0x6f, 0x2f, 0x73,
0x69, 0x62, 0x06, 0x70,
0x72, 0x6f, 0x74, 0x6f, 0x33,
-}
+})
var (
file_yunikorn_scheduler_interface_si_proto_rawDescOnce sync.Once
- file_yunikorn_scheduler_interface_si_proto_rawDescData =
file_yunikorn_scheduler_interface_si_proto_rawDesc
+ file_yunikorn_scheduler_interface_si_proto_rawDescData []byte
)
func file_yunikorn_scheduler_interface_si_proto_rawDescGZIP() []byte {
file_yunikorn_scheduler_interface_si_proto_rawDescOnce.Do(func() {
- file_yunikorn_scheduler_interface_si_proto_rawDescData =
protoimpl.X.CompressGZIP(file_yunikorn_scheduler_interface_si_proto_rawDescData)
+ file_yunikorn_scheduler_interface_si_proto_rawDescData =
protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_yunikorn_scheduler_interface_si_proto_rawDesc),
len(file_yunikorn_scheduler_interface_si_proto_rawDesc)))
})
return file_yunikorn_scheduler_interface_si_proto_rawDescData
}
@@ -3172,373 +3084,11 @@ func file_yunikorn_scheduler_interface_si_proto_init()
{
if File_yunikorn_scheduler_interface_si_proto != nil {
return
}
- if !protoimpl.UnsafeEnabled {
- file_yunikorn_scheduler_interface_si_proto_msgTypes[0].Exporter
= func(v any, i int) any {
- switch v := v.(*RegisterResourceManagerRequest); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
- file_yunikorn_scheduler_interface_si_proto_msgTypes[1].Exporter
= func(v any, i int) any {
- switch v := v.(*RegisterResourceManagerResponse); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
- file_yunikorn_scheduler_interface_si_proto_msgTypes[2].Exporter
= func(v any, i int) any {
- switch v := v.(*AllocationRequest); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
- file_yunikorn_scheduler_interface_si_proto_msgTypes[3].Exporter
= func(v any, i int) any {
- switch v := v.(*ApplicationRequest); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
- file_yunikorn_scheduler_interface_si_proto_msgTypes[4].Exporter
= func(v any, i int) any {
- switch v := v.(*NodeRequest); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
- file_yunikorn_scheduler_interface_si_proto_msgTypes[5].Exporter
= func(v any, i int) any {
- switch v := v.(*AllocationResponse); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
- file_yunikorn_scheduler_interface_si_proto_msgTypes[6].Exporter
= func(v any, i int) any {
- switch v := v.(*ApplicationResponse); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
- file_yunikorn_scheduler_interface_si_proto_msgTypes[7].Exporter
= func(v any, i int) any {
- switch v := v.(*NodeResponse); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
- file_yunikorn_scheduler_interface_si_proto_msgTypes[8].Exporter
= func(v any, i int) any {
- switch v := v.(*UpdatedApplication); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
- file_yunikorn_scheduler_interface_si_proto_msgTypes[9].Exporter
= func(v any, i int) any {
- switch v := v.(*RejectedApplication); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
-
file_yunikorn_scheduler_interface_si_proto_msgTypes[10].Exporter = func(v any,
i int) any {
- switch v := v.(*AcceptedApplication); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
-
file_yunikorn_scheduler_interface_si_proto_msgTypes[11].Exporter = func(v any,
i int) any {
- switch v := v.(*RejectedNode); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
-
file_yunikorn_scheduler_interface_si_proto_msgTypes[12].Exporter = func(v any,
i int) any {
- switch v := v.(*AcceptedNode); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
-
file_yunikorn_scheduler_interface_si_proto_msgTypes[13].Exporter = func(v any,
i int) any {
- switch v := v.(*Resource); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
-
file_yunikorn_scheduler_interface_si_proto_msgTypes[14].Exporter = func(v any,
i int) any {
- switch v := v.(*Quantity); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
-
file_yunikorn_scheduler_interface_si_proto_msgTypes[15].Exporter = func(v any,
i int) any {
- switch v := v.(*PreemptionPolicy); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
-
file_yunikorn_scheduler_interface_si_proto_msgTypes[16].Exporter = func(v any,
i int) any {
- switch v := v.(*AddApplicationRequest); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
-
file_yunikorn_scheduler_interface_si_proto_msgTypes[17].Exporter = func(v any,
i int) any {
- switch v := v.(*RemoveApplicationRequest); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
-
file_yunikorn_scheduler_interface_si_proto_msgTypes[18].Exporter = func(v any,
i int) any {
- switch v := v.(*UserGroupInformation); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
-
file_yunikorn_scheduler_interface_si_proto_msgTypes[19].Exporter = func(v any,
i int) any {
- switch v := v.(*Allocation); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
-
file_yunikorn_scheduler_interface_si_proto_msgTypes[20].Exporter = func(v any,
i int) any {
- switch v := v.(*AllocationReleasesRequest); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
-
file_yunikorn_scheduler_interface_si_proto_msgTypes[21].Exporter = func(v any,
i int) any {
- switch v := v.(*AllocationRelease); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
-
file_yunikorn_scheduler_interface_si_proto_msgTypes[22].Exporter = func(v any,
i int) any {
- switch v := v.(*NodeInfo); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
-
file_yunikorn_scheduler_interface_si_proto_msgTypes[23].Exporter = func(v any,
i int) any {
- switch v := v.(*RejectedAllocation); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
-
file_yunikorn_scheduler_interface_si_proto_msgTypes[24].Exporter = func(v any,
i int) any {
- switch v := v.(*PredicatesArgs); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
-
file_yunikorn_scheduler_interface_si_proto_msgTypes[25].Exporter = func(v any,
i int) any {
- switch v := v.(*PreemptionPredicatesArgs); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
-
file_yunikorn_scheduler_interface_si_proto_msgTypes[26].Exporter = func(v any,
i int) any {
- switch v := v.(*PreemptionPredicatesResponse); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
-
file_yunikorn_scheduler_interface_si_proto_msgTypes[27].Exporter = func(v any,
i int) any {
- switch v := v.(*UpdateContainerSchedulingStateRequest);
i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
-
file_yunikorn_scheduler_interface_si_proto_msgTypes[28].Exporter = func(v any,
i int) any {
- switch v := v.(*UpdateConfigurationRequest); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
-
file_yunikorn_scheduler_interface_si_proto_msgTypes[29].Exporter = func(v any,
i int) any {
- switch v := v.(*EventRecord); i {
- case 0:
- return &v.state
- case 1:
- return &v.sizeCache
- case 2:
- return &v.unknownFields
- default:
- return nil
- }
- }
- }
type x struct{}
out := protoimpl.TypeBuilder{
File: protoimpl.DescBuilder{
GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
- RawDescriptor:
file_yunikorn_scheduler_interface_si_proto_rawDesc,
+ RawDescriptor:
unsafe.Slice(unsafe.StringData(file_yunikorn_scheduler_interface_si_proto_rawDesc),
len(file_yunikorn_scheduler_interface_si_proto_rawDesc)),
NumEnums: 6,
NumMessages: 37,
NumExtensions: 1,
@@ -3551,7 +3101,6 @@ func file_yunikorn_scheduler_interface_si_proto_init() {
ExtensionInfos:
file_yunikorn_scheduler_interface_si_proto_extTypes,
}.Build()
File_yunikorn_scheduler_interface_si_proto = out.File
- file_yunikorn_scheduler_interface_si_proto_rawDesc = nil
file_yunikorn_scheduler_interface_si_proto_goTypes = nil
file_yunikorn_scheduler_interface_si_proto_depIdxs = nil
}
---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscr...@yunikorn.apache.org
For additional commands, e-mail: issues-h...@yunikorn.apache.org
