gce

package

Go to main page

Versions in this module

v0

v0.28.2

Dec 4, 2023

v0.27.1

Jul 20, 2023

Changes in this version

type Cloud

+ func (g *Cloud) GetNetwork(networkName string) (*compute.Network, error)

+ func (g *Cloud) LocalZone() string

+ func (g *Cloud) Regional() bool

type TestClusterValues

+ NetworkURL string

+ Regional bool

v0.26.2

Mar 7, 2023

Changes in this version

+ const AlphaFeatureSkipIGsManagement

+ const NetLBFinalizerV2

+ const RBSAnnotationKey

+ const RBSEnabled

type Cloud

+ func (g *Cloud) FilterInstanceGroupsByNamePrefix(namePrefix, zone string) ([]*compute.InstanceGroup, error)

+ func (g *Cloud) GetIPV6Address(networkInterface *compute.NetworkInterface) *net.IPNet

+ func (g *Cloud) PatchFirewall(f *compute.Firewall) error

v0.25.5

Dec 16, 2022

Changes in this version

type Cloud

+ func (g *Cloud) GetSubnetwork(projectName, region, subnetworkName string) (*compute.Subnetwork, error)

+ func (g *Cloud) InstanceByProviderID(providerID string) (res *compute.Instance, err error)

v0.25.3

Oct 28, 2022

v0.25.0

Sep 2, 2022

v0.24.0

Jul 8, 2022

v0.23.0

May 25, 2022

Changes in this version

type CloudConfig

+ StackType string

type ConfigGlobal

+ StackType string

+ type StackType string

+ const NetworkStackDualStack

+ const NetworkStackIPV4

+ const NetworkStackIPV6

v0.21.1

May 18, 2021

v0.21.0

May 5, 2021

Changes in this version

+ const AlphaFeatureILBSubsets

+ const DiskTypeSSD

+ const DiskTypeStandard

+ const ILBFinalizerV1

+ const ILBFinalizerV2

+ const LBTypeInternal

+ const NetworkTierAnnotationKey

+ const NetworkTierAnnotationPremium

+ const NetworkTierAnnotationStandard

+ const ProviderName

+ const ServiceAnnotationILBAllowGlobalAccess

+ const ServiceAnnotationILBBackendShare

+ const ServiceAnnotationILBSubnet

+ const ServiceAnnotationLoadBalancerType

+ const UIDCluster

+ const UIDConfigMapName

+ const UIDLengthBytes

+ const UIDNamespace

+ const UIDProvider

+ func FirewallToGCloudCreateCmd(fw *compute.Firewall, projectID string) string

+ func FirewallToGCloudDeleteCmd(fwName, projectID string) string

+ func FirewallToGCloudUpdateCmd(fw *compute.Firewall, projectID string) string

+ func GetGCERegion(zone string) (string, error)

+ func GetLoadBalancerAnnotationAllowGlobalAccess(service *v1.Service) bool

+ func GetLoadBalancerAnnotationBackendShare(service *v1.Service) bool

+ func GetLoadBalancerAnnotationSubnet(service *v1.Service) string

+ func GetNodesHealthCheckPath() string

+ func GetNodesHealthCheckPort() int32

+ func GetServiceNetworkTier(service *v1.Service) (cloud.NetworkTier, error)

+ func L4LoadBalancerSrcRanges() []string

+ func L7LoadBalancerSrcRanges() []string

+ func MakeFirewallName(name string) string

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

+ func MakeNodesHealthCheckName(clusterID string) string

+ func NewAltTokenSource(tokenURL, tokenBody string) oauth2.TokenSource

+ func UpdateFakeGCECloud(g *Cloud, vals TestClusterValues)

+ type AlphaFeatureGate struct

+ func NewAlphaFeatureGate(features []string) *AlphaFeatureGate

+ func (af *AlphaFeatureGate) Enabled(key string) bool

+ type AltTokenSource struct

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

+ type Cloud struct

+ AlphaFeatureGate *AlphaFeatureGate

+ ClusterID ClusterID

+ func CreateGCECloud(config *CloudConfig) (*Cloud, error)

