gce

package
v1.7.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 29, 2017 License: Apache-2.0 Imports: 47 Imported by: 0

Documentation

Overview

Package gce is an implementation of Interface, LoadBalancer and Instances for Google Compute Engine.

Index

Constants

View Source 
const (
	// ServiceAnnotationLoadBalancerType is annotated on a service with type LoadBalancer
	// dictates what specific kind of GCP LB should be assembled.
	// Currently, only "internal" is supported.
	ServiceAnnotationLoadBalancerType = "cloud.google.com/load-balancer-type"

	LBTypeInternal LoadBalancerType = "internal"

	// ServiceAnnotationInternalBackendShare is annotated on a service with "true" when users
	// want to share GCP Backend Services for a set of internal load balancers.
	// ALPHA feature - this may be removed in a future release.
	ServiceAnnotationILBBackendShare = "cloud.google.com/load-balancer-backend-share"
)
View Source 
const (
	// Key used to persist UIDs to configmaps.
	UIDConfigMapName = "ingress-uid"
	// Namespace which contains the above config map
	UIDNamespace = metav1.NamespaceSystem
	// Data keys for the specific ids
	UIDCluster     = "uid"
	UIDProvider    = "provider-uid"
	UIDLengthBytes = 8
)
View Source 
const (
	DiskTypeSSD      = "pd-ssd"
	DiskTypeStandard = "pd-standard"
)
View Source 
const (
	ProviderName = "gce"
)

Variables

This section is empty.

Functions

func GetGCERegion 

func GetGCERegion(zone string) (string, error)

GetGCERegion returns region of the gce zone. Zone names are of the form: ${region-name}-${ix}. For example, "us-central1-b" has a region of "us-central1". So we look for the last '-' and trim to just before that.

func GetLoadBalancerAnnotationBackendShare added in v1.7.0 

func GetLoadBalancerAnnotationBackendShare(service *v1.Service) bool

GetLoadBalancerAnnotationBackendShare returns whether this service's backend service should be shared with other load balancers. Health checks and the healthcheck firewall will be shared regardless.

func GetNodesHealthCheckPath added in v1.7.0 

func GetNodesHealthCheckPath() string

GetNodesHealthCheckPath returns the health check path used by the GCE load balancers (l4) for performing health checks on nodes.

func GetNodesHealthCheckPort added in v1.7.0 

func GetNodesHealthCheckPort() int32

GetNodesHealthCheckPort returns the health check port used by the GCE load balancers (l4) for performing health checks on nodes.

func LoadBalancerSrcRanges added in v1.7.0 

func LoadBalancerSrcRanges() []string

LoadBalancerSrcRanges contains the ranges of ips used by the GCE load balancers (l4 & L7) for proxying client requests and performing health checks.

func MakeHealthCheckFirewallName added in v1.7.0 

func MakeHealthCheckFirewallName(clusterID, hcName string, isNodesHealthCheck bool) string

MakeHealthCheckFirewallName returns the firewall name used by the GCE load balancers (l4) for performing health checks.

func NewAltTokenSource added in v1.3.0 

func NewAltTokenSource(tokenURL, tokenBody string) oauth2.TokenSource

Types

type AltTokenSource added in v1.3.0 

type AltTokenSource struct {
	// contains filtered or unexported fields
}

func (*AltTokenSource) Token added in v1.3.0 

func (a *AltTokenSource) Token() (*oauth2.Token, error)

type ClusterID added in v1.7.0 

type ClusterID struct {
	// contains filtered or unexported fields
}

func (*ClusterID) GetFederationId added in v1.7.0 

func (ci *ClusterID) GetFederationId() (string, bool, error)

GetFederationId returns the id which could represent the entire Federation or just the cluster if not federated.

func (*ClusterID) GetID added in v1.7.0 

func (ci *ClusterID) GetID() (string, error)

GetID returns the id which is unique to this cluster if federated, return the provider id (unique to the cluster) if not federated, return the cluster id

type Config 

type Config struct {
	Global struct {
		TokenURL           string   `gcfg:"token-url"`
		TokenBody          string   `gcfg:"token-body"`
		ProjectID          string   `gcfg:"project-id"`
		NetworkName        string   `gcfg:"network-name"`
		SubnetworkName     string   `gcfg:"subnetwork-name"`
		NodeTags           []string `gcfg:"node-tags"`
		NodeInstancePrefix string   `gcfg:"node-instance-prefix"`
		Multizone          bool     `gcfg:"multizone"`
	}
}

type DiskType added in v1.4.2 

type DiskType string

type Disks added in v1.3.0 

