代码拉取完成，页面将自动刷新
// Code generated by protoc-gen-go. DO NOT EDIT.
// versions:
// protoc-gen-go v1.36.10
// protoc v3.20.2
// source: agent.proto
package agent
import (
protoreflect "google.golang.org/protobuf/reflect/protoreflect"
protoimpl "google.golang.org/protobuf/runtime/protoimpl"
v1 "k8s.io/api/core/v1"
reflect "reflect"
sync "sync"
unsafe "unsafe"
)
const (
// Verify that this generated code is sufficiently up-to-date.
_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
// Verify that runtime/protoimpl is sufficiently up-to-date.
_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
)
type ActionCode int32
const (
ActionCode_SuccessCode ActionCode = 0
ActionCode_FailCode ActionCode = -1
)
// Enum value maps for ActionCode.
var (
ActionCode_name = map[int32]string{
0: "SuccessCode",
-1: "FailCode",
}
ActionCode_value = map[string]int32{
"SuccessCode": 0,
"FailCode": -1,
}
)
func (x ActionCode) Enum() *ActionCode {
p := new(ActionCode)
*p = x
return p
}
func (x ActionCode) String() string {
return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
}
func (ActionCode) Descriptor() protoreflect.EnumDescriptor {
return file_agent_proto_enumTypes[0].Descriptor()
}
func (ActionCode) Type() protoreflect.EnumType {
return &file_agent_proto_enumTypes[0]
}
func (x ActionCode) Number() protoreflect.EnumNumber {
return protoreflect.EnumNumber(x)
}
// Deprecated: Use ActionCode.Descriptor instead.
func (ActionCode) EnumDescriptor() ([]byte, []int) {
return file_agent_proto_rawDescGZIP(), []int{0}
}
type SpotStrategy int32
const (
SpotStrategy_NoSpot SpotStrategy = 0
SpotStrategy_SpotWithPriceLimit SpotStrategy = 1
SpotStrategy_SpotAsPriceGo SpotStrategy = 2
)
// Enum value maps for SpotStrategy.
var (
SpotStrategy_name = map[int32]string{
0: "NoSpot",
1: "SpotWithPriceLimit",
2: "SpotAsPriceGo",
}
SpotStrategy_value = map[string]int32{
"NoSpot": 0,
"SpotWithPriceLimit": 1,
"SpotAsPriceGo": 2,
}
)
func (x SpotStrategy) Enum() *SpotStrategy {
p := new(SpotStrategy)
*p = x
return p
}
func (x SpotStrategy) String() string {
return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
}
func (SpotStrategy) Descriptor() protoreflect.EnumDescriptor {
return file_agent_proto_enumTypes[1].Descriptor()
}
func (SpotStrategy) Type() protoreflect.EnumType {
return &file_agent_proto_enumTypes[1]
}
func (x SpotStrategy) Number() protoreflect.EnumNumber {
return protoreflect.EnumNumber(x)
}
// Deprecated: Use SpotStrategy.Descriptor instead.
func (SpotStrategy) EnumDescriptor() ([]byte, []int) {
return file_agent_proto_rawDescGZIP(), []int{1}
}
type DeleteCode int32
const (
DeleteCode_Default DeleteCode = 0
DeleteCode_SpotFailed DeleteCode = 1
DeleteCode_SpotDelayed DeleteCode = 2
DeleteCode_SpotCanceled DeleteCode = 3
)
// Enum value maps for DeleteCode.
var (
DeleteCode_name = map[int32]string{
0: "Default",
1: "SpotFailed",
2: "SpotDelayed",
3: "SpotCanceled",
}
DeleteCode_value = map[string]int32{
"Default": 0,
"SpotFailed": 1,
"SpotDelayed": 2,
"SpotCanceled": 3,
}
)
func (x DeleteCode) Enum() *DeleteCode {
p := new(DeleteCode)
*p = x
return p
}
func (x DeleteCode) String() string {
return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
}
func (DeleteCode) Descriptor() protoreflect.EnumDescriptor {
return file_agent_proto_enumTypes[2].Descriptor()
}
func (DeleteCode) Type() protoreflect.EnumType {
return &file_agent_proto_enumTypes[2]
}
func (x DeleteCode) Number() protoreflect.EnumNumber {
return protoreflect.EnumNumber(x)
}
// Deprecated: Use DeleteCode.Descriptor instead.
func (DeleteCode) EnumDescriptor() ([]byte, []int) {
return file_agent_proto_rawDescGZIP(), []int{2}
}
type NetworkInfo struct {
state protoimpl.MessageState `protogen:"open.v1"`
Ip string `protobuf:"bytes,1,opt,name=ip,proto3" json:"ip,omitempty"`
Vlan string `protobuf:"bytes,2,opt,name=vlan,proto3" json:"vlan,omitempty"`
Gateway string `protobuf:"bytes,3,opt,name=gateway,proto3" json:"gateway,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *NetworkInfo) Reset() {
*x = NetworkInfo{}
mi := &file_agent_proto_msgTypes[0]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *NetworkInfo) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*NetworkInfo) ProtoMessage() {}
func (x *NetworkInfo) ProtoReflect() protoreflect.Message {
mi := &file_agent_proto_msgTypes[0]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use NetworkInfo.ProtoReflect.Descriptor instead.
func (*NetworkInfo) Descriptor() ([]byte, []int) {
return file_agent_proto_rawDescGZIP(), []int{0}
}
func (x *NetworkInfo) GetIp() string {
if x != nil {
return x.Ip
}
return ""
}
func (x *NetworkInfo) GetVlan() string {
if x != nil {
return x.Vlan
}
return ""
}
func (x *NetworkInfo) GetGateway() string {
if x != nil {
return x.Gateway
}
return ""
}
type Env struct {
state protoimpl.MessageState `protogen:"open.v1"`
Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *Env) Reset() {
*x = Env{}
mi := &file_agent_proto_msgTypes[1]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *Env) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*Env) ProtoMessage() {}
func (x *Env) ProtoReflect() protoreflect.Message {
mi := &file_agent_proto_msgTypes[1]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use Env.ProtoReflect.Descriptor instead.
func (*Env) Descriptor() ([]byte, []int) {
return file_agent_proto_rawDescGZIP(), []int{1}
}
func (x *Env) GetKey() string {
if x != nil {
return x.Key
}
return ""
}
func (x *Env) GetValue() string {
if x != nil {
return x.Value
}
return ""
}
type ConfigMapVolume struct {
state protoimpl.MessageState `protogen:"open.v1"`
Source *v1.ConfigMap `protobuf:"bytes,1,opt,name=source,proto3,oneof" json:"source,omitempty"`
Volume *v1.ConfigMapVolumeSource `protobuf:"bytes,2,opt,name=volume,proto3,oneof" json:"volume,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *ConfigMapVolume) Reset() {
*x = ConfigMapVolume{}
mi := &file_agent_proto_msgTypes[2]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *ConfigMapVolume) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*ConfigMapVolume) ProtoMessage() {}
func (x *ConfigMapVolume) ProtoReflect() protoreflect.Message {
mi := &file_agent_proto_msgTypes[2]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use ConfigMapVolume.ProtoReflect.Descriptor instead.
func (*ConfigMapVolume) Descriptor() ([]byte, []int) {
return file_agent_proto_rawDescGZIP(), []int{2}
}
func (x *ConfigMapVolume) GetSource() *v1.ConfigMap {
if x != nil {
return x.Source
}
return nil
}
func (x *ConfigMapVolume) GetVolume() *v1.ConfigMapVolumeSource {
if x != nil {
return x.Volume
}
return nil
}
type SecretVolume struct {
state protoimpl.MessageState `protogen:"open.v1"`
Source *v1.Secret `protobuf:"bytes,1,opt,name=source,proto3,oneof" json:"source,omitempty"`
Volume *v1.SecretVolumeSource `protobuf:"bytes,2,opt,name=volume,proto3,oneof" json:"volume,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *SecretVolume) Reset() {
*x = SecretVolume{}
mi := &file_agent_proto_msgTypes[3]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *SecretVolume) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*SecretVolume) ProtoMessage() {}
func (x *SecretVolume) ProtoReflect() protoreflect.Message {
mi := &file_agent_proto_msgTypes[3]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use SecretVolume.ProtoReflect.Descriptor instead.
func (*SecretVolume) Descriptor() ([]byte, []int) {
return file_agent_proto_rawDescGZIP(), []int{3}
}
func (x *SecretVolume) GetSource() *v1.Secret {
if x != nil {
return x.Source
}
return nil
}
func (x *SecretVolume) GetVolume() *v1.SecretVolumeSource {
if x != nil {
return x.Volume
}
return nil
}
type NASVolumeInfo struct {
state protoimpl.MessageState `protogen:"open.v1"`
VolumeName string `protobuf:"bytes,1,opt,name=volume_name,json=volumeName,proto3" json:"volume_name,omitempty"`
Server string `protobuf:"bytes,2,opt,name=server,proto3" json:"server,omitempty"`
Path string `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`
MountOptions []string `protobuf:"bytes,4,rep,name=mount_options,json=mountOptions,proto3" json:"mount_options,omitempty"`
ReadOnly bool `protobuf:"varint,5,opt,name=read_only,json=readOnly,proto3" json:"read_only,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *NASVolumeInfo) Reset() {
*x = NASVolumeInfo{}
mi := &file_agent_proto_msgTypes[4]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *NASVolumeInfo) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*NASVolumeInfo) ProtoMessage() {}
func (x *NASVolumeInfo) ProtoReflect() protoreflect.Message {
mi := &file_agent_proto_msgTypes[4]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use NASVolumeInfo.ProtoReflect.Descriptor instead.
func (*NASVolumeInfo) Descriptor() ([]byte, []int) {
return file_agent_proto_rawDescGZIP(), []int{4}
}
func (x *NASVolumeInfo) GetVolumeName() string {
if x != nil {
return x.VolumeName
}
return ""
}
func (x *NASVolumeInfo) GetServer() string {
if x != nil {
return x.Server
}
return ""
}
func (x *NASVolumeInfo) GetPath() string {
if x != nil {
return x.Path
}
return ""
}
func (x *NASVolumeInfo) GetMountOptions() []string {
if x != nil {
return x.MountOptions
}
return nil
}
func (x *NASVolumeInfo) GetReadOnly() bool {
if x != nil {
return x.ReadOnly
}
return false
}
type Pod struct {
state protoimpl.MessageState `protogen:"open.v1"`
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
ContainerGroupName string `protobuf:"bytes,2,opt,name=containerGroupName,proto3" json:"containerGroupName,omitempty"`
Network *NetworkInfo `protobuf:"bytes,3,opt,name=network,proto3" json:"network,omitempty"`
RawPod *v1.Pod `protobuf:"bytes,4,opt,name=rawPod,proto3,oneof" json:"rawPod,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *Pod) Reset() {
*x = Pod{}
mi := &file_agent_proto_msgTypes[5]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *Pod) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*Pod) ProtoMessage() {}
func (x *Pod) ProtoReflect() protoreflect.Message {
mi := &file_agent_proto_msgTypes[5]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use Pod.ProtoReflect.Descriptor instead.
func (*Pod) Descriptor() ([]byte, []int) {
return file_agent_proto_rawDescGZIP(), []int{5}
}
func (x *Pod) GetId() string {
if x != nil {
return x.Id
}
return ""
}
func (x *Pod) GetContainerGroupName() string {
if x != nil {
return x.ContainerGroupName
}
return ""
}
func (x *Pod) GetNetwork() *NetworkInfo {
if x != nil {
return x.Network
}
return nil
}
func (x *Pod) GetRawPod() *v1.Pod {
if x != nil {
return x.RawPod
}
return nil
}
type PodRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
GpuType string `protobuf:"bytes,1,opt,name=gpu_type,json=gpuType,proto3" json:"gpu_type,omitempty"`
CpuType string `protobuf:"bytes,2,opt,name=cpu_type,json=cpuType,proto3" json:"cpu_type,omitempty"`
CustomerId string `protobuf:"bytes,3,opt,name=customer_id,json=customerId,proto3" json:"customer_id,omitempty"`
UserId string `protobuf:"bytes,4,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
RestartPolicy string `protobuf:"bytes,5,opt,name=restart_policy,json=restartPolicy,proto3" json:"restart_policy,omitempty"`
Cpu int64 `protobuf:"varint,6,opt,name=cpu,proto3" json:"cpu,omitempty"`
Ram int64 `protobuf:"varint,7,opt,name=ram,proto3" json:"ram,omitempty"`
Gpu int64 `protobuf:"varint,8,opt,name=gpu,proto3" json:"gpu,omitempty"`
Pods []*Pod `protobuf:"bytes,9,rep,name=pods,proto3" json:"pods,omitempty"`
TempStoreSize int64 `protobuf:"varint,10,opt,name=temp_store_size,json=tempStoreSize,proto3" json:"temp_store_size,omitempty"`
VnodeId string `protobuf:"bytes,12,opt,name=vnode_id,json=vnodeId,proto3" json:"vnode_id,omitempty"`
Secrets []*v1.Secret `protobuf:"bytes,13,rep,name=secrets,proto3" json:"secrets,omitempty"`
ConfigMaps []*v1.ConfigMap `protobuf:"bytes,14,rep,name=configMaps,proto3" json:"configMaps,omitempty"`
SpotStrategy string `protobuf:"bytes,15,opt,name=spotStrategy,proto3" json:"spotStrategy,omitempty"`
SpotPrice string `protobuf:"bytes,16,opt,name=spotPrice,proto3" json:"spotPrice,omitempty"`
Zone string `protobuf:"bytes,17,opt,name=zone,proto3" json:"zone,omitempty"`
CloudEdge bool `protobuf:"varint,18,opt,name=cloudEdge,proto3" json:"cloudEdge,omitempty"`
NasVolumes []*NASVolumeInfo `protobuf:"bytes,19,rep,name=nas_volumes,json=nasVolumes,proto3" json:"nas_volumes,omitempty"`
TestCreditProjectId int64 `protobuf:"varint,20,opt,name=test_credit_project_id,json=testCreditProjectId,proto3" json:"test_credit_project_id,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *PodRequest) Reset() {
*x = PodRequest{}
mi := &file_agent_proto_msgTypes[6]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *PodRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*PodRequest) ProtoMessage() {}
func (x *PodRequest) ProtoReflect() protoreflect.Message {
mi := &file_agent_proto_msgTypes[6]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use PodRequest.ProtoReflect.Descriptor instead.
func (*PodRequest) Descriptor() ([]byte, []int) {
return file_agent_proto_rawDescGZIP(), []int{6}
}
func (x *PodRequest) GetGpuType() string {
if x != nil {
return x.GpuType
}
return ""
}
func (x *PodRequest) GetCpuType() string {
if x != nil {
return x.CpuType
}
return ""
}
func (x *PodRequest) GetCustomerId() string {
if x != nil {
return x.CustomerId
}
return ""
}
func (x *PodRequest) GetUserId() string {
if x != nil {
return x.UserId
}
return ""
}
func (x *PodRequest) GetRestartPolicy() string {
if x != nil {
return x.RestartPolicy
}
return ""
}
func (x *PodRequest) GetCpu() int64 {
if x != nil {
return x.Cpu
}
return 0
}
func (x *PodRequest) GetRam() int64 {
if x != nil {
return x.Ram
}
return 0
}
func (x *PodRequest) GetGpu() int64 {
if x != nil {
return x.Gpu
}
return 0
}
func (x *PodRequest) GetPods() []*Pod {
if x != nil {
return x.Pods
}
return nil
}
func (x *PodRequest) GetTempStoreSize() int64 {
if x != nil {
return x.TempStoreSize
}
return 0
}
func (x *PodRequest) GetVnodeId() string {
if x != nil {
return x.VnodeId
}
return ""
}
func (x *PodRequest) GetSecrets() []*v1.Secret {
if x != nil {
return x.Secrets
}
return nil
}
func (x *PodRequest) GetConfigMaps() []*v1.ConfigMap {
if x != nil {
return x.ConfigMaps
}
return nil
}
func (x *PodRequest) GetSpotStrategy() string {
if x != nil {
return x.SpotStrategy
}
return ""
}
func (x *PodRequest) GetSpotPrice() string {
if x != nil {
return x.SpotPrice
}
return ""
}
func (x *PodRequest) GetZone() string {
if x != nil {
return x.Zone
}
return ""
}
func (x *PodRequest) GetCloudEdge() bool {
if x != nil {
return x.CloudEdge
}
return false
}
func (x *PodRequest) GetNasVolumes() []*NASVolumeInfo {
if x != nil {
return x.NasVolumes
}
return nil
}
func (x *PodRequest) GetTestCreditProjectId() int64 {
if x != nil {
return x.TestCreditProjectId
}
return 0
}
type PodDeleteRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
VNodeID string `protobuf:"bytes,1,opt,name=vNodeID,proto3" json:"vNodeID,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
Namespace string `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
Code DeleteCode `protobuf:"varint,4,opt,name=code,proto3,enum=agent.DeleteCode" json:"code,omitempty"`
RecycleProtectionPeriod int64 `protobuf:"varint,5,opt,name=recycleProtectionPeriod,proto3" json:"recycleProtectionPeriod,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *PodDeleteRequest) Reset() {
*x = PodDeleteRequest{}
mi := &file_agent_proto_msgTypes[7]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *PodDeleteRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*PodDeleteRequest) ProtoMessage() {}
func (x *PodDeleteRequest) ProtoReflect() protoreflect.Message {
mi := &file_agent_proto_msgTypes[7]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use PodDeleteRequest.ProtoReflect.Descriptor instead.
func (*PodDeleteRequest) Descriptor() ([]byte, []int) {
return file_agent_proto_rawDescGZIP(), []int{7}
}
func (x *PodDeleteRequest) GetVNodeID() string {
if x != nil {
return x.VNodeID
}
return ""
}
func (x *PodDeleteRequest) GetName() string {
if x != nil {
return x.Name
}
return ""
}
func (x *PodDeleteRequest) GetNamespace() string {
if x != nil {
return x.Namespace
}
return ""
}
func (x *PodDeleteRequest) GetCode() DeleteCode {
if x != nil {
return x.Code
}
return DeleteCode_Default
}
func (x *PodDeleteRequest) GetRecycleProtectionPeriod() int64 {
if x != nil {
return x.RecycleProtectionPeriod
}
return 0
}
type PodRebootRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
Namespace string `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *PodRebootRequest) Reset() {
*x = PodRebootRequest{}
mi := &file_agent_proto_msgTypes[8]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *PodRebootRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*PodRebootRequest) ProtoMessage() {}
func (x *PodRebootRequest) ProtoReflect() protoreflect.Message {
mi := &file_agent_proto_msgTypes[8]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use PodRebootRequest.ProtoReflect.Descriptor instead.
func (*PodRebootRequest) Descriptor() ([]byte, []int) {
return file_agent_proto_rawDescGZIP(), []int{8}
}
func (x *PodRebootRequest) GetName() string {
if x != nil {
return x.Name
}
return ""
}
func (x *PodRebootRequest) GetNamespace() string {
if x != nil {
return x.Namespace
}
return ""
}
type PodResponse struct {
state protoimpl.MessageState `protogen:"open.v1"`
Code ActionCode `protobuf:"varint,1,opt,name=code,proto3,enum=agent.ActionCode" json:"code,omitempty"`
Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *PodResponse) Reset() {
*x = PodResponse{}
mi := &file_agent_proto_msgTypes[9]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *PodResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*PodResponse) ProtoMessage() {}
func (x *PodResponse) ProtoReflect() protoreflect.Message {
mi := &file_agent_proto_msgTypes[9]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use PodResponse.ProtoReflect.Descriptor instead.
func (*PodResponse) Descriptor() ([]byte, []int) {
return file_agent_proto_rawDescGZIP(), []int{9}
}
func (x *PodResponse) GetCode() ActionCode {
if x != nil {
return x.Code
}
return ActionCode_SuccessCode
}
func (x *PodResponse) GetMessage() string {
if x != nil {
return x.Message
}
return ""
}
type Pods struct {
state protoimpl.MessageState `protogen:"open.v1"`
Network *NetworkInfo `protobuf:"bytes,1,opt,name=network,proto3" json:"network,omitempty"`
Pod *v1.Pod `protobuf:"bytes,2,opt,name=pod,proto3,oneof" json:"pod,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *Pods) Reset() {
*x = Pods{}
mi := &file_agent_proto_msgTypes[10]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *Pods) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*Pods) ProtoMessage() {}
func (x *Pods) ProtoReflect() protoreflect.Message {
mi := &file_agent_proto_msgTypes[10]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use Pods.ProtoReflect.Descriptor instead.
func (*Pods) Descriptor() ([]byte, []int) {
return file_agent_proto_rawDescGZIP(), []int{10}
}
func (x *Pods) GetNetwork() *NetworkInfo {
if x != nil {
return x.Network
}
return nil
}
func (x *Pods) GetPod() *v1.Pod {
if x != nil {
return x.Pod
}
return nil
}
type PodInfoRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
VnodeId string `protobuf:"bytes,3,opt,name=vnode_id,json=vnodeId,proto3" json:"vnode_id,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *PodInfoRequest) Reset() {
*x = PodInfoRequest{}
mi := &file_agent_proto_msgTypes[11]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *PodInfoRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*PodInfoRequest) ProtoMessage() {}
func (x *PodInfoRequest) ProtoReflect() protoreflect.Message {
mi := &file_agent_proto_msgTypes[11]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use PodInfoRequest.ProtoReflect.Descriptor instead.
func (*PodInfoRequest) Descriptor() ([]byte, []int) {
return file_agent_proto_rawDescGZIP(), []int{11}
}
func (x *PodInfoRequest) GetNamespace() string {
if x != nil {
return x.Namespace
}
return ""
}
func (x *PodInfoRequest) GetName() string {
if x != nil {
return x.Name
}
return ""
}
func (x *PodInfoRequest) GetVnodeId() string {
if x != nil {
return x.VnodeId
}
return ""
}
type PodInfoResponse struct {
state protoimpl.MessageState `protogen:"open.v1"`
Code ActionCode `protobuf:"varint,1,opt,name=code,proto3,enum=agent.ActionCode" json:"code,omitempty"`
Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
Pods []*Pods `protobuf:"bytes,3,rep,name=pods,proto3" json:"pods,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *PodInfoResponse) Reset() {
*x = PodInfoResponse{}
mi := &file_agent_proto_msgTypes[12]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *PodInfoResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*PodInfoResponse) ProtoMessage() {}
func (x *PodInfoResponse) ProtoReflect() protoreflect.Message {
mi := &file_agent_proto_msgTypes[12]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use PodInfoResponse.ProtoReflect.Descriptor instead.
func (*PodInfoResponse) Descriptor() ([]byte, []int) {
return file_agent_proto_rawDescGZIP(), []int{12}
}
func (x *PodInfoResponse) GetCode() ActionCode {
if x != nil {
return x.Code
}
return ActionCode_SuccessCode
}
func (x *PodInfoResponse) GetMessage() string {
if x != nil {
return x.Message
}
return ""
}
func (x *PodInfoResponse) GetPods() []*Pods {
if x != nil {
return x.Pods
}
return nil
}
type IpPoolSegments struct {
state protoimpl.MessageState `protogen:"open.v1"`
Vlan string `protobuf:"bytes,1,opt,name=vlan,proto3" json:"vlan,omitempty"`
Subnet string `protobuf:"bytes,2,opt,name=subnet,proto3" json:"subnet,omitempty"`
Gateway string `protobuf:"bytes,3,opt,name=gateway,proto3" json:"gateway,omitempty"`
AvailableZoneId string `protobuf:"bytes,4,opt,name=available_zone_id,json=availableZoneId,proto3" json:"available_zone_id,omitempty"`
StartEnd []string `protobuf:"bytes,5,rep,name=start_end,json=startEnd,proto3" json:"start_end,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *IpPoolSegments) Reset() {
*x = IpPoolSegments{}
mi := &file_agent_proto_msgTypes[13]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *IpPoolSegments) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*IpPoolSegments) ProtoMessage() {}
func (x *IpPoolSegments) ProtoReflect() protoreflect.Message {
mi := &file_agent_proto_msgTypes[13]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use IpPoolSegments.ProtoReflect.Descriptor instead.
func (*IpPoolSegments) Descriptor() ([]byte, []int) {
return file_agent_proto_rawDescGZIP(), []int{13}
}
func (x *IpPoolSegments) GetVlan() string {
if x != nil {
return x.Vlan
}
return ""
}
func (x *IpPoolSegments) GetSubnet() string {
if x != nil {
return x.Subnet
}
return ""
}
func (x *IpPoolSegments) GetGateway() string {
if x != nil {
return x.Gateway
}
return ""
}
func (x *IpPoolSegments) GetAvailableZoneId() string {
if x != nil {
return x.AvailableZoneId
}
return ""
}
func (x *IpPoolSegments) GetStartEnd() []string {
if x != nil {
return x.StartEnd
}
return nil
}
type PrivateNet struct {
state protoimpl.MessageState `protogen:"open.v1"`
Vlan string `protobuf:"bytes,1,opt,name=vlan,proto3" json:"vlan,omitempty"`
Subnet string `protobuf:"bytes,2,opt,name=subnet,proto3" json:"subnet,omitempty"`
Gateway string `protobuf:"bytes,3,opt,name=gateway,proto3" json:"gateway,omitempty"`
Ip string `protobuf:"bytes,4,opt,name=ip,proto3" json:"ip,omitempty"`
Eip string `protobuf:"bytes,5,opt,name=eip,proto3" json:"eip,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *PrivateNet) Reset() {
*x = PrivateNet{}
mi := &file_agent_proto_msgTypes[14]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *PrivateNet) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*PrivateNet) ProtoMessage() {}
func (x *PrivateNet) ProtoReflect() protoreflect.Message {
mi := &file_agent_proto_msgTypes[14]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use PrivateNet.ProtoReflect.Descriptor instead.
func (*PrivateNet) Descriptor() ([]byte, []int) {
return file_agent_proto_rawDescGZIP(), []int{14}
}
func (x *PrivateNet) GetVlan() string {
if x != nil {
return x.Vlan
}
return ""
}
func (x *PrivateNet) GetSubnet() string {
if x != nil {
return x.Subnet
}
return ""
}
func (x *PrivateNet) GetGateway() string {
if x != nil {
return x.Gateway
}
return ""
}
func (x *PrivateNet) GetIp() string {
if x != nil {
return x.Ip
}
return ""
}
func (x *PrivateNet) GetEip() string {
if x != nil {
return x.Eip
}
return ""
}
type QuantityInfo struct {
state protoimpl.MessageState `protogen:"open.v1"`
Cpu int64 `protobuf:"varint,1,opt,name=cpu,proto3" json:"cpu,omitempty"`
Ram int64 `protobuf:"varint,2,opt,name=ram,proto3" json:"ram,omitempty"`
Gpu int64 `protobuf:"varint,3,opt,name=gpu,proto3" json:"gpu,omitempty"`
CpuType string `protobuf:"bytes,4,opt,name=cpu_type,json=cpuType,proto3" json:"cpu_type,omitempty"`
GpuType string `protobuf:"bytes,5,opt,name=gpu_type,json=gpuType,proto3" json:"gpu_type,omitempty"`
MinSpotPrice string `protobuf:"bytes,6,opt,name=min_spot_price,json=minSpotPrice,proto3" json:"min_spot_price,omitempty"`
MaxSpotPrice string `protobuf:"bytes,7,opt,name=max_spot_price,json=maxSpotPrice,proto3" json:"max_spot_price,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *QuantityInfo) Reset() {
*x = QuantityInfo{}
mi := &file_agent_proto_msgTypes[15]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *QuantityInfo) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*QuantityInfo) ProtoMessage() {}
func (x *QuantityInfo) ProtoReflect() protoreflect.Message {
mi := &file_agent_proto_msgTypes[15]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use QuantityInfo.ProtoReflect.Descriptor instead.
func (*QuantityInfo) Descriptor() ([]byte, []int) {
return file_agent_proto_rawDescGZIP(), []int{15}
}
func (x *QuantityInfo) GetCpu() int64 {
if x != nil {
return x.Cpu
}
return 0
}
func (x *QuantityInfo) GetRam() int64 {
if x != nil {
return x.Ram
}
return 0
}
func (x *QuantityInfo) GetGpu() int64 {
if x != nil {
return x.Gpu
}
return 0
}
func (x *QuantityInfo) GetCpuType() string {
if x != nil {
return x.CpuType
}
return ""
}
func (x *QuantityInfo) GetGpuType() string {
if x != nil {
return x.GpuType
}
return ""
}
func (x *QuantityInfo) GetMinSpotPrice() string {
if x != nil {
return x.MinSpotPrice
}
return ""
}
func (x *QuantityInfo) GetMaxSpotPrice() string {
if x != nil {
return x.MaxSpotPrice
}
return ""
}
type ProductQuantity struct {
state protoimpl.MessageState `protogen:"open.v1"`
Quantity []*QuantityInfo `protobuf:"bytes,1,rep,name=quantity,proto3" json:"quantity,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *ProductQuantity) Reset() {
*x = ProductQuantity{}
mi := &file_agent_proto_msgTypes[16]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *ProductQuantity) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*ProductQuantity) ProtoMessage() {}
func (x *ProductQuantity) ProtoReflect() protoreflect.Message {
mi := &file_agent_proto_msgTypes[16]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use ProductQuantity.ProtoReflect.Descriptor instead.
func (*ProductQuantity) Descriptor() ([]byte, []int) {
return file_agent_proto_rawDescGZIP(), []int{16}
}
func (x *ProductQuantity) GetQuantity() []*QuantityInfo {
if x != nil {
return x.Quantity
}
return nil
}
type NodeQuantity struct {
state protoimpl.MessageState `protogen:"open.v1"`
Cpu int64 `protobuf:"varint,1,opt,name=cpu,proto3" json:"cpu,omitempty"`
Ram int64 `protobuf:"varint,2,opt,name=ram,proto3" json:"ram,omitempty"`
Gpu int64 `protobuf:"varint,3,opt,name=gpu,proto3" json:"gpu,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *NodeQuantity) Reset() {
*x = NodeQuantity{}
mi := &file_agent_proto_msgTypes[17]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *NodeQuantity) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*NodeQuantity) ProtoMessage() {}
func (x *NodeQuantity) ProtoReflect() protoreflect.Message {
mi := &file_agent_proto_msgTypes[17]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use NodeQuantity.ProtoReflect.Descriptor instead.
func (*NodeQuantity) Descriptor() ([]byte, []int) {
return file_agent_proto_rawDescGZIP(), []int{17}
}
func (x *NodeQuantity) GetCpu() int64 {
if x != nil {
return x.Cpu
}
return 0
}
func (x *NodeQuantity) GetRam() int64 {
if x != nil {
return x.Ram
}
return 0
}
func (x *NodeQuantity) GetGpu() int64 {
if x != nil {
return x.Gpu
}
return 0
}
type NodeRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
KubeConfig string `protobuf:"bytes,1,opt,name=kube_config,json=kubeConfig,proto3" json:"kube_config,omitempty"`
IpPoolSegments map[string]*IpPoolSegments `protobuf:"bytes,2,rep,name=ip_pool_segments,json=ipPoolSegments,proto3" json:"ip_pool_segments,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
CustomerId string `protobuf:"bytes,3,opt,name=customer_id,json=customerId,proto3" json:"customer_id,omitempty"`
UserId string `protobuf:"bytes,4,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
Id string `protobuf:"bytes,5,opt,name=id,proto3" json:"id,omitempty"`
PrivateNet *PrivateNet `protobuf:"bytes,6,opt,name=private_net,json=privateNet,proto3" json:"private_net,omitempty"`
Taints []*v1.Taint `protobuf:"bytes,7,rep,name=Taints,proto3" json:"Taints,omitempty"`
Labels map[string]string `protobuf:"bytes,8,rep,name=labels,proto3" json:"labels,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
NodeQuantity *NodeQuantity `protobuf:"bytes,9,opt,name=nodeQuantity,proto3" json:"nodeQuantity,omitempty"`
Image string `protobuf:"bytes,10,opt,name=image,proto3" json:"image,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *NodeRequest) Reset() {
*x = NodeRequest{}
mi := &file_agent_proto_msgTypes[18]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *NodeRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*NodeRequest) ProtoMessage() {}
func (x *NodeRequest) ProtoReflect() protoreflect.Message {
mi := &file_agent_proto_msgTypes[18]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use NodeRequest.ProtoReflect.Descriptor instead.
func (*NodeRequest) Descriptor() ([]byte, []int) {
return file_agent_proto_rawDescGZIP(), []int{18}
}
func (x *NodeRequest) GetKubeConfig() string {
if x != nil {
return x.KubeConfig
}
return ""
}
func (x *NodeRequest) GetIpPoolSegments() map[string]*IpPoolSegments {
if x != nil {
return x.IpPoolSegments
}
return nil
}
func (x *NodeRequest) GetCustomerId() string {
if x != nil {
return x.CustomerId
}
return ""
}
func (x *NodeRequest) GetUserId() string {
if x != nil {
return x.UserId
}
return ""
}
func (x *NodeRequest) GetId() string {
if x != nil {
return x.Id
}
return ""
}
func (x *NodeRequest) GetPrivateNet() *PrivateNet {
if x != nil {
return x.PrivateNet
}
return nil
}
func (x *NodeRequest) GetTaints() []*v1.Taint {
if x != nil {
return x.Taints
}
return nil
}
func (x *NodeRequest) GetLabels() map[string]string {
if x != nil {
return x.Labels
}
return nil
}
func (x *NodeRequest) GetNodeQuantity() *NodeQuantity {
if x != nil {
return x.NodeQuantity
}
return nil
}
func (x *NodeRequest) GetImage() string {
if x != nil {
return x.Image
}
return ""
}
type NodeResponse struct {
state protoimpl.MessageState `protogen:"open.v1"`
Code ActionCode `protobuf:"varint,1,opt,name=code,proto3,enum=agent.ActionCode" json:"code,omitempty"`
Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *NodeResponse) Reset() {
*x = NodeResponse{}
mi := &file_agent_proto_msgTypes[19]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *NodeResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*NodeResponse) ProtoMessage() {}
func (x *NodeResponse) ProtoReflect() protoreflect.Message {
mi := &file_agent_proto_msgTypes[19]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use NodeResponse.ProtoReflect.Descriptor instead.
func (*NodeResponse) Descriptor() ([]byte, []int) {
return file_agent_proto_rawDescGZIP(), []int{19}
}
func (x *NodeResponse) GetCode() ActionCode {
if x != nil {
return x.Code
}
return ActionCode_SuccessCode
}
func (x *NodeResponse) GetMessage() string {
if x != nil {
return x.Message
}
return ""
}
type NodeGpuUsageRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
NodeIds []string `protobuf:"bytes,1,rep,name=nodeIds,proto3" json:"nodeIds,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *NodeGpuUsageRequest) Reset() {
*x = NodeGpuUsageRequest{}
mi := &file_agent_proto_msgTypes[20]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *NodeGpuUsageRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*NodeGpuUsageRequest) ProtoMessage() {}
func (x *NodeGpuUsageRequest) ProtoReflect() protoreflect.Message {
mi := &file_agent_proto_msgTypes[20]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use NodeGpuUsageRequest.ProtoReflect.Descriptor instead.
func (*NodeGpuUsageRequest) Descriptor() ([]byte, []int) {
return file_agent_proto_rawDescGZIP(), []int{20}
}
func (x *NodeGpuUsageRequest) GetNodeIds() []string {
if x != nil {
return x.NodeIds
}
return nil
}
type NodeUsageRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *NodeUsageRequest) Reset() {
*x = NodeUsageRequest{}
mi := &file_agent_proto_msgTypes[21]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *NodeUsageRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*NodeUsageRequest) ProtoMessage() {}
func (x *NodeUsageRequest) ProtoReflect() protoreflect.Message {
mi := &file_agent_proto_msgTypes[21]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use NodeUsageRequest.ProtoReflect.Descriptor instead.
func (*NodeUsageRequest) Descriptor() ([]byte, []int) {
return file_agent_proto_rawDescGZIP(), []int{21}
}
type NodeGpuUsageResponse struct {
state protoimpl.MessageState `protogen:"open.v1"`
Code ActionCode `protobuf:"varint,1,opt,name=code,proto3,enum=agent.ActionCode" json:"code,omitempty"`
Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
NodeGpuUsage []*NodeGpuUsage `protobuf:"bytes,3,rep,name=node_gpu_usage,json=nodeGpuUsage,proto3" json:"node_gpu_usage,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *NodeGpuUsageResponse) Reset() {
*x = NodeGpuUsageResponse{}
mi := &file_agent_proto_msgTypes[22]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *NodeGpuUsageResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*NodeGpuUsageResponse) ProtoMessage() {}
func (x *NodeGpuUsageResponse) ProtoReflect() protoreflect.Message {
mi := &file_agent_proto_msgTypes[22]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use NodeGpuUsageResponse.ProtoReflect.Descriptor instead.
func (*NodeGpuUsageResponse) Descriptor() ([]byte, []int) {
return file_agent_proto_rawDescGZIP(), []int{22}
}
func (x *NodeGpuUsageResponse) GetCode() ActionCode {
if x != nil {
return x.Code
}
return ActionCode_SuccessCode
}
func (x *NodeGpuUsageResponse) GetMessage() string {
if x != nil {
return x.Message
}
return ""
}
func (x *NodeGpuUsageResponse) GetNodeGpuUsage() []*NodeGpuUsage {
if x != nil {
return x.NodeGpuUsage
}
return nil
}
type NodeGpuUsage struct {
state protoimpl.MessageState `protogen:"open.v1"`
NodeId string `protobuf:"bytes,1,opt,name=nodeId,proto3" json:"nodeId,omitempty"`
GpuType string `protobuf:"bytes,2,opt,name=gpuType,proto3" json:"gpuType,omitempty"`
TotalGpus int64 `protobuf:"varint,3,opt,name=totalGpus,proto3" json:"totalGpus,omitempty"`
UsedGpus int64 `protobuf:"varint,4,opt,name=usedGpus,proto3" json:"usedGpus,omitempty"`
PodIds []string `protobuf:"bytes,5,rep,name=podIds,proto3" json:"podIds,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *NodeGpuUsage) Reset() {
*x = NodeGpuUsage{}
mi := &file_agent_proto_msgTypes[23]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *NodeGpuUsage) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*NodeGpuUsage) ProtoMessage() {}
func (x *NodeGpuUsage) ProtoReflect() protoreflect.Message {
mi := &file_agent_proto_msgTypes[23]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use NodeGpuUsage.ProtoReflect.Descriptor instead.
func (*NodeGpuUsage) Descriptor() ([]byte, []int) {
return file_agent_proto_rawDescGZIP(), []int{23}
}
func (x *NodeGpuUsage) GetNodeId() string {
if x != nil {
return x.NodeId
}
return ""
}
func (x *NodeGpuUsage) GetGpuType() string {
if x != nil {
return x.GpuType
}
return ""
}
func (x *NodeGpuUsage) GetTotalGpus() int64 {
if x != nil {
return x.TotalGpus
}
return 0
}
func (x *NodeGpuUsage) GetUsedGpus() int64 {
if x != nil {
return x.UsedGpus
}
return 0
}
func (x *NodeGpuUsage) GetPodIds() []string {
if x != nil {
return x.PodIds
}
return nil
}
type NodeUsageResponse struct {
state protoimpl.MessageState `protogen:"open.v1"`
Usage []*NodeUsage `protobuf:"bytes,1,rep,name=usage,proto3" json:"usage,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *NodeUsageResponse) Reset() {
*x = NodeUsageResponse{}
mi := &file_agent_proto_msgTypes[24]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *NodeUsageResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*NodeUsageResponse) ProtoMessage() {}
func (x *NodeUsageResponse) ProtoReflect() protoreflect.Message {
mi := &file_agent_proto_msgTypes[24]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use NodeUsageResponse.ProtoReflect.Descriptor instead.
func (*NodeUsageResponse) Descriptor() ([]byte, []int) {
return file_agent_proto_rawDescGZIP(), []int{24}
}
func (x *NodeUsageResponse) GetUsage() []*NodeUsage {
if x != nil {
return x.Usage
}
return nil
}
type UsageInfo struct {
state protoimpl.MessageState `protogen:"open.v1"`
Gpus int64 `protobuf:"varint,1,opt,name=gpus,proto3" json:"gpus,omitempty"`
Cpus int64 `protobuf:"varint,2,opt,name=cpus,proto3" json:"cpus,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *UsageInfo) Reset() {
*x = UsageInfo{}
mi := &file_agent_proto_msgTypes[25]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *UsageInfo) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*UsageInfo) ProtoMessage() {}
func (x *UsageInfo) ProtoReflect() protoreflect.Message {
mi := &file_agent_proto_msgTypes[25]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use UsageInfo.ProtoReflect.Descriptor instead.
func (*UsageInfo) Descriptor() ([]byte, []int) {
return file_agent_proto_rawDescGZIP(), []int{25}
}
func (x *UsageInfo) GetGpus() int64 {
if x != nil {
return x.Gpus
}
return 0
}
func (x *UsageInfo) GetCpus() int64 {
if x != nil {
return x.Cpus
}
return 0
}
type NodeUsage struct {
state protoimpl.MessageState `protogen:"open.v1"`
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
GpuType string `protobuf:"bytes,3,opt,name=gpuType,proto3" json:"gpuType,omitempty"`
CpuType string `protobuf:"bytes,4,opt,name=cpuType,proto3" json:"cpuType,omitempty"`
TotalUsage *UsageInfo `protobuf:"bytes,5,opt,name=totalUsage,proto3" json:"totalUsage,omitempty"`
UsedUsage *UsageInfo `protobuf:"bytes,6,opt,name=usedUsage,proto3" json:"usedUsage,omitempty"`
UsedSpotPriceLimitUsage *UsageInfo `protobuf:"bytes,7,opt,name=usedSpotPriceLimitUsage,proto3" json:"usedSpotPriceLimitUsage,omitempty"`
UsedSpotAsPriceGoUsage *UsageInfo `protobuf:"bytes,8,opt,name=usedSpotAsPriceGoUsage,proto3" json:"usedSpotAsPriceGoUsage,omitempty"`
FamilyId string `protobuf:"bytes,9,opt,name=familyId,proto3" json:"familyId,omitempty"`
LowestPricePerUnit float32 `protobuf:"fixed32,10,opt,name=lowestPricePerUnit,proto3" json:"lowestPricePerUnit,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *NodeUsage) Reset() {
*x = NodeUsage{}
mi := &file_agent_proto_msgTypes[26]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *NodeUsage) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*NodeUsage) ProtoMessage() {}
func (x *NodeUsage) ProtoReflect() protoreflect.Message {
mi := &file_agent_proto_msgTypes[26]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use NodeUsage.ProtoReflect.Descriptor instead.
func (*NodeUsage) Descriptor() ([]byte, []int) {
return file_agent_proto_rawDescGZIP(), []int{26}
}
func (x *NodeUsage) GetId() string {
if x != nil {
return x.Id
}
return ""
}
func (x *NodeUsage) GetName() string {
if x != nil {
return x.Name
}
return ""
}
func (x *NodeUsage) GetGpuType() string {
if x != nil {
return x.GpuType
}
return ""
}
func (x *NodeUsage) GetCpuType() string {
if x != nil {
return x.CpuType
}
return ""
}
func (x *NodeUsage) GetTotalUsage() *UsageInfo {
if x != nil {
return x.TotalUsage
}
return nil
}
func (x *NodeUsage) GetUsedUsage() *UsageInfo {
if x != nil {
return x.UsedUsage
}
return nil
}
func (x *NodeUsage) GetUsedSpotPriceLimitUsage() *UsageInfo {
if x != nil {
return x.UsedSpotPriceLimitUsage
}
return nil
}
func (x *NodeUsage) GetUsedSpotAsPriceGoUsage() *UsageInfo {
if x != nil {
return x.UsedSpotAsPriceGoUsage
}
return nil
}
func (x *NodeUsage) GetFamilyId() string {
if x != nil {
return x.FamilyId
}
return ""
}
func (x *NodeUsage) GetLowestPricePerUnit() float32 {
if x != nil {
return x.LowestPricePerUnit
}
return 0
}
type CreateWsTokenRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
CustomerId string `protobuf:"bytes,1,opt,name=customer_id,json=customerId,proto3" json:"customer_id,omitempty"`
UserId string `protobuf:"bytes,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
PodName string `protobuf:"bytes,3,opt,name=pod_name,json=podName,proto3" json:"pod_name,omitempty"`
VnodeId string `protobuf:"bytes,4,opt,name=vnode_id,json=vnodeId,proto3" json:"vnode_id,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *CreateWsTokenRequest) Reset() {
*x = CreateWsTokenRequest{}
mi := &file_agent_proto_msgTypes[27]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *CreateWsTokenRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*CreateWsTokenRequest) ProtoMessage() {}
func (x *CreateWsTokenRequest) ProtoReflect() protoreflect.Message {
mi := &file_agent_proto_msgTypes[27]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use CreateWsTokenRequest.ProtoReflect.Descriptor instead.
func (*CreateWsTokenRequest) Descriptor() ([]byte, []int) {
return file_agent_proto_rawDescGZIP(), []int{27}
}
func (x *CreateWsTokenRequest) GetCustomerId() string {
if x != nil {
return x.CustomerId
}
return ""
}
func (x *CreateWsTokenRequest) GetUserId() string {
if x != nil {
return x.UserId
}
return ""
}
func (x *CreateWsTokenRequest) GetPodName() string {
if x != nil {
return x.PodName
}
return ""
}
func (x *CreateWsTokenRequest) GetVnodeId() string {
if x != nil {
return x.VnodeId
}
return ""
}
type CreateWsTokenResponse struct {
state protoimpl.MessageState `protogen:"open.v1"`
Code ActionCode `protobuf:"varint,1,opt,name=code,proto3,enum=agent.ActionCode" json:"code,omitempty"`
Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
Token string `protobuf:"bytes,3,opt,name=token,proto3" json:"token,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *CreateWsTokenResponse) Reset() {
*x = CreateWsTokenResponse{}
mi := &file_agent_proto_msgTypes[28]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *CreateWsTokenResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*CreateWsTokenResponse) ProtoMessage() {}
func (x *CreateWsTokenResponse) ProtoReflect() protoreflect.Message {
mi := &file_agent_proto_msgTypes[28]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use CreateWsTokenResponse.ProtoReflect.Descriptor instead.
func (*CreateWsTokenResponse) Descriptor() ([]byte, []int) {
return file_agent_proto_rawDescGZIP(), []int{28}
}
func (x *CreateWsTokenResponse) GetCode() ActionCode {
if x != nil {
return x.Code
}
return ActionCode_SuccessCode
}
func (x *CreateWsTokenResponse) GetMessage() string {
if x != nil {
return x.Message
}
return ""
}
func (x *CreateWsTokenResponse) GetToken() string {
if x != nil {
return x.Token
}
return ""
}
type QuotaRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
CustomerId string `protobuf:"bytes,1,opt,name=customerId,proto3" json:"customerId,omitempty"`
UserId string `protobuf:"bytes,2,opt,name=userId,proto3" json:"userId,omitempty"`
Quota *v1.ResourceQuotaSpec `protobuf:"bytes,3,opt,name=quota,proto3,oneof" json:"quota,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *QuotaRequest) Reset() {
*x = QuotaRequest{}
mi := &file_agent_proto_msgTypes[29]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *QuotaRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*QuotaRequest) ProtoMessage() {}
func (x *QuotaRequest) ProtoReflect() protoreflect.Message {
mi := &file_agent_proto_msgTypes[29]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use QuotaRequest.ProtoReflect.Descriptor instead.
func (*QuotaRequest) Descriptor() ([]byte, []int) {
return file_agent_proto_rawDescGZIP(), []int{29}
}
func (x *QuotaRequest) GetCustomerId() string {
if x != nil {
return x.CustomerId
}
return ""
}
func (x *QuotaRequest) GetUserId() string {
if x != nil {
return x.UserId
}
return ""
}
func (x *QuotaRequest) GetQuota() *v1.ResourceQuotaSpec {
if x != nil {
return x.Quota
}
return nil
}
type QuotaStatusResponse struct {
state protoimpl.MessageState `protogen:"open.v1"`
Quota *v1.ResourceQuotaStatus `protobuf:"bytes,1,opt,name=quota,proto3,oneof" json:"quota,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *QuotaStatusResponse) Reset() {
*x = QuotaStatusResponse{}
mi := &file_agent_proto_msgTypes[30]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *QuotaStatusResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*QuotaStatusResponse) ProtoMessage() {}
func (x *QuotaStatusResponse) ProtoReflect() protoreflect.Message {
mi := &file_agent_proto_msgTypes[30]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use QuotaStatusResponse.ProtoReflect.Descriptor instead.
func (*QuotaStatusResponse) Descriptor() ([]byte, []int) {
return file_agent_proto_rawDescGZIP(), []int{30}
}
func (x *QuotaStatusResponse) GetQuota() *v1.ResourceQuotaStatus {
if x != nil {
return x.Quota
}
return nil
}
type QuotaResponse struct {
state protoimpl.MessageState `protogen:"open.v1"`
Result bool `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"`
Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *QuotaResponse) Reset() {
*x = QuotaResponse{}
mi := &file_agent_proto_msgTypes[31]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *QuotaResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*QuotaResponse) ProtoMessage() {}
func (x *QuotaResponse) ProtoReflect() protoreflect.Message {
mi := &file_agent_proto_msgTypes[31]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use QuotaResponse.ProtoReflect.Descriptor instead.
func (*QuotaResponse) Descriptor() ([]byte, []int) {
return file_agent_proto_rawDescGZIP(), []int{31}
}
func (x *QuotaResponse) GetResult() bool {
if x != nil {
return x.Result
}
return false
}
func (x *QuotaResponse) GetMessage() string {
if x != nil {
return x.Message
}
return ""
}
type GetInstanceRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
CustomerId string `protobuf:"bytes,1,opt,name=customerId,proto3" json:"customerId,omitempty"`
UserId string `protobuf:"bytes,2,opt,name=userId,proto3" json:"userId,omitempty"`
InstanceIds []string `protobuf:"bytes,3,rep,name=InstanceIds,proto3" json:"InstanceIds,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *GetInstanceRequest) Reset() {
*x = GetInstanceRequest{}
mi := &file_agent_proto_msgTypes[32]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *GetInstanceRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*GetInstanceRequest) ProtoMessage() {}
func (x *GetInstanceRequest) ProtoReflect() protoreflect.Message {
mi := &file_agent_proto_msgTypes[32]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use GetInstanceRequest.ProtoReflect.Descriptor instead.
func (*GetInstanceRequest) Descriptor() ([]byte, []int) {
return file_agent_proto_rawDescGZIP(), []int{32}
}
func (x *GetInstanceRequest) GetCustomerId() string {
if x != nil {
return x.CustomerId
}
return ""
}
func (x *GetInstanceRequest) GetUserId() string {
if x != nil {
return x.UserId
}
return ""
}
func (x *GetInstanceRequest) GetInstanceIds() []string {
if x != nil {
return x.InstanceIds
}
return nil
}
type GetInstanceResponse struct {
state protoimpl.MessageState `protogen:"open.v1"`
InstanceIds []string `protobuf:"bytes,1,rep,name=InstanceIds,proto3" json:"InstanceIds,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *GetInstanceResponse) Reset() {
*x = GetInstanceResponse{}
mi := &file_agent_proto_msgTypes[33]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *GetInstanceResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*GetInstanceResponse) ProtoMessage() {}
func (x *GetInstanceResponse) ProtoReflect() protoreflect.Message {
mi := &file_agent_proto_msgTypes[33]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use GetInstanceResponse.ProtoReflect.Descriptor instead.
func (*GetInstanceResponse) Descriptor() ([]byte, []int) {
return file_agent_proto_rawDescGZIP(), []int{33}
}
func (x *GetInstanceResponse) GetInstanceIds() []string {
if x != nil {
return x.InstanceIds
}
return nil
}
type FamilySpecRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
ProductQuantity map[string]*ProductQuantity `protobuf:"bytes,1,rep,name=productQuantity,proto3" json:"productQuantity,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *FamilySpecRequest) Reset() {
*x = FamilySpecRequest{}
mi := &file_agent_proto_msgTypes[34]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *FamilySpecRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*FamilySpecRequest) ProtoMessage() {}
func (x *FamilySpecRequest) ProtoReflect() protoreflect.Message {
mi := &file_agent_proto_msgTypes[34]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use FamilySpecRequest.ProtoReflect.Descriptor instead.
func (*FamilySpecRequest) Descriptor() ([]byte, []int) {
return file_agent_proto_rawDescGZIP(), []int{34}
}
func (x *FamilySpecRequest) GetProductQuantity() map[string]*ProductQuantity {
if x != nil {
return x.ProductQuantity
}
return nil
}
type FamilySpecResponse struct {
state protoimpl.MessageState `protogen:"open.v1"`
Result bool `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"`
Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *FamilySpecResponse) Reset() {
*x = FamilySpecResponse{}
mi := &file_agent_proto_msgTypes[35]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *FamilySpecResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*FamilySpecResponse) ProtoMessage() {}
func (x *FamilySpecResponse) ProtoReflect() protoreflect.Message {
mi := &file_agent_proto_msgTypes[35]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use FamilySpecResponse.ProtoReflect.Descriptor instead.
func (*FamilySpecResponse) Descriptor() ([]byte, []int) {
return file_agent_proto_rawDescGZIP(), []int{35}
}
func (x *FamilySpecResponse) GetResult() bool {
if x != nil {
return x.Result
}
return false
}
func (x *FamilySpecResponse) GetMessage() string {
if x != nil {
return x.Message
}
return ""
}
type DataCacheRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
Network *DataCacheNetworkInfo `protobuf:"bytes,1,opt,name=network,proto3" json:"network,omitempty"`
Image string `protobuf:"bytes,2,opt,name=image,proto3" json:"image,omitempty"`
Dest *DataCacheOptions `protobuf:"bytes,3,opt,name=dest,proto3" json:"dest,omitempty"`
Source *DataCacheOptions `protobuf:"bytes,4,opt,name=source,proto3" json:"source,omitempty"`
Id string `protobuf:"bytes,5,opt,name=id,proto3" json:"id,omitempty"`
CustomerId string `protobuf:"bytes,6,opt,name=customer_id,json=customerId,proto3" json:"customer_id,omitempty"`
UserId string `protobuf:"bytes,7,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *DataCacheRequest) Reset() {
*x = DataCacheRequest{}
mi := &file_agent_proto_msgTypes[36]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *DataCacheRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*DataCacheRequest) ProtoMessage() {}
func (x *DataCacheRequest) ProtoReflect() protoreflect.Message {
mi := &file_agent_proto_msgTypes[36]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use DataCacheRequest.ProtoReflect.Descriptor instead.
func (*DataCacheRequest) Descriptor() ([]byte, []int) {
return file_agent_proto_rawDescGZIP(), []int{36}
}
func (x *DataCacheRequest) GetNetwork() *DataCacheNetworkInfo {
if x != nil {
return x.Network
}
return nil
}
func (x *DataCacheRequest) GetImage() string {
if x != nil {
return x.Image
}
return ""
}
func (x *DataCacheRequest) GetDest() *DataCacheOptions {
if x != nil {
return x.Dest
}
return nil
}
func (x *DataCacheRequest) GetSource() *DataCacheOptions {
if x != nil {
return x.Source
}
return nil
}
func (x *DataCacheRequest) GetId() string {
if x != nil {
return x.Id
}
return ""
}
func (x *DataCacheRequest) GetCustomerId() string {
if x != nil {
return x.CustomerId
}
return ""
}
func (x *DataCacheRequest) GetUserId() string {
if x != nil {
return x.UserId
}
return ""
}
type DataCacheOptions struct {
state protoimpl.MessageState `protogen:"open.v1"`
Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
Url string `protobuf:"bytes,3,opt,name=url,proto3" json:"url,omitempty"`
Server string `protobuf:"bytes,4,opt,name=server,proto3" json:"server,omitempty"`
OtherOpts string `protobuf:"bytes,5,opt,name=otherOpts,proto3" json:"otherOpts,omitempty"`
Bucket string `protobuf:"bytes,6,opt,name=bucket,proto3" json:"bucket,omitempty"`
AkId string `protobuf:"bytes,7,opt,name=akId,proto3" json:"akId,omitempty"`
AkSecret string `protobuf:"bytes,8,opt,name=akSecret,proto3" json:"akSecret,omitempty"`
AccessToken string `protobuf:"bytes,9,opt,name=accessToken,proto3" json:"accessToken,omitempty"`
RepoSource string `protobuf:"bytes,10,opt,name=repoSource,proto3" json:"repoSource,omitempty"`
RepoId string `protobuf:"bytes,11,opt,name=repoId,proto3" json:"repoId,omitempty"`
Revision string `protobuf:"bytes,12,opt,name=revision,proto3" json:"revision,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *DataCacheOptions) Reset() {
*x = DataCacheOptions{}
mi := &file_agent_proto_msgTypes[37]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *DataCacheOptions) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*DataCacheOptions) ProtoMessage() {}
func (x *DataCacheOptions) ProtoReflect() protoreflect.Message {
mi := &file_agent_proto_msgTypes[37]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use DataCacheOptions.ProtoReflect.Descriptor instead.
func (*DataCacheOptions) Descriptor() ([]byte, []int) {
return file_agent_proto_rawDescGZIP(), []int{37}
}
func (x *DataCacheOptions) GetType() string {
if x != nil {
return x.Type
}
return ""
}
func (x *DataCacheOptions) GetPath() string {
if x != nil {
return x.Path
}
return ""
}
func (x *DataCacheOptions) GetUrl() string {
if x != nil {
return x.Url
}
return ""
}
func (x *DataCacheOptions) GetServer() string {
if x != nil {
return x.Server
}
return ""
}
func (x *DataCacheOptions) GetOtherOpts() string {
if x != nil {
return x.OtherOpts
}
return ""
}
func (x *DataCacheOptions) GetBucket() string {
if x != nil {
return x.Bucket
}
return ""
}
func (x *DataCacheOptions) GetAkId() string {
if x != nil {
return x.AkId
}
return ""
}
func (x *DataCacheOptions) GetAkSecret() string {
if x != nil {
return x.AkSecret
}
return ""
}
func (x *DataCacheOptions) GetAccessToken() string {
if x != nil {
return x.AccessToken
}
return ""
}
func (x *DataCacheOptions) GetRepoSource() string {
if x != nil {
return x.RepoSource
}
return ""
}
func (x *DataCacheOptions) GetRepoId() string {
if x != nil {
return x.RepoId
}
return ""
}
func (x *DataCacheOptions) GetRevision() string {
if x != nil {
return x.Revision
}
return ""
}
type DataCacheResponse struct {
state protoimpl.MessageState `protogen:"open.v1"`
Code ActionCode `protobuf:"varint,1,opt,name=code,proto3,enum=agent.ActionCode" json:"code,omitempty"`
Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *DataCacheResponse) Reset() {
*x = DataCacheResponse{}
mi := &file_agent_proto_msgTypes[38]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *DataCacheResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*DataCacheResponse) ProtoMessage() {}
func (x *DataCacheResponse) ProtoReflect() protoreflect.Message {
mi := &file_agent_proto_msgTypes[38]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use DataCacheResponse.ProtoReflect.Descriptor instead.
func (*DataCacheResponse) Descriptor() ([]byte, []int) {
return file_agent_proto_rawDescGZIP(), []int{38}
}
func (x *DataCacheResponse) GetCode() ActionCode {
if x != nil {
return x.Code
}
return ActionCode_SuccessCode
}
func (x *DataCacheResponse) GetMessage() string {
if x != nil {
return x.Message
}
return ""
}
type DataCacheNetworkInfo struct {
state protoimpl.MessageState `protogen:"open.v1"`
Ip string `protobuf:"bytes,1,opt,name=ip,proto3" json:"ip,omitempty"`
Vlan string `protobuf:"bytes,2,opt,name=vlan,proto3" json:"vlan,omitempty"`
Gateway string `protobuf:"bytes,3,opt,name=gateway,proto3" json:"gateway,omitempty"`
Dns string `protobuf:"bytes,4,opt,name=dns,proto3" json:"dns,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *DataCacheNetworkInfo) Reset() {
*x = DataCacheNetworkInfo{}
mi := &file_agent_proto_msgTypes[39]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *DataCacheNetworkInfo) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*DataCacheNetworkInfo) ProtoMessage() {}
func (x *DataCacheNetworkInfo) ProtoReflect() protoreflect.Message {
mi := &file_agent_proto_msgTypes[39]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use DataCacheNetworkInfo.ProtoReflect.Descriptor instead.
func (*DataCacheNetworkInfo) Descriptor() ([]byte, []int) {
return file_agent_proto_rawDescGZIP(), []int{39}
}
func (x *DataCacheNetworkInfo) GetIp() string {
if x != nil {
return x.Ip
}
return ""
}
func (x *DataCacheNetworkInfo) GetVlan() string {
if x != nil {
return x.Vlan
}
return ""
}
func (x *DataCacheNetworkInfo) GetGateway() string {
if x != nil {
return x.Gateway
}
return ""
}
func (x *DataCacheNetworkInfo) GetDns() string {
if x != nil {
return x.Dns
}
return ""
}
type EventRequest struct {
state protoimpl.MessageState `protogen:"open.v1"`
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *EventRequest) Reset() {
*x = EventRequest{}
mi := &file_agent_proto_msgTypes[40]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *EventRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*EventRequest) ProtoMessage() {}
func (x *EventRequest) ProtoReflect() protoreflect.Message {
mi := &file_agent_proto_msgTypes[40]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use EventRequest.ProtoReflect.Descriptor instead.
func (*EventRequest) Descriptor() ([]byte, []int) {
return file_agent_proto_rawDescGZIP(), []int{40}
}
func (x *EventRequest) GetName() string {
if x != nil {
return x.Name
}
return ""
}
func (x *EventRequest) GetNamespace() string {
if x != nil {
return x.Namespace
}
return ""
}
type PodEvent struct {
state protoimpl.MessageState `protogen:"open.v1"`
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
FirstTimestamp string `protobuf:"bytes,4,opt,name=firstTimestamp,proto3" json:"firstTimestamp,omitempty"`
LastTimestamp string `protobuf:"bytes,5,opt,name=lastTimestamp,proto3" json:"lastTimestamp,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *PodEvent) Reset() {
*x = PodEvent{}
mi := &file_agent_proto_msgTypes[41]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *PodEvent) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*PodEvent) ProtoMessage() {}
func (x *PodEvent) ProtoReflect() protoreflect.Message {
mi := &file_agent_proto_msgTypes[41]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use PodEvent.ProtoReflect.Descriptor instead.
func (*PodEvent) Descriptor() ([]byte, []int) {
return file_agent_proto_rawDescGZIP(), []int{41}
}
func (x *PodEvent) GetName() string {
if x != nil {
return x.Name
}
return ""
}
func (x *PodEvent) GetType() string {
if x != nil {
return x.Type
}
return ""
}
func (x *PodEvent) GetMessage() string {
if x != nil {
return x.Message
}
return ""
}
func (x *PodEvent) GetFirstTimestamp() string {
if x != nil {
return x.FirstTimestamp
}
return ""
}
func (x *PodEvent) GetLastTimestamp() string {
if x != nil {
return x.LastTimestamp
}
return ""
}
type EventResponse struct {
state protoimpl.MessageState `protogen:"open.v1"`
Events []*PodEvent `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
unknownFields protoimpl.UnknownFields
sizeCache protoimpl.SizeCache
}
func (x *EventResponse) Reset() {
*x = EventResponse{}
mi := &file_agent_proto_msgTypes[42]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
func (x *EventResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*EventResponse) ProtoMessage() {}
func (x *EventResponse) ProtoReflect() protoreflect.Message {
mi := &file_agent_proto_msgTypes[42]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use EventResponse.ProtoReflect.Descriptor instead.
func (*EventResponse) Descriptor() ([]byte, []int) {
return file_agent_proto_rawDescGZIP(), []int{42}
}
func (x *EventResponse) GetEvents() []*PodEvent {
if x != nil {
return x.Events
}
return nil
}
var File_agent_proto protoreflect.FileDescriptor
const file_agent_proto_rawDesc = "" +
"\n" +
"\vagent.proto\x12\x05agent\x1a\"k8s.io/api/core/v1/generated.proto\"K\n" +
"\vNetworkInfo\x12\x0e\n" +
"\x02ip\x18\x01 \x01(\tR\x02ip\x12\x12\n" +
"\x04vlan\x18\x02 \x01(\tR\x04vlan\x12\x18\n" +
"\agateway\x18\x03 \x01(\tR\agateway\"-\n" +
"\x03Env\x12\x10\n" +
"\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n" +
"\x05value\x18\x02 \x01(\tR\x05value\"\xab\x01\n" +
"\x0fConfigMapVolume\x12:\n" +
"\x06source\x18\x01 \x01(\v2\x1d.k8s.io.api.core.v1.ConfigMapH\x00R\x06source\x88\x01\x01\x12F\n" +
"\x06volume\x18\x02 \x01(\v2).k8s.io.api.core.v1.ConfigMapVolumeSourceH\x01R\x06volume\x88\x01\x01B\t\n" +
"\a_sourceB\t\n" +
"\a_volume\"\xa2\x01\n" +
"\fSecretVolume\x127\n" +
"\x06source\x18\x01 \x01(\v2\x1a.k8s.io.api.core.v1.SecretH\x00R\x06source\x88\x01\x01\x12C\n" +
"\x06volume\x18\x02 \x01(\v2&.k8s.io.api.core.v1.SecretVolumeSourceH\x01R\x06volume\x88\x01\x01B\t\n" +
"\a_sourceB\t\n" +
"\a_volume\"\x9e\x01\n" +
"\rNASVolumeInfo\x12\x1f\n" +
"\vvolume_name\x18\x01 \x01(\tR\n" +
"volumeName\x12\x16\n" +
"\x06server\x18\x02 \x01(\tR\x06server\x12\x12\n" +
"\x04path\x18\x03 \x01(\tR\x04path\x12#\n" +
"\rmount_options\x18\x04 \x03(\tR\fmountOptions\x12\x1b\n" +
"\tread_only\x18\x05 \x01(\bR\breadOnly\"\xb4\x01\n" +
"\x03Pod\x12\x0e\n" +
"\x02id\x18\x01 \x01(\tR\x02id\x12.\n" +
"\x12containerGroupName\x18\x02 \x01(\tR\x12containerGroupName\x12,\n" +
"\anetwork\x18\x03 \x01(\v2\x12.agent.NetworkInfoR\anetwork\x124\n" +
"\x06rawPod\x18\x04 \x01(\v2\x17.k8s.io.api.core.v1.PodH\x00R\x06rawPod\x88\x01\x01B\t\n" +
"\a_rawPod\"\x91\x05\n" +
"\n" +
"PodRequest\x12\x19\n" +
"\bgpu_type\x18\x01 \x01(\tR\agpuType\x12\x19\n" +
"\bcpu_type\x18\x02 \x01(\tR\acpuType\x12\x1f\n" +
"\vcustomer_id\x18\x03 \x01(\tR\n" +
"customerId\x12\x17\n" +
"\auser_id\x18\x04 \x01(\tR\x06userId\x12%\n" +
"\x0erestart_policy\x18\x05 \x01(\tR\rrestartPolicy\x12\x10\n" +
"\x03cpu\x18\x06 \x01(\x03R\x03cpu\x12\x10\n" +
"\x03ram\x18\a \x01(\x03R\x03ram\x12\x10\n" +
"\x03gpu\x18\b \x01(\x03R\x03gpu\x12\x1e\n" +
"\x04pods\x18\t \x03(\v2\n" +
".agent.PodR\x04pods\x12&\n" +
"\x0ftemp_store_size\x18\n" +
" \x01(\x03R\rtempStoreSize\x12\x19\n" +
"\bvnode_id\x18\f \x01(\tR\avnodeId\x124\n" +
"\asecrets\x18\r \x03(\v2\x1a.k8s.io.api.core.v1.SecretR\asecrets\x12=\n" +
"\n" +
"configMaps\x18\x0e \x03(\v2\x1d.k8s.io.api.core.v1.ConfigMapR\n" +
"configMaps\x12\"\n" +
"\fspotStrategy\x18\x0f \x01(\tR\fspotStrategy\x12\x1c\n" +
"\tspotPrice\x18\x10 \x01(\tR\tspotPrice\x12\x12\n" +
"\x04zone\x18\x11 \x01(\tR\x04zone\x12\x1c\n" +
"\tcloudEdge\x18\x12 \x01(\bR\tcloudEdge\x125\n" +
"\vnas_volumes\x18\x13 \x03(\v2\x14.agent.NASVolumeInfoR\n" +
"nasVolumes\x123\n" +
"\x16test_credit_project_id\x18\x14 \x01(\x03R\x13testCreditProjectId\"\xbf\x01\n" +
"\x10PodDeleteRequest\x12\x18\n" +
"\avNodeID\x18\x01 \x01(\tR\avNodeID\x12\x12\n" +
"\x04name\x18\x02 \x01(\tR\x04name\x12\x1c\n" +
"\tnamespace\x18\x03 \x01(\tR\tnamespace\x12%\n" +
"\x04code\x18\x04 \x01(\x0e2\x11.agent.DeleteCodeR\x04code\x128\n" +
"\x17recycleProtectionPeriod\x18\x05 \x01(\x03R\x17recycleProtectionPeriod\"D\n" +
"\x10PodRebootRequest\x12\x12\n" +
"\x04name\x18\x02 \x01(\tR\x04name\x12\x1c\n" +
"\tnamespace\x18\x03 \x01(\tR\tnamespace\"N\n" +
"\vPodResponse\x12%\n" +
"\x04code\x18\x01 \x01(\x0e2\x11.agent.ActionCodeR\x04code\x12\x18\n" +
"\amessage\x18\x02 \x01(\tR\amessage\"l\n" +
"\x04Pods\x12,\n" +
"\anetwork\x18\x01 \x01(\v2\x12.agent.NetworkInfoR\anetwork\x12.\n" +
"\x03pod\x18\x02 \x01(\v2\x17.k8s.io.api.core.v1.PodH\x00R\x03pod\x88\x01\x01B\x06\n" +
"\x04_pod\"]\n" +
"\x0ePodInfoRequest\x12\x1c\n" +
"\tnamespace\x18\x01 \x01(\tR\tnamespace\x12\x12\n" +
"\x04name\x18\x02 \x01(\tR\x04name\x12\x19\n" +
"\bvnode_id\x18\x03 \x01(\tR\avnodeId\"s\n" +
"\x0fPodInfoResponse\x12%\n" +
"\x04code\x18\x01 \x01(\x0e2\x11.agent.ActionCodeR\x04code\x12\x18\n" +
"\amessage\x18\x02 \x01(\tR\amessage\x12\x1f\n" +
"\x04pods\x18\x03 \x03(\v2\v.agent.PodsR\x04pods\"\x9f\x01\n" +
"\x0eIpPoolSegments\x12\x12\n" +
"\x04vlan\x18\x01 \x01(\tR\x04vlan\x12\x16\n" +
"\x06subnet\x18\x02 \x01(\tR\x06subnet\x12\x18\n" +
"\agateway\x18\x03 \x01(\tR\agateway\x12*\n" +
"\x11available_zone_id\x18\x04 \x01(\tR\x0favailableZoneId\x12\x1b\n" +
"\tstart_end\x18\x05 \x03(\tR\bstartEnd\"t\n" +
"\n" +
"PrivateNet\x12\x12\n" +
"\x04vlan\x18\x01 \x01(\tR\x04vlan\x12\x16\n" +
"\x06subnet\x18\x02 \x01(\tR\x06subnet\x12\x18\n" +
"\agateway\x18\x03 \x01(\tR\agateway\x12\x0e\n" +
"\x02ip\x18\x04 \x01(\tR\x02ip\x12\x10\n" +
"\x03eip\x18\x05 \x01(\tR\x03eip\"\xc6\x01\n" +
"\fQuantityInfo\x12\x10\n" +
"\x03cpu\x18\x01 \x01(\x03R\x03cpu\x12\x10\n" +
"\x03ram\x18\x02 \x01(\x03R\x03ram\x12\x10\n" +
"\x03gpu\x18\x03 \x01(\x03R\x03gpu\x12\x19\n" +
"\bcpu_type\x18\x04 \x01(\tR\acpuType\x12\x19\n" +
"\bgpu_type\x18\x05 \x01(\tR\agpuType\x12$\n" +
"\x0emin_spot_price\x18\x06 \x01(\tR\fminSpotPrice\x12$\n" +
"\x0emax_spot_price\x18\a \x01(\tR\fmaxSpotPrice\"B\n" +
"\x0fProductQuantity\x12/\n" +
"\bquantity\x18\x01 \x03(\v2\x13.agent.QuantityInfoR\bquantity\"D\n" +
"\fNodeQuantity\x12\x10\n" +
"\x03cpu\x18\x01 \x01(\x03R\x03cpu\x12\x10\n" +
"\x03ram\x18\x02 \x01(\x03R\x03ram\x12\x10\n" +
"\x03gpu\x18\x03 \x01(\x03R\x03gpu\"\xcd\x04\n" +
"\vNodeRequest\x12\x1f\n" +
"\vkube_config\x18\x01 \x01(\tR\n" +
"kubeConfig\x12P\n" +
"\x10ip_pool_segments\x18\x02 \x03(\v2&.agent.NodeRequest.IpPoolSegmentsEntryR\x0eipPoolSegments\x12\x1f\n" +
"\vcustomer_id\x18\x03 \x01(\tR\n" +
"customerId\x12\x17\n" +
"\auser_id\x18\x04 \x01(\tR\x06userId\x12\x0e\n" +
"\x02id\x18\x05 \x01(\tR\x02id\x122\n" +
"\vprivate_net\x18\x06 \x01(\v2\x11.agent.PrivateNetR\n" +
"privateNet\x121\n" +
"\x06Taints\x18\a \x03(\v2\x19.k8s.io.api.core.v1.TaintR\x06Taints\x126\n" +
"\x06labels\x18\b \x03(\v2\x1e.agent.NodeRequest.LabelsEntryR\x06labels\x127\n" +
"\fnodeQuantity\x18\t \x01(\v2\x13.agent.NodeQuantityR\fnodeQuantity\x12\x14\n" +
"\x05image\x18\n" +
" \x01(\tR\x05image\x1aX\n" +
"\x13IpPoolSegmentsEntry\x12\x10\n" +
"\x03key\x18\x01 \x01(\tR\x03key\x12+\n" +
"\x05value\x18\x02 \x01(\v2\x15.agent.IpPoolSegmentsR\x05value:\x028\x01\x1a9\n" +
"\vLabelsEntry\x12\x10\n" +
"\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n" +
"\x05value\x18\x02 \x01(\tR\x05value:\x028\x01\"O\n" +
"\fNodeResponse\x12%\n" +
"\x04code\x18\x01 \x01(\x0e2\x11.agent.ActionCodeR\x04code\x12\x18\n" +
"\amessage\x18\x02 \x01(\tR\amessage\"/\n" +
"\x13NodeGpuUsageRequest\x12\x18\n" +
"\anodeIds\x18\x01 \x03(\tR\anodeIds\"\x12\n" +
"\x10NodeUsageRequest\"\x92\x01\n" +
"\x14NodeGpuUsageResponse\x12%\n" +
"\x04code\x18\x01 \x01(\x0e2\x11.agent.ActionCodeR\x04code\x12\x18\n" +
"\amessage\x18\x02 \x01(\tR\amessage\x129\n" +
"\x0enode_gpu_usage\x18\x03 \x03(\v2\x13.agent.NodeGpuUsageR\fnodeGpuUsage\"\x92\x01\n" +
"\fNodeGpuUsage\x12\x16\n" +
"\x06nodeId\x18\x01 \x01(\tR\x06nodeId\x12\x18\n" +
"\agpuType\x18\x02 \x01(\tR\agpuType\x12\x1c\n" +
"\ttotalGpus\x18\x03 \x01(\x03R\ttotalGpus\x12\x1a\n" +
"\busedGpus\x18\x04 \x01(\x03R\busedGpus\x12\x16\n" +
"\x06podIds\x18\x05 \x03(\tR\x06podIds\";\n" +
"\x11NodeUsageResponse\x12&\n" +
"\x05usage\x18\x01 \x03(\v2\x10.agent.NodeUsageR\x05usage\"3\n" +
"\tUsageInfo\x12\x12\n" +
"\x04gpus\x18\x01 \x01(\x03R\x04gpus\x12\x12\n" +
"\x04cpus\x18\x02 \x01(\x03R\x04cpus\"\xa7\x03\n" +
"\tNodeUsage\x12\x0e\n" +
"\x02id\x18\x01 \x01(\tR\x02id\x12\x12\n" +
"\x04name\x18\x02 \x01(\tR\x04name\x12\x18\n" +
"\agpuType\x18\x03 \x01(\tR\agpuType\x12\x18\n" +
"\acpuType\x18\x04 \x01(\tR\acpuType\x120\n" +
"\n" +
"totalUsage\x18\x05 \x01(\v2\x10.agent.UsageInfoR\n" +
"totalUsage\x12.\n" +
"\tusedUsage\x18\x06 \x01(\v2\x10.agent.UsageInfoR\tusedUsage\x12J\n" +
"\x17usedSpotPriceLimitUsage\x18\a \x01(\v2\x10.agent.UsageInfoR\x17usedSpotPriceLimitUsage\x12H\n" +
"\x16usedSpotAsPriceGoUsage\x18\b \x01(\v2\x10.agent.UsageInfoR\x16usedSpotAsPriceGoUsage\x12\x1a\n" +
"\bfamilyId\x18\t \x01(\tR\bfamilyId\x12.\n" +
"\x12lowestPricePerUnit\x18\n" +
" \x01(\x02R\x12lowestPricePerUnit\"\x86\x01\n" +
"\x14CreateWsTokenRequest\x12\x1f\n" +
"\vcustomer_id\x18\x01 \x01(\tR\n" +
"customerId\x12\x17\n" +
"\auser_id\x18\x02 \x01(\tR\x06userId\x12\x19\n" +
"\bpod_name\x18\x03 \x01(\tR\apodName\x12\x19\n" +
"\bvnode_id\x18\x04 \x01(\tR\avnodeId\"n\n" +
"\x15CreateWsTokenResponse\x12%\n" +
"\x04code\x18\x01 \x01(\x0e2\x11.agent.ActionCodeR\x04code\x12\x18\n" +
"\amessage\x18\x02 \x01(\tR\amessage\x12\x14\n" +
"\x05token\x18\x03 \x01(\tR\x05token\"\x92\x01\n" +
"\fQuotaRequest\x12\x1e\n" +
"\n" +
"customerId\x18\x01 \x01(\tR\n" +
"customerId\x12\x16\n" +
"\x06userId\x18\x02 \x01(\tR\x06userId\x12@\n" +
"\x05quota\x18\x03 \x01(\v2%.k8s.io.api.core.v1.ResourceQuotaSpecH\x00R\x05quota\x88\x01\x01B\b\n" +
"\x06_quota\"c\n" +
"\x13QuotaStatusResponse\x12B\n" +
"\x05quota\x18\x01 \x01(\v2'.k8s.io.api.core.v1.ResourceQuotaStatusH\x00R\x05quota\x88\x01\x01B\b\n" +
"\x06_quota\"A\n" +
"\rQuotaResponse\x12\x16\n" +
"\x06result\x18\x01 \x01(\bR\x06result\x12\x18\n" +
"\amessage\x18\x02 \x01(\tR\amessage\"n\n" +
"\x12GetInstanceRequest\x12\x1e\n" +
"\n" +
"customerId\x18\x01 \x01(\tR\n" +
"customerId\x12\x16\n" +
"\x06userId\x18\x02 \x01(\tR\x06userId\x12 \n" +
"\vInstanceIds\x18\x03 \x03(\tR\vInstanceIds\"7\n" +
"\x13GetInstanceResponse\x12 \n" +
"\vInstanceIds\x18\x01 \x03(\tR\vInstanceIds\"\xc8\x01\n" +
"\x11FamilySpecRequest\x12W\n" +
"\x0fproductQuantity\x18\x01 \x03(\v2-.agent.FamilySpecRequest.ProductQuantityEntryR\x0fproductQuantity\x1aZ\n" +
"\x14ProductQuantityEntry\x12\x10\n" +
"\x03key\x18\x01 \x01(\tR\x03key\x12,\n" +
"\x05value\x18\x02 \x01(\v2\x16.agent.ProductQuantityR\x05value:\x028\x01\"F\n" +
"\x12FamilySpecResponse\x12\x16\n" +
"\x06result\x18\x01 \x01(\bR\x06result\x12\x18\n" +
"\amessage\x18\x02 \x01(\tR\amessage\"\x87\x02\n" +
"\x10DataCacheRequest\x125\n" +
"\anetwork\x18\x01 \x01(\v2\x1b.agent.DataCacheNetworkInfoR\anetwork\x12\x14\n" +
"\x05image\x18\x02 \x01(\tR\x05image\x12+\n" +
"\x04dest\x18\x03 \x01(\v2\x17.agent.DataCacheOptionsR\x04dest\x12/\n" +
"\x06source\x18\x04 \x01(\v2\x17.agent.DataCacheOptionsR\x06source\x12\x0e\n" +
"\x02id\x18\x05 \x01(\tR\x02id\x12\x1f\n" +
"\vcustomer_id\x18\x06 \x01(\tR\n" +
"customerId\x12\x17\n" +
"\auser_id\x18\a \x01(\tR\x06userId\"\xc0\x02\n" +
"\x10DataCacheOptions\x12\x12\n" +
"\x04type\x18\x01 \x01(\tR\x04type\x12\x12\n" +
"\x04path\x18\x02 \x01(\tR\x04path\x12\x10\n" +
"\x03url\x18\x03 \x01(\tR\x03url\x12\x16\n" +
"\x06server\x18\x04 \x01(\tR\x06server\x12\x1c\n" +
"\totherOpts\x18\x05 \x01(\tR\totherOpts\x12\x16\n" +
"\x06bucket\x18\x06 \x01(\tR\x06bucket\x12\x12\n" +
"\x04akId\x18\a \x01(\tR\x04akId\x12\x1a\n" +
"\bakSecret\x18\b \x01(\tR\bakSecret\x12 \n" +
"\vaccessToken\x18\t \x01(\tR\vaccessToken\x12\x1e\n" +
"\n" +
"repoSource\x18\n" +
" \x01(\tR\n" +
"repoSource\x12\x16\n" +
"\x06repoId\x18\v \x01(\tR\x06repoId\x12\x1a\n" +
"\brevision\x18\f \x01(\tR\brevision\"T\n" +
"\x11DataCacheResponse\x12%\n" +
"\x04code\x18\x01 \x01(\x0e2\x11.agent.ActionCodeR\x04code\x12\x18\n" +
"\amessage\x18\x02 \x01(\tR\amessage\"f\n" +
"\x14DataCacheNetworkInfo\x12\x0e\n" +
"\x02ip\x18\x01 \x01(\tR\x02ip\x12\x12\n" +
"\x04vlan\x18\x02 \x01(\tR\x04vlan\x12\x18\n" +
"\agateway\x18\x03 \x01(\tR\agateway\x12\x10\n" +
"\x03dns\x18\x04 \x01(\tR\x03dns\"@\n" +
"\fEventRequest\x12\x12\n" +
"\x04name\x18\x01 \x01(\tR\x04name\x12\x1c\n" +
"\tnamespace\x18\x02 \x01(\tR\tnamespace\"\x9a\x01\n" +
"\bPodEvent\x12\x12\n" +
"\x04name\x18\x01 \x01(\tR\x04name\x12\x12\n" +
"\x04type\x18\x02 \x01(\tR\x04type\x12\x18\n" +
"\amessage\x18\x03 \x01(\tR\amessage\x12&\n" +
"\x0efirstTimestamp\x18\x04 \x01(\tR\x0efirstTimestamp\x12$\n" +
"\rlastTimestamp\x18\x05 \x01(\tR\rlastTimestamp\"8\n" +
"\rEventResponse\x12'\n" +
"\x06events\x18\x01 \x03(\v2\x0f.agent.PodEventR\x06events*4\n" +
"\n" +
"ActionCode\x12\x0f\n" +
"\vSuccessCode\x10\x00\x12\x15\n" +
"\bFailCode\x10\xff\xff\xff\xff\xff\xff\xff\xff\xff\x01*E\n" +
"\fSpotStrategy\x12\n" +
"\n" +
"\x06NoSpot\x10\x00\x12\x16\n" +
"\x12SpotWithPriceLimit\x10\x01\x12\x11\n" +
"\rSpotAsPriceGo\x10\x02*L\n" +
"\n" +
"DeleteCode\x12\v\n" +
"\aDefault\x10\x00\x12\x0e\n" +
"\n" +
"SpotFailed\x10\x01\x12\x0f\n" +
"\vSpotDelayed\x10\x02\x12\x10\n" +
"\fSpotCanceled\x10\x032\xdf\n" +
"\n" +
"\x05Agent\x124\n" +
"\tCreatePod\x12\x11.agent.PodRequest\x1a\x12.agent.PodResponse\"\x00\x124\n" +
"\tUpdatePod\x12\x11.agent.PodRequest\x1a\x12.agent.PodResponse\"\x00\x12:\n" +
"\tDeletePod\x12\x17.agent.PodDeleteRequest\x1a\x12.agent.PodResponse\"\x00\x12:\n" +
"\tRebootPod\x12\x17.agent.PodRebootRequest\x1a\x12.agent.PodResponse\"\x00\x129\n" +
"\x06GetPod\x12\x15.agent.PodInfoRequest\x1a\x16.agent.PodInfoResponse\"\x00\x12:\n" +
"\aGetPods\x12\x15.agent.PodInfoRequest\x1a\x16.agent.PodInfoResponse\"\x00\x12?\n" +
"\fGetPodStatus\x12\x15.agent.PodInfoRequest\x1a\x16.agent.PodInfoResponse\"\x00\x12:\n" +
"\vGetPodEvent\x12\x13.agent.EventRequest\x1a\x14.agent.EventResponse\"\x00\x12?\n" +
"\x12CheckResourceQuota\x12\x11.agent.PodRequest\x1a\x14.agent.QuotaResponse\"\x00\x12E\n" +
"\x10GetResourceQuota\x12\x13.agent.QuotaRequest\x1a\x1a.agent.QuotaStatusResponse\"\x00\x12?\n" +
"\x10SetResourceQuota\x12\x13.agent.QuotaRequest\x1a\x14.agent.QuotaResponse\"\x00\x127\n" +
"\n" +
"CreateNode\x12\x12.agent.NodeRequest\x1a\x13.agent.NodeResponse\"\x00\x127\n" +
"\n" +
"UpdateNode\x12\x12.agent.NodeRequest\x1a\x13.agent.NodeResponse\"\x00\x127\n" +
"\n" +
"DeleteNode\x12\x12.agent.NodeRequest\x1a\x13.agent.NodeResponse\"\x00\x12L\n" +
"\x0fGetNodeGpuUsage\x12\x1a.agent.NodeGpuUsageRequest\x1a\x1b.agent.NodeGpuUsageResponse\"\x00\x12C\n" +
"\fGetNodeUsage\x12\x17.agent.NodeUsageRequest\x1a\x18.agent.NodeUsageResponse\"\x00\x12L\n" +
"\rCreateWsToken\x12\x1b.agent.CreateWsTokenRequest\x1a\x1c.agent.CreateWsTokenResponse\"\x00\x12J\n" +
"\x0fGetECIInstances\x12\x19.agent.GetInstanceRequest\x1a\x1a.agent.GetInstanceResponse\"\x00\x12M\n" +
"\x14UpdateFamilySpecInfo\x12\x18.agent.FamilySpecRequest\x1a\x19.agent.FamilySpecResponse\"\x00\x12F\n" +
"\x0fCreateDataCache\x12\x17.agent.DataCacheRequest\x1a\x18.agent.DataCacheResponse\"\x00\x12F\n" +
"\x0fDeleteDataCache\x12\x17.agent.DataCacheRequest\x1a\x18.agent.DataCacheResponse\"\x00B\tZ\a./agentb\x06proto3"
var (
file_agent_proto_rawDescOnce sync.Once
file_agent_proto_rawDescData []byte
)
func file_agent_proto_rawDescGZIP() []byte {
file_agent_proto_rawDescOnce.Do(func() {
file_agent_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_agent_proto_rawDesc), len(file_agent_proto_rawDesc)))
})
return file_agent_proto_rawDescData
}
var file_agent_proto_enumTypes = make([]protoimpl.EnumInfo, 3)
var file_agent_proto_msgTypes = make([]protoimpl.MessageInfo, 46)
var file_agent_proto_goTypes = []any{
(ActionCode)(0), // 0: agent.ActionCode
(SpotStrategy)(0), // 1: agent.SpotStrategy
(DeleteCode)(0), // 2: agent.DeleteCode
(*NetworkInfo)(nil), // 3: agent.NetworkInfo
(*Env)(nil), // 4: agent.Env
(*ConfigMapVolume)(nil), // 5: agent.ConfigMapVolume
(*SecretVolume)(nil), // 6: agent.SecretVolume
(*NASVolumeInfo)(nil), // 7: agent.NASVolumeInfo
(*Pod)(nil), // 8: agent.Pod
(*PodRequest)(nil), // 9: agent.PodRequest
(*PodDeleteRequest)(nil), // 10: agent.PodDeleteRequest
(*PodRebootRequest)(nil), // 11: agent.PodRebootRequest
(*PodResponse)(nil), // 12: agent.PodResponse
(*Pods)(nil), // 13: agent.Pods
(*PodInfoRequest)(nil), // 14: agent.PodInfoRequest
(*PodInfoResponse)(nil), // 15: agent.PodInfoResponse
(*IpPoolSegments)(nil), // 16: agent.IpPoolSegments
(*PrivateNet)(nil), // 17: agent.PrivateNet
(*QuantityInfo)(nil), // 18: agent.QuantityInfo
(*ProductQuantity)(nil), // 19: agent.ProductQuantity
(*NodeQuantity)(nil), // 20: agent.NodeQuantity
(*NodeRequest)(nil), // 21: agent.NodeRequest
(*NodeResponse)(nil), // 22: agent.NodeResponse
(*NodeGpuUsageRequest)(nil), // 23: agent.NodeGpuUsageRequest
(*NodeUsageRequest)(nil), // 24: agent.NodeUsageRequest
(*NodeGpuUsageResponse)(nil), // 25: agent.NodeGpuUsageResponse
(*NodeGpuUsage)(nil), // 26: agent.NodeGpuUsage
(*NodeUsageResponse)(nil), // 27: agent.NodeUsageResponse
(*UsageInfo)(nil), // 28: agent.UsageInfo
(*NodeUsage)(nil), // 29: agent.NodeUsage
(*CreateWsTokenRequest)(nil), // 30: agent.CreateWsTokenRequest
(*CreateWsTokenResponse)(nil), // 31: agent.CreateWsTokenResponse
(*QuotaRequest)(nil), // 32: agent.QuotaRequest
(*QuotaStatusResponse)(nil), // 33: agent.QuotaStatusResponse
(*QuotaResponse)(nil), // 34: agent.QuotaResponse
(*GetInstanceRequest)(nil), // 35: agent.GetInstanceRequest
(*GetInstanceResponse)(nil), // 36: agent.GetInstanceResponse
(*FamilySpecRequest)(nil), // 37: agent.FamilySpecRequest
(*FamilySpecResponse)(nil), // 38: agent.FamilySpecResponse
(*DataCacheRequest)(nil), // 39: agent.DataCacheRequest
(*DataCacheOptions)(nil), // 40: agent.DataCacheOptions
(*DataCacheResponse)(nil), // 41: agent.DataCacheResponse
(*DataCacheNetworkInfo)(nil), // 42: agent.DataCacheNetworkInfo
(*EventRequest)(nil), // 43: agent.EventRequest
(*PodEvent)(nil), // 44: agent.PodEvent
(*EventResponse)(nil), // 45: agent.EventResponse
nil, // 46: agent.NodeRequest.IpPoolSegmentsEntry
nil, // 47: agent.NodeRequest.LabelsEntry
nil, // 48: agent.FamilySpecRequest.ProductQuantityEntry
(*v1.ConfigMap)(nil), // 49: k8s.io.api.core.v1.ConfigMap
(*v1.ConfigMapVolumeSource)(nil), // 50: k8s.io.api.core.v1.ConfigMapVolumeSource
(*v1.Secret)(nil), // 51: k8s.io.api.core.v1.Secret
(*v1.SecretVolumeSource)(nil), // 52: k8s.io.api.core.v1.SecretVolumeSource
(*v1.Pod)(nil), // 53: k8s.io.api.core.v1.Pod
(*v1.Taint)(nil), // 54: k8s.io.api.core.v1.Taint
(*v1.ResourceQuotaSpec)(nil), // 55: k8s.io.api.core.v1.ResourceQuotaSpec
(*v1.ResourceQuotaStatus)(nil), // 56: k8s.io.api.core.v1.ResourceQuotaStatus
}
var file_agent_proto_depIdxs = []int32{
49, // 0: agent.ConfigMapVolume.source:type_name -> k8s.io.api.core.v1.ConfigMap
50, // 1: agent.ConfigMapVolume.volume:type_name -> k8s.io.api.core.v1.ConfigMapVolumeSource
51, // 2: agent.SecretVolume.source:type_name -> k8s.io.api.core.v1.Secret
52, // 3: agent.SecretVolume.volume:type_name -> k8s.io.api.core.v1.SecretVolumeSource
3, // 4: agent.Pod.network:type_name -> agent.NetworkInfo
53, // 5: agent.Pod.rawPod:type_name -> k8s.io.api.core.v1.Pod
8, // 6: agent.PodRequest.pods:type_name -> agent.Pod
51, // 7: agent.PodRequest.secrets:type_name -> k8s.io.api.core.v1.Secret
49, // 8: agent.PodRequest.configMaps:type_name -> k8s.io.api.core.v1.ConfigMap
7, // 9: agent.PodRequest.nas_volumes:type_name -> agent.NASVolumeInfo
2, // 10: agent.PodDeleteRequest.code:type_name -> agent.DeleteCode
0, // 11: agent.PodResponse.code:type_name -> agent.ActionCode
3, // 12: agent.Pods.network:type_name -> agent.NetworkInfo
53, // 13: agent.Pods.pod:type_name -> k8s.io.api.core.v1.Pod
0, // 14: agent.PodInfoResponse.code:type_name -> agent.ActionCode
13, // 15: agent.PodInfoResponse.pods:type_name -> agent.Pods
18, // 16: agent.ProductQuantity.quantity:type_name -> agent.QuantityInfo
46, // 17: agent.NodeRequest.ip_pool_segments:type_name -> agent.NodeRequest.IpPoolSegmentsEntry
17, // 18: agent.NodeRequest.private_net:type_name -> agent.PrivateNet
54, // 19: agent.NodeRequest.Taints:type_name -> k8s.io.api.core.v1.Taint
47, // 20: agent.NodeRequest.labels:type_name -> agent.NodeRequest.LabelsEntry
20, // 21: agent.NodeRequest.nodeQuantity:type_name -> agent.NodeQuantity
0, // 22: agent.NodeResponse.code:type_name -> agent.ActionCode
0, // 23: agent.NodeGpuUsageResponse.code:type_name -> agent.ActionCode
26, // 24: agent.NodeGpuUsageResponse.node_gpu_usage:type_name -> agent.NodeGpuUsage
29, // 25: agent.NodeUsageResponse.usage:type_name -> agent.NodeUsage
28, // 26: agent.NodeUsage.totalUsage:type_name -> agent.UsageInfo
28, // 27: agent.NodeUsage.usedUsage:type_name -> agent.UsageInfo
28, // 28: agent.NodeUsage.usedSpotPriceLimitUsage:type_name -> agent.UsageInfo
28, // 29: agent.NodeUsage.usedSpotAsPriceGoUsage:type_name -> agent.UsageInfo
0, // 30: agent.CreateWsTokenResponse.code:type_name -> agent.ActionCode
55, // 31: agent.QuotaRequest.quota:type_name -> k8s.io.api.core.v1.ResourceQuotaSpec
56, // 32: agent.QuotaStatusResponse.quota:type_name -> k8s.io.api.core.v1.ResourceQuotaStatus
48, // 33: agent.FamilySpecRequest.productQuantity:type_name -> agent.FamilySpecRequest.ProductQuantityEntry
42, // 34: agent.DataCacheRequest.network:type_name -> agent.DataCacheNetworkInfo
40, // 35: agent.DataCacheRequest.dest:type_name -> agent.DataCacheOptions
40, // 36: agent.DataCacheRequest.source:type_name -> agent.DataCacheOptions
0, // 37: agent.DataCacheResponse.code:type_name -> agent.ActionCode
44, // 38: agent.EventResponse.events:type_name -> agent.PodEvent
16, // 39: agent.NodeRequest.IpPoolSegmentsEntry.value:type_name -> agent.IpPoolSegments
19, // 40: agent.FamilySpecRequest.ProductQuantityEntry.value:type_name -> agent.ProductQuantity
9, // 41: agent.Agent.CreatePod:input_type -> agent.PodRequest
9, // 42: agent.Agent.UpdatePod:input_type -> agent.PodRequest
10, // 43: agent.Agent.DeletePod:input_type -> agent.PodDeleteRequest
11, // 44: agent.Agent.RebootPod:input_type -> agent.PodRebootRequest
14, // 45: agent.Agent.GetPod:input_type -> agent.PodInfoRequest
14, // 46: agent.Agent.GetPods:input_type -> agent.PodInfoRequest
14, // 47: agent.Agent.GetPodStatus:input_type -> agent.PodInfoRequest
43, // 48: agent.Agent.GetPodEvent:input_type -> agent.EventRequest
9, // 49: agent.Agent.CheckResourceQuota:input_type -> agent.PodRequest
32, // 50: agent.Agent.GetResourceQuota:input_type -> agent.QuotaRequest
32, // 51: agent.Agent.SetResourceQuota:input_type -> agent.QuotaRequest
21, // 52: agent.Agent.CreateNode:input_type -> agent.NodeRequest
21, // 53: agent.Agent.UpdateNode:input_type -> agent.NodeRequest
21, // 54: agent.Agent.DeleteNode:input_type -> agent.NodeRequest
23, // 55: agent.Agent.GetNodeGpuUsage:input_type -> agent.NodeGpuUsageRequest
24, // 56: agent.Agent.GetNodeUsage:input_type -> agent.NodeUsageRequest
30, // 57: agent.Agent.CreateWsToken:input_type -> agent.CreateWsTokenRequest
35, // 58: agent.Agent.GetECIInstances:input_type -> agent.GetInstanceRequest
37, // 59: agent.Agent.UpdateFamilySpecInfo:input_type -> agent.FamilySpecRequest
39, // 60: agent.Agent.CreateDataCache:input_type -> agent.DataCacheRequest
39, // 61: agent.Agent.DeleteDataCache:input_type -> agent.DataCacheRequest
12, // 62: agent.Agent.CreatePod:output_type -> agent.PodResponse
12, // 63: agent.Agent.UpdatePod:output_type -> agent.PodResponse
12, // 64: agent.Agent.DeletePod:output_type -> agent.PodResponse
12, // 65: agent.Agent.RebootPod:output_type -> agent.PodResponse
15, // 66: agent.Agent.GetPod:output_type -> agent.PodInfoResponse
15, // 67: agent.Agent.GetPods:output_type -> agent.PodInfoResponse
15, // 68: agent.Agent.GetPodStatus:output_type -> agent.PodInfoResponse
45, // 69: agent.Agent.GetPodEvent:output_type -> agent.EventResponse
34, // 70: agent.Agent.CheckResourceQuota:output_type -> agent.QuotaResponse
33, // 71: agent.Agent.GetResourceQuota:output_type -> agent.QuotaStatusResponse
34, // 72: agent.Agent.SetResourceQuota:output_type -> agent.QuotaResponse
22, // 73: agent.Agent.CreateNode:output_type -> agent.NodeResponse
22, // 74: agent.Agent.UpdateNode:output_type -> agent.NodeResponse
22, // 75: agent.Agent.DeleteNode:output_type -> agent.NodeResponse
25, // 76: agent.Agent.GetNodeGpuUsage:output_type -> agent.NodeGpuUsageResponse
27, // 77: agent.Agent.GetNodeUsage:output_type -> agent.NodeUsageResponse
31, // 78: agent.Agent.CreateWsToken:output_type -> agent.CreateWsTokenResponse
36, // 79: agent.Agent.GetECIInstances:output_type -> agent.GetInstanceResponse
38, // 80: agent.Agent.UpdateFamilySpecInfo:output_type -> agent.FamilySpecResponse
41, // 81: agent.Agent.CreateDataCache:output_type -> agent.DataCacheResponse
41, // 82: agent.Agent.DeleteDataCache:output_type -> agent.DataCacheResponse
62, // [62:83] is the sub-list for method output_type
41, // [41:62] is the sub-list for method input_type
41, // [41:41] is the sub-list for extension type_name
41, // [41:41] is the sub-list for extension extendee
0, // [0:41] is the sub-list for field type_name
}
func init() { file_agent_proto_init() }
func file_agent_proto_init() {
if File_agent_proto != nil {
return
}
file_agent_proto_msgTypes[2].OneofWrappers = []any{}
file_agent_proto_msgTypes[3].OneofWrappers = []any{}
file_agent_proto_msgTypes[5].OneofWrappers = []any{}
file_agent_proto_msgTypes[10].OneofWrappers = []any{}
file_agent_proto_msgTypes[29].OneofWrappers = []any{}
file_agent_proto_msgTypes[30].OneofWrappers = []any{}
type x struct{}
out := protoimpl.TypeBuilder{
File: protoimpl.DescBuilder{
GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
RawDescriptor: unsafe.Slice(unsafe.StringData(file_agent_proto_rawDesc), len(file_agent_proto_rawDesc)),
NumEnums: 3,
NumMessages: 46,
NumExtensions: 0,
NumServices: 1,
},
GoTypes: file_agent_proto_goTypes,
DependencyIndexes: file_agent_proto_depIdxs,
EnumInfos: file_agent_proto_enumTypes,
MessageInfos: file_agent_proto_msgTypes,
}.Build()
File_agent_proto = out.File
file_agent_proto_goTypes = nil
file_agent_proto_depIdxs = nil
}
此处可能存在不合适展示的内容，页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容，可点击提交进行申诉，我们将尽快为您处理。
马建仓 AI 助手