+ func CreateGCECloudWithCloud(config *CloudConfig, c cloud.Cloud) (*Cloud, error)

+ func NewFakeGCECloud(vals TestClusterValues) *Cloud

+ func (g *Cloud) AddAliasToInstanceByProviderID(providerID string, alias *net.IPNet) error

+ func (g *Cloud) AddInstancesToInstanceGroup(name string, zone string, instanceRefs []*compute.InstanceReference) error

+ func (g *Cloud) AddInstancesToTargetPool(name, region string, instanceRefs []*compute.InstanceReference) error

+ func (g *Cloud) AddRuletoBetaSecurityPolicy(name string, spr *computebeta.SecurityPolicyRule) error

+ func (g *Cloud) AddSSHKeyToAllInstances(ctx context.Context, user string, keyData []byte) error

+ func (g *Cloud) AggregatedListNetworkEndpointGroup() (map[string][]*computebeta.NetworkEndpointGroup, error)

+ func (g *Cloud) AliasRangesByProviderID(providerID string) (cidrs []string, err error)

+ func (g *Cloud) AttachDisk(diskName string, nodeName types.NodeName, readOnly bool, regional bool) error

+ func (g *Cloud) AttachNetworkEndpoints(name, zone string, endpoints []*computebeta.NetworkEndpoint) error

+ func (g *Cloud) BulkDisksAreAttached(diskByNodes map[types.NodeName][]string) (map[types.NodeName]map[string]bool, error)

+ func (g *Cloud) Clusters() (cloudprovider.Clusters, bool)

+ func (g *Cloud) Compute() cloud.Cloud

+ func (g *Cloud) ComputeServices() *Services

+ func (g *Cloud) ContainerService() *container.Service

+ func (g *Cloud) CreateAlphaGlobalBackendService(bg *computealpha.BackendService) error

+ func (g *Cloud) CreateAlphaHealthCheck(hc *computealpha.HealthCheck) error

+ func (g *Cloud) CreateAlphaRegionForwardingRule(rule *computealpha.ForwardingRule, region string) error

+ func (g *Cloud) CreateBetaGlobalBackendService(bg *computebeta.BackendService) error

+ func (g *Cloud) CreateBetaHealthCheck(hc *computebeta.HealthCheck) error

+ func (g *Cloud) CreateBetaRegionForwardingRule(rule *computebeta.ForwardingRule, region string) error

+ func (g *Cloud) CreateBetaSecurityPolicy(sp *computebeta.SecurityPolicy) error

+ func (g *Cloud) CreateDisk(name string, diskType string, zone string, sizeGb int64, ...) (*Disk, error)

+ func (g *Cloud) CreateFirewall(f *compute.Firewall) error

+ func (g *Cloud) CreateGlobalBackendService(bg *compute.BackendService) error

+ func (g *Cloud) CreateGlobalForwardingRule(rule *compute.ForwardingRule) error

+ func (g *Cloud) CreateHTTPHealthCheck(hc *compute.HttpHealthCheck) error

+ func (g *Cloud) CreateHTTPSHealthCheck(hc *compute.HttpsHealthCheck) error

+ func (g *Cloud) CreateHealthCheck(hc *compute.HealthCheck) error

+ func (g *Cloud) CreateInstanceGroup(ig *compute.InstanceGroup, zone string) error

+ func (g *Cloud) CreateNetworkEndpointGroup(neg *computebeta.NetworkEndpointGroup, zone string) error

+ func (g *Cloud) CreateRegionBackendService(bg *compute.BackendService, region string) error

+ func (g *Cloud) CreateRegionForwardingRule(rule *compute.ForwardingRule, region string) error

+ func (g *Cloud) CreateRegionalDisk(name string, diskType string, replicaZones sets.String, sizeGb int64, ...) (*Disk, error)

+ func (g *Cloud) CreateRoute(ctx context.Context, clusterName string, nameHint string, ...) error

+ func (g *Cloud) CreateSslCertificate(sslCerts *compute.SslCertificate) (*compute.SslCertificate, error)

+ func (g *Cloud) CreateTPU(ctx context.Context, name, zone string, node *tpuapi.Node) (*tpuapi.Node, error)