type Disks interface {
	// AttachDisk attaches given disk to the node with the specified NodeName.
	// Current instance is used when instanceID is empty string.
	AttachDisk(diskName string, nodeName types.NodeName, readOnly bool) error

	// DetachDisk detaches given disk to the node with the specified NodeName.
	// Current instance is used when nodeName is empty string.
	DetachDisk(devicePath string, nodeName types.NodeName) error

	// DiskIsAttached checks if a disk is attached to the node with the specified NodeName.
	DiskIsAttached(diskName string, nodeName types.NodeName) (bool, error)

	// DisksAreAttached is a batch function to check if a list of disks are attached
	// to the node with the specified NodeName.
	DisksAreAttached(diskNames []string, nodeName types.NodeName) (map[string]bool, error)

	// CreateDisk creates a new PD with given properties. Tags are serialized
	// as JSON into Description field.
	CreateDisk(name string, diskType string, zone string, sizeGb int64, tags map[string]string) error

	// DeleteDisk deletes PD.
	DeleteDisk(diskToDelete string) error

	// GetAutoLabelsForPD returns labels to apply to PersistentVolume
	// representing this PD, namely failure domain and zone.
	// zone can be provided to specify the zone for the PD,
	// if empty all managed zones will be searched.
	GetAutoLabelsForPD(name string, zone string) (map[string]string, error)
}

Disks is interface for manipulation with GCE PDs.

type GCECloud 

type GCECloud struct {
	// ClusterID contains functionality for getting (and initializing) the ingress-uid. Call GCECloud.Initialize()
	// for the cloudprovider to start watching the configmap.
	ClusterID ClusterID
	// contains filtered or unexported fields
}

GCECloud is an implementation of Interface, LoadBalancer and Instances for Google Compute Engine.

func CreateGCECloud 

func CreateGCECloud(projectID, region, zone string, managedZones []string, networkURL, subnetworkURL string, nodeTags []string,
	nodeInstancePrefix string, tokenSource oauth2.TokenSource, useMetadataServer bool) (*GCECloud, error)

Creates a GCECloud object using the specified parameters. If no networkUrl is specified, loads networkName via rest call. If no tokenSource is specified, uses oauth2.DefaultTokenSource. If managedZones is nil / empty all zones in the region will be managed.

func (*GCECloud) AddInstancesToInstanceGroup 

func (gce *GCECloud) AddInstancesToInstanceGroup(name string, zone string, instanceRefs []*compute.InstanceReference) error

AddInstancesToInstanceGroup adds the given instances to the given instance group.

func (*GCECloud) AddInstancesToTargetPool added in v1.7.0 

func (gce *GCECloud) AddInstancesToTargetPool(name, region string, instanceRefs []*compute.InstanceReference) error

AddInstancesToTargetPool adds instances by link to the TargetPool

func (*GCECloud) AddSSHKeyToAllInstances 

func (gce *GCECloud) AddSSHKeyToAllInstances(user string, keyData []byte) error

func (*GCECloud) AliasRanges added in v1.7.0 

func (gce *GCECloud) AliasRanges(nodeName types.NodeName) (cidrs []string, err error)

AliasRanges returns a list of CIDR ranges that are assigned to the `node` for allocation to pods. Returns a list of the form "<ip>/<netmask>".

func (*GCECloud) AttachDisk 

func (gce *GCECloud) AttachDisk(diskName string, nodeName types.NodeName, readOnly bool) error

func (*GCECloud) Clusters 

func (gce *GCECloud) Clusters() (cloudprovider.Clusters, bool)

func (*GCECloud) CreateDisk 

func (gce *GCECloud) CreateDisk(
	name string, diskType string, zone string, sizeGb int64, tags map[string]string) error

CreateDisk creates a new Persistent Disk, with the specified name & size, in the specified zone. It stores specified tags encoded in JSON in Description field.

func (*GCECloud) CreateFirewall 

func (gce *GCECloud) CreateFirewall(f *compute.Firewall) error

CreateFirewall creates the passed firewall

func (*GCECloud) CreateGlobalBackendService added in v1.7.0 

func (gce *GCECloud) CreateGlobalBackendService(bg *compute.BackendService) error

CreateGlobalBackendService creates the given BackendService.

func (*GCECloud) CreateGlobalForwardingRule 

func (gce *GCECloud) CreateGlobalForwardingRule(targetProxyLink, ip, name, portRange string) (*compute.ForwardingRule, error)

CreateGlobalForwardingRule creates and returns a GlobalForwardingRule that points to the given TargetHttp(s)Proxy. targetProxyLink is the SelfLink of a TargetHttp(s)Proxy.

func (*GCECloud) CreateHealthCheck added in v1.7.0 

func (gce *GCECloud) CreateHealthCheck(hc *compute.HealthCheck) error

