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

cloudprovider methods to list resources and get health

Browse Source
This commit is contained in:
Prashanth Balasubramanian 2015-10-22 11:25:04 -07:00
parent e42f5af6a1
commit f7db2eefef
1 changed files with 38 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

38
pkg/cloudprovider/providers/gce/gce.go
View File

@ -956,6 +956,11 @@ func (gce *GCECloud) DeleteUrlMap(name string) error {
return gce.waitForGlobalOp(op) return gce.waitForGlobalOp(op)
} }
// ListUrlMaps lists all UrlMaps in the project.
func (gce *GCECloud) ListUrlMaps() (*compute.UrlMapList, error) {
return gce.service.UrlMaps.List(gce.projectID).Do()
}
// TargetHttpProxy management // TargetHttpProxy management
// GetTargetHttpProxy returns the UrlMap by name. // GetTargetHttpProxy returns the UrlMap by name.
@ -1000,6 +1005,11 @@ func (gce *GCECloud) DeleteTargetHttpProxy(name string) error {
return gce.waitForGlobalOp(op) return gce.waitForGlobalOp(op)
} }
// ListTargetHttpProxies lists all TargetHttpProxies in the project.
func (gce *GCECloud) ListTargetHttpProxies() (*compute.TargetHttpProxyList, error) {
return gce.service.TargetHttpProxies.List(gce.projectID).Do()
}
// GlobalForwardingRule management // GlobalForwardingRule management
// CreateGlobalForwardingRule creates and returns a GlobalForwardingRule that points to the given TargetHttpProxy. // CreateGlobalForwardingRule creates and returns a GlobalForwardingRule that points to the given TargetHttpProxy.
@ -1046,6 +1056,11 @@ func (gce *GCECloud) GetGlobalForwardingRule(name string) (*compute.ForwardingRu
return gce.service.GlobalForwardingRules.Get(gce.projectID, name).Do() return gce.service.GlobalForwardingRules.Get(gce.projectID, name).Do()
} }
// ListGlobalForwardingRules lists all GlobalForwardingRules in the project.
func (gce *GCECloud) ListGlobalForwardingRules() (*compute.ForwardingRuleList, error) {
return gce.service.GlobalForwardingRules.List(gce.projectID).Do()
}
// BackendService Management // BackendService Management
// GetBackendService retrieves a backend by name. // GetBackendService retrieves a backend by name.
@ -1083,6 +1098,19 @@ func (gce *GCECloud) CreateBackendService(bg *compute.BackendService) error {
return gce.waitForGlobalOp(op) return gce.waitForGlobalOp(op)
} }
// ListBackendServices lists all backend services in the project.
func (gce *GCECloud) ListBackendServices() (*compute.BackendServiceList, error) {
return gce.service.BackendServices.List(gce.projectID).Do()
}
// GetHealth returns the health of the BackendService identified by the given
// name, in the given instanceGroup. The instanceGroupLink is the fully
// qualified self link of an instance group.
func (gce *GCECloud) GetHealth(name string, instanceGroupLink string) (*compute.BackendServiceGroupHealth, error) {
groupRef := &compute.ResourceGroupReference{instanceGroupLink}
return gce.service.BackendServices.GetHealth(gce.projectID, name, groupRef).Do()
}
// Health Checks // Health Checks
// GetHttpHealthCheck returns the given HttpHealthCheck by name. // GetHttpHealthCheck returns the given HttpHealthCheck by name.
@ -1120,6 +1148,11 @@ func (gce *GCECloud) CreateHttpHealthCheck(hc *compute.HttpHealthCheck) error {
return gce.waitForGlobalOp(op) return gce.waitForGlobalOp(op)
} }
// ListHttpHealthCheck lists all HttpHealthChecks in the project.
func (gce *GCECloud) ListHttpHealthChecks() (*compute.HttpHealthCheckList, error) {
return gce.service.HttpHealthChecks.List(gce.projectID).Do()
}
// InstanceGroup Management // InstanceGroup Management
// CreateInstanceGroup creates an instance group with the given instances. It is the callers responsibility to add named ports. // CreateInstanceGroup creates an instance group with the given instances. It is the callers responsibility to add named ports.
@ -1145,6 +1178,11 @@ func (gce *GCECloud) DeleteInstanceGroup(name string) error {
return gce.waitForZoneOp(op) return gce.waitForZoneOp(op)
} }
// ListInstanceGroups lists all InstanceGroups in the project and zone.
func (gce *GCECloud) ListInstanceGroups() (*compute.InstanceGroupList, error) {
return gce.service.InstanceGroups.List(gce.projectID, gce.zone).Do()
}
// ListInstancesInInstanceGroup lists all the instances in a given istance group and state. // ListInstancesInInstanceGroup lists all the instances in a given istance group and state.
func (gce *GCECloud) ListInstancesInInstanceGroup(name string, state string) (*compute.InstanceGroupsListInstances, error) { func (gce *GCECloud) ListInstancesInInstanceGroup(name string, state string) (*compute.InstanceGroupsListInstances, error) {
return gce.service.InstanceGroups.ListInstances( return gce.service.InstanceGroups.ListInstances(