+ func (g *Cloud) CreateTargetHTTPProxy(proxy *compute.TargetHttpProxy) error

+ func (g *Cloud) CreateTargetHTTPSProxy(proxy *compute.TargetHttpsProxy) error

+ func (g *Cloud) CreateTargetPool(tp *compute.TargetPool, region string) error

+ func (g *Cloud) CreateURLMap(urlMap *compute.UrlMap) error

+ func (g *Cloud) CurrentNodeName(ctx context.Context, hostname string) (types.NodeName, error)

+ func (g *Cloud) DeleteBetaSecurityPolicy(name string) error

+ func (g *Cloud) DeleteDisk(diskToDelete string) error

+ func (g *Cloud) DeleteExternalTargetPoolAndChecks(service *v1.Service, name, region, clusterID string, hcNames ...string) error

+ func (g *Cloud) DeleteFirewall(name string) error

+ func (g *Cloud) DeleteGlobalAddress(name string) error

+ func (g *Cloud) DeleteGlobalBackendService(name string) error

+ func (g *Cloud) DeleteGlobalForwardingRule(name string) error

+ func (g *Cloud) DeleteHTTPHealthCheck(name string) error

+ func (g *Cloud) DeleteHTTPSHealthCheck(name string) error

+ func (g *Cloud) DeleteHealthCheck(name string) error

+ func (g *Cloud) DeleteInstance(project, zone, name string) error

+ func (g *Cloud) DeleteInstanceGroup(name string, zone string) error

+ func (g *Cloud) DeleteNetworkEndpointGroup(name string, zone string) error

+ func (g *Cloud) DeleteRegionAddress(name, region string) error

+ func (g *Cloud) DeleteRegionBackendService(name, region string) error

+ func (g *Cloud) DeleteRegionForwardingRule(name, region string) error

+ func (g *Cloud) DeleteRoute(ctx context.Context, clusterName string, route *cloudprovider.Route) error

+ func (g *Cloud) DeleteSslCertificate(name string) error

+ func (g *Cloud) DeleteTPU(ctx context.Context, name, zone string) error

+ func (g *Cloud) DeleteTargetHTTPProxy(name string) error

+ func (g *Cloud) DeleteTargetHTTPSProxy(name string) error

+ func (g *Cloud) DeleteTargetPool(name, region string) error

+ func (g *Cloud) DeleteURLMap(name string) error

+ func (g *Cloud) DetachDisk(devicePath string, nodeName types.NodeName) error

+ func (g *Cloud) DetachNetworkEndpoints(name, zone string, endpoints []*computebeta.NetworkEndpoint) error

+ func (g *Cloud) DiskIsAttached(diskName string, nodeName types.NodeName) (bool, error)

+ func (g *Cloud) DisksAreAttached(diskNames []string, nodeName types.NodeName) (map[string]bool, error)

+ func (g *Cloud) EnsureLoadBalancer(ctx context.Context, clusterName string, svc *v1.Service, nodes []*v1.Node) (*v1.LoadBalancerStatus, error)

+ func (g *Cloud) EnsureLoadBalancerDeleted(ctx context.Context, clusterName string, svc *v1.Service) error

+ func (g *Cloud) GetAllCurrentZones() (sets.String, error)

+ func (g *Cloud) GetAllZonesFromCloudProvider() (sets.String, error)

+ func (g *Cloud) GetAlphaGlobalBackendService(name string) (*computealpha.BackendService, error)

+ func (g *Cloud) GetAlphaHealthCheck(name string) (*computealpha.HealthCheck, error)

+ func (g *Cloud) GetAlphaRegionForwardingRule(name, region string) (*computealpha.ForwardingRule, error)

+ func (g *Cloud) GetAutoLabelsForPD(disk *Disk) (map[string]string, error)

+ func (g *Cloud) GetBetaGlobalBackendService(name string) (*computebeta.BackendService, error)

+ func (g *Cloud) GetBetaHealthCheck(name string) (*computebeta.HealthCheck, error)

+ func (g *Cloud) GetBetaRegionAddress(name, region string) (*computebeta.Address, error)