CreateHealthCheck creates the given HealthCheck.

func (*GCECloud) CreateHttpHealthCheck 

func (gce *GCECloud) CreateHttpHealthCheck(hc *compute.HttpHealthCheck) error

CreateHttpHealthCheck creates the given HttpHealthCheck.

func (*GCECloud) CreateHttpsHealthCheck added in v1.7.0 

func (gce *GCECloud) CreateHttpsHealthCheck(hc *compute.HttpsHealthCheck) error

CreateHttpsHealthCheck creates the given HttpsHealthCheck.

func (*GCECloud) CreateInstanceGroup 

func (gce *GCECloud) CreateInstanceGroup(name string, zone string) (*compute.InstanceGroup, error)

CreateInstanceGroup creates an instance group with the given instances. It is the callers responsibility to add named ports.

func (*GCECloud) CreateRegionBackendService added in v1.7.0 

func (gce *GCECloud) CreateRegionBackendService(bg *compute.BackendService, region string) error

CreateRegionBackendService creates the given BackendService.

func (*GCECloud) CreateRegionForwardingRule added in v1.7.0 

func (gce *GCECloud) CreateRegionForwardingRule(rule *compute.ForwardingRule, region string) error

CreateRegionForwardingRule creates and returns a RegionalForwardingRule that points to the given BackendService

func (*GCECloud) CreateRoute 

func (gce *GCECloud) CreateRoute(clusterName string, nameHint string, route *cloudprovider.Route) error

func (*GCECloud) CreateSslCertificate 

func (gce *GCECloud) CreateSslCertificate(sslCerts *compute.SslCertificate) (*compute.SslCertificate, error)

CreateSslCertificate creates and returns a SslCertificate.

func (*GCECloud) CreateTargetHttpProxy 

func (gce *GCECloud) CreateTargetHttpProxy(urlMap *compute.UrlMap, name string) (*compute.TargetHttpProxy, error)

CreateTargetHttpProxy creates and returns a TargetHttpProxy with the given UrlMap.

func (*GCECloud) CreateTargetHttpsProxy 

func (gce *GCECloud) CreateTargetHttpsProxy(urlMap *compute.UrlMap, sslCert *compute.SslCertificate, name string) (*compute.TargetHttpsProxy, error)

CreateTargetHttpsProxy creates and returns a TargetHttpsProxy with the given UrlMap and SslCertificate.

func (*GCECloud) CreateTargetPool added in v1.7.0 

func (gce *GCECloud) CreateTargetPool(tp *compute.TargetPool, region string) (*compute.TargetPool, error)

CreateTargetPool creates the passed TargetPool

func (*GCECloud) CreateUrlMap 

func (gce *GCECloud) CreateUrlMap(backend *compute.BackendService, name string) (*compute.UrlMap, error)

CreateUrlMap creates an url map, using the given backend service as the default service.

func (*GCECloud) CurrentNodeName 

func (gce *GCECloud) CurrentNodeName(hostname string) (types.NodeName, error)

Implementation of Instances.CurrentNodeName

func (*GCECloud) DeleteDisk 

func (gce *GCECloud) DeleteDisk(diskToDelete string) error

func (*GCECloud) DeleteExternalTargetPoolAndChecks added in v1.7.0 

func (gce *GCECloud) DeleteExternalTargetPoolAndChecks(name, region string, hcNames ...string) error

func (*GCECloud) DeleteFirewall 

func (gce *GCECloud) DeleteFirewall(name string) error

DeleteFirewall deletes the given firewall rule.

func (*GCECloud) DeleteGlobalAddress added in v1.7.0 

func (gce *GCECloud) DeleteGlobalAddress(name string) error

DeleteGlobalAddress deletes a global address by name.

func (*GCECloud) DeleteGlobalBackendService added in v1.7.0 

func (gce *GCECloud) DeleteGlobalBackendService(name string) error

DeleteGlobalBackendService deletes the given BackendService by name.

func (*GCECloud) DeleteGlobalForwardingRule 

func (gce *GCECloud) DeleteGlobalForwardingRule(name string) error

DeleteGlobalForwardingRule deletes the GlobalForwardingRule by name.

func (*GCECloud) DeleteHealthCheck added in v1.7.0 

func (gce *GCECloud) DeleteHealthCheck(name string) error

DeleteHealthCheck deletes the given HealthCheck by name.

func (*GCECloud) DeleteHttpHealthCheck 

func (gce *GCECloud) DeleteHttpHealthCheck(name string) error

DeleteHttpHealthCheck deletes the given HttpHealthCheck by name.

func (*GCECloud) DeleteHttpsHealthCheck added in v1.7.0 

