Browse Source

update mod site

pull/9/head
zhouqunjie 3 years ago
parent
commit
b8321dd95c
41 changed files with 149 additions and 149 deletions
  1. +4
    -4
      adaptor/pod/server/ali/create_container_group.go
  2. +4
    -4
      adaptor/pod/server/ali/delete_container_group.go
  3. +3
    -3
      adaptor/pod/server/ali/describe_container_groups.go
  4. +4
    -4
      adaptor/pod/server/ali/update_container_group.go
  5. +51
    -51
      adaptor/pod/server/kubernetes/api/core/v1/types.go
  6. +1
    -1
      adaptor/pod/server/kubernetes/client-go/kubernetes/clientset.go
  7. +5
    -5
      adaptor/pod/server/kubernetes/client-go/kubernetes/typed/core/v1/pod.go
  8. +4
    -4
      adaptor/pod/server/pod.go
  9. +3
    -3
      adaptor/pod/service/ali_eci.go
  10. +3
    -3
      adaptor/pod/service/huawei_cci.go
  11. +3
    -3
      adaptor/pod/service/k8s.go
  12. +3
    -3
      adaptor/pod/service/poder.go
  13. +3
    -3
      adaptor/pod/service/tencent_eks.go
  14. +4
    -4
      adaptor/vm/server/ecs/list.go
  15. +2
    -2
      adaptor/vm/server/ecs/list_test.go
  16. +2
    -2
      adaptor/vm/server/ecs/main_test.go
  17. +3
    -3
      adaptor/vm/service/ecser/ali.go
  18. +3
    -3
      adaptor/vm/service/ecser/aws.go
  19. +3
    -3
      adaptor/vm/service/ecser/ecser.go
  20. +3
    -3
      adaptor/vm/service/ecser/ecser_test.go
  21. +3
    -3
      adaptor/vm/service/ecser/harvester.go
  22. +3
    -3
      adaptor/vm/service/ecser/huawei.go
  23. +2
    -2
      adaptor/vm/service/ecser/main_test.go
  24. +3
    -3
      adaptor/vm/service/ecser/tencent.go
  25. +3
    -3
      common/server/server.go
  26. +2
    -2
      common/server/server_ecs.go
  27. +2
    -2
      common/server/server_pod.go
  28. +1
    -1
      common/tenanter/main_test.go
  29. +1
    -1
      common/tenanter/region.go
  30. +1
    -1
      common/tenanter/region_test.go
  31. +1
    -1
      common/tenanter/tenanter.go
  32. +1
    -1
      examples/pcm_ali.go
  33. +2
    -2
      examples/pcm_huawei.go
  34. +1
    -1
      go.mod
  35. +1
    -1
      idl/demo/demo.proto
  36. +1
    -1
      idl/pbecs/ecs.proto
  37. +1
    -1
      idl/pbpod/pod.proto
  38. +2
    -2
      idl/pbtenant/tenant.proto
  39. +1
    -1
      lan_trans/idl/pbecs/ecs.pb.go
  40. +1
    -1
      lan_trans/idl/pbpod/pod.pb.go
  41. +5
    -5
      main.go

+ 4
- 4
adaptor/pod/server/ali/create_container_group.go View File

@@ -1,10 +1,10 @@
package ali package ali