+ func (g *Cloud) GetBetaRegionAddressByIP(region, ipAddress string) (*computebeta.Address, error)

+ func (g *Cloud) GetBetaRegionForwardingRule(name, region string) (*computebeta.ForwardingRule, error)

+ func (g *Cloud) GetBetaSecurityPolicy(name string) (*computebeta.SecurityPolicy, error)

+ func (g *Cloud) GetDiskByNameUnknownZone(diskName string) (*Disk, error)

+ func (g *Cloud) GetFirewall(name string) (*compute.Firewall, error)

+ func (g *Cloud) GetGlobalAddress(name string) (*compute.Address, error)

+ func (g *Cloud) GetGlobalBackendService(name string) (*compute.BackendService, error)

+ func (g *Cloud) GetGlobalBackendServiceHealth(name string, instanceGroupLink string) (*compute.BackendServiceGroupHealth, error)

+ func (g *Cloud) GetGlobalForwardingRule(name string) (*compute.ForwardingRule, error)

+ func (g *Cloud) GetHTTPHealthCheck(name string) (*compute.HttpHealthCheck, error)

+ func (g *Cloud) GetHTTPSHealthCheck(name string) (*compute.HttpsHealthCheck, error)

+ func (g *Cloud) GetHealthCheck(name string) (*compute.HealthCheck, error)

+ func (g *Cloud) GetInstanceGroup(name string, zone string) (*compute.InstanceGroup, error)

+ func (g *Cloud) GetLabelsForVolume(ctx context.Context, pv *v1.PersistentVolume) (map[string]string, error)

+ func (g *Cloud) GetLoadBalancer(ctx context.Context, clusterName string, svc *v1.Service) (*v1.LoadBalancerStatus, bool, error)

+ func (g *Cloud) GetLoadBalancerName(ctx context.Context, clusterName string, svc *v1.Service) string

+ func (g *Cloud) GetManagedClusters(ctx context.Context) ([]*container.Cluster, error)

+ func (g *Cloud) GetNetworkEndpointGroup(name string, zone string) (*computebeta.NetworkEndpointGroup, error)

+ func (g *Cloud) GetNodeTags(nodeNames []string) ([]string, error)

+ func (g *Cloud) GetRegionAddress(name, region string) (*compute.Address, error)

+ func (g *Cloud) GetRegionAddressByIP(region, ipAddress string) (*compute.Address, error)

+ func (g *Cloud) GetRegionBackendService(name, region string) (*compute.BackendService, error)

+ func (g *Cloud) GetRegionForwardingRule(name, region string) (*compute.ForwardingRule, error)

+ func (g *Cloud) GetRegionalBackendServiceHealth(name, region string, instanceGroupLink string) (*compute.BackendServiceGroupHealth, error)

+ func (g *Cloud) GetRuleForBetaSecurityPolicy(name string) (*computebeta.SecurityPolicyRule, error)

+ func (g *Cloud) GetSslCertificate(name string) (*compute.SslCertificate, error)

+ func (g *Cloud) GetTPU(ctx context.Context, name, zone string) (*tpuapi.Node, error)

+ func (g *Cloud) GetTargetHTTPProxy(name string) (*compute.TargetHttpProxy, error)

+ func (g *Cloud) GetTargetHTTPSProxy(name string) (*compute.TargetHttpsProxy, error)

+ func (g *Cloud) GetTargetPool(name, region string) (*compute.TargetPool, error)

+ func (g *Cloud) GetURLMap(name string) (*compute.UrlMap, error)

+ func (g *Cloud) GetZone(ctx context.Context) (cloudprovider.Zone, error)

+ func (g *Cloud) GetZoneByNodeName(ctx context.Context, nodeName types.NodeName) (cloudprovider.Zone, error)

+ func (g *Cloud) GetZoneByProviderID(ctx context.Context, providerID string) (cloudprovider.Zone, error)

+ func (g *Cloud) HasClusterID() bool

+ func (g *Cloud) Initialize(clientBuilder cloudprovider.ControllerClientBuilder, stop <-chan struct{})

