openstack

package
v1.35.0 Latest Latest
Warning

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

 Go to latest Published: Jan 23, 2026 License: Apache-2.0 Imports: 28 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ExistingPolicy added in v1.19.4 

type ExistingPolicy struct {
	Policy l7policies.L7Policy
	Rules  []l7policies.Rule
}

type IngPolicy added in v1.19.4 

type IngPolicy struct {
	RedirectPoolName string
	Opts             l7policies.CreateOpts
	RulesOpts        []l7policies.CreateRuleOpts
}

type IngPool added in v1.19.4 

type IngPool struct {
	Name        string
	Opts        pools.CreateOptsBuilder
	PoolMembers []pools.BatchUpdateMemberOpts
}

type OpenStack 

type OpenStack struct {
	Octavia *gophercloud.ServiceClient

	Barbican *gophercloud.ServiceClient
	// contains filtered or unexported fields
}

OpenStack is an implementation of cloud provider Interface for OpenStack.

func NewOpenStack 

func NewOpenStack(cfg config.Config) (*OpenStack, error)

NewOpenStack gets openstack struct

func (*OpenStack) EnsureFloatingIP 

func (os *OpenStack) EnsureFloatingIP(ctx context.Context, needDelete bool, portID string, existingfloatingIP string, floatingIPNetwork string, description string) (string, error)

EnsureFloatingIP makes sure a floating IP is allocated for the port

func (*OpenStack) EnsureListener 

func (os *OpenStack) EnsureListener(ctx context.Context, name string, lbID string, secretRefs []string, listenerAllowedCIDRs []string, timeoutClientData, timeoutMemberData, timeoutTCPInspect, timeoutMemberConnect *int) (*listeners.Listener, error)

EnsureListener creates a loadbalancer listener in octavia if it does not exist, wait for the loadbalancer to be ACTIVE.

func (*OpenStack) EnsureLoadBalancer 

func (os *OpenStack) EnsureLoadBalancer(ctx context.Context, name string, subnetID string, ingNamespace string, ingName string, clusterName string, flavorId string) (*loadbalancers.LoadBalancer, error)

EnsureLoadBalancer creates a loadbalancer in octavia if it does not exist, wait for the loadbalancer to be ACTIVE.

func (*OpenStack) EnsurePoolMembers 

func (os *OpenStack) EnsurePoolMembers(ctx context.Context, deleted bool, poolName string, lbID string, listenerID string, nodePort *int, nodes []*apiv1.Node) (*string, error)

EnsurePoolMembers ensure the pool and its members exist if deleted flag is not set, delete the pool and all its members otherwise.

func (*OpenStack) EnsurePortSecurityGroup added in v1.14.0 

func (os *OpenStack) EnsurePortSecurityGroup(ctx context.Context, needDelete bool, sgID string, nodes []*v1.Node) error

EnsurePortSecurityGroup ensures the security group is attached to all the node ports or detached from all the ports according to needDelete param.

func (*OpenStack) EnsureSecurityGroup added in v1.14.0 

func (os *OpenStack) EnsureSecurityGroup(ctx context.Context, needDelete bool, name string, description string, tags []string) (string, error)

EnsureSecurityGroup make sure the security group with given tags exists or not according to need_delete param. Make sure the EnsurePortSecurityGroup function is called before EnsureSecurityGroup if you want to delete the security group.

func (*OpenStack) EnsureSecurityGroupRules added in v1.14.0 

func (os *OpenStack) EnsureSecurityGroupRules(ctx context.Context, sgID string, sourceIP string, dstPorts []int) error

EnsureSecurityGroupRules ensures the only dstPorts are allowed in the given security group.

func (*OpenStack) GetSecurityGroups added in v1.14.0 

func (os *OpenStack) GetSecurityGroups(ctx context.Context, listOpts groups.ListOpts) ([]groups.SecGroup, error)

GetSecurityGroups gets all the filtered security groups.

func (*OpenStack) GetSubnet added in v1.14.0 

func (os *OpenStack) GetSubnet(ctx context.Context, subnetID string) (*subnets.Subnet, error)

GetSubnet get a subnet by the given ID.

func (*OpenStack) UpdateLoadBalancerDescription added in v1.14.0 

func (os *OpenStack) UpdateLoadBalancerDescription(ctx context.Context, lbID string, newDescription string) error

UpdateLoadBalancerDescription updates the load balancer description field.

func (*OpenStack) UpdateLoadbalancerMembers 

func (os *OpenStack) UpdateLoadbalancerMembers(ctx context.Context, lbID string, nodes []*apiv1.Node) error

UpdateLoadbalancerMembers update members for all the pools in the specified load balancer.

type ResourceTracker added in v1.19.4 

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

ResourceTracker tracks the resources created for Ingress.

func NewResourceTracker added in v1.19.4 

func NewResourceTracker(ingressName string, client *gophercloud.ServiceClient, lbID string, listenerID string, newPools []IngPool, newPolicies []IngPolicy, oldPools []pools.Pool, oldPolicies []ExistingPolicy) *ResourceTracker

func (*ResourceTracker) CleanupResources added in v1.19.4 

func (rt *ResourceTracker) CleanupResources(ctx context.Context) error

func (*ResourceTracker) CreateResources added in v1.19.4 

func (rt *ResourceTracker) CreateResources(ctx context.Context) error

createResources only creates resources when necessary.

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.