1
0
mirror of https://github.com/lxc/incus.git synced 2026-02-05 09:46:19 +01:00

client: Add network address set functions

Signed-off-by: Isidore Reinhardt <pro.irhndt@4fk.fr>
This commit is contained in:
Isidore Reinhardt
2025-03-11 19:23:29 -04:00
committed by Stéphane Graber
parent 067a228d09
commit 8eed850782
2 changed files with 145 additions and 0 deletions

View File

@@ -0,0 +1,135 @@
package incus
import (
"fmt"
"net/url"
"github.com/lxc/incus/v6/shared/api"
)
// GetNetworkAddressSetNames returns a list of network address set names.
func (r *ProtocolIncus) GetNetworkAddressSetNames() ([]string, error) {
if !r.HasExtension("network_address_set") {
return nil, fmt.Errorf(`The server is missing the required "network_address_set" API extension`)
}
// Fetch the raw URL values.
urls := []string{}
baseURL := "/network-address-sets"
_, err := r.queryStruct("GET", baseURL, nil, "", &urls)
if err != nil {
return nil, err
}
// Parse it.
return urlsToResourceNames(baseURL, urls...)
}
// GetNetworkAddressSets returns a list of network address set structs.
func (r *ProtocolIncus) GetNetworkAddressSets() ([]api.NetworkAddressSet, error) {
if !r.HasExtension("network_address_set") {
return nil, fmt.Errorf(`The server is missing the required "network_address_set" API extension`)
}
addressSets := []api.NetworkAddressSet{}
// Fetch the raw value.
_, err := r.queryStruct("GET", "/network-address-sets?recursion=1", nil, "", &addressSets)
if err != nil {
return nil, err
}
return addressSets, nil
}
// GetNetworkAddressSetsAllProjects returns a list of network address set structs across all projects.
func (r *ProtocolIncus) GetNetworkAddressSetsAllProjects() ([]api.NetworkAddressSet, error) {
if !r.HasExtension("network_address_sets_all_projects") {
return nil, fmt.Errorf(`The server is missing the required "network_address_sets_all_projects" API extension`)
}
addressSets := []api.NetworkAddressSet{}
_, err := r.queryStruct("GET", "/network-address-sets?recursion=1&all-projects=true", nil, "", &addressSets)
if err != nil {
return nil, err
}
return addressSets, nil
}
// GetNetworkAddressSet returns a network address set entry for the provided name.
func (r *ProtocolIncus) GetNetworkAddressSet(name string) (*api.NetworkAddressSet, string, error) {
if !r.HasExtension("network_address_set") {
return nil, "", fmt.Errorf(`The server is missing the required "network_address_set" API extension`)
}
addrSet := api.NetworkAddressSet{}
// Fetch the raw value.
etag, err := r.queryStruct("GET", fmt.Sprintf("/network-address-sets/%s", url.PathEscape(name)), nil, "", &addrSet)
if err != nil {
return nil, "", err
}
return &addrSet, etag, nil
}
// CreateNetworkAddressSet defines a new network address set using the provided struct.
func (r *ProtocolIncus) CreateNetworkAddressSet(as api.NetworkAddressSetsPost) error {
if !r.HasExtension("network_address_set") {
return fmt.Errorf(`The server is missing the required "network_address_set" API extension`)
}
// Send the request.
_, _, err := r.query("POST", "/network-address-sets", as, "")
if err != nil {
return err
}
return nil
}
// UpdateNetworkAddressSet updates the network address set to match the provided struct.
func (r *ProtocolIncus) UpdateNetworkAddressSet(name string, as api.NetworkAddressSetPut, ETag string) error {
if !r.HasExtension("network_address_set") {
return fmt.Errorf(`The server is missing the required "network_address_set" API extension`)
}
// Send the request.
_, _, err := r.query("PUT", fmt.Sprintf("/network-address-sets/%s", url.PathEscape(name)), as, ETag)
if err != nil {
return err
}
return nil
}
// RenameNetworkAddressSet renames an existing network address set entry.
func (r *ProtocolIncus) RenameNetworkAddressSet(name string, as api.NetworkAddressSetPost) error {
if !r.HasExtension("network_address_set") {
return fmt.Errorf(`The server is missing the required "network_address_set" API extension`)
}
// Send the request.
_, _, err := r.query("POST", fmt.Sprintf("/network-address-sets/%s", url.PathEscape(name)), as, "")
if err != nil {
return err
}
return nil
}
// DeleteNetworkAddressSet deletes an existing network address set.
func (r *ProtocolIncus) DeleteNetworkAddressSet(name string) error {
if !r.HasExtension("network_address_set") {
return fmt.Errorf(`The server is missing the required "network_address_set" API extension`)
}
// Send the request.
_, _, err := r.query("DELETE", fmt.Sprintf("/network-address-sets/%s", url.PathEscape(name)), nil, "")
if err != nil {
return err
}
return nil
}

View File

@@ -239,6 +239,16 @@ type InstanceServer interface {
RenameNetworkACL(name string, acl api.NetworkACLPost) (err error)
DeleteNetworkACL(name string) (err error)
// Network address set functions ("network_address_set" API extension)
GetNetworkAddressSetNames() (names []string, err error)
GetNetworkAddressSets() (AddressSets []api.NetworkAddressSet, err error)
GetNetworkAddressSetsAllProjects() (AddressSets []api.NetworkAddressSet, err error)
GetNetworkAddressSet(name string) (AddressSet *api.NetworkAddressSet, ETag string, err error)
CreateNetworkAddressSet(AddressSet api.NetworkAddressSetsPost) (err error)
UpdateNetworkAddressSet(name string, AddressSet api.NetworkAddressSetPut, ETag string) (err error)
RenameNetworkAddressSet(name string, AddressSet api.NetworkAddressSetPost) (err error)
DeleteNetworkAddressSet(name string) (err error)
// Network allocations functions ("network_allocations" API extension)
GetNetworkAllocations() (allocations []api.NetworkAllocations, err error)
GetNetworkAllocationsAllProjects() (allocations []api.NetworkAllocations, err error)