+ func (g *Cloud) InsertInstance(project string, zone string, i *compute.Instance) error

+ func (g *Cloud) InstanceExists(ctx context.Context, node *v1.Node) (bool, error)

+ func (g *Cloud) InstanceExistsByProviderID(ctx context.Context, providerID string) (bool, error)

+ func (g *Cloud) InstanceID(ctx context.Context, nodeName types.NodeName) (string, error)

+ func (g *Cloud) InstanceMetadata(ctx context.Context, node *v1.Node) (*cloudprovider.InstanceMetadata, error)

+ func (g *Cloud) InstanceShutdown(ctx context.Context, node *v1.Node) (bool, error)

+ func (g *Cloud) InstanceShutdownByProviderID(ctx context.Context, providerID string) (bool, error)

+ func (g *Cloud) InstanceType(ctx context.Context, nodeName types.NodeName) (string, error)

+ func (g *Cloud) InstanceTypeByProviderID(ctx context.Context, providerID string) (string, error)

+ func (g *Cloud) Instances() (cloudprovider.Instances, bool)

+ func (g *Cloud) InstancesV2() (cloudprovider.InstancesV2, bool)

+ func (g *Cloud) IsLegacyNetwork() bool

+ func (g *Cloud) ListAlphaRegionForwardingRules(region string) ([]*computealpha.ForwardingRule, error)

+ func (g *Cloud) ListBetaRegionForwardingRules(region string) ([]*computebeta.ForwardingRule, error)

+ func (g *Cloud) ListBetaSecurityPolicy() ([]*computebeta.SecurityPolicy, error)

+ func (g *Cloud) ListClusters(ctx context.Context) ([]string, error)

+ func (g *Cloud) ListGlobalBackendServices() ([]*compute.BackendService, error)

+ func (g *Cloud) ListGlobalForwardingRules() ([]*compute.ForwardingRule, error)

+ func (g *Cloud) ListHTTPHealthChecks() ([]*compute.HttpHealthCheck, error)

+ func (g *Cloud) ListHTTPSHealthChecks() ([]*compute.HttpsHealthCheck, error)

+ func (g *Cloud) ListHealthChecks() ([]*compute.HealthCheck, error)

+ func (g *Cloud) ListInstanceGroups(zone string) ([]*compute.InstanceGroup, error)

+ func (g *Cloud) ListInstanceNames(project, zone string) (string, error)

+ func (g *Cloud) ListInstancesInInstanceGroup(name string, zone string, state string) ([]*compute.InstanceWithNamedPorts, error)

+ func (g *Cloud) ListLocations(ctx context.Context) ([]*tpuapi.Location, error)

+ func (g *Cloud) ListNetworkEndpointGroup(zone string) ([]*computebeta.NetworkEndpointGroup, error)

+ func (g *Cloud) ListNetworkEndpoints(name, zone string, showHealthStatus bool) ([]*computebeta.NetworkEndpointWithHealthStatus, error)

+ func (g *Cloud) ListRegionBackendServices(region string) ([]*compute.BackendService, error)

+ func (g *Cloud) ListRegionForwardingRules(region string) ([]*compute.ForwardingRule, error)

+ func (g *Cloud) ListRoutes(ctx context.Context, clusterName string) ([]*cloudprovider.Route, error)

+ func (g *Cloud) ListSslCertificates() ([]*compute.SslCertificate, error)

+ func (g *Cloud) ListTPUs(ctx context.Context, zone string) ([]*tpuapi.Node, error)

+ func (g *Cloud) ListTargetHTTPProxies() ([]*compute.TargetHttpProxy, error)

+ func (g *Cloud) ListTargetHTTPSProxies() ([]*compute.TargetHttpsProxy, error)

+ func (g *Cloud) ListURLMaps() ([]*compute.UrlMap, error)

+ func (g *Cloud) ListZonesInRegion(region string) ([]*compute.Zone, error)

+ func (g *Cloud) LoadBalancer() (cloudprovider.LoadBalancer, bool)

+ func (g *Cloud) Master(ctx context.Context, clusterName string) (string, error)

+ func (g *Cloud) NetworkProjectID() string

