Versions in this module Expand all Collapse all v1 v1.16.3 Nov 9, 2022 Changes in this version + func ConstructFirewallForLBService(svc *v1.Service, nodeTag string) *compute.Firewall + func ConstructHealthCheckFirewallForLBService(clusterID string, svc *v1.Service, nodeTag string, isNodesHealthCheck bool) *compute.Firewall + func GcloudComputeResourceCreate(resource, name, project string, args ...string) error + func GcloudComputeResourceDelete(resource, name, project string, args ...string) error + func GetClusterID(c clientset.Interface) (string, error) + func GetClusterName(instancePrefix string) string + func GetE2eFirewalls(masterName, masterTag, nodeTag, network, clusterIPRange string) []*compute.Firewall + func GetGCECloud() (*gcecloud.Cloud, error) + func GetInstancePrefix(masterName string) (string, error) + func GetInstanceTags(cloudConfig framework.CloudConfig, instanceName string) *compute.Tags + func GetNodeTags(c clientset.Interface, cloudConfig framework.CloudConfig) []string + func IsGoogleAPIHTTPErrorCode(err error, code int) bool + func MakeFirewallNameForLBService(name string) string + func MakeHealthCheckFirewallNameForLBService(clusterID, name string, isNodesHealthCheck bool) string + func NewProvider(gceCloud *gcecloud.Cloud) framework.ProviderInterface + func PackProtocolsPortsFromFirewall(alloweds []*compute.FirewallAllowed) []string + func RecreateNodes(c clientset.Interface, nodes []v1.Node) error + func SameStringArray(result, expected []string, include bool) error + func SetInstanceTags(cloudConfig framework.CloudConfig, instanceName, zone string, tags []string) []string + func VerifyFirewallRule(res, exp *compute.Firewall, network string, portsSubset bool) error + func WaitForFirewallRule(gceCloud *gcecloud.Cloud, fwName string, exist bool, timeout time.Duration) (*compute.Firewall, error) + func WaitForNodeBootIdsToChange(c clientset.Interface, nodes []v1.Node, timeout time.Duration) error + type IngressController struct + Client clientset.Interface + Cloud framework.CloudConfig + Ns string + UID string + func (cont *IngressController) BackendServiceUsingIG(svcPorts map[string]v1.ServicePort) error + func (cont *IngressController) BackendServiceUsingNEG(svcPorts map[string]v1.ServicePort) error + func (cont *IngressController) Cleanup(del bool) error + func (cont *IngressController) CleanupIngressController() error + func (cont *IngressController) CleanupIngressControllerWithTimeout(timeout time.Duration) error + func (cont *IngressController) CreateStaticIP(name string) string + func (cont *IngressController) GetFirewallRule() *compute.Firewall + func (cont *IngressController) GetFirewallRuleName() string + func (cont *IngressController) GetFirewallRuleOrError() (*compute.Firewall, error) + func (cont *IngressController) GetGlobalAddress(ipName string) *compute.Address + func (cont *IngressController) Init() error + func (cont *IngressController) ListGlobalBackendServices() []*compute.BackendService + func (cont *IngressController) ListGlobalForwardingRules() []*compute.ForwardingRule + func (cont *IngressController) ListInstanceGroups() []*compute.InstanceGroup + func (cont *IngressController) ListSslCertificates() []*compute.SslCertificate + func (cont *IngressController) ListTargetHTTPProxies() []*compute.TargetHttpProxy + func (cont *IngressController) ListTargetHTTPSProxies() []*compute.TargetHttpsProxy + func (cont *IngressController) ListURLMaps() []*compute.UrlMap + func (cont *IngressController) WaitForIgBackendService(svcPorts map[string]v1.ServicePort) error + func (cont *IngressController) WaitForNegBackendService(svcPorts map[string]v1.ServicePort) error + type Provider struct + func (p *Provider) CleanupServiceResources(c clientset.Interface, loadBalancerName, region, zone string) + func (p *Provider) CreatePD(zone string) (string, error) + func (p *Provider) CreatePVSource(zone, diskName string) (*v1.PersistentVolumeSource, error) + func (p *Provider) DeleteNode(node *v1.Node) error + func (p *Provider) DeletePD(pdName string) error + func (p *Provider) DeletePVSource(pvSource *v1.PersistentVolumeSource) error + func (p *Provider) EnableAndDisableInternalLB() (enable, disable func(svc *v1.Service)) + func (p *Provider) EnsureLoadBalancerResourcesDeleted(ip, portRange string) error + func (p *Provider) GetGroupNodes(group string) ([]string, error) + func (p *Provider) GroupSize(group string) (int, error) + func (p *Provider) LoadBalancerSrcRanges() []string + func (p *Provider) ResizeGroup(group string, size int32) error