github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-14 06:15:45 +00:00
Code Issues Projects Releases Wiki Activity

cleanup some dead cloudprovider code

Browse Source
This commit is contained in:
Guoliang Wang 2018-05-29 22:57:04 +08:00
parent 07e6410cf7
commit b8f70a84ed
4 changed files with 0 additions and 42 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
pkg/cloudprovider/providers/aws/aws.go
View File

@ -999,10 +999,6 @@ func updateConfigZone(cfg *CloudConfig, metadata EC2Metadata) error {
return nil return nil
} }
func getInstanceType(metadata EC2Metadata) (string, error) {
return metadata.GetMetadata("instance-type")
}
func getAvailabilityZone(metadata EC2Metadata) (string, error) { func getAvailabilityZone(metadata EC2Metadata) (string, error) {
return metadata.GetMetadata("placement/availability-zone") return metadata.GetMetadata("placement/availability-zone")
} }
@ -1920,23 +1916,6 @@ func (c *Cloud) buildSelfAWSInstance() (*awsInstance, error) {
return newAWSInstance(c.ec2, instance), nil return newAWSInstance(c.ec2, instance), nil
} }
// Gets the awsInstance with for the node with the specified nodeName, or the 'self' instance if nodeName == ""
func (c *Cloud) getAwsInstance(nodeName types.NodeName) (*awsInstance, error) {
var awsInstance *awsInstance
if nodeName == "" {
awsInstance = c.selfAWSInstance
} else {
instance, err := c.getInstanceByNodeName(nodeName)
if err != nil {
return nil, err
}
awsInstance = newAWSInstance(c.ec2, instance)
}
return awsInstance, nil
}
// wrapAttachError wraps the error returned by an AttachVolume request with // wrapAttachError wraps the error returned by an AttachVolume request with
// additional information, if needed and possible. // additional information, if needed and possible.
func wrapAttachError(err error, disk *awsDisk, instance string) error { func wrapAttachError(err error, disk *awsDisk, instance string) error {

4
pkg/cloudprovider/providers/gce/gce_loadbalancer.go
View File

@ -41,10 +41,6 @@ var (
lbSrcRngsFlag cidrs lbSrcRngsFlag cidrs
) )
func newLoadBalancerMetricContext(request, region string) *metricContext {
return newGenericMetricContext("loadbalancer", request, region, unusedMetricLabel, computeV1Version)
}
func init() { func init() {
var err error var err error
// LB L7 proxies and all L3/4/7 health checkers have client addresses within these known CIDRs. // LB L7 proxies and all L3/4/7 health checkers have client addresses within these known CIDRs.

5
pkg/cloudprovider/providers/gce/gce_util.go
View File

@ -138,11 +138,6 @@ func mapNodeNameToInstanceName(nodeName types.NodeName) string {
return string(nodeName) return string(nodeName)
} }
// mapInstanceToNodeName maps a GCE Instance to a k8s NodeName
func mapInstanceToNodeName(instance *compute.Instance) types.NodeName {
return types.NodeName(instance.Name)
}
// GetGCERegion returns region of the gce zone. Zone names // GetGCERegion returns region of the gce zone. Zone names
// are of the form: ${region-name}-${ix}. // are of the form: ${region-name}-${ix}.
// For example, "us-central1-b" has a region of "us-central1". // For example, "us-central1-b" has a region of "us-central1".

12
pkg/cloudprovider/providers/vsphere/vsphere_util.go
View File

@ -81,18 +81,6 @@ func getVSphereConfig() (*VSphereConfig, error) {
return &cfg, nil return &cfg, nil
} }
func getVSphereConn(cfg *VSphereConfig) *vclib.VSphereConnection {
vSphereConn := &vclib.VSphereConnection{
Username: cfg.Global.User,
Password: cfg.Global.Password,
Hostname: cfg.Global.VCenterIP,
Insecure: cfg.Global.InsecureFlag,
RoundTripperCount: cfg.Global.RoundTripperCount,
Port: cfg.Global.VCenterPort,
}
return vSphereConn
}
// Returns the accessible datastores for the given node VM. // Returns the accessible datastores for the given node VM.
func getAccessibleDatastores(ctx context.Context, nodeVmDetail *NodeDetails, nodeManager *NodeManager) ([]*vclib.DatastoreInfo, error) { func getAccessibleDatastores(ctx context.Context, nodeVmDetail *NodeDetails, nodeManager *NodeManager) ([]*vclib.DatastoreInfo, error) {
accessibleDatastores, err := nodeVmDetail.vm.GetAllAccessibleDatastores(ctx) accessibleDatastores, err := nodeVmDetail.vm.GetAllAccessibleDatastores(ctx)