+ func (g *Cloud) NetworkURL() string

+ func (g *Cloud) NodeAddresses(ctx context.Context, nodeName types.NodeName) ([]v1.NodeAddress, error)

+ func (g *Cloud) NodeAddressesByProviderID(ctx context.Context, providerID string) ([]v1.NodeAddress, error)

+ func (g *Cloud) OnXPN() bool

+ func (g *Cloud) PatchBetaSecurityPolicy(sp *computebeta.SecurityPolicy) error

+ func (g *Cloud) PatchRuleForBetaSecurityPolicy(name string, spr *computebeta.SecurityPolicyRule) error

+ func (g *Cloud) ProjectID() string

+ func (g *Cloud) ProviderName() string

+ func (g *Cloud) Region() string

+ func (g *Cloud) RemoveInstancesFromInstanceGroup(name string, zone string, instanceRefs []*compute.InstanceReference) error

+ func (g *Cloud) RemoveInstancesFromTargetPool(name, region string, instanceRefs []*compute.InstanceReference) error

+ func (g *Cloud) RemoveRuleFromBetaSecurityPolicy(name string) error

+ func (g *Cloud) ReserveBetaRegionAddress(addr *computebeta.Address, region string) error

+ func (g *Cloud) ReserveGlobalAddress(addr *compute.Address) error

+ func (g *Cloud) ReserveRegionAddress(addr *compute.Address, region string) error

+ func (g *Cloud) ResizeDisk(diskToResize string, oldSize resource.Quantity, newSize resource.Quantity) (resource.Quantity, error)

+ func (g *Cloud) Routes() (cloudprovider.Routes, bool)

+ func (g *Cloud) SetInformers(informerFactory informers.SharedInformerFactory)

+ func (g *Cloud) SetNamedPortsOfInstanceGroup(igName, zone string, namedPorts []*compute.NamedPort) error

+ func (g *Cloud) SetProxyForGlobalForwardingRule(forwardingRuleName, targetProxyLink string) error

+ func (g *Cloud) SetRateLimiter(rl cloud.RateLimiter)

+ func (g *Cloud) SetSecurityPolicyForAlphaGlobalBackendService(backendServiceName string, ...) error

+ func (g *Cloud) SetSecurityPolicyForBetaGlobalBackendService(backendServiceName string, ...) error

+ func (g *Cloud) SetSslCertificateForTargetHTTPSProxy(proxy *compute.TargetHttpsProxy, sslCertURLs []string) error

+ func (g *Cloud) SetURLMapForTargetHTTPProxy(proxy *compute.TargetHttpProxy, urlMapLink string) error

+ func (g *Cloud) SetURLMapForTargetHTTPSProxy(proxy *compute.TargetHttpsProxy, urlMapLink string) error

+ func (g *Cloud) SubnetworkURL() string

+ func (g *Cloud) ToInstanceReferences(zone string, instanceNames []string) (refs []*compute.InstanceReference)

+ func (g *Cloud) UpdateAlphaGlobalBackendService(bg *computealpha.BackendService) error

+ func (g *Cloud) UpdateAlphaHealthCheck(hc *computealpha.HealthCheck) error

+ func (g *Cloud) UpdateBetaGlobalBackendService(bg *computebeta.BackendService) error

+ func (g *Cloud) UpdateBetaHealthCheck(hc *computebeta.HealthCheck) error

+ func (g *Cloud) UpdateFirewall(f *compute.Firewall) error

+ func (g *Cloud) UpdateGlobalBackendService(bg *compute.BackendService) error

+ func (g *Cloud) UpdateHTTPHealthCheck(hc *compute.HttpHealthCheck) error

+ func (g *Cloud) UpdateHTTPSHealthCheck(hc *compute.HttpsHealthCheck) error

+ func (g *Cloud) UpdateHealthCheck(hc *compute.HealthCheck) error

+ func (g *Cloud) UpdateLoadBalancer(ctx context.Context, clusterName string, svc *v1.Service, nodes []*v1.Node) error

+ func (g *Cloud) UpdateRegionBackendService(bg *compute.BackendService, region string) error

