openstack

Documentation

Index

• type ExistingPolicy
• type IngPolicy
• type IngPool
• type OpenStack
  • func NewOpenStack(cfg config.Config) (*OpenStack, error)
  • func (os *OpenStack) EnsureFloatingIP(needDelete bool, portID string, floatingIPNetwork string, description string) (string, error)
  • func (os *OpenStack) EnsureListener(name string, lbID string, secretRefs []string, listenerAllowedCIDRs []string) (*listeners.Listener, error)
  • func (os *OpenStack) EnsureLoadBalancer(name string, subnetID string, ingNamespace string, ingName string, ...) (*loadbalancers.LoadBalancer, error)
  • func (os *OpenStack) EnsurePoolMembers(deleted bool, poolName string, lbID string, listenerID string, nodePort *int, ...) (*string, error)
  • func (os *OpenStack) EnsurePortSecurityGroup(needDelete bool, sgID string, nodes []*v1.Node) error
  • func (os *OpenStack) EnsureSecurityGroup(needDelete bool, name string, description string, tags []string) (string, error)
  • func (os *OpenStack) EnsureSecurityGroupRules(sgID string, sourceIP string, dstPorts []int) error
  • func (os *OpenStack) GetSecurityGroups(listOpts groups.ListOpts) ([]groups.SecGroup, error)
  • func (os *OpenStack) GetSubnet(subnetID string) (*subnets.Subnet, error)
  • func (os *OpenStack) UpdateLoadBalancerDescription(lbID string, newDescription string) error
  • func (os *OpenStack) UpdateLoadbalancerMembers(lbID string, nodes []*apiv1.Node) error
• type ResourceTracker
  • func NewResourceTracker(ingressName string, client *gophercloud.ServiceClient, lbID string, ...) *ResourceTracker
  • func (rt *ResourceTracker) CleanupResources() error
  • func (rt *ResourceTracker) CreateResources() error

Types

type ExistingPolicy

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

type IngPolicy

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

type IngPool

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(needDelete bool, portID 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(name string, lbID string, secretRefs []string, listenerAllowedCIDRs []string) (*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(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(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

func (os *OpenStack) EnsurePortSecurityGroup(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

func (os *OpenStack) EnsureSecurityGroup(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

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

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

func (*OpenStack) GetSecurityGroups

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

GetSecurityGroups gets all the filtered security groups.

func (*OpenStack) GetSubnet

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

GetSubnet get a subnet by the given ID.

func (*OpenStack) UpdateLoadBalancerDescription

func (os *OpenStack) UpdateLoadBalancerDescription(lbID string, newDescription string) error

UpdateLoadBalancerDescription updates the load balancer description field.

func (*OpenStack) UpdateLoadbalancerMembers

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

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

type ResourceTracker

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

ResourceTracker tracks the resources created for Ingress.

func NewResourceTracker

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

func (*ResourceTracker) CleanupResources

func (rt *ResourceTracker) CleanupResources() error

func (*ResourceTracker) CreateResources

func (rt *ResourceTracker) CreateResources() error

createResources only creates resources when necessary.