func (gce *GCECloud) DeleteHttpsHealthCheck(name string) error

DeleteHttpsHealthCheck deletes the given HttpsHealthCheck by name.

func (*GCECloud) DeleteInstanceGroup 

func (gce *GCECloud) DeleteInstanceGroup(name string, zone string) error

DeleteInstanceGroup deletes an instance group.

func (*GCECloud) DeleteRegionAddress added in v1.7.0 

func (gce *GCECloud) DeleteRegionAddress(name, region string) error

DeleteRegionAddress deletes a region address by name.

func (*GCECloud) DeleteRegionBackendService added in v1.7.0 

func (gce *GCECloud) DeleteRegionBackendService(name, region string) error

DeleteRegionBackendService deletes the given BackendService by name.

func (*GCECloud) DeleteRegionForwardingRule added in v1.7.0 

func (gce *GCECloud) DeleteRegionForwardingRule(name, region string) error

DeleteRegionForwardingRule deletes the RegionalForwardingRule by name & region.

func (*GCECloud) DeleteRoute 

func (gce *GCECloud) DeleteRoute(clusterName string, route *cloudprovider.Route) error

func (*GCECloud) DeleteSslCertificate 

func (gce *GCECloud) DeleteSslCertificate(name string) error

DeleteSslCertificate deletes the SslCertificate by name.

func (*GCECloud) DeleteTargetHttpProxy 

func (gce *GCECloud) DeleteTargetHttpProxy(name string) error

DeleteTargetHttpProxy deletes the TargetHttpProxy by name.

func (*GCECloud) DeleteTargetHttpsProxy 

func (gce *GCECloud) DeleteTargetHttpsProxy(name string) error

DeleteTargetHttpsProxy deletes the TargetHttpsProxy by name.

func (*GCECloud) DeleteTargetPool added in v1.5.1 

func (gce *GCECloud) DeleteTargetPool(name, region string) error

DeleteTargetPool deletes TargetPool by name.

func (*GCECloud) DeleteUrlMap 

func (gce *GCECloud) DeleteUrlMap(name string) error

DeleteUrlMap deletes a url map by name.

func (*GCECloud) DetachDisk 

func (gce *GCECloud) DetachDisk(devicePath string, nodeName types.NodeName) error

func (*GCECloud) DiskIsAttached 

func (gce *GCECloud) DiskIsAttached(diskName string, nodeName types.NodeName) (bool, error)

func (*GCECloud) DisksAreAttached added in v1.4.7 

func (gce *GCECloud) DisksAreAttached(diskNames []string, nodeName types.NodeName) (map[string]bool, error)

func (*GCECloud) EnsureLoadBalancer 

func (gce *GCECloud) EnsureLoadBalancer(clusterName string, svc *v1.Service, nodes []*v1.Node) (*v1.LoadBalancerStatus, error)

EnsureLoadBalancer is an implementation of LoadBalancer.EnsureLoadBalancer.

func (*GCECloud) EnsureLoadBalancerDeleted 

func (gce *GCECloud) EnsureLoadBalancerDeleted(clusterName string, svc *v1.Service) error

EnsureLoadBalancerDeleted is an implementation of LoadBalancer.EnsureLoadBalancerDeleted.

func (*GCECloud) ExternalID 

func (gce *GCECloud) ExternalID(nodeName types.NodeName) (string, error)

ExternalID returns the cloud provider ID of the node with the specified NodeName (deprecated).

func (*GCECloud) GetAllZones added in v1.3.0 

func (gce *GCECloud) GetAllZones() (sets.String, error)

GetAllZones returns all the zones in which nodes are running

func (*GCECloud) GetAutoLabelsForPD 

func (gce *GCECloud) GetAutoLabelsForPD(name string, zone string) (map[string]string, error)

Builds the labels that should be automatically added to a PersistentVolume backed by a GCE PD Specifically, this builds FailureDomain (zone) and Region labels. The PersistentVolumeLabel admission controller calls this and adds the labels when a PV is created. If zone is specified, the volume will only be found in the specified zone, otherwise all managed zones will be searched.

func (*GCECloud) GetComputeService 

func (g *GCECloud) GetComputeService() *compute.Service

Raw access to the underlying GCE service, probably should only be used for e2e tests

func (*GCECloud) GetDiskByNameUnknownZone added in v1.7.0 

func (gce *GCECloud) GetDiskByNameUnknownZone(diskName string) (*GCEDisk, error)

Scans all managed zones to return the GCE PD Prefer getDiskByName, if the zone can be established Return cloudprovider.DiskNotFound if the given disk cannot be found in any zone

func (*GCECloud) GetFirewall 

func (gce *GCECloud) GetFirewall(name string) (*compute.Firewall, error)

GetFirewall returns the Firewall by name.

func (*GCECloud) GetGlobalAddress added in v1.7.0 

func (gce *GCECloud) GetGlobalAddress(name string) (*compute.Address, error)

GetGlobalAddress returns the global address by name.

func (*GCECloud) GetGlobalBackendService added in v1.7.0 

func (gce *GCECloud) GetGlobalBackendService(name string) (*compute.BackendService, error)

GetGlobalBackendService retrieves a backend by name.

func (*GCECloud) GetGlobalBackendServiceHealth added in v1.7.0 

func (gce *GCECloud) GetGlobalBackendServiceHealth(name string, instanceGroupLink string) (*compute.BackendServiceGroupHealth, error)

GetGlobalBackendServiceHealth 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 (*GCECloud) GetGlobalForwardingRule 

func (gce *GCECloud) GetGlobalForwardingRule(name string) (*compute.ForwardingRule, error)

GetGlobalForwardingRule returns the GlobalForwardingRule by name.

func (*GCECloud) GetHealthCheck added in v1.7.0 

func (gce *GCECloud) GetHealthCheck(name string) (*compute.HealthCheck, error)

GetHealthCheck returns the given HealthCheck by name.

func (*GCECloud) GetHttpHealthCheck 

func (gce *GCECloud) GetHttpHealthCheck(name string) (*compute.HttpHealthCheck, error)

GetHttpHealthCheck returns the given HttpHealthCheck by name.

func (*GCECloud) GetHttpsHealthCheck added in v1.7.0 

func (gce *GCECloud) GetHttpsHealthCheck(name string) (*compute.HttpsHealthCheck, error)

GetHttpsHealthCheck returns the given HttpsHealthCheck by name.

func (*GCECloud) GetInstanceGroup 

func (gce *GCECloud) GetInstanceGroup(name string, zone string) (*compute.InstanceGroup, error)

GetInstanceGroup returns an instance group by name.

func (*GCECloud) GetLoadBalancer 

func (gce *GCECloud) GetLoadBalancer(clusterName string, svc *v1.Service) (*v1.LoadBalancerStatus, bool, error)

GetLoadBalancer is an implementation of LoadBalancer.GetLoadBalancer

func (*GCECloud) GetNodeTags added in v1.7.0 

func (gce *GCECloud) GetNodeTags(nodeNames []string) ([]string, error)

GetNodeTags will first try returning the list of tags specified in GCE cloud Configuration. If they weren't provided, it'll compute the host tags with the given hostnames. If the list of hostnames has not changed, a cached set of nodetags are returned.

func (*GCECloud) GetRegionAddress added in v1.7.0 

func (gce *GCECloud) GetRegionAddress(name, region string) (*compute.Address, error)

GetRegionAddress returns the region address by name

func (*GCECloud) GetRegionBackendService added in v1.7.0 

func (gce *GCECloud) GetRegionBackendService(name, region string) (*compute.BackendService, error)

GetRegionBackendService retrieves a backend by name.

func (*GCECloud) GetRegionForwardingRule added in v1.7.0 

func (gce *GCECloud) GetRegionForwardingRule(name, region string) (*compute.ForwardingRule, error)

GetRegionForwardingRule returns the RegionalForwardingRule by name & region.

func (*GCECloud) GetRegionalBackendServiceHealth added in v1.7.0 

func (gce *GCECloud) GetRegionalBackendServiceHealth(name, region string, instanceGroupLink string) (*compute.BackendServiceGroupHealth, error)

GetRegionalBackendServiceHealth 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 (*GCECloud) GetSslCertificate 

func (gce *GCECloud) GetSslCertificate(name string) (*compute.SslCertificate, error)

GetSslCertificate returns the SslCertificate by name.

func (*GCECloud) GetTargetHttpProxy 

func (gce *GCECloud) GetTargetHttpProxy(name string) (*compute.TargetHttpProxy, error)

GetTargetHttpProxy returns the UrlMap by name.

func (*GCECloud) GetTargetHttpsProxy 

func (gce *GCECloud) GetTargetHttpsProxy(name string) (*compute.TargetHttpsProxy, error)

GetTargetHttpsProxy returns the UrlMap by name.

func (*GCECloud) GetTargetPool added in v1.7.0 

func (gce *GCECloud) GetTargetPool(name, region string) (*compute.TargetPool, error)

GetTargetPool returns the TargetPool by name.

func (*GCECloud) GetUrlMap 

func (gce *GCECloud) GetUrlMap(name string) (*compute.UrlMap, error)

GetUrlMap returns the UrlMap by name.

func (*GCECloud) GetZone 

func (gce *GCECloud) GetZone() (cloudprovider.Zone, error)

