Rainbond/worker/server/pb/app_runtime_server.pb.go
2019-08-23 13:31:16 +08:00

1618 lines
59 KiB
Go

// Code generated by protoc-gen-go. DO NOT EDIT.
// source: app_runtime_server.proto
package pb
import (
context "context"
fmt "fmt"
proto "github.com/golang/protobuf/proto"
grpc "google.golang.org/grpc"
math "math"
)
// Reference imports to suppress errors if they are not otherwise used.
var _ = proto.Marshal
var _ = fmt.Errorf
var _ = math.Inf
// This is a compile-time assertion to ensure that this generated file
// is compatible with the proto package it is being compiled against.
// A compilation error at this line likely means your copy of the
// proto package needs to be updated.
const _ = proto.ProtoPackageIsVersion2 // please upgrade the proto package
type Empty struct {
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *Empty) Reset() { *m = Empty{} }
func (m *Empty) String() string { return proto.CompactTextString(m) }
func (*Empty) ProtoMessage() {}
func (*Empty) Descriptor() ([]byte, []int) {
return fileDescriptor_f94cf1a886c479d6, []int{0}
}
func (m *Empty) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_Empty.Unmarshal(m, b)
}
func (m *Empty) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_Empty.Marshal(b, m, deterministic)
}
func (m *Empty) XXX_Merge(src proto.Message) {
xxx_messageInfo_Empty.Merge(m, src)
}
func (m *Empty) XXX_Size() int {
return xxx_messageInfo_Empty.Size(m)
}
func (m *Empty) XXX_DiscardUnknown() {
xxx_messageInfo_Empty.DiscardUnknown(m)
}
var xxx_messageInfo_Empty proto.InternalMessageInfo
type ServiceRequest struct {
ServiceId string `protobuf:"bytes,1,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *ServiceRequest) Reset() { *m = ServiceRequest{} }
func (m *ServiceRequest) String() string { return proto.CompactTextString(m) }
func (*ServiceRequest) ProtoMessage() {}
func (*ServiceRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_f94cf1a886c479d6, []int{1}
}
func (m *ServiceRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_ServiceRequest.Unmarshal(m, b)
}
func (m *ServiceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_ServiceRequest.Marshal(b, m, deterministic)
}
func (m *ServiceRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_ServiceRequest.Merge(m, src)
}
func (m *ServiceRequest) XXX_Size() int {
return xxx_messageInfo_ServiceRequest.Size(m)
}
func (m *ServiceRequest) XXX_DiscardUnknown() {
xxx_messageInfo_ServiceRequest.DiscardUnknown(m)
}
var xxx_messageInfo_ServiceRequest proto.InternalMessageInfo
func (m *ServiceRequest) GetServiceId() string {
if m != nil {
return m.ServiceId
}
return ""
}
type ServicesRequest struct {
ServiceIds string `protobuf:"bytes,1,opt,name=service_ids,json=serviceIds,proto3" json:"service_ids,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *ServicesRequest) Reset() { *m = ServicesRequest{} }
func (m *ServicesRequest) String() string { return proto.CompactTextString(m) }
func (*ServicesRequest) ProtoMessage() {}
func (*ServicesRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_f94cf1a886c479d6, []int{2}
}
func (m *ServicesRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_ServicesRequest.Unmarshal(m, b)
}
func (m *ServicesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_ServicesRequest.Marshal(b, m, deterministic)
}
func (m *ServicesRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_ServicesRequest.Merge(m, src)
}
func (m *ServicesRequest) XXX_Size() int {
return xxx_messageInfo_ServicesRequest.Size(m)
}
func (m *ServicesRequest) XXX_DiscardUnknown() {
xxx_messageInfo_ServicesRequest.DiscardUnknown(m)
}
var xxx_messageInfo_ServicesRequest proto.InternalMessageInfo
func (m *ServicesRequest) GetServiceIds() string {
if m != nil {
return m.ServiceIds
}
return ""
}
type TenantRequest struct {
TenantId string `protobuf:"bytes,1,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *TenantRequest) Reset() { *m = TenantRequest{} }
func (m *TenantRequest) String() string { return proto.CompactTextString(m) }
func (*TenantRequest) ProtoMessage() {}
func (*TenantRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_f94cf1a886c479d6, []int{3}
}
func (m *TenantRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_TenantRequest.Unmarshal(m, b)
}
func (m *TenantRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_TenantRequest.Marshal(b, m, deterministic)
}
func (m *TenantRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_TenantRequest.Merge(m, src)
}
func (m *TenantRequest) XXX_Size() int {
return xxx_messageInfo_TenantRequest.Size(m)
}
func (m *TenantRequest) XXX_DiscardUnknown() {
xxx_messageInfo_TenantRequest.DiscardUnknown(m)
}
var xxx_messageInfo_TenantRequest proto.InternalMessageInfo
func (m *TenantRequest) GetTenantId() string {
if m != nil {
return m.TenantId
}
return ""
}
type StatusMessage struct {
Status map[string]string `protobuf:"bytes,1,rep,name=status,proto3" json:"status,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *StatusMessage) Reset() { *m = StatusMessage{} }
func (m *StatusMessage) String() string { return proto.CompactTextString(m) }
func (*StatusMessage) ProtoMessage() {}
func (*StatusMessage) Descriptor() ([]byte, []int) {
return fileDescriptor_f94cf1a886c479d6, []int{4}
}
func (m *StatusMessage) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_StatusMessage.Unmarshal(m, b)
}
func (m *StatusMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_StatusMessage.Marshal(b, m, deterministic)
}
func (m *StatusMessage) XXX_Merge(src proto.Message) {
xxx_messageInfo_StatusMessage.Merge(m, src)
}
func (m *StatusMessage) XXX_Size() int {
return xxx_messageInfo_StatusMessage.Size(m)
}
func (m *StatusMessage) XXX_DiscardUnknown() {
xxx_messageInfo_StatusMessage.DiscardUnknown(m)
}
var xxx_messageInfo_StatusMessage proto.InternalMessageInfo
func (m *StatusMessage) GetStatus() map[string]string {
if m != nil {
return m.Status
}
return nil
}
type DiskMessage struct {
Disks map[string]float64 `protobuf:"bytes,1,rep,name=disks,proto3" json:"disks,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"fixed64,2,opt,name=value,proto3"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *DiskMessage) Reset() { *m = DiskMessage{} }
func (m *DiskMessage) String() string { return proto.CompactTextString(m) }
func (*DiskMessage) ProtoMessage() {}
func (*DiskMessage) Descriptor() ([]byte, []int) {
return fileDescriptor_f94cf1a886c479d6, []int{5}
}
func (m *DiskMessage) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_DiskMessage.Unmarshal(m, b)
}
func (m *DiskMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_DiskMessage.Marshal(b, m, deterministic)
}
func (m *DiskMessage) XXX_Merge(src proto.Message) {
xxx_messageInfo_DiskMessage.Merge(m, src)
}
func (m *DiskMessage) XXX_Size() int {
return xxx_messageInfo_DiskMessage.Size(m)
}
func (m *DiskMessage) XXX_DiscardUnknown() {
xxx_messageInfo_DiskMessage.DiscardUnknown(m)
}
var xxx_messageInfo_DiskMessage proto.InternalMessageInfo
func (m *DiskMessage) GetDisks() map[string]float64 {
if m != nil {
return m.Disks
}
return nil
}
type ServiceAppPodList struct {
OldPods []*ServiceAppPod `protobuf:"bytes,1,rep,name=oldPods,proto3" json:"oldPods,omitempty"`
NewPods []*ServiceAppPod `protobuf:"bytes,2,rep,name=newPods,proto3" json:"newPods,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *ServiceAppPodList) Reset() { *m = ServiceAppPodList{} }
func (m *ServiceAppPodList) String() string { return proto.CompactTextString(m) }
func (*ServiceAppPodList) ProtoMessage() {}
func (*ServiceAppPodList) Descriptor() ([]byte, []int) {
return fileDescriptor_f94cf1a886c479d6, []int{6}
}
func (m *ServiceAppPodList) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_ServiceAppPodList.Unmarshal(m, b)
}
func (m *ServiceAppPodList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_ServiceAppPodList.Marshal(b, m, deterministic)
}
func (m *ServiceAppPodList) XXX_Merge(src proto.Message) {
xxx_messageInfo_ServiceAppPodList.Merge(m, src)
}
func (m *ServiceAppPodList) XXX_Size() int {
return xxx_messageInfo_ServiceAppPodList.Size(m)
}
func (m *ServiceAppPodList) XXX_DiscardUnknown() {
xxx_messageInfo_ServiceAppPodList.DiscardUnknown(m)
}
var xxx_messageInfo_ServiceAppPodList proto.InternalMessageInfo
func (m *ServiceAppPodList) GetOldPods() []*ServiceAppPod {
if m != nil {
return m.OldPods
}
return nil
}
func (m *ServiceAppPodList) GetNewPods() []*ServiceAppPod {
if m != nil {
return m.NewPods
}
return nil
}
type ServiceAppPod struct {
ServiceId string `protobuf:"bytes,1,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"`
DeployId string `protobuf:"bytes,2,opt,name=deploy_id,json=deployId,proto3" json:"deploy_id,omitempty"`
DeployType string `protobuf:"bytes,3,opt,name=deploy_type,json=deployType,proto3" json:"deploy_type,omitempty"`
PodName string `protobuf:"bytes,4,opt,name=pod_name,json=podName,proto3" json:"pod_name,omitempty"`
PodIp string `protobuf:"bytes,5,opt,name=pod_ip,json=podIp,proto3" json:"pod_ip,omitempty"`
PodStatus string `protobuf:"bytes,6,opt,name=pod_status,json=podStatus,proto3" json:"pod_status,omitempty"`
Containers map[string]*Container `protobuf:"bytes,7,rep,name=containers,proto3" json:"containers,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *ServiceAppPod) Reset() { *m = ServiceAppPod{} }
func (m *ServiceAppPod) String() string { return proto.CompactTextString(m) }
func (*ServiceAppPod) ProtoMessage() {}
func (*ServiceAppPod) Descriptor() ([]byte, []int) {
return fileDescriptor_f94cf1a886c479d6, []int{7}
}
func (m *ServiceAppPod) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_ServiceAppPod.Unmarshal(m, b)
}
func (m *ServiceAppPod) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_ServiceAppPod.Marshal(b, m, deterministic)
}
func (m *ServiceAppPod) XXX_Merge(src proto.Message) {
xxx_messageInfo_ServiceAppPod.Merge(m, src)
}
func (m *ServiceAppPod) XXX_Size() int {
return xxx_messageInfo_ServiceAppPod.Size(m)
}
func (m *ServiceAppPod) XXX_DiscardUnknown() {
xxx_messageInfo_ServiceAppPod.DiscardUnknown(m)
}
var xxx_messageInfo_ServiceAppPod proto.InternalMessageInfo
func (m *ServiceAppPod) GetServiceId() string {
if m != nil {
return m.ServiceId
}
return ""
}
func (m *ServiceAppPod) GetDeployId() string {
if m != nil {
return m.DeployId
}
return ""
}
func (m *ServiceAppPod) GetDeployType() string {
if m != nil {
return m.DeployType
}
return ""
}
func (m *ServiceAppPod) GetPodName() string {
if m != nil {
return m.PodName
}
return ""
}
func (m *ServiceAppPod) GetPodIp() string {
if m != nil {
return m.PodIp
}
return ""
}
func (m *ServiceAppPod) GetPodStatus() string {
if m != nil {
return m.PodStatus
}
return ""
}
func (m *ServiceAppPod) GetContainers() map[string]*Container {
if m != nil {
return m.Containers
}
return nil
}
type Container struct {
ContainerName string `protobuf:"bytes,1,opt,name=container_name,json=containerName,proto3" json:"container_name,omitempty"`
MemoryLimit int64 `protobuf:"varint,2,opt,name=memory_limit,json=memoryLimit,proto3" json:"memory_limit,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *Container) Reset() { *m = Container{} }
func (m *Container) String() string { return proto.CompactTextString(m) }
func (*Container) ProtoMessage() {}
func (*Container) Descriptor() ([]byte, []int) {
return fileDescriptor_f94cf1a886c479d6, []int{8}
}
func (m *Container) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_Container.Unmarshal(m, b)
}
func (m *Container) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_Container.Marshal(b, m, deterministic)
}
func (m *Container) XXX_Merge(src proto.Message) {
xxx_messageInfo_Container.Merge(m, src)
}
func (m *Container) XXX_Size() int {
return xxx_messageInfo_Container.Size(m)
}
func (m *Container) XXX_DiscardUnknown() {
xxx_messageInfo_Container.DiscardUnknown(m)
}
var xxx_messageInfo_Container proto.InternalMessageInfo
func (m *Container) GetContainerName() string {
if m != nil {
return m.ContainerName
}
return ""
}
func (m *Container) GetMemoryLimit() int64 {
if m != nil {
return m.MemoryLimit
}
return 0
}
type DeployInfo struct {
Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
Statefuleset string `protobuf:"bytes,2,opt,name=statefuleset,proto3" json:"statefuleset,omitempty"`
Deployment string `protobuf:"bytes,3,opt,name=deployment,proto3" json:"deployment,omitempty"`
Pods map[string]string `protobuf:"bytes,4,rep,name=pods,proto3" json:"pods,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
Services map[string]string `protobuf:"bytes,5,rep,name=services,proto3" json:"services,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
Endpoints map[string]string `protobuf:"bytes,6,rep,name=endpoints,proto3" json:"endpoints,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
Secrets map[string]string `protobuf:"bytes,7,rep,name=secrets,proto3" json:"secrets,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
Ingresses map[string]string `protobuf:"bytes,8,rep,name=ingresses,proto3" json:"ingresses,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
Replicatset map[string]string `protobuf:"bytes,9,rep,name=replicatset,proto3" json:"replicatset,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
Status string `protobuf:"bytes,10,opt,name=status,proto3" json:"status,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *DeployInfo) Reset() { *m = DeployInfo{} }
func (m *DeployInfo) String() string { return proto.CompactTextString(m) }
func (*DeployInfo) ProtoMessage() {}
func (*DeployInfo) Descriptor() ([]byte, []int) {
return fileDescriptor_f94cf1a886c479d6, []int{9}
}
func (m *DeployInfo) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_DeployInfo.Unmarshal(m, b)
}
func (m *DeployInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_DeployInfo.Marshal(b, m, deterministic)
}
func (m *DeployInfo) XXX_Merge(src proto.Message) {
xxx_messageInfo_DeployInfo.Merge(m, src)
}
func (m *DeployInfo) XXX_Size() int {
return xxx_messageInfo_DeployInfo.Size(m)
}
func (m *DeployInfo) XXX_DiscardUnknown() {
xxx_messageInfo_DeployInfo.DiscardUnknown(m)
}
var xxx_messageInfo_DeployInfo proto.InternalMessageInfo
func (m *DeployInfo) GetNamespace() string {
if m != nil {
return m.Namespace
}
return ""
}
func (m *DeployInfo) GetStatefuleset() string {
if m != nil {
return m.Statefuleset
}
return ""
}
func (m *DeployInfo) GetDeployment() string {
if m != nil {
return m.Deployment
}
return ""
}
func (m *DeployInfo) GetPods() map[string]string {
if m != nil {
return m.Pods
}
return nil
}
func (m *DeployInfo) GetServices() map[string]string {
if m != nil {
return m.Services
}
return nil
}
func (m *DeployInfo) GetEndpoints() map[string]string {
if m != nil {
return m.Endpoints
}
return nil
}
func (m *DeployInfo) GetSecrets() map[string]string {
if m != nil {
return m.Secrets
}
return nil
}
func (m *DeployInfo) GetIngresses() map[string]string {
if m != nil {
return m.Ingresses
}
return nil
}
func (m *DeployInfo) GetReplicatset() map[string]string {
if m != nil {
return m.Replicatset
}
return nil
}
func (m *DeployInfo) GetStatus() string {
if m != nil {
return m.Status
}
return ""
}
type TenantResource struct {
CpuRequest int64 `protobuf:"varint,1,opt,name=cpu_request,json=cpuRequest,proto3" json:"cpu_request,omitempty"`
CpuLimit int64 `protobuf:"varint,2,opt,name=cpu_limit,json=cpuLimit,proto3" json:"cpu_limit,omitempty"`
MemoryRequest int64 `protobuf:"varint,3,opt,name=memory_request,json=memoryRequest,proto3" json:"memory_request,omitempty"`
MemoryLimit int64 `protobuf:"varint,4,opt,name=memory_limit,json=memoryLimit,proto3" json:"memory_limit,omitempty"`
RunningAppNum int64 `protobuf:"varint,5,opt,name=running_app_num,json=runningAppNum,proto3" json:"running_app_num,omitempty"`
UnscdCpuReq int64 `protobuf:"varint,6,opt,name=unscd_cpu_req,json=unscdCpuReq,proto3" json:"unscd_cpu_req,omitempty"`
UnscdCpuLimit int64 `protobuf:"varint,7,opt,name=unscd_cpu_limit,json=unscdCpuLimit,proto3" json:"unscd_cpu_limit,omitempty"`
UnscdMemoryReq int64 `protobuf:"varint,8,opt,name=unscd_memory_req,json=unscdMemoryReq,proto3" json:"unscd_memory_req,omitempty"`
UnscdMemoryLimit int64 `protobuf:"varint,9,opt,name=unscd_memory_limit,json=unscdMemoryLimit,proto3" json:"unscd_memory_limit,omitempty"`
RunningAppThirdNum int64 `protobuf:"varint,10,opt,name=running_app_third_num,json=runningAppThirdNum,proto3" json:"running_app_third_num,omitempty"`
RunningAppInternalNum int64 `protobuf:"varint,11,opt,name=running_app_internal_num,json=runningAppInternalNum,proto3" json:"running_app_internal_num,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *TenantResource) Reset() { *m = TenantResource{} }
func (m *TenantResource) String() string { return proto.CompactTextString(m) }
func (*TenantResource) ProtoMessage() {}
func (*TenantResource) Descriptor() ([]byte, []int) {
return fileDescriptor_f94cf1a886c479d6, []int{10}
}
func (m *TenantResource) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_TenantResource.Unmarshal(m, b)
}
func (m *TenantResource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_TenantResource.Marshal(b, m, deterministic)
}
func (m *TenantResource) XXX_Merge(src proto.Message) {
xxx_messageInfo_TenantResource.Merge(m, src)
}
func (m *TenantResource) XXX_Size() int {
return xxx_messageInfo_TenantResource.Size(m)
}
func (m *TenantResource) XXX_DiscardUnknown() {
xxx_messageInfo_TenantResource.DiscardUnknown(m)
}
var xxx_messageInfo_TenantResource proto.InternalMessageInfo
func (m *TenantResource) GetCpuRequest() int64 {
if m != nil {
return m.CpuRequest
}
return 0
}
func (m *TenantResource) GetCpuLimit() int64 {
if m != nil {
return m.CpuLimit
}
return 0
}
func (m *TenantResource) GetMemoryRequest() int64 {
if m != nil {
return m.MemoryRequest
}
return 0
}
func (m *TenantResource) GetMemoryLimit() int64 {
if m != nil {
return m.MemoryLimit
}
return 0
}
func (m *TenantResource) GetRunningAppNum() int64 {
if m != nil {
return m.RunningAppNum
}
return 0
}
func (m *TenantResource) GetUnscdCpuReq() int64 {
if m != nil {
return m.UnscdCpuReq
}
return 0
}
func (m *TenantResource) GetUnscdCpuLimit() int64 {
if m != nil {
return m.UnscdCpuLimit
}
return 0
}
func (m *TenantResource) GetUnscdMemoryReq() int64 {
if m != nil {
return m.UnscdMemoryReq
}
return 0
}
func (m *TenantResource) GetUnscdMemoryLimit() int64 {
if m != nil {
return m.UnscdMemoryLimit
}
return 0
}
func (m *TenantResource) GetRunningAppThirdNum() int64 {
if m != nil {
return m.RunningAppThirdNum
}
return 0
}
func (m *TenantResource) GetRunningAppInternalNum() int64 {
if m != nil {
return m.RunningAppInternalNum
}
return 0
}
type AddThirdPartyEndpointsReq struct {
Uuid string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
Sid string `protobuf:"bytes,2,opt,name=sid,proto3" json:"sid,omitempty"`
Ip string `protobuf:"bytes,3,opt,name=ip,proto3" json:"ip,omitempty"`
Port int32 `protobuf:"varint,4,opt,name=port,proto3" json:"port,omitempty"`
IsOnline bool `protobuf:"varint,5,opt,name=is_online,json=isOnline,proto3" json:"is_online,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *AddThirdPartyEndpointsReq) Reset() { *m = AddThirdPartyEndpointsReq{} }
func (m *AddThirdPartyEndpointsReq) String() string { return proto.CompactTextString(m) }
func (*AddThirdPartyEndpointsReq) ProtoMessage() {}
func (*AddThirdPartyEndpointsReq) Descriptor() ([]byte, []int) {
return fileDescriptor_f94cf1a886c479d6, []int{11}
}
func (m *AddThirdPartyEndpointsReq) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_AddThirdPartyEndpointsReq.Unmarshal(m, b)
}
func (m *AddThirdPartyEndpointsReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_AddThirdPartyEndpointsReq.Marshal(b, m, deterministic)
}
func (m *AddThirdPartyEndpointsReq) XXX_Merge(src proto.Message) {
xxx_messageInfo_AddThirdPartyEndpointsReq.Merge(m, src)
}
func (m *AddThirdPartyEndpointsReq) XXX_Size() int {
return xxx_messageInfo_AddThirdPartyEndpointsReq.Size(m)
}
func (m *AddThirdPartyEndpointsReq) XXX_DiscardUnknown() {
xxx_messageInfo_AddThirdPartyEndpointsReq.DiscardUnknown(m)
}
var xxx_messageInfo_AddThirdPartyEndpointsReq proto.InternalMessageInfo
func (m *AddThirdPartyEndpointsReq) GetUuid() string {
if m != nil {
return m.Uuid
}
return ""
}
func (m *AddThirdPartyEndpointsReq) GetSid() string {
if m != nil {
return m.Sid
}
return ""
}
func (m *AddThirdPartyEndpointsReq) GetIp() string {
if m != nil {
return m.Ip
}
return ""
}
func (m *AddThirdPartyEndpointsReq) GetPort() int32 {
if m != nil {
return m.Port
}
return 0
}
func (m *AddThirdPartyEndpointsReq) GetIsOnline() bool {
if m != nil {
return m.IsOnline
}
return false
}
type UpdThirdPartyEndpointsReq struct {
Uuid string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
Sid string `protobuf:"bytes,2,opt,name=sid,proto3" json:"sid,omitempty"`
Ip string `protobuf:"bytes,3,opt,name=ip,proto3" json:"ip,omitempty"`
Port int32 `protobuf:"varint,4,opt,name=port,proto3" json:"port,omitempty"`
IsOnline bool `protobuf:"varint,5,opt,name=is_online,json=isOnline,proto3" json:"is_online,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *UpdThirdPartyEndpointsReq) Reset() { *m = UpdThirdPartyEndpointsReq{} }
func (m *UpdThirdPartyEndpointsReq) String() string { return proto.CompactTextString(m) }
func (*UpdThirdPartyEndpointsReq) ProtoMessage() {}
func (*UpdThirdPartyEndpointsReq) Descriptor() ([]byte, []int) {
return fileDescriptor_f94cf1a886c479d6, []int{12}
}
func (m *UpdThirdPartyEndpointsReq) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_UpdThirdPartyEndpointsReq.Unmarshal(m, b)
}
func (m *UpdThirdPartyEndpointsReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_UpdThirdPartyEndpointsReq.Marshal(b, m, deterministic)
}
func (m *UpdThirdPartyEndpointsReq) XXX_Merge(src proto.Message) {
xxx_messageInfo_UpdThirdPartyEndpointsReq.Merge(m, src)
}
func (m *UpdThirdPartyEndpointsReq) XXX_Size() int {
return xxx_messageInfo_UpdThirdPartyEndpointsReq.Size(m)
}
func (m *UpdThirdPartyEndpointsReq) XXX_DiscardUnknown() {
xxx_messageInfo_UpdThirdPartyEndpointsReq.DiscardUnknown(m)
}
var xxx_messageInfo_UpdThirdPartyEndpointsReq proto.InternalMessageInfo
func (m *UpdThirdPartyEndpointsReq) GetUuid() string {
if m != nil {
return m.Uuid
}
return ""
}
func (m *UpdThirdPartyEndpointsReq) GetSid() string {
if m != nil {
return m.Sid
}
return ""
}
func (m *UpdThirdPartyEndpointsReq) GetIp() string {
if m != nil {
return m.Ip
}
return ""
}
func (m *UpdThirdPartyEndpointsReq) GetPort() int32 {
if m != nil {
return m.Port
}
return 0
}
func (m *UpdThirdPartyEndpointsReq) GetIsOnline() bool {
if m != nil {
return m.IsOnline
}
return false
}
type DelThirdPartyEndpointsReq struct {
Uuid string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
Sid string `protobuf:"bytes,2,opt,name=sid,proto3" json:"sid,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *DelThirdPartyEndpointsReq) Reset() { *m = DelThirdPartyEndpointsReq{} }
func (m *DelThirdPartyEndpointsReq) String() string { return proto.CompactTextString(m) }
func (*DelThirdPartyEndpointsReq) ProtoMessage() {}
func (*DelThirdPartyEndpointsReq) Descriptor() ([]byte, []int) {
return fileDescriptor_f94cf1a886c479d6, []int{13}
}
func (m *DelThirdPartyEndpointsReq) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_DelThirdPartyEndpointsReq.Unmarshal(m, b)
}
func (m *DelThirdPartyEndpointsReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_DelThirdPartyEndpointsReq.Marshal(b, m, deterministic)
}
func (m *DelThirdPartyEndpointsReq) XXX_Merge(src proto.Message) {
xxx_messageInfo_DelThirdPartyEndpointsReq.Merge(m, src)
}
func (m *DelThirdPartyEndpointsReq) XXX_Size() int {
return xxx_messageInfo_DelThirdPartyEndpointsReq.Size(m)
}
func (m *DelThirdPartyEndpointsReq) XXX_DiscardUnknown() {
xxx_messageInfo_DelThirdPartyEndpointsReq.DiscardUnknown(m)
}
var xxx_messageInfo_DelThirdPartyEndpointsReq proto.InternalMessageInfo
func (m *DelThirdPartyEndpointsReq) GetUuid() string {
if m != nil {
return m.Uuid
}
return ""
}
func (m *DelThirdPartyEndpointsReq) GetSid() string {
if m != nil {
return m.Sid
}
return ""
}
type ThirdPartyEndpoint struct {
Uuid string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
Sid string `protobuf:"bytes,2,opt,name=sid,proto3" json:"sid,omitempty"`
Ip string `protobuf:"bytes,3,opt,name=ip,proto3" json:"ip,omitempty"`
Port int32 `protobuf:"varint,4,opt,name=port,proto3" json:"port,omitempty"`
Status string `protobuf:"bytes,5,opt,name=status,proto3" json:"status,omitempty"`
IsOnline bool `protobuf:"varint,6,opt,name=is_online,json=isOnline,proto3" json:"is_online,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *ThirdPartyEndpoint) Reset() { *m = ThirdPartyEndpoint{} }
func (m *ThirdPartyEndpoint) String() string { return proto.CompactTextString(m) }
func (*ThirdPartyEndpoint) ProtoMessage() {}
func (*ThirdPartyEndpoint) Descriptor() ([]byte, []int) {
return fileDescriptor_f94cf1a886c479d6, []int{14}
}
func (m *ThirdPartyEndpoint) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_ThirdPartyEndpoint.Unmarshal(m, b)
}
func (m *ThirdPartyEndpoint) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_ThirdPartyEndpoint.Marshal(b, m, deterministic)
}
func (m *ThirdPartyEndpoint) XXX_Merge(src proto.Message) {
xxx_messageInfo_ThirdPartyEndpoint.Merge(m, src)
}
func (m *ThirdPartyEndpoint) XXX_Size() int {
return xxx_messageInfo_ThirdPartyEndpoint.Size(m)
}
func (m *ThirdPartyEndpoint) XXX_DiscardUnknown() {
xxx_messageInfo_ThirdPartyEndpoint.DiscardUnknown(m)
}
var xxx_messageInfo_ThirdPartyEndpoint proto.InternalMessageInfo
func (m *ThirdPartyEndpoint) GetUuid() string {
if m != nil {
return m.Uuid
}
return ""
}
func (m *ThirdPartyEndpoint) GetSid() string {
if m != nil {
return m.Sid
}
return ""
}
func (m *ThirdPartyEndpoint) GetIp() string {
if m != nil {
return m.Ip
}
return ""
}
func (m *ThirdPartyEndpoint) GetPort() int32 {
if m != nil {
return m.Port
}
return 0
}
func (m *ThirdPartyEndpoint) GetStatus() string {
if m != nil {
return m.Status
}
return ""
}
func (m *ThirdPartyEndpoint) GetIsOnline() bool {
if m != nil {
return m.IsOnline
}
return false
}
type ThirdPartyEndpoints struct {
Obj []*ThirdPartyEndpoint `protobuf:"bytes,1,rep,name=obj,proto3" json:"obj,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *ThirdPartyEndpoints) Reset() { *m = ThirdPartyEndpoints{} }
func (m *ThirdPartyEndpoints) String() string { return proto.CompactTextString(m) }
func (*ThirdPartyEndpoints) ProtoMessage() {}
func (*ThirdPartyEndpoints) Descriptor() ([]byte, []int) {
return fileDescriptor_f94cf1a886c479d6, []int{15}
}
func (m *ThirdPartyEndpoints) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_ThirdPartyEndpoints.Unmarshal(m, b)
}
func (m *ThirdPartyEndpoints) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_ThirdPartyEndpoints.Marshal(b, m, deterministic)
}
func (m *ThirdPartyEndpoints) XXX_Merge(src proto.Message) {
xxx_messageInfo_ThirdPartyEndpoints.Merge(m, src)
}
func (m *ThirdPartyEndpoints) XXX_Size() int {
return xxx_messageInfo_ThirdPartyEndpoints.Size(m)
}
func (m *ThirdPartyEndpoints) XXX_DiscardUnknown() {
xxx_messageInfo_ThirdPartyEndpoints.DiscardUnknown(m)
}
var xxx_messageInfo_ThirdPartyEndpoints proto.InternalMessageInfo
func (m *ThirdPartyEndpoints) GetObj() []*ThirdPartyEndpoint {
if m != nil {
return m.Obj
}
return nil
}
type ListPodsBySIDReq struct {
Sid string `protobuf:"bytes,1,opt,name=sid,proto3" json:"sid,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *ListPodsBySIDReq) Reset() { *m = ListPodsBySIDReq{} }
func (m *ListPodsBySIDReq) String() string { return proto.CompactTextString(m) }
func (*ListPodsBySIDReq) ProtoMessage() {}
func (*ListPodsBySIDReq) Descriptor() ([]byte, []int) {
return fileDescriptor_f94cf1a886c479d6, []int{16}
}
func (m *ListPodsBySIDReq) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_ListPodsBySIDReq.Unmarshal(m, b)
}
func (m *ListPodsBySIDReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_ListPodsBySIDReq.Marshal(b, m, deterministic)
}
func (m *ListPodsBySIDReq) XXX_Merge(src proto.Message) {
xxx_messageInfo_ListPodsBySIDReq.Merge(m, src)
}
func (m *ListPodsBySIDReq) XXX_Size() int {
return xxx_messageInfo_ListPodsBySIDReq.Size(m)
}
func (m *ListPodsBySIDReq) XXX_DiscardUnknown() {
xxx_messageInfo_ListPodsBySIDReq.DiscardUnknown(m)
}
var xxx_messageInfo_ListPodsBySIDReq proto.InternalMessageInfo
func (m *ListPodsBySIDReq) GetSid() string {
if m != nil {
return m.Sid
}
return ""
}
type GetPodEventsReq struct {
Sid string `protobuf:"bytes,1,opt,name=sid,proto3" json:"sid,omitempty"`
PodName string `protobuf:"bytes,2,opt,name=podName,proto3" json:"podName,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *GetPodEventsReq) Reset() { *m = GetPodEventsReq{} }
func (m *GetPodEventsReq) String() string { return proto.CompactTextString(m) }
func (*GetPodEventsReq) ProtoMessage() {}
func (*GetPodEventsReq) Descriptor() ([]byte, []int) {
return fileDescriptor_f94cf1a886c479d6, []int{17}
}
func (m *GetPodEventsReq) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_GetPodEventsReq.Unmarshal(m, b)
}
func (m *GetPodEventsReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_GetPodEventsReq.Marshal(b, m, deterministic)
}
func (m *GetPodEventsReq) XXX_Merge(src proto.Message) {
xxx_messageInfo_GetPodEventsReq.Merge(m, src)
}
func (m *GetPodEventsReq) XXX_Size() int {
return xxx_messageInfo_GetPodEventsReq.Size(m)
}
func (m *GetPodEventsReq) XXX_DiscardUnknown() {
xxx_messageInfo_GetPodEventsReq.DiscardUnknown(m)
}
var xxx_messageInfo_GetPodEventsReq proto.InternalMessageInfo
func (m *GetPodEventsReq) GetSid() string {
if m != nil {
return m.Sid
}
return ""
}
func (m *GetPodEventsReq) GetPodName() string {
if m != nil {
return m.PodName
}
return ""
}
type GetPodEventsResp struct {
Evnets []*PodEvent `protobuf:"bytes,1,rep,name=evnets,proto3" json:"evnets,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *GetPodEventsResp) Reset() { *m = GetPodEventsResp{} }
func (m *GetPodEventsResp) String() string { return proto.CompactTextString(m) }
func (*GetPodEventsResp) ProtoMessage() {}
func (*GetPodEventsResp) Descriptor() ([]byte, []int) {
return fileDescriptor_f94cf1a886c479d6, []int{18}
}
func (m *GetPodEventsResp) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_GetPodEventsResp.Unmarshal(m, b)
}
func (m *GetPodEventsResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_GetPodEventsResp.Marshal(b, m, deterministic)
}
func (m *GetPodEventsResp) XXX_Merge(src proto.Message) {
xxx_messageInfo_GetPodEventsResp.Merge(m, src)
}
func (m *GetPodEventsResp) XXX_Size() int {
return xxx_messageInfo_GetPodEventsResp.Size(m)
}
func (m *GetPodEventsResp) XXX_DiscardUnknown() {
xxx_messageInfo_GetPodEventsResp.DiscardUnknown(m)
}
var xxx_messageInfo_GetPodEventsResp proto.InternalMessageInfo
func (m *GetPodEventsResp) GetEvnets() []*PodEvent {
if m != nil {
return m.Evnets
}
return nil
}
type PodEvent struct {
Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
Age string `protobuf:"bytes,3,opt,name=age,proto3" json:"age,omitempty"`
From string `protobuf:"bytes,4,opt,name=from,proto3" json:"from,omitempty"`
Message string `protobuf:"bytes,5,opt,name=message,proto3" json:"message,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *PodEvent) Reset() { *m = PodEvent{} }
func (m *PodEvent) String() string { return proto.CompactTextString(m) }
func (*PodEvent) ProtoMessage() {}
func (*PodEvent) Descriptor() ([]byte, []int) {
return fileDescriptor_f94cf1a886c479d6, []int{19}
}
func (m *PodEvent) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_PodEvent.Unmarshal(m, b)
}
func (m *PodEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_PodEvent.Marshal(b, m, deterministic)
}
func (m *PodEvent) XXX_Merge(src proto.Message) {
xxx_messageInfo_PodEvent.Merge(m, src)
}
func (m *PodEvent) XXX_Size() int {
return xxx_messageInfo_PodEvent.Size(m)
}
func (m *PodEvent) XXX_DiscardUnknown() {
xxx_messageInfo_PodEvent.DiscardUnknown(m)
}
var xxx_messageInfo_PodEvent proto.InternalMessageInfo
func (m *PodEvent) GetType() string {
if m != nil {
return m.Type
}
return ""
}
func (m *PodEvent) GetReason() string {
if m != nil {
return m.Reason
}
return ""
}
func (m *PodEvent) GetAge() string {
if m != nil {
return m.Age
}
return ""
}
func (m *PodEvent) GetFrom() string {
if m != nil {
return m.From
}
return ""
}
func (m *PodEvent) GetMessage() string {
if m != nil {
return m.Message
}
return ""
}
func init() {
proto.RegisterType((*Empty)(nil), "pb.Empty")
proto.RegisterType((*ServiceRequest)(nil), "pb.ServiceRequest")
proto.RegisterType((*ServicesRequest)(nil), "pb.ServicesRequest")
proto.RegisterType((*TenantRequest)(nil), "pb.TenantRequest")
proto.RegisterType((*StatusMessage)(nil), "pb.StatusMessage")
proto.RegisterMapType((map[string]string)(nil), "pb.StatusMessage.StatusEntry")
proto.RegisterType((*DiskMessage)(nil), "pb.DiskMessage")
proto.RegisterMapType((map[string]float64)(nil), "pb.DiskMessage.DisksEntry")
proto.RegisterType((*ServiceAppPodList)(nil), "pb.ServiceAppPodList")
proto.RegisterType((*ServiceAppPod)(nil), "pb.ServiceAppPod")
proto.RegisterMapType((map[string]*Container)(nil), "pb.ServiceAppPod.ContainersEntry")
proto.RegisterType((*Container)(nil), "pb.Container")
proto.RegisterType((*DeployInfo)(nil), "pb.DeployInfo")
proto.RegisterMapType((map[string]string)(nil), "pb.DeployInfo.EndpointsEntry")
proto.RegisterMapType((map[string]string)(nil), "pb.DeployInfo.IngressesEntry")
proto.RegisterMapType((map[string]string)(nil), "pb.DeployInfo.PodsEntry")
proto.RegisterMapType((map[string]string)(nil), "pb.DeployInfo.ReplicatsetEntry")
proto.RegisterMapType((map[string]string)(nil), "pb.DeployInfo.SecretsEntry")
proto.RegisterMapType((map[string]string)(nil), "pb.DeployInfo.ServicesEntry")
proto.RegisterType((*TenantResource)(nil), "pb.TenantResource")
proto.RegisterType((*AddThirdPartyEndpointsReq)(nil), "pb.AddThirdPartyEndpointsReq")
proto.RegisterType((*UpdThirdPartyEndpointsReq)(nil), "pb.UpdThirdPartyEndpointsReq")
proto.RegisterType((*DelThirdPartyEndpointsReq)(nil), "pb.DelThirdPartyEndpointsReq")
proto.RegisterType((*ThirdPartyEndpoint)(nil), "pb.ThirdPartyEndpoint")
proto.RegisterType((*ThirdPartyEndpoints)(nil), "pb.ThirdPartyEndpoints")
proto.RegisterType((*ListPodsBySIDReq)(nil), "pb.ListPodsBySIDReq")
proto.RegisterType((*GetPodEventsReq)(nil), "pb.GetPodEventsReq")
proto.RegisterType((*GetPodEventsResp)(nil), "pb.GetPodEventsResp")
proto.RegisterType((*PodEvent)(nil), "pb.PodEvent")
}
func init() { proto.RegisterFile("app_runtime_server.proto", fileDescriptor_f94cf1a886c479d6) }
var fileDescriptor_f94cf1a886c479d6 = []byte{
// 1279 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xc4, 0x57, 0x5b, 0x6f, 0x1b, 0x45,
0x14, 0x8e, 0xef, 0xf6, 0x71, 0xec, 0x38, 0xd3, 0xa6, 0xdd, 0xba, 0x2d, 0x6d, 0x97, 0x82, 0x22,
0x51, 0x05, 0x08, 0xaa, 0x9a, 0x5e, 0x00, 0x99, 0x26, 0x0a, 0x96, 0xda, 0x52, 0x6d, 0xda, 0x67,
0x6b, 0xe3, 0x9d, 0x86, 0x25, 0xde, 0xd9, 0x61, 0x67, 0xd6, 0xc8, 0x8f, 0xf0, 0x17, 0xf8, 0x51,
0xbc, 0xa1, 0xfe, 0x24, 0x74, 0xe6, 0xb2, 0x17, 0xdb, 0x51, 0x09, 0x20, 0xf1, 0x36, 0x7b, 0xe6,
0xfb, 0xce, 0x75, 0xe6, 0xcc, 0x59, 0x70, 0x7c, 0xce, 0x27, 0x49, 0xca, 0x64, 0x18, 0xd1, 0x89,
0xa0, 0xc9, 0x9c, 0x26, 0x7b, 0x3c, 0x89, 0x65, 0x4c, 0xaa, 0xfc, 0xd4, 0x6d, 0x41, 0xe3, 0x28,
0xe2, 0x72, 0xe1, 0x7e, 0x0e, 0xfd, 0x13, 0x9a, 0xcc, 0xc3, 0x29, 0xf5, 0xe8, 0xcf, 0x29, 0x15,
0x92, 0xdc, 0x06, 0x10, 0x5a, 0x32, 0x09, 0x03, 0xa7, 0x72, 0xb7, 0xb2, 0xdb, 0xf1, 0x3a, 0x46,
0x32, 0x0e, 0xdc, 0x7d, 0xd8, 0x32, 0x04, 0x61, 0x19, 0x77, 0xa0, 0x9b, 0x33, 0x84, 0xa1, 0x40,
0x46, 0x11, 0xee, 0x03, 0xe8, 0xbd, 0xa1, 0xcc, 0x67, 0xd2, 0x32, 0x6e, 0x42, 0x47, 0x2a, 0x41,
0x6e, 0xa2, 0xad, 0x05, 0xe3, 0xc0, 0xfd, 0xb5, 0x02, 0xbd, 0x13, 0xe9, 0xcb, 0x54, 0xbc, 0xa4,
0x42, 0xf8, 0x67, 0x94, 0x3c, 0x84, 0xa6, 0x50, 0x02, 0xa7, 0x72, 0xb7, 0xb6, 0xdb, 0xdd, 0xbf,
0xbd, 0xc7, 0x4f, 0xf7, 0x4a, 0x10, 0xf3, 0x75, 0xc4, 0x64, 0xb2, 0xf0, 0x0c, 0x78, 0xf8, 0x18,
0xba, 0x05, 0x31, 0x19, 0x40, 0xed, 0x9c, 0x2e, 0x8c, 0x39, 0x5c, 0x92, 0xab, 0xd0, 0x98, 0xfb,
0xb3, 0x94, 0x3a, 0x55, 0x25, 0xd3, 0x1f, 0x4f, 0xaa, 0x07, 0x15, 0x77, 0x01, 0xdd, 0xc3, 0x50,
0x9c, 0x5b, 0x07, 0xbe, 0x80, 0x46, 0x10, 0x8a, 0x73, 0x6b, 0x7f, 0x88, 0xf6, 0x0b, 0xfb, 0x6a,
0x6d, 0x8c, 0x6b, 0xe0, 0xf0, 0x00, 0x20, 0x17, 0x7e, 0xc8, 0x74, 0xa5, 0x68, 0x3a, 0x82, 0x6d,
0x93, 0xe0, 0x11, 0xe7, 0xaf, 0xe3, 0xe0, 0x45, 0x28, 0x24, 0xf9, 0x0c, 0x5a, 0xf1, 0x2c, 0x78,
0x1d, 0x07, 0xd6, 0x85, 0x6d, 0x95, 0x82, 0x22, 0xce, 0xb3, 0x08, 0x04, 0x33, 0xfa, 0x8b, 0x02,
0x57, 0x2f, 0x04, 0x1b, 0x84, 0xfb, 0x67, 0x15, 0x7a, 0xa5, 0xad, 0x0f, 0x1c, 0x00, 0xac, 0x5d,
0x40, 0xf9, 0x2c, 0x5e, 0xe0, 0xae, 0x4e, 0x5c, 0x5b, 0x0b, 0xc6, 0x01, 0x1e, 0x05, 0xb3, 0x29,
0x17, 0x9c, 0x3a, 0x35, 0x7d, 0x14, 0xb4, 0xe8, 0xcd, 0x82, 0x53, 0x72, 0x03, 0xda, 0x3c, 0x0e,
0x26, 0xcc, 0x8f, 0xa8, 0x53, 0x57, 0xbb, 0x2d, 0x1e, 0x07, 0xaf, 0xfc, 0x88, 0x92, 0x1d, 0x68,
0xe2, 0x56, 0xc8, 0x9d, 0x86, 0x2e, 0x07, 0x8f, 0x83, 0x31, 0x47, 0x77, 0x50, 0x6c, 0x0e, 0x40,
0x53, 0xbb, 0xc3, 0xe3, 0x40, 0x97, 0x96, 0x8c, 0x00, 0xa6, 0x31, 0x93, 0x7e, 0xc8, 0x68, 0x22,
0x9c, 0x96, 0x8a, 0xf7, 0xde, 0x4a, 0xbc, 0x7b, 0xcf, 0x33, 0x8c, 0x2e, 0x53, 0x81, 0x34, 0x7c,
0x01, 0x5b, 0x4b, 0xdb, 0x6b, 0x0a, 0xf6, 0x71, 0xb1, 0x60, 0xdd, 0xfd, 0x1e, 0x9a, 0xc8, 0x58,
0xc5, 0xfa, 0xbd, 0x85, 0x4e, 0x26, 0x27, 0x9f, 0x40, 0x3f, 0x33, 0xa4, 0x83, 0xd6, 0x2a, 0x7b,
0x99, 0x54, 0x85, 0x7e, 0x0f, 0x36, 0x23, 0x1a, 0xc5, 0xc9, 0x62, 0x32, 0x0b, 0xa3, 0x50, 0x2a,
0x1b, 0x35, 0xaf, 0xab, 0x65, 0x2f, 0x50, 0xe4, 0xbe, 0x6f, 0x02, 0x1c, 0xea, 0x34, 0xb3, 0x77,
0x31, 0xb9, 0x05, 0x1d, 0x54, 0x27, 0xb8, 0x3f, 0xb5, 0x3a, 0x73, 0x01, 0x71, 0x61, 0x13, 0xf3,
0x45, 0xdf, 0xa5, 0x33, 0x2a, 0xa8, 0x34, 0x65, 0x2a, 0xc9, 0xc8, 0x47, 0x60, 0xea, 0x12, 0x51,
0x26, 0xcb, 0x95, 0x42, 0x09, 0x79, 0x00, 0x75, 0x8e, 0x47, 0xa8, 0xae, 0x52, 0xea, 0xa8, 0x23,
0x9f, 0xd9, 0xdf, 0xc3, 0xb3, 0xa3, 0x33, 0xa9, 0x50, 0xe4, 0x00, 0xda, 0xe6, 0x88, 0x08, 0xa7,
0xa1, 0x18, 0xb7, 0x96, 0x18, 0xb6, 0x6b, 0x68, 0x56, 0x86, 0x26, 0x4f, 0xa1, 0x43, 0x59, 0xc0,
0xe3, 0x90, 0x49, 0x2c, 0x6f, 0x76, 0xbf, 0x0b, 0xd4, 0x23, 0xbb, 0xaf, 0xb9, 0x39, 0x9e, 0x3c,
0x84, 0x96, 0xa0, 0xd3, 0x84, 0x4a, 0x5b, 0xfa, 0x9b, 0x2b, 0x56, 0xd5, 0xae, 0x26, 0x5a, 0x2c,
0xda, 0x0c, 0xd9, 0x59, 0x42, 0x85, 0xa0, 0xc2, 0x69, 0xaf, 0xb5, 0x39, 0xb6, 0xfb, 0xc6, 0x66,
0x86, 0x27, 0x23, 0xe8, 0x26, 0x94, 0xcf, 0xc2, 0xa9, 0x2f, 0x31, 0xb7, 0x1d, 0x45, 0xbf, 0xb3,
0x44, 0xf7, 0x72, 0x84, 0x56, 0x50, 0xe4, 0x90, 0x6b, 0x59, 0x43, 0x03, 0x95, 0x77, 0xdb, 0xb1,
0x1e, 0x41, 0x27, 0x4b, 0xec, 0x65, 0xfa, 0xd5, 0xf0, 0x69, 0x76, 0x89, 0xff, 0x01, 0xf9, 0x19,
0xf4, 0xcb, 0x19, 0xbe, 0x14, 0xfb, 0x09, 0x6c, 0x16, 0x93, 0x7c, 0x59, 0xcb, 0xe5, 0x3c, 0x5f,
0x8a, 0xfd, 0x0d, 0x0c, 0x96, 0xd3, 0x7c, 0xa9, 0x26, 0xff, 0xbe, 0x06, 0x7d, 0xfb, 0x2e, 0x89,
0x38, 0x4d, 0xa6, 0x14, 0xfb, 0xd7, 0x94, 0xa7, 0x93, 0x44, 0xbf, 0x53, 0x4a, 0x4d, 0xcd, 0x83,
0x29, 0x4f, 0x0b, 0x2f, 0x17, 0x02, 0x8a, 0xd7, 0xb4, 0x3d, 0xe5, 0xa9, 0xba, 0xa3, 0x78, 0xdb,
0xcd, 0x35, 0xb6, 0x0a, 0x6a, 0x0a, 0xd1, 0xd3, 0x52, 0xab, 0x63, 0xf9, 0xb6, 0xd7, 0x57, 0x6e,
0x3b, 0xf9, 0x14, 0xb6, 0x92, 0x94, 0xb1, 0x90, 0x9d, 0x4d, 0xf0, 0x1d, 0x67, 0x69, 0xa4, 0x9a,
0x62, 0xcd, 0xeb, 0x19, 0xf1, 0x88, 0xf3, 0x57, 0x69, 0x44, 0x5c, 0xe8, 0xa5, 0x4c, 0x4c, 0x83,
0x89, 0xf1, 0x5a, 0xf5, 0xc7, 0x9a, 0xd7, 0x55, 0xc2, 0xe7, 0xca, 0x6d, 0xd4, 0x95, 0x63, 0xb4,
0xc5, 0x96, 0xd6, 0x65, 0x51, 0xda, 0xe6, 0x2e, 0x0c, 0x34, 0x2e, 0x8f, 0xc1, 0x69, 0x2b, 0x60,
0x5f, 0xc9, 0x5f, 0xda, 0x20, 0xc8, 0x03, 0x20, 0x25, 0xa4, 0x56, 0xda, 0x51, 0xd8, 0x41, 0x01,
0xab, 0xf5, 0x7e, 0x09, 0x3b, 0xc5, 0x58, 0xe4, 0x8f, 0x61, 0x12, 0xa8, 0x88, 0x40, 0x11, 0x48,
0x1e, 0xd1, 0x1b, 0xdc, 0xc2, 0xb0, 0x1e, 0x81, 0x53, 0xa4, 0x84, 0x4c, 0xd2, 0x84, 0xf9, 0x33,
0xc5, 0xea, 0x2a, 0xd6, 0x4e, 0xce, 0x1a, 0x9b, 0xdd, 0x57, 0x69, 0xe4, 0xfe, 0x56, 0x81, 0x1b,
0xa3, 0x20, 0x50, 0x8a, 0x5e, 0xfb, 0x89, 0x5c, 0x64, 0x07, 0x1b, 0xfd, 0x26, 0x50, 0x4f, 0xd3,
0xec, 0x4d, 0x53, 0x6b, 0x3c, 0x30, 0x22, 0x7b, 0xc8, 0x70, 0x49, 0xfa, 0x50, 0x0d, 0xb9, 0x69,
0x88, 0xd5, 0x90, 0x23, 0x8b, 0xc7, 0x89, 0x2e, 0x53, 0xc3, 0x53, 0x6b, 0x3c, 0x06, 0xa1, 0x98,
0xc4, 0x6c, 0x16, 0x32, 0xaa, 0x2a, 0xd3, 0xf6, 0xda, 0xa1, 0xf8, 0x41, 0x7d, 0x2b, 0x27, 0xde,
0xf2, 0xff, 0xd9, 0x89, 0x11, 0xdc, 0x38, 0xa4, 0xb3, 0x7f, 0xe3, 0x83, 0xfb, 0x7b, 0x05, 0xc8,
0xaa, 0x82, 0xff, 0x30, 0x80, 0xbc, 0x0d, 0x36, 0x8a, 0x6d, 0xb0, 0x1c, 0x58, 0x73, 0x29, 0xb0,
0x6f, 0xe1, 0xca, 0x9a, 0xa8, 0xc8, 0x2e, 0xd4, 0xe2, 0xd3, 0x9f, 0xcc, 0x74, 0x74, 0x0d, 0xbb,
0xf1, 0x2a, 0xca, 0x43, 0x88, 0x7b, 0x1f, 0x06, 0x38, 0x53, 0x61, 0xa3, 0xfd, 0x6e, 0x71, 0x32,
0x3e, 0xc4, 0x84, 0x18, 0xff, 0x2b, 0x79, 0xf0, 0x5f, 0xc3, 0xd6, 0x31, 0x45, 0xd0, 0xd1, 0x9c,
0x9a, 0xac, 0xad, 0x80, 0x88, 0x03, 0x76, 0x7a, 0x31, 0xa1, 0xdb, 0x4f, 0xf7, 0x00, 0x06, 0x65,
0xba, 0xe0, 0xe4, 0x3e, 0x34, 0xe9, 0x9c, 0xe1, 0x5b, 0xa5, 0xbd, 0xdc, 0x44, 0x2f, 0x2d, 0xc4,
0x33, 0x7b, 0xee, 0x1c, 0xda, 0x56, 0x86, 0x49, 0x53, 0x73, 0x94, 0x49, 0x35, 0xae, 0x31, 0x69,
0x09, 0xf5, 0x45, 0xcc, 0x8c, 0x49, 0xf3, 0x85, 0xde, 0xf9, 0x67, 0x76, 0xe4, 0xc2, 0x25, 0xb2,
0xdf, 0x25, 0x71, 0x64, 0xe6, 0x2c, 0xb5, 0x46, 0x8f, 0x23, 0x3d, 0xb4, 0x9a, 0x9c, 0xdb, 0xcf,
0xfd, 0x3f, 0xea, 0xd0, 0x1f, 0x71, 0xee, 0xe9, 0x5f, 0x86, 0x93, 0x05, 0x9b, 0x92, 0x03, 0xd8,
0x3c, 0xa6, 0x72, 0xc4, 0xb9, 0x99, 0xb5, 0xae, 0x14, 0xe6, 0x2a, 0x3b, 0xfd, 0x0f, 0xb7, 0x57,
0x86, 0x71, 0x77, 0x83, 0x3c, 0x06, 0xd0, 0x4c, 0x35, 0x90, 0x92, 0x02, 0xcf, 0xd2, 0x76, 0x56,
0x66, 0x34, 0x2c, 0x8a, 0xbb, 0x41, 0x1e, 0x42, 0xef, 0x98, 0xca, 0xc2, 0xa8, 0xb3, 0x8e, 0xdd,
0x2f, 0x3f, 0xb7, 0xee, 0x06, 0x79, 0x06, 0xdb, 0xc7, 0x54, 0x2e, 0xb5, 0x73, 0xe5, 0x5b, 0xe9,
0xd7, 0x63, 0x48, 0x8a, 0x22, 0x0d, 0x73, 0x37, 0xc8, 0xf7, 0x70, 0x1d, 0xcd, 0xaf, 0x3b, 0x58,
0xeb, 0xcc, 0x5f, 0x5f, 0x7f, 0xbe, 0x84, 0xbb, 0x41, 0x9e, 0xc3, 0xce, 0xda, 0x06, 0x44, 0xd4,
0x80, 0x71, 0x61, 0x6f, 0x1a, 0x76, 0x70, 0x5b, 0xff, 0x93, 0x29, 0x25, 0x6b, 0x1b, 0x88, 0x56,
0x72, 0x61, 0x6f, 0x59, 0x51, 0xb2, 0xb6, 0x03, 0x10, 0x33, 0xea, 0xcc, 0xfe, 0x8e, 0x92, 0x7d,
0xe8, 0x95, 0x2e, 0x0b, 0xb9, 0x8a, 0xbb, 0xcb, 0xf7, 0xa7, 0xc4, 0x39, 0x6d, 0xaa, 0xff, 0xcc,
0xaf, 0xfe, 0x0a, 0x00, 0x00, 0xff, 0xff, 0x99, 0x33, 0xe9, 0x6b, 0x83, 0x0e, 0x00, 0x00,
}
// Reference imports to suppress errors if they are not otherwise used.
var _ context.Context
var _ grpc.ClientConn
// This is a compile-time assertion to ensure that this generated file
// is compatible with the grpc package it is being compiled against.
const _ = grpc.SupportPackageIsVersion4
// AppRuntimeSyncClient is the client API for AppRuntimeSync service.
//
// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
type AppRuntimeSyncClient interface {
GetAppStatus(ctx context.Context, in *ServicesRequest, opts ...grpc.CallOption) (*StatusMessage, error)
GetAppPods(ctx context.Context, in *ServiceRequest, opts ...grpc.CallOption) (*ServiceAppPodList, error)
GetDeployInfo(ctx context.Context, in *ServiceRequest, opts ...grpc.CallOption) (*DeployInfo, error)
GetTenantResource(ctx context.Context, in *TenantRequest, opts ...grpc.CallOption) (*TenantResource, error)
ListThirdPartyEndpoints(ctx context.Context, in *ServiceRequest, opts ...grpc.CallOption) (*ThirdPartyEndpoints, error)
AddThirdPartyEndpoint(ctx context.Context, in *AddThirdPartyEndpointsReq, opts ...grpc.CallOption) (*Empty, error)
UpdThirdPartyEndpoint(ctx context.Context, in *UpdThirdPartyEndpointsReq, opts ...grpc.CallOption) (*Empty, error)
DelThirdPartyEndpoint(ctx context.Context, in *DelThirdPartyEndpointsReq, opts ...grpc.CallOption) (*Empty, error)
ListPodsBySID(ctx context.Context, in *ListPodsBySIDReq, opts ...grpc.CallOption) (*Empty, error)
}
type appRuntimeSyncClient struct {
cc *grpc.ClientConn
}
func NewAppRuntimeSyncClient(cc *grpc.ClientConn) AppRuntimeSyncClient {
return &appRuntimeSyncClient{cc}
}
func (c *appRuntimeSyncClient) GetAppStatus(ctx context.Context, in *ServicesRequest, opts ...grpc.CallOption) (*StatusMessage, error) {
out := new(StatusMessage)
err := c.cc.Invoke(ctx, "/pb.AppRuntimeSync/GetAppStatus", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *appRuntimeSyncClient) GetAppPods(ctx context.Context, in *ServiceRequest, opts ...grpc.CallOption) (*ServiceAppPodList, error) {
out := new(ServiceAppPodList)
err := c.cc.Invoke(ctx, "/pb.AppRuntimeSync/GetAppPods", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *appRuntimeSyncClient) GetDeployInfo(ctx context.Context, in *ServiceRequest, opts ...grpc.CallOption) (*DeployInfo, error) {
out := new(DeployInfo)
err := c.cc.Invoke(ctx, "/pb.AppRuntimeSync/GetDeployInfo", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *appRuntimeSyncClient) GetTenantResource(ctx context.Context, in *TenantRequest, opts ...grpc.CallOption) (*TenantResource, error) {
out := new(TenantResource)
err := c.cc.Invoke(ctx, "/pb.AppRuntimeSync/GetTenantResource", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *appRuntimeSyncClient) ListThirdPartyEndpoints(ctx context.Context, in *ServiceRequest, opts ...grpc.CallOption) (*ThirdPartyEndpoints, error) {
out := new(ThirdPartyEndpoints)
err := c.cc.Invoke(ctx, "/pb.AppRuntimeSync/ListThirdPartyEndpoints", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *appRuntimeSyncClient) AddThirdPartyEndpoint(ctx context.Context, in *AddThirdPartyEndpointsReq, opts ...grpc.CallOption) (*Empty, error) {
out := new(Empty)
err := c.cc.Invoke(ctx, "/pb.AppRuntimeSync/AddThirdPartyEndpoint", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *appRuntimeSyncClient) UpdThirdPartyEndpoint(ctx context.Context, in *UpdThirdPartyEndpointsReq, opts ...grpc.CallOption) (*Empty, error) {
out := new(Empty)
err := c.cc.Invoke(ctx, "/pb.AppRuntimeSync/UpdThirdPartyEndpoint", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *appRuntimeSyncClient) DelThirdPartyEndpoint(ctx context.Context, in *DelThirdPartyEndpointsReq, opts ...grpc.CallOption) (*Empty, error) {
out := new(Empty)
err := c.cc.Invoke(ctx, "/pb.AppRuntimeSync/DelThirdPartyEndpoint", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *appRuntimeSyncClient) ListPodsBySID(ctx context.Context, in *ListPodsBySIDReq, opts ...grpc.CallOption) (*Empty, error) {
out := new(Empty)
err := c.cc.Invoke(ctx, "/pb.AppRuntimeSync/ListPodsBySID", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
// AppRuntimeSyncServer is the server API for AppRuntimeSync service.
type AppRuntimeSyncServer interface {
GetAppStatus(context.Context, *ServicesRequest) (*StatusMessage, error)
GetAppPods(context.Context, *ServiceRequest) (*ServiceAppPodList, error)
GetDeployInfo(context.Context, *ServiceRequest) (*DeployInfo, error)
GetTenantResource(context.Context, *TenantRequest) (*TenantResource, error)
ListThirdPartyEndpoints(context.Context, *ServiceRequest) (*ThirdPartyEndpoints, error)
AddThirdPartyEndpoint(context.Context, *AddThirdPartyEndpointsReq) (*Empty, error)
UpdThirdPartyEndpoint(context.Context, *UpdThirdPartyEndpointsReq) (*Empty, error)
DelThirdPartyEndpoint(context.Context, *DelThirdPartyEndpointsReq) (*Empty, error)
ListPodsBySID(context.Context, *ListPodsBySIDReq) (*Empty, error)
}
func RegisterAppRuntimeSyncServer(s *grpc.Server, srv AppRuntimeSyncServer) {
s.RegisterService(&_AppRuntimeSync_serviceDesc, srv)
}
func _AppRuntimeSync_GetAppStatus_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(ServicesRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(AppRuntimeSyncServer).GetAppStatus(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/pb.AppRuntimeSync/GetAppStatus",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(AppRuntimeSyncServer).GetAppStatus(ctx, req.(*ServicesRequest))
}
return interceptor(ctx, in, info, handler)
}
func _AppRuntimeSync_GetAppPods_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(ServiceRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(AppRuntimeSyncServer).GetAppPods(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/pb.AppRuntimeSync/GetAppPods",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(AppRuntimeSyncServer).GetAppPods(ctx, req.(*ServiceRequest))
}
return interceptor(ctx, in, info, handler)
}
func _AppRuntimeSync_GetDeployInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(ServiceRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(AppRuntimeSyncServer).GetDeployInfo(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/pb.AppRuntimeSync/GetDeployInfo",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(AppRuntimeSyncServer).GetDeployInfo(ctx, req.(*ServiceRequest))
}
return interceptor(ctx, in, info, handler)
}
func _AppRuntimeSync_GetTenantResource_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(TenantRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(AppRuntimeSyncServer).GetTenantResource(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/pb.AppRuntimeSync/GetTenantResource",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(AppRuntimeSyncServer).GetTenantResource(ctx, req.(*TenantRequest))
}
return interceptor(ctx, in, info, handler)
}
func _AppRuntimeSync_ListThirdPartyEndpoints_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(ServiceRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(AppRuntimeSyncServer).ListThirdPartyEndpoints(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/pb.AppRuntimeSync/ListThirdPartyEndpoints",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(AppRuntimeSyncServer).ListThirdPartyEndpoints(ctx, req.(*ServiceRequest))
}
return interceptor(ctx, in, info, handler)
}
func _AppRuntimeSync_AddThirdPartyEndpoint_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(AddThirdPartyEndpointsReq)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(AppRuntimeSyncServer).AddThirdPartyEndpoint(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/pb.AppRuntimeSync/AddThirdPartyEndpoint",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(AppRuntimeSyncServer).AddThirdPartyEndpoint(ctx, req.(*AddThirdPartyEndpointsReq))
}
return interceptor(ctx, in, info, handler)
}
func _AppRuntimeSync_UpdThirdPartyEndpoint_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(UpdThirdPartyEndpointsReq)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(AppRuntimeSyncServer).UpdThirdPartyEndpoint(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/pb.AppRuntimeSync/UpdThirdPartyEndpoint",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(AppRuntimeSyncServer).UpdThirdPartyEndpoint(ctx, req.(*UpdThirdPartyEndpointsReq))
}
return interceptor(ctx, in, info, handler)
}
func _AppRuntimeSync_DelThirdPartyEndpoint_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(DelThirdPartyEndpointsReq)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(AppRuntimeSyncServer).DelThirdPartyEndpoint(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/pb.AppRuntimeSync/DelThirdPartyEndpoint",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(AppRuntimeSyncServer).DelThirdPartyEndpoint(ctx, req.(*DelThirdPartyEndpointsReq))
}
return interceptor(ctx, in, info, handler)
}
func _AppRuntimeSync_ListPodsBySID_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(ListPodsBySIDReq)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(AppRuntimeSyncServer).ListPodsBySID(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/pb.AppRuntimeSync/ListPodsBySID",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(AppRuntimeSyncServer).ListPodsBySID(ctx, req.(*ListPodsBySIDReq))
}
return interceptor(ctx, in, info, handler)
}
var _AppRuntimeSync_serviceDesc = grpc.ServiceDesc{
ServiceName: "pb.AppRuntimeSync",
HandlerType: (*AppRuntimeSyncServer)(nil),
Methods: []grpc.MethodDesc{
{
MethodName: "GetAppStatus",
Handler: _AppRuntimeSync_GetAppStatus_Handler,
},
{
MethodName: "GetAppPods",
Handler: _AppRuntimeSync_GetAppPods_Handler,
},
{
MethodName: "GetDeployInfo",
Handler: _AppRuntimeSync_GetDeployInfo_Handler,
},
{
MethodName: "GetTenantResource",
Handler: _AppRuntimeSync_GetTenantResource_Handler,
},
{
MethodName: "ListThirdPartyEndpoints",
Handler: _AppRuntimeSync_ListThirdPartyEndpoints_Handler,
},
{
MethodName: "AddThirdPartyEndpoint",
Handler: _AppRuntimeSync_AddThirdPartyEndpoint_Handler,
},
{
MethodName: "UpdThirdPartyEndpoint",
Handler: _AppRuntimeSync_UpdThirdPartyEndpoint_Handler,
},
{
MethodName: "DelThirdPartyEndpoint",
Handler: _AppRuntimeSync_DelThirdPartyEndpoint_Handler,
},
{
MethodName: "ListPodsBySID",
Handler: _AppRuntimeSync_ListPodsBySID_Handler,
},
},
Streams: []grpc.StreamDesc{},
Metadata: "app_runtime_server.proto",
}