import ( import (
"code.gitlink.org.cn/JCCE/PCM/adaptor/pod/server"
"code.gitlink.org.cn/JCCE/PCM/common/tenanter"
"code.gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbpod"
"code.gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbtenant"
"code.gitlink.org.cn/JCCE/PCM.git/adaptor/pod/server"
"code.gitlink.org.cn/JCCE/PCM.git/common/tenanter"
"code.gitlink.org.cn/JCCE/PCM.git/lan_trans/idl/pbpod"
"code.gitlink.org.cn/JCCE/PCM.git/lan_trans/idl/pbtenant"
"errors" "errors"
"flag" "flag"
"github.com/aliyun/alibaba-cloud-sdk-go/sdk/requests" "github.com/aliyun/alibaba-cloud-sdk-go/sdk/requests"


+ 4
- 4
adaptor/pod/server/ali/delete_container_group.go View File

@@ -16,10 +16,10 @@
package ali package ali


import ( import (
"code.gitlink.org.cn/JCCE/PCM/adaptor/pod/server"
"code.gitlink.org.cn/JCCE/PCM/common/tenanter"
"code.gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbpod"
"code.gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbtenant"
"code.gitlink.org.cn/JCCE/PCM.git/adaptor/pod/server"
"code.gitlink.org.cn/JCCE/PCM.git/common/tenanter"
"code.gitlink.org.cn/JCCE/PCM.git/lan_trans/idl/pbpod"
"code.gitlink.org.cn/JCCE/PCM.git/lan_trans/idl/pbtenant"
"errors" "errors"
"flag" "flag"
"github.com/aliyun/alibaba-cloud-sdk-go/sdk/requests" "github.com/aliyun/alibaba-cloud-sdk-go/sdk/requests"


+ 3
- 3
adaptor/pod/server/ali/describe_container_groups.go View File

@@ -1,9 +1,9 @@
package ali package ali


import ( import (
"code.gitlink.org.cn/JCCE/PCM/adaptor/pod/server"
"code.gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbpod"
"code.gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbtenant"
"code.gitlink.org.cn/JCCE/PCM.git/adaptor/pod/server"
"code.gitlink.org.cn/JCCE/PCM.git/lan_trans/idl/pbpod"
"code.gitlink.org.cn/JCCE/PCM.git/lan_trans/idl/pbtenant"
"github.com/aliyun/alibaba-cloud-sdk-go/sdk/requests" "github.com/aliyun/alibaba-cloud-sdk-go/sdk/requests"
"github.com/aliyun/alibaba-cloud-sdk-go/sdk/responses" "github.com/aliyun/alibaba-cloud-sdk-go/sdk/responses"
) )


+ 4
- 4
adaptor/pod/server/ali/update_container_group.go View File

@@ -16,10 +16,10 @@
package ali package ali


import ( import (
"code.gitlink.org.cn/JCCE/PCM/adaptor/pod/server"
"code.gitlink.org.cn/JCCE/PCM/common/tenanter"
"code.gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbpod"
"code.gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbtenant"
"code.gitlink.org.cn/JCCE/PCM.git/adaptor/pod/server"
"code.gitlink.org.cn/JCCE/PCM.git/common/tenanter"
"code.gitlink.org.cn/JCCE/PCM.git/lan_trans/idl/pbpod"
"code.gitlink.org.cn/JCCE/PCM.git/lan_trans/idl/pbtenant"
"errors" "errors"
"flag" "flag"
"github.com/aliyun/alibaba-cloud-sdk-go/sdk/requests" "github.com/aliyun/alibaba-cloud-sdk-go/sdk/requests"


+ 51
- 51
adaptor/pod/server/kubernetes/api/core/v1/types.go View File

@@ -299,7 +299,7 @@ const (


// +genclient // +genclient
// +genclient:nonNamespaced // +genclient:nonNamespaced
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM.git/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object


// PersistentVolume (PV) is a storage resource provisioned by an administrator. // PersistentVolume (PV) is a storage resource provisioned by an administrator.
// It is analogous to a node. // It is analogous to a node.
@@ -415,7 +415,7 @@ type PersistentVolumeStatus struct {
Reason string `json:"reason,omitempty" protobuf:"bytes,3,opt,name=reason"` Reason string `json:"reason,omitempty" protobuf:"bytes,3,opt,name=reason"`
} }


// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM.git/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object


// PersistentVolumeList is a list of PersistentVolume items. // PersistentVolumeList is a list of PersistentVolume items.
type PersistentVolumeList struct { type PersistentVolumeList struct {
@@ -430,7 +430,7 @@ type PersistentVolumeList struct {
} }


// +genclient // +genclient
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM.git/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object


// PersistentVolumeClaim is a user's request for and claim to a persistent volume // PersistentVolumeClaim is a user's request for and claim to a persistent volume
type PersistentVolumeClaim struct { type PersistentVolumeClaim struct {
@@ -452,7 +452,7 @@ type PersistentVolumeClaim struct {
Status PersistentVolumeClaimStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"` Status PersistentVolumeClaimStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"`
} }


// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM.git/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object


// PersistentVolumeClaimList is a list of PersistentVolumeClaim items. // PersistentVolumeClaimList is a list of PersistentVolumeClaim items.
type PersistentVolumeClaimList struct { type PersistentVolumeClaimList struct {
@@ -3664,7 +3664,7 @@ type PodStatus struct {
EphemeralContainerStatuses []ContainerStatus `json:"ephemeralContainerStatuses,omitempty" protobuf:"bytes,13,rep,name=ephemeralContainerStatuses"` EphemeralContainerStatuses []ContainerStatus `json:"ephemeralContainerStatuses,omitempty" protobuf:"bytes,13,rep,name=ephemeralContainerStatuses"`
} }


// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM.git/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object


// PodStatusResult is a wrapper for PodStatus returned by kubelet that can be encode/decoded // PodStatusResult is a wrapper for PodStatus returned by kubelet that can be encode/decoded
type PodStatusResult struct { type PodStatusResult struct {
@@ -3685,7 +3685,7 @@ type PodStatusResult struct {
// +genclient // +genclient
// +genclient:method=GetEphemeralContainers,verb=get,subresource=ephemeralcontainers,result=EphemeralContainers // +genclient:method=GetEphemeralContainers,verb=get,subresource=ephemeralcontainers,result=EphemeralContainers
// +genclient:method=UpdateEphemeralContainers,verb=update,subresource=ephemeralcontainers,input=EphemeralContainers,result=EphemeralContainers // +genclient:method=UpdateEphemeralContainers,verb=update,subresource=ephemeralcontainers,input=EphemeralContainers,result=EphemeralContainers
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM.git/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object


// Pod is a collection of containers that can run on a host. This resource is created // Pod is a collection of containers that can run on a host. This resource is created
// by clients and scheduled onto hosts. // by clients and scheduled onto hosts.
@@ -3710,7 +3710,7 @@ type Pod struct {
Status PodStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"` Status PodStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"`
} }


// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM.git/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object


// PodList is a list of Pods. // PodList is a list of Pods.
type PodList struct { type PodList struct {
@@ -3739,7 +3739,7 @@ type PodTemplateSpec struct {
} }


// +genclient // +genclient
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM.git/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object


// PodTemplate describes a template for creating copies of a predefined pod. // PodTemplate describes a template for creating copies of a predefined pod.
type PodTemplate struct { type PodTemplate struct {
@@ -3755,7 +3755,7 @@ type PodTemplate struct {
Template PodTemplateSpec `json:"template,omitempty" protobuf:"bytes,2,opt,name=template"` Template PodTemplateSpec `json:"template,omitempty" protobuf:"bytes,2,opt,name=template"`
} }


// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM.git/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object


// PodTemplateList is a list of PodTemplates. // PodTemplateList is a list of PodTemplates.
type PodTemplateList struct { type PodTemplateList struct {
@@ -3863,9 +3863,9 @@ type ReplicationControllerCondition struct {
} }


// +genclient // +genclient
// +genclient:method=GetScale,verb=get,subresource=scale,result=code.gitlink.org.cn/JCCE/PCM/adaptor/pod/server/kubernetes/api/autoscaling/v1.Scale
// +genclient:method=UpdateScale,verb=update,subresource=scale,input=code.gitlink.org.cn/JCCE/PCM/adaptor/pod/server/kubernetes/api/autoscaling/v1.Scale,result=code.gitlink.org.cn/JCCE/PCM/adaptor/pod/server/kubernetes/api/autoscaling/v1.Scale
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object
// +genclient:method=GetScale,verb=get,subresource=scale,result=code.gitlink.org.cn/JCCE/PCM.git/adaptor/pod/server/kubernetes/api/autoscaling/v1.Scale
// +genclient:method=UpdateScale,verb=update,subresource=scale,input=code.gitlink.org.cn/JCCE/PCM.git/adaptor/pod/server/kubernetes/api/autoscaling/v1.Scale,result=code.gitlink.org.cn/JCCE/PCM.git/adaptor/pod/server/kubernetes/api/autoscaling/v1.Scale
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM.git/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object


// ReplicationController represents the configuration of a replication controller. // ReplicationController represents the configuration of a replication controller.
type ReplicationController struct { type ReplicationController struct {
@@ -3891,7 +3891,7 @@ type ReplicationController struct {
Status ReplicationControllerStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"` Status ReplicationControllerStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"`
} }


// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM.git/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object


// ReplicationControllerList is a collection of replication controllers. // ReplicationControllerList is a collection of replication controllers.
type ReplicationControllerList struct { type ReplicationControllerList struct {
@@ -4374,7 +4374,7 @@ type ServicePort struct {


// +genclient // +genclient
// +genclient:skipVerbs=deleteCollection // +genclient:skipVerbs=deleteCollection
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM.git/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object


// Service is a named abstraction of software service (for example, mysql) consisting of local port // Service is a named abstraction of software service (for example, mysql) consisting of local port
// (for example 3306) that the proxy listens on, and the selector that determines which pods // (for example 3306) that the proxy listens on, and the selector that determines which pods
@@ -4405,7 +4405,7 @@ const (
ClusterIPNone = "None" ClusterIPNone = "None"
) )


// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM.git/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object


// ServiceList holds a list of services. // ServiceList holds a list of services.
type ServiceList struct { type ServiceList struct {
@@ -4420,8 +4420,8 @@ type ServiceList struct {
} }


// +genclient // +genclient
// +genclient:method=CreateToken,verb=create,subresource=token,input=code.gitlink.org.cn/JCCE/PCM/adaptor/pod/server/kubernetes/api/authentication/v1.TokenRequest,result=code.gitlink.org.cn/JCCE/PCM/adaptor/pod/server/kubernetes/api/authentication/v1.TokenRequest
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object
// +genclient:method=CreateToken,verb=create,subresource=token,input=code.gitlink.org.cn/JCCE/PCM.git/adaptor/pod/server/kubernetes/api/authentication/v1.TokenRequest,result=code.gitlink.org.cn/JCCE/PCM.git/adaptor/pod/server/kubernetes/api/authentication/v1.TokenRequest
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM.git/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object


// ServiceAccount binds together: // ServiceAccount binds together:
// * a name, understood by users, and perhaps by peripheral systems, for an identity // * a name, understood by users, and perhaps by peripheral systems, for an identity
@@ -4454,7 +4454,7 @@ type ServiceAccount struct {
AutomountServiceAccountToken *bool `json:"automountServiceAccountToken,omitempty" protobuf:"varint,4,opt,name=automountServiceAccountToken"` AutomountServiceAccountToken *bool `json:"automountServiceAccountToken,omitempty" protobuf:"varint,4,opt,name=automountServiceAccountToken"`
} }


// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM.git/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object


// ServiceAccountList is a list of ServiceAccount objects // ServiceAccountList is a list of ServiceAccount objects
type ServiceAccountList struct { type ServiceAccountList struct {
@@ -4470,7 +4470,7 @@ type ServiceAccountList struct {
} }


// +genclient // +genclient
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM.git/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object


// Endpoints is a collection of endpoints that implement the actual service. Example: // Endpoints is a collection of endpoints that implement the actual service. Example:
// Name: "mysvc", // Name: "mysvc",
@@ -4577,7 +4577,7 @@ type EndpointPort struct {
AppProtocol *string `json:"appProtocol,omitempty" protobuf:"bytes,4,opt,name=appProtocol"` AppProtocol *string `json:"appProtocol,omitempty" protobuf:"bytes,4,opt,name=appProtocol"`
} }


// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM.git/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object


// EndpointsList is a list of endpoints. // EndpointsList is a list of endpoints.
type EndpointsList struct { type EndpointsList struct {
@@ -4970,7 +4970,7 @@ type ResourceList map[ResourceName]resource.Quantity


// +genclient // +genclient
// +genclient:nonNamespaced // +genclient:nonNamespaced
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM.git/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object


// Node is a worker node in Kubernetes. // Node is a worker node in Kubernetes.
// Each node will have a unique identifier in the cache (i.e. in etcd). // Each node will have a unique identifier in the cache (i.e. in etcd).
@@ -4994,7 +4994,7 @@ type Node struct {
Status NodeStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"` Status NodeStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"`
} }


// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM.git/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object


// NodeList is the whole list of all Nodes which have been registered with master. // NodeList is the whole list of all Nodes which have been registered with master.
type NodeList struct { type NodeList struct {
@@ -5088,7 +5088,7 @@ type NamespaceCondition struct {
// +genclient // +genclient
// +genclient:nonNamespaced // +genclient:nonNamespaced
// +genclient:skipVerbs=deleteCollection // +genclient:skipVerbs=deleteCollection
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM.git/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object


// Namespace provides a scope for Names. // Namespace provides a scope for Names.
// Use of multiple namespaces is optional. // Use of multiple namespaces is optional.
@@ -5110,7 +5110,7 @@ type Namespace struct {
Status NamespaceStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"` Status NamespaceStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"`
} }


// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM.git/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object


// NamespaceList is a list of Namespaces. // NamespaceList is a list of Namespaces.
type NamespaceList struct { type NamespaceList struct {
@@ -5125,7 +5125,7 @@ type NamespaceList struct {
Items []Namespace `json:"items" protobuf:"bytes,2,rep,name=items"` Items []Namespace `json:"items" protobuf:"bytes,2,rep,name=items"`
} }


// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM.git/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object


// Binding ties one object to another; for example, a pod is bound to a node by a scheduler. // Binding ties one object to another; for example, a pod is bound to a node by a scheduler.
// Deprecated in 1.7, please use the bindings subresource of pods instead. // Deprecated in 1.7, please use the bindings subresource of pods instead.
@@ -5140,7 +5140,7 @@ type Binding struct {
Target ObjectReference `json:"target" protobuf:"bytes,2,opt,name=target"` Target ObjectReference `json:"target" protobuf:"bytes,2,opt,name=target"`
} }


// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM.git/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object


// A list of ephemeral containers used with the Pod ephemeralcontainers subresource. // A list of ephemeral containers used with the Pod ephemeralcontainers subresource.
type EphemeralContainers struct { type EphemeralContainers struct {
@@ -5161,11 +5161,11 @@ type EphemeralContainers struct {
type Preconditions struct { type Preconditions struct {
// Specifies the target UID. // Specifies the target UID.
// +optional // +optional
UID *types.UID `json:"uid,omitempty" protobuf:"bytes,1,opt,name=uid,casttype=code.gitlink.org.cn/JCCE/PCM/adaptor/pod/server/kubernetes/apimachinery/pkg/types.UID"`
UID *types.UID `json:"uid,omitempty" protobuf:"bytes,1,opt,name=uid,casttype=code.gitlink.org.cn/JCCE/PCM.git/adaptor/pod/server/kubernetes/apimachinery/pkg/types.UID"`
} }


// +k8s:conversion-gen:explicit-from=net/url.Values // +k8s:conversion-gen:explicit-from=net/url.Values
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM.git/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object


// PodLogOptions is the query options for a Pod's logs REST call. // PodLogOptions is the query options for a Pod's logs REST call.
type PodLogOptions struct { type PodLogOptions struct {
@@ -5217,7 +5217,7 @@ type PodLogOptions struct {
} }


// +k8s:conversion-gen:explicit-from=net/url.Values // +k8s:conversion-gen:explicit-from=net/url.Values
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM.git/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object


// PodAttachOptions is the query options to a Pod's remote attach call. // PodAttachOptions is the query options to a Pod's remote attach call.
// --- // ---
@@ -5255,7 +5255,7 @@ type PodAttachOptions struct {
} }


// +k8s:conversion-gen:explicit-from=net/url.Values // +k8s:conversion-gen:explicit-from=net/url.Values
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM.git/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object


// PodExecOptions is the query options to a Pod's remote exec call. // PodExecOptions is the query options to a Pod's remote exec call.
// --- // ---
@@ -5294,7 +5294,7 @@ type PodExecOptions struct {
} }


// +k8s:conversion-gen:explicit-from=net/url.Values // +k8s:conversion-gen:explicit-from=net/url.Values
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM.git/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object


// PodPortForwardOptions is the query options to a Pod's port forward call // PodPortForwardOptions is the query options to a Pod's port forward call
// when using WebSockets. // when using WebSockets.
@@ -5312,7 +5312,7 @@ type PodPortForwardOptions struct {
} }


// +k8s:conversion-gen:explicit-from=net/url.Values // +k8s:conversion-gen:explicit-from=net/url.Values
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM.git/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object


// PodProxyOptions is the query options to a Pod's proxy call. // PodProxyOptions is the query options to a Pod's proxy call.
type PodProxyOptions struct { type PodProxyOptions struct {
@@ -5324,7 +5324,7 @@ type PodProxyOptions struct {
} }


// +k8s:conversion-gen:explicit-from=net/url.Values // +k8s:conversion-gen:explicit-from=net/url.Values
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM.git/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object


// NodeProxyOptions is the query options to a Node's proxy call. // NodeProxyOptions is the query options to a Node's proxy call.
type NodeProxyOptions struct { type NodeProxyOptions struct {
@@ -5336,7 +5336,7 @@ type NodeProxyOptions struct {
} }


// +k8s:conversion-gen:explicit-from=net/url.Values // +k8s:conversion-gen:explicit-from=net/url.Values
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM.git/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object


// ServiceProxyOptions is the query options to a Service's proxy call. // ServiceProxyOptions is the query options to a Service's proxy call.
type ServiceProxyOptions struct { type ServiceProxyOptions struct {
@@ -5366,7 +5366,7 @@ type ServiceProxyOptions struct {
// will affect numerous schemas. Don't make new APIs embed an underspecified API type they do not control. // will affect numerous schemas. Don't make new APIs embed an underspecified API type they do not control.
// Instead of using this type, create a locally provided and used type that is well-focused on your reference. // Instead of using this type, create a locally provided and used type that is well-focused on your reference.
// For example, ServiceReferences for admission registration: https://github.com/kubernetes/api/blob/release-1.17/admissionregistration/v1/types.go#L533 . // For example, ServiceReferences for admission registration: https://github.com/kubernetes/api/blob/release-1.17/admissionregistration/v1/types.go#L533 .
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM.git/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object
type ObjectReference struct { type ObjectReference struct {
// Kind of the referent. // Kind of the referent.
// More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#types-kinds // More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#types-kinds
@@ -5383,7 +5383,7 @@ type ObjectReference struct {
// UID of the referent. // UID of the referent.
// More info: https://kubernetes.io/docs/concepts/overview/working-with-objects/names/#uids // More info: https://kubernetes.io/docs/concepts/overview/working-with-objects/names/#uids
// +optional // +optional
UID types.UID `json:"uid,omitempty" protobuf:"bytes,4,opt,name=uid,casttype=code.gitlink.org.cn/JCCE/PCM/adaptor/pod/server/kubernetes/apimachinery/pkg/types.UID"`
UID types.UID `json:"uid,omitempty" protobuf:"bytes,4,opt,name=uid,casttype=code.gitlink.org.cn/JCCE/PCM.git/adaptor/pod/server/kubernetes/apimachinery/pkg/types.UID"`
// API version of the referent. // API version of the referent.
// +optional // +optional
APIVersion string `json:"apiVersion,omitempty" protobuf:"bytes,5,opt,name=apiVersion"` APIVersion string `json:"apiVersion,omitempty" protobuf:"bytes,5,opt,name=apiVersion"`
@@ -5428,7 +5428,7 @@ type TypedLocalObjectReference struct {
Name string `json:"name" protobuf:"bytes,3,opt,name=name"` Name string `json:"name" protobuf:"bytes,3,opt,name=name"`
} }


// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM.git/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object


// SerializedReference is a reference to serialized object. // SerializedReference is a reference to serialized object.
type SerializedReference struct { type SerializedReference struct {
@@ -5457,7 +5457,7 @@ const (
) )


// +genclient // +genclient
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM.git/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object


// Event is a report of an event somewhere in the cluster. Events // Event is a report of an event somewhere in the cluster. Events
// have a limited retention time and triggers and messages may evolve // have a limited retention time and triggers and messages may evolve
@@ -5541,7 +5541,7 @@ type EventSeries struct {
// +k8s:deprecated=state,protobuf=3 // +k8s:deprecated=state,protobuf=3
} }


// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM.git/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object


// EventList is a list of events. // EventList is a list of events.
type EventList struct { type EventList struct {
@@ -5555,7 +5555,7 @@ type EventList struct {
Items []Event `json:"items" protobuf:"bytes,2,rep,name=items"` Items []Event `json:"items" protobuf:"bytes,2,rep,name=items"`
} }


// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM.git/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object


// List holds a list of objects, which may not be known by the server. // List holds a list of objects, which may not be known by the server.
type List metav1.List type List metav1.List
@@ -5600,7 +5600,7 @@ type LimitRangeSpec struct {
} }


// +genclient // +genclient
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM.git/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object


// LimitRange sets resource usage limits for each kind of resource in a Namespace. // LimitRange sets resource usage limits for each kind of resource in a Namespace.
type LimitRange struct { type LimitRange struct {
@@ -5616,7 +5616,7 @@ type LimitRange struct {
Spec LimitRangeSpec `json:"spec,omitempty" protobuf:"bytes,2,opt,name=spec"` Spec LimitRangeSpec `json:"spec,omitempty" protobuf:"bytes,2,opt,name=spec"`
} }


// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM.git/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object


// LimitRangeList is a list of LimitRange items. // LimitRangeList is a list of LimitRange items.
type LimitRangeList struct { type LimitRangeList struct {
@@ -5759,7 +5759,7 @@ type ResourceQuotaStatus struct {
} }


// +genclient // +genclient
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM.git/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object


// ResourceQuota sets aggregate quota restrictions enforced per namespace // ResourceQuota sets aggregate quota restrictions enforced per namespace
type ResourceQuota struct { type ResourceQuota struct {
@@ -5780,7 +5780,7 @@ type ResourceQuota struct {
Status ResourceQuotaStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"` Status ResourceQuotaStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"`
} }


// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM.git/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object


// ResourceQuotaList is a list of ResourceQuota items. // ResourceQuotaList is a list of ResourceQuota items.
type ResourceQuotaList struct { type ResourceQuotaList struct {
@@ -5796,7 +5796,7 @@ type ResourceQuotaList struct {
} }


// +genclient // +genclient
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM.git/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object


// Secret holds secret data of a certain type. The total bytes of the values in // Secret holds secret data of a certain type. The total bytes of the values in
// the Data field must be less than MaxSecretSize bytes. // the Data field must be less than MaxSecretSize bytes.
@@ -5921,7 +5921,7 @@ const (
SecretTypeBootstrapToken SecretType = "bootstrap.kubernetes.io/token" SecretTypeBootstrapToken SecretType = "bootstrap.kubernetes.io/token"
) )


// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM.git/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object


// SecretList is a list of Secret. // SecretList is a list of Secret.
type SecretList struct { type SecretList struct {
@@ -5937,7 +5937,7 @@ type SecretList struct {
} }


// +genclient // +genclient
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM.git/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object


// ConfigMap holds configuration data for pods to consume. // ConfigMap holds configuration data for pods to consume.
type ConfigMap struct { type ConfigMap struct {
@@ -5973,7 +5973,7 @@ type ConfigMap struct {
BinaryData map[string][]byte `json:"binaryData,omitempty" protobuf:"bytes,3,rep,name=binaryData"` BinaryData map[string][]byte `json:"binaryData,omitempty" protobuf:"bytes,3,rep,name=binaryData"`
} }


// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM.git/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object


// ConfigMapList is a resource containing a list of ConfigMap objects. // ConfigMapList is a resource containing a list of ConfigMap objects.
type ConfigMapList struct { type ConfigMapList struct {
@@ -6015,7 +6015,7 @@ type ComponentCondition struct {


// +genclient // +genclient
// +genclient:nonNamespaced // +genclient:nonNamespaced
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM.git/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object


// ComponentStatus (and ComponentStatusList) holds the cluster validation info. // ComponentStatus (and ComponentStatusList) holds the cluster validation info.
// Deprecated: This API is deprecated in v1.19+ // Deprecated: This API is deprecated in v1.19+
@@ -6033,7 +6033,7 @@ type ComponentStatus struct {
Conditions []ComponentCondition `json:"conditions,omitempty" patchStrategy:"merge" patchMergeKey:"type" protobuf:"bytes,2,rep,name=conditions"` Conditions []ComponentCondition `json:"conditions,omitempty" patchStrategy:"merge" patchMergeKey:"type" protobuf:"bytes,2,rep,name=conditions"`
} }


// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM.git/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object


// Status of all the conditions for the component as a list of ComponentStatus objects. // Status of all the conditions for the component as a list of ComponentStatus objects.
// Deprecated: This API is deprecated in v1.19+ // Deprecated: This API is deprecated in v1.19+
@@ -6219,7 +6219,7 @@ type WindowsSecurityContextOptions struct {
RunAsUserName *string `json:"runAsUserName,omitempty" protobuf:"bytes,3,opt,name=runAsUserName"` RunAsUserName *string `json:"runAsUserName,omitempty" protobuf:"bytes,3,opt,name=runAsUserName"`
} }


// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object
// +k8s:deepcopy-gen:interfaces=code.gitlink.org.cn/JCCE/PCM.git/adaptor/pod/server/kubernetes/apimachinery/pkg/runtime.Object


// RangeAllocation is not a public type. // RangeAllocation is not a public type.
type RangeAllocation struct { type RangeAllocation struct {


+ 1
- 1
adaptor/pod/server/kubernetes/client-go/kubernetes/clientset.go View File

@@ -21,7 +21,7 @@ package kubernetes
import ( import (
"fmt" "fmt"


corev1 "code.gitlink.org.cn/JCCE/PCM/adaptor/pod/server/kubernetes/client-go/kubernetes/typed/core/v1"
corev1 "code.gitlink.org.cn/JCCE/PCM.git/adaptor/pod/server/kubernetes/client-go/kubernetes/typed/core/v1"
discovery "k8s.io/client-go/discovery" discovery "k8s.io/client-go/discovery"
admissionregistrationv1 "k8s.io/client-go/kubernetes/typed/admissionregistration/v1" admissionregistrationv1 "k8s.io/client-go/kubernetes/typed/admissionregistration/v1"
admissionregistrationv1beta1 "k8s.io/client-go/kubernetes/typed/admissionregistration/v1beta1" admissionregistrationv1beta1 "k8s.io/client-go/kubernetes/typed/admissionregistration/v1beta1"


+ 5
- 5
adaptor/pod/server/kubernetes/client-go/kubernetes/typed/core/v1/pod.go View File

@@ -1,10 +1,10 @@
package v1 package v1


import ( import (
"code.gitlink.org.cn/JCCE/PCM/adaptor/pod/server"
"code.gitlink.org.cn/JCCE/PCM/common/tenanter"
"code.gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbpod"
"code.gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbtenant"
"code.gitlink.org.cn/JCCE/PCM.git/adaptor/pod/server"
"code.gitlink.org.cn/JCCE/PCM.git/common/tenanter"
"code.gitlink.org.cn/JCCE/PCM.git/lan_trans/idl/pbpod"
"code.gitlink.org.cn/JCCE/PCM.git/lan_trans/idl/pbtenant"
"context" "context"
json "encoding/json" json "encoding/json"
"errors" "errors"
@@ -15,7 +15,7 @@ import (
"strconv" "strconv"
"time" "time"


v1 "code.gitlink.org.cn/JCCE/PCM/adaptor/pod/server/kubernetes/api/core/v1"
v1 "code.gitlink.org.cn/JCCE/PCM.git/adaptor/pod/server/kubernetes/api/core/v1"
types "k8s.io/apimachinery/pkg/types" types "k8s.io/apimachinery/pkg/types"
watch "k8s.io/apimachinery/pkg/watch" watch "k8s.io/apimachinery/pkg/watch"
corev1 "k8s.io/client-go/applyconfigurations/core/v1" corev1 "k8s.io/client-go/applyconfigurations/core/v1"


+ 4
- 4
adaptor/pod/server/pod.go View File

@@ -6,10 +6,10 @@ import (
"fmt" "fmt"
"sync" "sync"


"code.gitlink.org.cn/JCCE/PCM/adaptor/pod/service"
"code.gitlink.org.cn/JCCE/PCM/common/tenanter"
"code.gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbpod"
"code.gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbtenant"
"code.gitlink.org.cn/JCCE/PCM.git/adaptor/pod/service"
"code.gitlink.org.cn/JCCE/PCM.git/common/tenanter"
"code.gitlink.org.cn/JCCE/PCM.git/lan_trans/idl/pbpod"
"code.gitlink.org.cn/JCCE/PCM.git/lan_trans/idl/pbtenant"


"github.com/golang/glog" "github.com/golang/glog"
"github.com/pkg/errors" "github.com/pkg/errors"


+ 3
- 3
adaptor/pod/service/ali_eci.go View File

@@ -9,9 +9,9 @@ import (
"strconv" "strconv"
"sync" "sync"


"code.gitlink.org.cn/JCCE/PCM/common/tenanter"
"code.gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbpod"
"code.gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbtenant"
"code.gitlink.org.cn/JCCE/PCM.git/common/tenanter"
"code.gitlink.org.cn/JCCE/PCM.git/lan_trans/idl/pbpod"
"code.gitlink.org.cn/JCCE/PCM.git/lan_trans/idl/pbtenant"
"github.com/pkg/errors" "github.com/pkg/errors"
) )




+ 3
- 3
adaptor/pod/service/huawei_cci.go View File

@@ -12,15 +12,15 @@ import (


metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"


"code.gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbpod"
"code.gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbtenant"
"code.gitlink.org.cn/JCCE/PCM.git/lan_trans/idl/pbpod"
"code.gitlink.org.cn/JCCE/PCM.git/lan_trans/idl/pbtenant"


corev1 "k8s.io/api/core/v1" corev1 "k8s.io/api/core/v1"
huaweicci "k8s.io/client-go/kubernetes" huaweicci "k8s.io/client-go/kubernetes"
"k8s.io/client-go/tools/clientcmd" "k8s.io/client-go/tools/clientcmd"
"k8s.io/client-go/tools/clientcmd/api" "k8s.io/client-go/tools/clientcmd/api"


"code.gitlink.org.cn/JCCE/PCM/common/tenanter"
"code.gitlink.org.cn/JCCE/PCM.git/common/tenanter"
"github.com/pkg/errors" "github.com/pkg/errors"
) )




+ 3
- 3
adaptor/pod/service/k8s.go View File

@@ -1,9 +1,9 @@
package poder package poder


import ( import (
"code.gitlink.org.cn/JCCE/PCM/common/tenanter"
"code.gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbpod"
"code.gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbtenant"
"code.gitlink.org.cn/JCCE/PCM.git/common/tenanter"
"code.gitlink.org.cn/JCCE/PCM.git/lan_trans/idl/pbpod"
"code.gitlink.org.cn/JCCE/PCM.git/lan_trans/idl/pbtenant"
"context" "context"
"fmt" "fmt"
"github.com/golang/glog" "github.com/golang/glog"


+ 3
- 3
adaptor/pod/service/poder.go View File

@@ -1,9 +1,9 @@
package poder package poder


import ( import (
"code.gitlink.org.cn/JCCE/PCM/common/tenanter"
"code.gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbpod"
"code.gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbtenant"
"code.gitlink.org.cn/JCCE/PCM.git/common/tenanter"
"code.gitlink.org.cn/JCCE/PCM.git/lan_trans/idl/pbpod"
"code.gitlink.org.cn/JCCE/PCM.git/lan_trans/idl/pbtenant"
"context" "context"


"github.com/golang/glog" "github.com/golang/glog"


+ 3
- 3
adaptor/pod/service/tencent_eks.go View File

@@ -7,10 +7,10 @@ import (


"github.com/golang/glog" "github.com/golang/glog"


"code.gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbtenant"
"code.gitlink.org.cn/JCCE/PCM.git/lan_trans/idl/pbtenant"


"code.gitlink.org.cn/JCCE/PCM/common/tenanter"
"code.gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbpod"
"code.gitlink.org.cn/JCCE/PCM.git/common/tenanter"
"code.gitlink.org.cn/JCCE/PCM.git/lan_trans/idl/pbpod"
"github.com/pkg/errors" "github.com/pkg/errors"
"github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common" "github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common"
"github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common/profile" "github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common/profile"


+ 4
- 4
adaptor/vm/server/ecs/list.go View File

@@ -4,10 +4,10 @@ import (
"context" "context"
"sync" "sync"


"code.gitlink.org.cn/JCCE/PCM/adaptor/vm/service/ecser"
"code.gitlink.org.cn/JCCE/PCM/common/tenanter"
"code.gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbecs"
"code.gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbtenant"
"code.gitlink.org.cn/JCCE/PCM.git/adaptor/vm/service/ecser"
"code.gitlink.org.cn/JCCE/PCM.git/common/tenanter"
"code.gitlink.org.cn/JCCE/PCM.git/lan_trans/idl/pbecs"
"code.gitlink.org.cn/JCCE/PCM.git/lan_trans/idl/pbtenant"
"github.com/golang/glog" "github.com/golang/glog"
"github.com/pkg/errors" "github.com/pkg/errors"
) )


+ 2
- 2
adaptor/vm/server/ecs/list_test.go View File

@@ -1,8 +1,8 @@
package ecs package ecs


import ( import (
"code.gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbecs"
"code.gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbtenant"
"code.gitlink.org.cn/JCCE/PCM.git/lan_trans/idl/pbecs"
"code.gitlink.org.cn/JCCE/PCM.git/lan_trans/idl/pbtenant"
"context" "context"
"testing" "testing"
) )


+ 2
- 2
adaptor/vm/server/ecs/main_test.go View File

@@ -1,8 +1,8 @@
package ecs package ecs


import ( import (
"code.gitlink.org.cn/JCCE/PCM/common/tenanter"
"code.gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbtenant"
"code.gitlink.org.cn/JCCE/PCM.git/common/tenanter"
"code.gitlink.org.cn/JCCE/PCM.git/lan_trans/idl/pbtenant"
"os" "os"
"testing" "testing"
) )


+ 3
- 3
adaptor/vm/service/ecser/ali.go View File

@@ -4,9 +4,9 @@ import (
"context" "context"
"sync" "sync"


"code.gitlink.org.cn/JCCE/PCM/common/tenanter"
"code.gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbecs"
"code.gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbtenant"
"code.gitlink.org.cn/JCCE/PCM.git/common/tenanter"
"code.gitlink.org.cn/JCCE/PCM.git/lan_trans/idl/pbecs"
"code.gitlink.org.cn/JCCE/PCM.git/lan_trans/idl/pbtenant"
openapi "github.com/alibabacloud-go/darabonba-openapi/client" openapi "github.com/alibabacloud-go/darabonba-openapi/client"
string_ "github.com/alibabacloud-go/darabonba-string/client" string_ "github.com/alibabacloud-go/darabonba-string/client"
aliecs "github.com/alibabacloud-go/ecs-20140526/v2/client" aliecs "github.com/alibabacloud-go/ecs-20140526/v2/client"


+ 3
- 3
adaptor/vm/service/ecser/aws.go View File

@@ -10,10 +10,10 @@ package ecser
// awsec2 "github.com/aws/aws-sdk-go-v2/service/ec2" // awsec2 "github.com/aws/aws-sdk-go-v2/service/ec2"
// "github.com/pkg/errors" // "github.com/pkg/errors"
// //
// "code.gitlink.org.cn/JCCE/PCM/common/tenanter"
// "code.gitlink.org.cn/JCCE/PCM.git/common/tenanter"
// //
// "code.gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbecs"
// "code.gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbtenant"
// "code.gitlink.org.cn/JCCE/PCM.git/lan_trans/idl/pbecs"
// "code.gitlink.org.cn/JCCE/PCM.git/lan_trans/idl/pbtenant"
//) //)
// //
//type AwsEcs struct { //type AwsEcs struct {


+ 3
- 3
adaptor/vm/service/ecser/ecser.go View File

@@ -3,9 +3,9 @@ package ecser
import ( import (
"context" "context"


"code.gitlink.org.cn/JCCE/PCM/common/tenanter"
"code.gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbecs"
"code.gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbtenant"
"code.gitlink.org.cn/JCCE/PCM.git/common/tenanter"
"code.gitlink.org.cn/JCCE/PCM.git/lan_trans/idl/pbecs"
"code.gitlink.org.cn/JCCE/PCM.git/lan_trans/idl/pbtenant"


"github.com/golang/glog" "github.com/golang/glog"
"github.com/pkg/errors" "github.com/pkg/errors"


+ 3
- 3
adaptor/vm/service/ecser/ecser_test.go View File

@@ -1,9 +1,9 @@
package ecser package ecser


import ( import (
"code.gitlink.org.cn/JCCE/PCM/common/tenanter"
"code.gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbecs"
"code.gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbtenant"
"code.gitlink.org.cn/JCCE/PCM.git/common/tenanter"
"code.gitlink.org.cn/JCCE/PCM.git/lan_trans/idl/pbecs"
"code.gitlink.org.cn/JCCE/PCM.git/lan_trans/idl/pbtenant"
"context" "context"
"testing" "testing"
) )


+ 3
- 3
adaptor/vm/service/ecser/harvester.go View File

@@ -1,9 +1,9 @@
package ecser package ecser


import ( import (
"code.gitlink.org.cn/JCCE/PCM/common/tenanter"
"code.gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbecs"
"code.gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbtenant"
"code.gitlink.org.cn/JCCE/PCM.git/common/tenanter"
"code.gitlink.org.cn/JCCE/PCM.git/lan_trans/idl/pbecs"
"code.gitlink.org.cn/JCCE/PCM.git/lan_trans/idl/pbtenant"
"context" "context"
"fmt" "fmt"
"github.com/harvester/harvester/pkg/apis/harvesterhci.io/v1beta1" "github.com/harvester/harvester/pkg/apis/harvesterhci.io/v1beta1"


+ 3
- 3
adaptor/vm/service/ecser/huawei.go View File

@@ -4,9 +4,9 @@ import (
"context" "context"
"strconv" "strconv"


"code.gitlink.org.cn/JCCE/PCM/common/tenanter"
"code.gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbecs"
"code.gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbtenant"
"code.gitlink.org.cn/JCCE/PCM.git/common/tenanter"
"code.gitlink.org.cn/JCCE/PCM.git/lan_trans/idl/pbecs"
"code.gitlink.org.cn/JCCE/PCM.git/lan_trans/idl/pbtenant"
string_ "github.com/alibabacloud-go/darabonba-string/client" string_ "github.com/alibabacloud-go/darabonba-string/client"
util "github.com/alibabacloud-go/tea-utils/service" util "github.com/alibabacloud-go/tea-utils/service"
"github.com/alibabacloud-go/tea/tea" "github.com/alibabacloud-go/tea/tea"


+ 2
- 2
adaptor/vm/service/ecser/main_test.go View File

@@ -1,8 +1,8 @@
package ecser package ecser


import ( import (
"code.gitlink.org.cn/JCCE/PCM/common/tenanter"
"code.gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbtenant"
"code.gitlink.org.cn/JCCE/PCM.git/common/tenanter"
"code.gitlink.org.cn/JCCE/PCM.git/lan_trans/idl/pbtenant"
"os" "os"
"testing" "testing"
) )


+ 3
- 3
adaptor/vm/service/ecser/tencent.go View File

@@ -4,9 +4,9 @@ import (
"context" "context"
"strconv" "strconv"


"code.gitlink.org.cn/JCCE/PCM/common/tenanter"
"code.gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbecs"
"code.gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbtenant"
"code.gitlink.org.cn/JCCE/PCM.git/common/tenanter"
"code.gitlink.org.cn/JCCE/PCM.git/lan_trans/idl/pbecs"
"code.gitlink.org.cn/JCCE/PCM.git/lan_trans/idl/pbtenant"
string_ "github.com/alibabacloud-go/darabonba-string/client" string_ "github.com/alibabacloud-go/darabonba-string/client"
util "github.com/alibabacloud-go/tea-utils/service" util "github.com/alibabacloud-go/tea-utils/service"
"github.com/alibabacloud-go/tea/tea" "github.com/alibabacloud-go/tea/tea"


+ 3
- 3
common/server/server.go View File

@@ -1,9 +1,9 @@
package server package server


import ( import (
"code.gitlink.org.cn/JCCE/PCM/lan_trans/idl/demo"
"code.gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbecs"
"code.gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbpod"
"code.gitlink.org.cn/JCCE/PCM.git/lan_trans/idl/demo"
"code.gitlink.org.cn/JCCE/PCM.git/lan_trans/idl/pbecs"
"code.gitlink.org.cn/JCCE/PCM.git/lan_trans/idl/pbpod"
"context" "context"
) )




+ 2
- 2
common/server/server_ecs.go View File

@@ -3,8 +3,8 @@ package server
import ( import (
"context" "context"


"code.gitlink.org.cn/JCCE/PCM/adaptor/vm/server/ecs"
"code.gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbecs"
"code.gitlink.org.cn/JCCE/PCM.git/adaptor/vm/server/ecs"
"code.gitlink.org.cn/JCCE/PCM.git/lan_trans/idl/pbecs"


"github.com/golang/glog" "github.com/golang/glog"
"google.golang.org/grpc/codes" "google.golang.org/grpc/codes"


+ 2
- 2
common/server/server_pod.go View File

@@ -1,10 +1,10 @@
package server package server


import ( import (
"code.gitlink.org.cn/JCCE/PCM/adaptor/pod/server"
"code.gitlink.org.cn/JCCE/PCM.git/adaptor/pod/server"
"context" "context"


"code.gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbpod"
"code.gitlink.org.cn/JCCE/PCM.git/lan_trans/idl/pbpod"


"github.com/golang/glog" "github.com/golang/glog"
"google.golang.org/grpc/codes" "google.golang.org/grpc/codes"


+ 1
- 1
common/tenanter/main_test.go View File

@@ -1,7 +1,7 @@
package tenanter package tenanter


import ( import (
"code.gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbtenant"
"code.gitlink.org.cn/JCCE/PCM.git/lan_trans/idl/pbtenant"
"os" "os"
"testing" "testing"
) )


+ 1
- 1
common/tenanter/region.go View File

@@ -3,7 +3,7 @@ package tenanter
import ( import (
"strings" "strings"


"code.gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbtenant"
"code.gitlink.org.cn/JCCE/PCM.git/lan_trans/idl/pbtenant"


"github.com/pkg/errors" "github.com/pkg/errors"
) )


+ 1
- 1
common/tenanter/region_test.go View File

@@ -3,7 +3,7 @@ package tenanter
import ( import (
"testing" "testing"


"code.gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbtenant"
"code.gitlink.org.cn/JCCE/PCM.git/lan_trans/idl/pbtenant"
) )


func TestGetAllRegionIds(t *testing.T) { func TestGetAllRegionIds(t *testing.T) {


+ 1
- 1
common/tenanter/tenanter.go View File

@@ -1,7 +1,7 @@
package tenanter package tenanter


import ( import (
"code.gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbtenant"
"code.gitlink.org.cn/JCCE/PCM.git/lan_trans/idl/pbtenant"
"encoding/json" "encoding/json"
"flag" "flag"
"github.com/golang/glog" "github.com/golang/glog"


+ 1
- 1
examples/pcm_ali.go View File

@@ -1,7 +1,7 @@
package main package main


import ( import (
pcm_pod_ali "code.gitlink.org.cn/JCCE/PCM/adaptor/pod/server/ali"
pcm_pod_ali "code.gitlink.org.cn/JCCE/PCM.git/adaptor/pod/server/ali"
"github.com/alibabacloud-go/tea/tea" "github.com/alibabacloud-go/tea/tea"
"os" "os"
) )


+ 2
- 2
examples/pcm_huawei.go View File

@@ -1,8 +1,8 @@
package main package main


import ( import (
corev1 "code.gitlink.org.cn/JCCE/PCM/adaptor/pod/server/kubernetes/api/core/v1"
"code.gitlink.org.cn/JCCE/PCM/adaptor/pod/server/kubernetes/client-go/kubernetes"
corev1 "code.gitlink.org.cn/JCCE/PCM.git/adaptor/pod/server/kubernetes/api/core/v1"
"code.gitlink.org.cn/JCCE/PCM.git/adaptor/pod/server/kubernetes/client-go/kubernetes"
"context" "context"
"fmt" "fmt"
"github.com/pkg/errors" "github.com/pkg/errors"


+ 1
- 1
go.mod View File

@@ -1,4 +1,4 @@
module code.gitlink.org.cn/JCCE/PCM
module code.gitlink.org.cn/JCCE/PCM.git


go 1.17 go 1.17




+ 1
- 1
idl/demo/demo.proto View File

@@ -1,7 +1,7 @@
syntax = "proto3"; syntax = "proto3";
package demo; package demo;


option go_package = "code.gitlink.org.cn/JCCE/PCM/lan_trans/gen/idl/demo";
option go_package = "code.gitlink.org.cn/JCCE/PCM.git/lan_trans/gen/idl/demo";


import "google/api/annotations.proto"; import "google/api/annotations.proto";
import "protoc-gen-openapiv2/options/annotations.proto"; import "protoc-gen-openapiv2/options/annotations.proto";


+ 1
- 1
idl/pbecs/ecs.proto View File

@@ -1,7 +1,7 @@
syntax = "proto3"; syntax = "proto3";
package pbecs; package pbecs;


option go_package = "code.gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbecs";
option go_package = "code.gitlink.org.cn/JCCE/PCM.git/lan_trans/idl/pbecs";


import "idl/pbtenant/tenant.proto"; import "idl/pbtenant/tenant.proto";
import "google/api/annotations.proto"; import "google/api/annotations.proto";


+ 1
- 1
idl/pbpod/pod.proto View File

@@ -1,7 +1,7 @@
syntax = "proto3"; syntax = "proto3";
package pbpod; package pbpod;


option go_package = "code.gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbpod";
option go_package = "code.gitlink.org.cn/JCCE/PCM.git/lan_trans/idl/pbpod";


import "idl/pbtenant/tenant.proto"; import "idl/pbtenant/tenant.proto";
import "google/api/annotations.proto"; import "google/api/annotations.proto";


+ 2
- 2
idl/pbtenant/tenant.proto View File

@@ -1,7 +1,7 @@
syntax = "proto3"; syntax = "proto3";
package pbtenant; package pbtenant;


option go_package = "code.gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbtenant";
option go_package = "code.gitlink.org.cn/JCCE/PCM.git/lan_trans/idl/pbtenant";


import "google/api/annotations.proto"; import "google/api/annotations.proto";
import "protoc-gen-openapiv2/options/annotations.proto"; import "protoc-gen-openapiv2/options/annotations.proto";
@@ -173,7 +173,7 @@ service TenantService {
option (grpc.gateway.protoc_gen_openapiv2.options.openapiv2_tag) = { option (grpc.gateway.protoc_gen_openapiv2.options.openapiv2_tag) = {
description : "所有云租户的认证服务" description : "所有云租户的认证服务"
external_docs : { external_docs : {
url : "https://code.gitlink.org.cn/JCCE/PCM"
url : "https://code.gitlink.org.cn/JCCE/PCM.git"
description: "Find out more about PCM" description: "Find out more about PCM"
} }
}; };


+ 1
- 1
lan_trans/idl/pbecs/ecs.pb.go View File

@@ -7,7 +7,7 @@
package pbecs package pbecs


import ( import (
pbtenant "code.gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbtenant"
pbtenant "code.gitlink.org.cn/JCCE/PCM.git/lan_trans/idl/pbtenant"
_ "google.golang.org/genproto/googleapis/api/annotations" _ "google.golang.org/genproto/googleapis/api/annotations"
protoreflect "google.golang.org/protobuf/reflect/protoreflect" protoreflect "google.golang.org/protobuf/reflect/protoreflect"
protoimpl "google.golang.org/protobuf/runtime/protoimpl" protoimpl "google.golang.org/protobuf/runtime/protoimpl"


+ 1
- 1
lan_trans/idl/pbpod/pod.pb.go View File

@@ -7,7 +7,7 @@
package pbpod package pbpod


import ( import (
pbtenant "code.gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbtenant"
pbtenant "code.gitlink.org.cn/JCCE/PCM.git/lan_trans/idl/pbtenant"
_ "google.golang.org/genproto/googleapis/api/annotations" _ "google.golang.org/genproto/googleapis/api/annotations"
protoreflect "google.golang.org/protobuf/reflect/protoreflect" protoreflect "google.golang.org/protobuf/reflect/protoreflect"
protoimpl "google.golang.org/protobuf/runtime/protoimpl" protoimpl "google.golang.org/protobuf/runtime/protoimpl"


+ 5
- 5
main.go View File

@@ -1,11 +1,11 @@
package main package main


import ( import (
"code.gitlink.org.cn/JCCE/PCM/common/server"
"code.gitlink.org.cn/JCCE/PCM/common/tenanter"
"code.gitlink.org.cn/JCCE/PCM/lan_trans/idl/demo"
"code.gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbecs"
"code.gitlink.org.cn/JCCE/PCM/lan_trans/idl/pbpod"
"code.gitlink.org.cn/JCCE/PCM.git/common/server"
"code.gitlink.org.cn/JCCE/PCM.git/common/tenanter"
"code.gitlink.org.cn/JCCE/PCM.git/lan_trans/idl/demo"
"code.gitlink.org.cn/JCCE/PCM.git/lan_trans/idl/pbecs"
"code.gitlink.org.cn/JCCE/PCM.git/lan_trans/idl/pbpod"
"context" "context"
"flag" "flag"
"net" "net"


Loading…
Cancel
Save