GetZone creates a cloudprovider.Zone of the current zone and region

func (*GCECloud) Initialize added in v1.7.0 

func (gce *GCECloud) Initialize(clientBuilder controller.ControllerClientBuilder)

Initialize takes in a clientBuilder and spawns a goroutine for watching the clusterid configmap. This must be called before utilizing the funcs of gce.ClusterID

func (*GCECloud) InstanceID 

func (gce *GCECloud) InstanceID(nodeName types.NodeName) (string, error)

InstanceID returns the cloud provider ID of the node with the specified NodeName.

func (*GCECloud) InstanceType 

func (gce *GCECloud) InstanceType(nodeName types.NodeName) (string, error)

InstanceType returns the type of the specified node with the specified NodeName.

func (*GCECloud) InstanceTypeByProviderID added in v1.7.0 

func (gce *GCECloud) InstanceTypeByProviderID(providerID string) (string, error)

InstanceTypeByProviderID returns the cloudprovider instance type of the node with the specified unique providerID This method will not be called from the node that is requesting this ID. i.e. metadata service and other local methods cannot be used here

func (*GCECloud) Instances 

func (gce *GCECloud) Instances() (cloudprovider.Instances, bool)

Instances returns an implementation of Instances for Google Compute Engine.

func (*GCECloud) ListClusters 

func (gce *GCECloud) ListClusters() ([]string, error)

func (*GCECloud) ListGlobalBackendServices added in v1.7.0 

func (gce *GCECloud) ListGlobalBackendServices() (*compute.BackendServiceList, error)

ListGlobalBackendServices lists all backend services in the project.

func (*GCECloud) ListGlobalForwardingRules 

func (gce *GCECloud) ListGlobalForwardingRules() (*compute.ForwardingRuleList, error)

ListGlobalForwardingRules lists all GlobalForwardingRules in the project.

func (*GCECloud) ListHealthChecks added in v1.7.0 

func (gce *GCECloud) ListHealthChecks() (*compute.HealthCheckList, error)

ListHealthChecks lists all HealthCheck in the project.

func (*GCECloud) ListHttpHealthChecks 

func (gce *GCECloud) ListHttpHealthChecks() (*compute.HttpHealthCheckList, error)

ListHttpHealthChecks lists all HttpHealthChecks in the project.

func (*GCECloud) ListHttpsHealthChecks added in v1.7.0 

func (gce *GCECloud) ListHttpsHealthChecks() (*compute.HttpsHealthCheckList, error)

ListHttpsHealthChecks lists all HttpsHealthChecks in the project.

func (*GCECloud) ListInstanceGroups 

func (gce *GCECloud) ListInstanceGroups(zone string) (*compute.InstanceGroupList, error)

ListInstanceGroups lists all InstanceGroups in the project and zone.

func (*GCECloud) ListInstancesInInstanceGroup 

func (gce *GCECloud) ListInstancesInInstanceGroup(name string, zone string, state string) (*compute.InstanceGroupsListInstances, error)

ListInstancesInInstanceGroup lists all the instances in a given instance group and state.

func (*GCECloud) ListRegionBackendServices added in v1.7.0 

func (gce *GCECloud) ListRegionBackendServices(region string) (*compute.BackendServiceList, error)

ListRegionBackendServices lists all backend services in the project.

func (*GCECloud) ListRegionForwardingRules added in v1.7.0 

func (gce *GCECloud) ListRegionForwardingRules(region string) (*compute.ForwardingRuleList, error)

ListRegionForwardingRules lists all RegionalForwardingRules in the project & region.

func (*GCECloud) ListRoutes 

func (gce *GCECloud) ListRoutes(clusterName string) ([]*cloudprovider.Route, error)

func (*GCECloud) ListSslCertificates 

func (gce *GCECloud) ListSslCertificates() (*compute.SslCertificateList, error)

ListSslCertificates lists all SslCertificates in the project.

func (*GCECloud) ListTargetHttpProxies 

func (gce *GCECloud) ListTargetHttpProxies() (*compute.TargetHttpProxyList, error)

ListTargetHttpProxies lists all TargetHttpProxies in the project.

func (*GCECloud) ListTargetHttpsProxies 

func (gce *GCECloud) ListTargetHttpsProxies() (*compute.TargetHttpsProxyList, error)

ListTargetHttpsProxies lists all TargetHttpsProxies in the project.

func (*GCECloud) ListUrlMaps 

func (gce *GCECloud) ListUrlMaps() (*compute.UrlMapList, error)

ListUrlMaps lists all UrlMaps in the project.

func (*GCECloud) ListZonesInRegion added in v1.7.0 