+ func (g *Cloud) UpdateURLMap(urlMap *compute.UrlMap) error

+ func (g *Cloud) Zones() (cloudprovider.Zones, bool)

+ type CloudAddressService interface

+ DeleteRegionAddress func(name, region string) error

+ GetBetaRegionAddress func(name string, region string) (*computebeta.Address, error)

+ GetBetaRegionAddressByIP func(region, ipAddress string) (*computebeta.Address, error)

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

+ GetRegionAddressByIP func(region, ipAddress string) (*compute.Address, error)

+ ReserveBetaRegionAddress func(address *computebeta.Address, region string) error

+ ReserveRegionAddress func(address *compute.Address, region string) error

+ type CloudConfig struct

+ APIEndpoint string

+ AlphaFeatureGate *AlphaFeatureGate

+ ContainerAPIEndpoint string

+ ManagedZones []string

+ NetworkName string

+ NetworkProjectID string

+ NetworkURL string

+ NodeInstancePrefix string

+ NodeTags []string

+ ProjectID string

+ Region string

+ Regional bool

+ SecondaryRangeName string

+ SubnetworkName string

+ SubnetworkURL string

+ TokenSource oauth2.TokenSource

+ UseMetadataServer bool

+ Zone string

+ type CloudForwardingRuleService interface

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

+ DeleteRegionForwardingRule func(name, region string) error

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

+ type ClusterID struct

+ func (ci *ClusterID) GetFederationID() (string, bool, error)

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

+ type ConfigFile struct

+ Global ConfigGlobal

+ type ConfigGlobal struct

+ APIEndpoint string

+ AlphaFeatures []string

+ ContainerAPIEndpoint string

+ LocalZone string

+ Multizone bool

+ NetworkName string

+ NetworkProjectID string

+ NodeInstancePrefix string

+ NodeTags []string

+ ProjectID string

+ Regional bool

+ SecondaryRangeName string

+ SubnetworkName string

+ TokenBody string

+ TokenURL string

+ type Disk struct

+ Kind string

+ Name string

+ Region string

+ SizeGb int64

+ Type string

+ ZoneInfo zoneType

+ type DiskType string

+ type Disks interface

+ AttachDisk func(diskName string, nodeName types.NodeName, readOnly bool, regional bool) error

+ BulkDisksAreAttached func(diskByNodes map[types.NodeName][]string) (map[types.NodeName]map[string]bool, error)

+ CreateDisk func(name string, diskType string, zone string, sizeGb int64, ...) (*Disk, error)

+ CreateRegionalDisk func(name string, diskType string, replicaZones sets.String, sizeGb int64, ...) (*Disk, error)

+ DeleteDisk func(diskToDelete string) error

+ DetachDisk func(devicePath string, nodeName types.NodeName) error

+ DiskIsAttached func(diskName string, nodeName types.NodeName) (bool, error)

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

+ GetAutoLabelsForPD func(disk *Disk) (map[string]string, error)

+ ResizeDisk func(diskToResize string, oldSize resource.Quantity, newSize resource.Quantity) (resource.Quantity, error)

+ type ILBOptions struct

+ AllowGlobalAccess bool

+ SubnetName string

+ type L4ILBServiceState struct

+ EnabledCustomSubnet bool

+ EnabledGlobalAccess bool

+ InSuccess bool

+ type LoadBalancerMetrics struct

+ func (lm *LoadBalancerMetrics) DeleteL4ILBService(svcKey string)

+ func (lm *LoadBalancerMetrics) Run(stopCh <-chan struct{})

+ func (lm *LoadBalancerMetrics) SetL4ILBService(svcKey string, state L4ILBServiceState)

+ type LoadBalancerType string

+ func GetLoadBalancerAnnotationType(service *v1.Service) LoadBalancerType

+ type Services struct

+ Alpha *computealpha.Service

+ Beta *computebeta.Service

+ GA *compute.Service

+ type TestClusterValues struct

+ ClusterID string

+ ClusterName string

+ OnXPN bool

+ ProjectID string

+ Region string

+ SecondaryZoneName string

+ ZoneName string

+ func DefaultTestClusterValues() TestClusterValues

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL