openstack

func BindFIPToPort ¶

func BindFIPToPort(
	ctx context.Context,
	fipClient openstack.FipClient,
	fipID string,
	portID *string,
) error

BindFIPToPort binds a fip to a port

func BindSecGroupToPortIfNeeded ¶

func BindSecGroupToPortIfNeeded(
	ctx context.Context,
	portClient openstack.PortClient,
	secGroup *string,
	port *ports.Port,
) (bool, error)

BindSecGroupToPortIfNeeded binds a SecGroup to a port if needed.

func CreateFIP ¶

func CreateFIP(
	ctx context.Context,
	fipClient openstack.FipClient,
	lb *yawolv1beta1.LoadBalancer,
) (*floatingips.FloatingIP, error)

CreateFIP creates a FIP and returns it.

func CreateNonExistingSecGroupRules ¶

func CreateNonExistingSecGroupRules(
	ctx context.Context,
	ruleClient openstack.RuleClient,
	namespacedName string,
	secGroup *groups.SecGroup,
	desiredSecGroupRules []rules.SecGroupRule,
) error

CreateNonExistingSecGroupRules create desiredSecGroupRules if not present in secGroup.

func CreatePort ¶

func CreatePort(
	ctx context.Context,
	portClient openstack.PortClient,
	portName string,
	networkID string,
) (*ports.Port, error)

CreatePort creates a port in openstack

func CreateSecGroup ¶

func CreateSecGroup(
	ctx context.Context,
	groupClient openstack.GroupClient,
	name string,
) (*groups.SecGroup, error)

CreateSecGroup creates a SecGroup and returns it.

func CreateSecGroupRule ¶

func CreateSecGroupRule(
	ctx context.Context,
	ruleClient openstack.RuleClient,
	secGroupID string,
	namespacedName string,
	rule *rules.SecGroupRule,
) error

func CreateServer ¶

func CreateServer(
	ctx context.Context,
	serverClient openstack.ServerClient,
	opts servers.CreateOptsBuilder,
) (*servers.Server, error)

func CreateServerGroup ¶ added in v0.11.0

func CreateServerGroup(
	ctx context.Context,
	serverGroupClient openstack.ServerGroupClient,
	serverGroupName string,
	affinity string,
) (*servergroups.ServerGroup, error)

CreateServerGroup creates a server group in openstack

func DeleteFIP ¶

func DeleteFIP(
	ctx context.Context,
	fipClient openstack.FipClient,
	fipID string,
) error

DeleteFIP deletes a FIP and returns the error.

func DeletePort ¶

func DeletePort(
	ctx context.Context,
	portClient openstack.PortClient,
	portID string,
) error

DeletePort deletes a port by ID

func DeleteSecGroup ¶

func DeleteSecGroup(
	ctx context.Context,
	groupClient openstack.GroupClient,
	secGroupID string,
) error

DeleteSecGroup deletes a SecGroup by ID.

func DeleteSecGroupRule ¶

func DeleteSecGroupRule(
	ctx context.Context,
	ruleClient openstack.RuleClient,
	ruleID string,
) error

func DeleteServer ¶

func DeleteServer(
	ctx context.Context,
	serverClient openstack.ServerClient,
	serverID string,
) error

func DeleteServerGroup ¶ added in v0.11.0

func DeleteServerGroup(
	ctx context.Context,
	serverGroupClient openstack.ServerGroupClient,
	serverGroupID string,
) error

DeleteServerGroup deletes a server group by ID

func DeleteUnusedSecGroupRulesFromSecGroup ¶

func DeleteUnusedSecGroupRulesFromSecGroup(
	ctx context.Context,
	ruleClient openstack.RuleClient,
	secGroup *groups.SecGroup,
	desiredSecGroupRules []rules.SecGroupRule,
) error

DeleteUnusedSecGroupRulesFromSecGroup deletes rules that are not used anymore. Deletion must happen before creation in order to not have temporary duplicated / overlapping rules

func GetAllPorts ¶

func GetAllPorts(
	ctx context.Context,
	portClient openstack.PortClient,
) ([]ports.Port, error)

GetAllPorts returns all ports that can be shown.

func GetFIPByID ¶

func GetFIPByID(
	ctx context.Context,
	fipClient openstack.FipClient,
	fipID string,
) (*floatingips.FloatingIP, error)

GetFIPByID returns a FIP filtered by an openstack ID. Returns an error on connection issues. Returns err if not found.

func GetFIPByIP ¶

func GetFIPByIP(
	ctx context.Context,
	fipClient openstack.FipClient,
	fipIP string,
) (*floatingips.FloatingIP, error)

GetFIPByIP returns a FIP filtered By IP. Returns an error on connection issues. Returns nil if not found.

func GetFIPByName ¶

func GetFIPByName(
	ctx context.Context,
	fipClient openstack.FipClient,
	fipName string,
) (*floatingips.FloatingIP, error)

GetFIPByName returns a FIP filtered By Name. Returns an error on connection issues. Returns nil if not found.

func GetOpenStackClientForInfrastructure ¶ added in v0.11.0

func GetOpenStackClientForInfrastructure(
	ctx context.Context,
	c client.Client,
	infra yawolv1beta1.LoadBalancerInfrastructure,
	getOsClientForIni openstack.GetOSClientFunc,
) (openstack.Client, error)

func GetPortByID ¶

func GetPortByID(
	ctx context.Context,
	portClient openstack.PortClient,
	portID string,
) (*ports.Port, error)

GetPortByID returns a port by an openstack ID. Returns an error on connection issues. Returns err if not found.

func GetPortByName ¶

func GetPortByName(
	ctx context.Context,
	portClient openstack.PortClient,
	portName string,
) (*ports.Port, error)

GetPortByName returns a Port filtered By Name. Returns an error on connection issues. Returns nil if not found.

func GetSecGroupByID ¶

func GetSecGroupByID(
	ctx context.Context,
	secGroupClient openstack.GroupClient,
	secGroupID string,
) (*groups.SecGroup, error)

GetSecGroupByID returns a secGroup by an openstack ID. Returns an error on connection issues. Returns err if not found.

func GetSecGroupByName ¶

func GetSecGroupByName(
	ctx context.Context,
	groupClient openstack.GroupClient,
	groupName string,
) (*groups.SecGroup, error)

GetSecGroupByName returns a Port filtered By Name. Returns an error on connection issues. Returns nil if not found.

func GetServerByID ¶

func GetServerByID(
	ctx context.Context,
	serverClient openstack.ServerClient,
	serverID string,
) (*servers.Server, error)

func GetServerByName ¶

func GetServerByName(
	ctx context.Context,
	serverClient openstack.ServerClient,
	serverName string,
) (*servers.Server, error)

GetServerByName returns a Server filtered By Name. Returns an error on connection issues. Returns nil if not found.

func GetServerGroupByID ¶ added in v0.11.0

func GetServerGroupByID(
	ctx context.Context,
	serverGroupClient openstack.ServerGroupClient,
	serverGroupID string,
) (*servergroups.ServerGroup, error)

GetServerGroupByID returns a server group by an openstack ID. Returns an error on connection issues. Returns err if not found.

func GetServerGroupByName ¶ added in v0.11.0

func GetServerGroupByName(
	ctx context.Context,
	serverGroupClient openstack.ServerGroupClient,
	serverGroupName string,
) (*servergroups.ServerGroup, error)

GetServerGroupByName returns a server group filtered By Name. Returns an error on connection issues. Returns nil if not found.

func RemoveSecGroupFromPortIfNeeded ¶

func RemoveSecGroupFromPortIfNeeded(
	ctx context.Context,
	portClient openstack.PortClient,
	port *ports.Port,
	secGroupID string,
) error

RemoveSecGroupFromPortIfNeeded removes a SecGroup from a port if needed.

func SecGroupRuleIsEqual ¶

func SecGroupRuleIsEqual(first, second *rules.SecGroupRule) bool

SecGroupRuleIsEqual returns true if both SecGroupRules are equal.

func SetAllowedAddressPairsInPort ¶

func SetAllowedAddressPairsInPort(
	ctx context.Context,
	portClient openstack.PortClient,
	port *ports.Port,
	addressPair *[]ports.AddressPair,
) error

BindSecGroupToPortIfNeeded binds a SecGroup to a port if needed.