func (gce *GCECloud) ListZonesInRegion(region string) ([]*compute.Zone, error)

ListZonesInRegion returns all zones in a GCP region

func (*GCECloud) LoadBalancer 

func (gce *GCECloud) LoadBalancer() (cloudprovider.LoadBalancer, bool)

LoadBalancer returns an implementation of LoadBalancer for Google Compute Engine.

func (*GCECloud) Master 

func (gce *GCECloud) Master(clusterName string) (string, error)

func (*GCECloud) NetworkURL added in v1.7.0 

func (gce *GCECloud) NetworkURL() string

NetworkURL returns the network url

func (*GCECloud) NodeAddresses 

func (gce *GCECloud) NodeAddresses(_ types.NodeName) ([]v1.NodeAddress, error)

NodeAddresses is an implementation of Instances.NodeAddresses.

func (*GCECloud) NodeAddressesByProviderID added in v1.7.0 

func (gce *GCECloud) NodeAddressesByProviderID(providerID string) ([]v1.NodeAddress, error)

This method will not be called from the node that is requesting this ID. i.e. metadata service and other local methods cannot be used here

func (*GCECloud) OnXPN added in v1.7.0 

func (gce *GCECloud) OnXPN() bool

OnXPN returns true if the cluster is running on a cross project network (XPN)

func (*GCECloud) ProviderName 

func (gce *GCECloud) ProviderName() string

ProviderName returns the cloud provider ID.

func (*GCECloud) Region added in v1.7.0 

func (gce *GCECloud) Region() string

Region returns the region

func (*GCECloud) RemoveInstancesFromInstanceGroup 

func (gce *GCECloud) RemoveInstancesFromInstanceGroup(name string, zone string, instanceRefs []*compute.InstanceReference) error

RemoveInstancesFromInstanceGroup removes the given instances from the instance group.

func (*GCECloud) RemoveInstancesFromTargetPool added in v1.7.0 

func (gce *GCECloud) RemoveInstancesFromTargetPool(name, region string, instanceRefs []*compute.InstanceReference) error

RemoveInstancesToTargetPool removes instances by link to the TargetPool

func (*GCECloud) ReserveGlobalAddress added in v1.7.0 

func (gce *GCECloud) ReserveGlobalAddress(addr *compute.Address) (*compute.Address, error)

ReserveGlobalAddress creates a global address. Caller is allocated a random IP if they do not specify an ipAddress. If an ipAddress is specified, it must belong to the current project, eg: an ephemeral IP associated with a global forwarding rule.

func (*GCECloud) ReserveRegionAddress added in v1.7.0 

func (gce *GCECloud) ReserveRegionAddress(addr *compute.Address, region string) (*compute.Address, error)

ReserveRegionAddress creates a region address

func (*GCECloud) Routes 

func (gce *GCECloud) Routes() (cloudprovider.Routes, bool)

Routes returns an implementation of Routes for Google Compute Engine.

func (*GCECloud) ScrubDNS 

func (gce *GCECloud) ScrubDNS(nameservers, searches []string) (nsOut, srchOut []string)

ScrubDNS filters DNS settings for pods.

func (*GCECloud) SetNamedPortsOfInstanceGroup added in v1.7.0 

func (gce *GCECloud) SetNamedPortsOfInstanceGroup(igName, zone string, namedPorts []*compute.NamedPort) error

SetNamedPortsOfInstanceGroup sets the list of named ports on a given instance group

func (*GCECloud) SetProxyForGlobalForwardingRule 

func (gce *GCECloud) SetProxyForGlobalForwardingRule(forwardingRuleName, targetProxyLink string) error

SetProxyForGlobalForwardingRule links the given TargetHttp(s)Proxy with the given GlobalForwardingRule. targetProxyLink is the SelfLink of a TargetHttp(s)Proxy.

func (*GCECloud) SetSslCertificateForTargetHttpsProxy 

func (gce *GCECloud) SetSslCertificateForTargetHttpsProxy(proxy *compute.TargetHttpsProxy, sslCert *compute.SslCertificate) error

SetSslCertificateForTargetHttpsProxy sets the given SslCertificate for the given TargetHttpsProxy.

func (*GCECloud) SetUrlMapForTargetHttpProxy 

func (gce *GCECloud) SetUrlMapForTargetHttpProxy(proxy *compute.TargetHttpProxy, urlMap *compute.UrlMap) error

SetUrlMapForTargetHttpProxy sets the given UrlMap for the given TargetHttpProxy.

func (*GCECloud) SetUrlMapForTargetHttpsProxy 

func (gce *GCECloud) SetUrlMapForTargetHttpsProxy(proxy *compute.TargetHttpsProxy, urlMap *compute.UrlMap) error

SetUrlMapForTargetHttpsProxy sets the given UrlMap for the given TargetHttpsProxy.

func (*GCECloud) SubnetworkURL added in v1.7.0 

func (gce *GCECloud) SubnetworkURL() string

SubnetworkURL returns the subnetwork url

func (*GCECloud) ToInstanceReferences added in v1.7.0 

func (gce *GCECloud) ToInstanceReferences(zone string, instanceNames []string) (refs []*compute.InstanceReference)

ToInstanceReferences returns instance references by links

func (*GCECloud) UpdateFirewall 

func (gce *GCECloud) UpdateFirewall(f *compute.Firewall) error

UpdateFirewall applies the given firewall as an update to an existing service.

func (*GCECloud) UpdateGlobalBackendService added in v1.7.0 

func (gce *GCECloud) UpdateGlobalBackendService(bg *compute.BackendService) error

UpdateGlobalBackendService applies the given BackendService as an update to an existing service.

func (*GCECloud) UpdateHealthCheck added in v1.7.0 

func (gce *GCECloud) UpdateHealthCheck(hc *compute.HealthCheck) error

UpdateHealthCheck applies the given HealthCheck as an update.

func (*GCECloud) UpdateHttpHealthCheck 

func (gce *GCECloud) UpdateHttpHealthCheck(hc *compute.HttpHealthCheck) error

UpdateHttpHealthCheck applies the given HttpHealthCheck as an update.

func (*GCECloud) UpdateHttpsHealthCheck added in v1.7.0 

func (gce *GCECloud) UpdateHttpsHealthCheck(hc *compute.HttpsHealthCheck) error

UpdateHttpsHealthCheck applies the given HttpsHealthCheck as an update.

func (*GCECloud) UpdateLoadBalancer 

func (gce *GCECloud) UpdateLoadBalancer(clusterName string, svc *v1.Service, nodes []*v1.Node) error

UpdateLoadBalancer is an implementation of LoadBalancer.UpdateLoadBalancer.

func (*GCECloud) UpdateRegionBackendService added in v1.7.0 

func (gce *GCECloud) UpdateRegionBackendService(bg *compute.BackendService, region string) error

UpdateRegionBackendService applies the given BackendService as an update to an existing service.

func (*GCECloud) UpdateUrlMap 

func (gce *GCECloud) UpdateUrlMap(urlMap *compute.UrlMap) (*compute.UrlMap, error)

UpdateUrlMap applies the given UrlMap as an update, and returns the new UrlMap.

func (*GCECloud) Zones 

func (gce *GCECloud) Zones() (cloudprovider.Zones, bool)

Zones returns an implementation of Zones for Google Compute Engine.

type GCEDisk added in v1.7.0 

type GCEDisk struct {
	Zone string
	Name string
	Kind string
	Type string
}

type GCEServiceManager added in v1.7.0 

type GCEServiceManager struct {
	// contains filtered or unexported fields
}

func (*GCEServiceManager) CreateDisk added in v1.7.0 

func (manager *GCEServiceManager) CreateDisk(
	project string,
	zone string,
	disk *compute.Disk) (*compute.Operation, error)

func (*GCEServiceManager) DeleteDisk added in v1.7.0 

func (manager *GCEServiceManager) DeleteDisk(
	project string,
	zone string,
	diskName string) (*compute.Operation, error)

func (*GCEServiceManager) GetDisk added in v1.7.0 

func (manager *GCEServiceManager) GetDisk(
	project string,
	zone string,
	diskName string) (*compute.Disk, error)

func (*GCEServiceManager) WaitForZoneOp added in v1.7.0 

func (manager *GCEServiceManager) WaitForZoneOp(op *compute.Operation, zone string, mc *metricContext) error

type LoadBalancerType added in v1.7.0 

type LoadBalancerType string

func GetLoadBalancerAnnotationType added in v1.7.0 

func GetLoadBalancerAnnotationType(service *v1.Service) (LoadBalancerType, bool)

GetLoadBalancerAnnotationType returns the type of GCP load balancer which should be assembled.

type ServiceManager added in v1.7.0 

type ServiceManager interface {
	// Creates a new persistent disk on GCE with the given disk spec.
	CreateDisk(project string, zone string, disk *compute.Disk) (*compute.Operation, error)

	// Gets the persistent disk from GCE with the given diskName.
	GetDisk(project string, zone string, diskName string) (*compute.Disk, error)

	// Deletes the persistent disk from GCE with the given diskName.
	DeleteDisk(project string, zone string, disk string) (*compute.Operation, error)

	// Waits until GCE reports the given operation in the given zone as done.
	WaitForZoneOp(op *compute.Operation, zone string, mc *metricContext) error
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.