db

package

Go to main page

Versions in this module

v0

v0.7.0

Mar 26, 2024

Changes in this version

type ClusterTx — linux/amd64

+ func (c *ClusterTx) GetNetworkPeersURLByIntegration(ctx context.Context, networkIntegration string) ([]string, error)

v0.6.0

Feb 22, 2024

Changes in this version

type ClusterTx — linux/amd64

+ func (c *ClusterTx) CreateStoragePoolBucketBackup(ctx context.Context, args StoragePoolBucketBackup) error

+ func (c *ClusterTx) DeleteStoragePoolBucketBackup(ctx context.Context, name string) error

+ func (c *ClusterTx) GetExpiredStorageBucketBackups(ctx context.Context) ([]StoragePoolBucketBackup, error)

+ func (c *ClusterTx) GetStoragePoolBucketBackup(ctx context.Context, projectName string, poolName string, backupName string) (StoragePoolBucketBackup, error)

+ func (c *ClusterTx) GetStoragePoolBucketBackupsName(ctx context.Context, projectName string, bucketName string) ([]string, error)

+ func (c *ClusterTx) GetStoragePoolBucketWithID(ctx context.Context, bucketID int) (StorageBucket, error)

+ func (c *ClusterTx) RenameBucketBackup(ctx context.Context, oldName, newName string) error

+ func (c *ClusterTx) UpdateRemoteStoragePoolAfterNodeJoin(ctx context.Context, poolID int64, nodeID int64) error

+ type StoragePoolBucketBackup struct — linux/amd64

+ BucketID int64

+ CompressionAlgorithm string

+ CreationDate time.Time

+ ExpiryDate time.Time

+ ID int

+ Name string

v0.5.1

Jan 28, 2024

v0.5.0

Jan 25, 2024

Changes in this version

type ClusterTx — linux/amd64

+ func (c *ClusterTx) AddImageToLocalNode(ctx context.Context, project, fingerprint string) error

+ func (c *ClusterTx) CopyDefaultImageProfiles(ctx context.Context, id int, newID int) error

+ func (c *ClusterTx) CreateImage(ctx context.Context, project string, fp string, fname string, sz int64, ...) error

+ func (c *ClusterTx) CreateImageSource(ctx context.Context, id int, server string, protocol string, ...) error

+ func (c *ClusterTx) CreateInstanceBackup(ctx context.Context, args InstanceBackup) error

+ func (c *ClusterTx) CreateNetwork(ctx context.Context, projectName string, name string, description string, ...) (int64, error)

+ func (c *ClusterTx) CreateNetworkACL(ctx context.Context, projectName string, info *api.NetworkACLsPost) (int64, error)

+ func (c *ClusterTx) CreateNetworkForward(ctx context.Context, networkID int64, memberSpecific bool, ...) (int64, error)

+ func (c *ClusterTx) CreateNetworkLoadBalancer(ctx context.Context, networkID int64, memberSpecific bool, ...) (int64, error)

+ func (c *ClusterTx) CreateNetworkPeer(ctx context.Context, networkID int64, info *api.NetworkPeersPost) (int64, bool, error)

+ func (c *ClusterTx) CreateNetworkZone(ctx context.Context, projectName string, info *api.NetworkZonesPost) (int64, error)

+ func (c *ClusterTx) CreateNetworkZoneRecord(ctx context.Context, zone int64, info api.NetworkZoneRecordsPost) (int64, error)

+ func (c *ClusterTx) CreateStoragePool(ctx context.Context, poolName string, poolDescription string, ...) (int64, error)

+ func (c *ClusterTx) CreateStoragePoolBucket(ctx context.Context, poolID int64, projectName string, memberSpecific bool, ...) (int64, error)

+ func (c *ClusterTx) CreateStoragePoolBucketKey(ctx context.Context, bucketID int64, info api.StorageBucketKeysPost) (int64, error)

+ func (c *ClusterTx) CreateStoragePoolVolume(ctx context.Context, projectName string, volumeName string, ...) (int64, error)

+ func (c *ClusterTx) CreateStoragePoolVolumeBackup(ctx context.Context, args StoragePoolVolumeBackup) error

+ func (c *ClusterTx) CreateStorageVolumeSnapshot(ctx context.Context, projectName string, volumeName string, ...) (int64, error)

+ func (c *ClusterTx) DeleteImage(ctx context.Context, id int) error

+ func (c *ClusterTx) DeleteInstance(ctx context.Context, project, name string) error

+ func (c *ClusterTx) DeleteInstanceBackup(ctx context.Context, name string) error

+ func (c *ClusterTx) DeleteNetwork(ctx context.Context, project string, name string) error

+ func (c *ClusterTx) DeleteNetworkACL(ctx context.Context, id int64) error

+ func (c *ClusterTx) DeleteNetworkForward(ctx context.Context, networkID int64, forwardID int64) error

+ func (c *ClusterTx) DeleteNetworkLoadBalancer(ctx context.Context, networkID int64, loadBalancerID int64) error

+ func (c *ClusterTx) DeleteNetworkZone(ctx context.Context, id int64) error

+ func (c *ClusterTx) DeleteNetworkZoneRecord(ctx context.Context, id int64) error

+ func (c *ClusterTx) DeleteReadyStateFromLocalInstances(ctx context.Context) error

+ func (c *ClusterTx) DeleteStoragePoolBucket(ctx context.Context, poolID int64, bucketID int64) error

+ func (c *ClusterTx) DeleteStoragePoolBucketKey(ctx context.Context, bucketID int64, keyID int64) error

+ func (c *ClusterTx) DeleteStoragePoolVolumeBackup(ctx context.Context, name string) error

+ func (c *ClusterTx) GetCreatedNetworkNamesByProject(ctx context.Context, project string) ([]string, error)

+ func (c *ClusterTx) GetCreatedStoragePoolNames(ctx context.Context) ([]string, error)

+ func (c *ClusterTx) GetExpiredInstanceBackups(ctx context.Context) ([]InstanceBackup, error)

+ func (c *ClusterTx) GetImage(ctx context.Context, fingerprintPrefix string, filter cluster.ImageFilter) (int, *api.Image, error)

+ func (c *ClusterTx) GetImageFromAnyProject(ctx context.Context, fingerprint string) (int, *api.Image, error)

+ func (c *ClusterTx) GetImages(ctx context.Context) (map[string][]string, error)

+ func (c *ClusterTx) GetImagesOnLocalNode(ctx context.Context) (map[string][]string, error)

+ func (c *ClusterTx) GetImagesOnNode(ctx context.Context, id int64) (map[string][]string, error)

+ func (c *ClusterTx) GetInstanceBackup(ctx context.Context, projectName string, name string) (InstanceBackup, error)

+ func (c *ClusterTx) GetInstanceBackupWithID(ctx context.Context, backupID int) (InstanceBackup, error)

+ func (c *ClusterTx) GetInstanceBackups(ctx context.Context, projectName string, name string) ([]string, error)

+ func (c *ClusterTx) GetInstanceConfig(ctx context.Context, id int, key string) (string, error)

+ func (c *ClusterTx) GetInstanceID(ctx context.Context, project, name string) (int, error)

+ func (c *ClusterTx) GetInstanceProjectAndName(ctx context.Context, id int) (string, string, error)

+ func (c *ClusterTx) GetInstanceSnapshotID(ctx context.Context, project, instance, name string) (int, error)

+ func (c *ClusterTx) GetInstanceSnapshotsNames(ctx context.Context, project, name string) ([]string, error)

+ func (c *ClusterTx) GetInstancesWithProfile(ctx context.Context, project, profile string) (map[string][]string, error)

+ func (c *ClusterTx) GetLocalStoragePoolVolumeSnapshotsWithType(ctx context.Context, projectName string, volumeName string, volumeType int, ...) ([]StorageVolumeArgs, error)

+ func (c *ClusterTx) GetNetworkACL(ctx context.Context, projectName string, name string) (int64, *api.NetworkACL, error)

+ func (c *ClusterTx) GetNetworkACLIDsByNames(ctx context.Context, project string) (map[string]int64, error)

+ func (c *ClusterTx) GetNetworkACLNameAndProjectWithID(ctx context.Context, networkACLID int) (string, string, error)

+ func (c *ClusterTx) GetNetworkACLs(ctx context.Context, project string) ([]string, error)

+ func (c *ClusterTx) GetNetworkForward(ctx context.Context, networkID int64, memberSpecific bool, ...) (int64, *api.NetworkForward, error)

+ func (c *ClusterTx) GetNetworkForwardListenAddresses(ctx context.Context, networkID int64, memberSpecific bool) (map[int64]string, error)

+ func (c *ClusterTx) GetNetworkForwards(ctx context.Context, networkID int64, memberSpecific bool, ...) (map[int64]*api.NetworkForward, error)

+ func (c *ClusterTx) GetNetworkInAnyState(ctx context.Context, projectName string, networkName string) (int64, *api.Network, map[int64]NetworkNode, error)

+ func (c *ClusterTx) GetNetworkLoadBalancer(ctx context.Context, networkID int64, memberSpecific bool, ...) (int64, *api.NetworkLoadBalancer, error)

+ func (c *ClusterTx) GetNetworkLoadBalancerListenAddresses(ctx context.Context, networkID int64, memberSpecific bool) (map[int64]string, error)

+ func (c *ClusterTx) GetNetworkLoadBalancers(ctx context.Context, networkID int64, memberSpecific bool, ...) (map[int64]*api.NetworkLoadBalancer, error)

+ func (c *ClusterTx) GetNetworkNameAndProjectWithID(ctx context.Context, networkID int) (string, string, error)

+ func (c *ClusterTx) GetNetworkPeer(ctx context.Context, networkID int64, peerName string) (int64, *api.NetworkPeer, error)

+ func (c *ClusterTx) GetNetworkPeerNames(ctx context.Context, networkID int64) (map[int64]string, error)

+ func (c *ClusterTx) GetNetworkPeers(ctx context.Context, networkID int64) (map[int64]*api.NetworkPeer, error)

+ func (c *ClusterTx) GetNetworkWithInterface(ctx context.Context, devName string) (int64, *api.Network, error)

+ func (c *ClusterTx) GetNetworkZone(ctx context.Context, name string) (int64, string, *api.NetworkZone, error)

+ func (c *ClusterTx) GetNetworkZoneByProject(ctx context.Context, projectName string, name string) (int64, *api.NetworkZone, error)

+ func (c *ClusterTx) GetNetworkZoneKeys(ctx context.Context) (map[string]string, error)

+ func (c *ClusterTx) GetNetworkZoneRecord(ctx context.Context, zone int64, name string) (int64, *api.NetworkZoneRecord, error)

+ func (c *ClusterTx) GetNetworkZoneRecordNames(ctx context.Context, zone int64) ([]string, error)

+ func (c *ClusterTx) GetNetworkZonesByProject(ctx context.Context, project string) ([]string, error)

+ func (c *ClusterTx) GetNetworks(ctx context.Context, project string) ([]string, error)

+ func (c *ClusterTx) GetNextInstanceSnapshotIndex(ctx context.Context, project string, name string, pattern string) int

+ func (c *ClusterTx) GetNextStorageVolumeSnapshotIndex(ctx context.Context, pool, name string, typ int, pattern string) int

+ func (c *ClusterTx) GetNodesWithImage(ctx context.Context, fingerprint string) ([]string, error)

+ func (c *ClusterTx) GetNodesWithImageAndAutoUpdate(ctx context.Context, fingerprint string, autoUpdate bool) ([]string, error)

+ func (c *ClusterTx) GetNodesWithoutImage(ctx context.Context, fingerprint string) ([]string, error)

+ func (c *ClusterTx) GetPoolNamesFromIDs(ctx context.Context, poolIDs []int64) ([]string, error)

+ func (c *ClusterTx) GetPoolsWithImage(ctx context.Context, imageFingerprint string) ([]int64, error)

+ func (c *ClusterTx) GetProfile(ctx context.Context, project, name string) (int64, *api.Profile, error)

+ func (c *ClusterTx) GetProfileNames(ctx context.Context, project string) ([]string, error)

+ func (c *ClusterTx) GetProfiles(ctx context.Context, projectName string, profileNames []string) ([]api.Profile, error)

+ func (c *ClusterTx) GetStoragePool(ctx context.Context, poolName string) (int64, *api.StoragePool, map[int64]StoragePoolNode, error)

+ func (c *ClusterTx) GetStoragePoolDrivers(ctx context.Context) ([]string, error)

+ func (c *ClusterTx) GetStoragePoolInAnyState(ctx context.Context, poolName string) (int64, *api.StoragePool, map[int64]StoragePoolNode, error)

+ func (c *ClusterTx) GetStoragePoolNames(ctx context.Context) ([]string, error)

+ func (c *ClusterTx) GetStoragePoolNodeVolumeID(ctx context.Context, projectName string, volumeName string, volumeType int, ...) (int64, error)

+ func (c *ClusterTx) GetStoragePoolVolumeBackup(ctx context.Context, projectName string, poolName string, backupName string) (StoragePoolVolumeBackup, error)

+ func (c *ClusterTx) GetStoragePoolVolumeBackupWithID(ctx context.Context, backupID int) (StoragePoolVolumeBackup, error)

+ func (c *ClusterTx) GetStoragePoolVolumeBackups(ctx context.Context, projectName string, volumeName string, poolID int64) ([]StoragePoolVolumeBackup, error)

+ func (c *ClusterTx) GetStoragePoolVolumeBackupsNames(ctx context.Context, projectName string, volumeName string, poolID int64) ([]string, error)

+ func (c *ClusterTx) GetStoragePoolWithID(ctx context.Context, poolID int) (int64, *api.StoragePool, map[int64]StoragePoolNode, error)

+ func (c *ClusterTx) GetStoragePools(ctx context.Context, state *StoragePoolState, poolNames ...string) (map[int64]api.StoragePool, map[int64]map[int64]StoragePoolNode, error)

+ func (c *ClusterTx) GetStorageVolumeSnapshotExpiry(ctx context.Context, volumeID int64) (time.Time, error)

+ func (c *ClusterTx) GetStorageVolumeSnapshotWithID(ctx context.Context, snapshotID int) (StorageVolumeArgs, error)

+ func (c *ClusterTx) GetURIFromEntity(ctx context.Context, entityType int, entityID int) (string, error)

+ func (c *ClusterTx) ImageExists(ctx context.Context, project string, fingerprint string) (bool, error)

+ func (c *ClusterTx) ImageIsReferencedByOtherProjects(ctx context.Context, project string, fingerprint string) (bool, error)

+ func (c *ClusterTx) InstanceList(ctx context.Context, ...) error

+ func (c *ClusterTx) IsRemoteStorage(ctx context.Context, poolID int64) (bool, error)

+ func (c *ClusterTx) LocateImage(ctx context.Context, fingerprint string) (string, error)

+ func (c *ClusterTx) MoveImageAlias(ctx context.Context, source int, destination int) error

+ func (c *ClusterTx) RemoveStoragePool(ctx context.Context, poolName string) (*api.StoragePool, error)

+ func (c *ClusterTx) RemoveStoragePoolVolume(ctx context.Context, projectName string, volumeName string, volumeType int, ...) error

+ func (c *ClusterTx) RemoveUnreferencedProfiles(ctx context.Context) error

+ func (c *ClusterTx) RenameImageAlias(ctx context.Context, id int, name string) error

+ func (c *ClusterTx) RenameInstanceBackup(ctx context.Context, oldName, newName string) error

+ func (c *ClusterTx) RenameNetwork(ctx context.Context, project string, oldName string, newName string) error

+ func (c *ClusterTx) RenameNetworkACL(ctx context.Context, id int64, newName string) error

+ func (c *ClusterTx) RenameStoragePoolVolume(ctx context.Context, projectName string, oldVolumeName string, ...) error

+ func (c *ClusterTx) RenameVolumeBackup(ctx context.Context, oldName, newName string) error

+ func (c *ClusterTx) SetImageCachedAndLastUseDate(ctx context.Context, projectName string, fingerprint string, ...) error

+ func (c *ClusterTx) UpdateImage(ctx context.Context, id int, fname string, sz int64, public bool, ...) error

+ func (c *ClusterTx) UpdateInstanceSnapshotCreationDate(ctx context.Context, instanceID int, date time.Time) error

+ func (c *ClusterTx) UpdateInstanceStatefulFlag(ctx context.Context, id int, stateful bool) error

+ func (c *ClusterTx) UpdateNetworkACL(ctx context.Context, id int64, config *api.NetworkACLPut) error

+ func (c *ClusterTx) UpdateNetworkForward(ctx context.Context, networkID int64, forwardID int64, ...) error

+ func (c *ClusterTx) UpdateNetworkLoadBalancer(ctx context.Context, networkID int64, loadBalancerID int64, ...) error

+ func (c *ClusterTx) UpdateNetworkPeer(ctx context.Context, networkID int64, peerID int64, info *api.NetworkPeerPut) error

+ func (c *ClusterTx) UpdateNetworkZoneRecord(ctx context.Context, id int64, config api.NetworkZoneRecordPut) error

+ func (c *ClusterTx) UpdateStoragePool(ctx context.Context, poolName, description string, ...) error

+ func (c *ClusterTx) UpdateStoragePoolBucket(ctx context.Context, poolID int64, bucketID int64, info *api.StorageBucketPut) error

+ func (c *ClusterTx) UpdateStoragePoolBucketKey(ctx context.Context, bucketID int64, bucketKeyID int64, ...) error

+ func (c *ClusterTx) UpdateStoragePoolVolume(ctx context.Context, projectName string, volumeName string, volumeType int, ...) error

+ func (c *ClusterTx) UpdateStorageVolumeSnapshot(ctx context.Context, projectName string, volumeName string, volumeType int, ...) error

+ func (c *ClusterTx) UpsertWarning(ctx context.Context, nodeName string, projectName string, entityTypeCode int, ...) error

+ func (c *ClusterTx) UpsertWarningLocalNode(ctx context.Context, projectName string, entityTypeCode int, entityID int, ...) error

v0.4.0

Dec 21, 2023

v0.3.0

Nov 26, 2023

Changes in this version

+ func StoragePoolVolumeTypeToName(volumeType int) (string, error) — linux/amd64

v0.2.0

Oct 27, 2023

Changes in this version

type ClusterTx — linux/amd64

+ func (c *ClusterTx) UpdateStorageVolumeNode(ctx context.Context, projectName string, oldName string, newName string, ...) error

v0.1.0

Oct 7, 2023

Changes in this version

+ const ClusterMemberStateCreated — linux/amd64

+ const ClusterMemberStateEvacuated — linux/amd64

+ const ClusterMemberStatePending — linux/amd64

+ const ClusterRoleDatabase — linux/amd64

+ const ClusterRoleDatabaseLeader — linux/amd64

+ const ClusterRoleDatabaseStandBy — linux/amd64

+ const ClusterRoleEventHub — linux/amd64

+ const ClusterRoleOVNChassis — linux/amd64

+ const DefaultOfflineThreshold — linux/amd64

+ const RaftSpare — linux/amd64

+ const RaftStandBy — linux/amd64

+ const RaftVoter — linux/amd64

+ const StoragePoolVolumeContentTypeBlock — linux/amd64

+ const StoragePoolVolumeContentTypeFS — linux/amd64

+ const StoragePoolVolumeContentTypeISO — linux/amd64

+ const StoragePoolVolumeContentTypeNameBlock — linux/amd64

+ const StoragePoolVolumeContentTypeNameFS — linux/amd64

+ const StoragePoolVolumeContentTypeNameISO — linux/amd64

+ const StoragePoolVolumeTypeContainer — linux/amd64

+ const StoragePoolVolumeTypeCustom — linux/amd64

+ const StoragePoolVolumeTypeImage — linux/amd64

+ const StoragePoolVolumeTypeNameContainer — linux/amd64

+ const StoragePoolVolumeTypeNameCustom — linux/amd64

+ const StoragePoolVolumeTypeNameImage — linux/amd64

+ const StoragePoolVolumeTypeNameVM — linux/amd64

+ const StoragePoolVolumeTypeVM — linux/amd64

+ var ClusterRoles = map[int]ClusterRole — linux/amd64

+ var ErrAlreadyDefined = fmt.Errorf("The record already exists")

+ var ErrInstanceListStop = fmt.Errorf("search stopped") — linux/amd64

+ var ErrNoClusterMember = fmt.Errorf("No cluster member found")

+ var ErrSomeNodesAreBehind = fmt.Errorf("some nodes are behind this node's version") — linux/amd64

+ var ErrUnknownEntityID = fmt.Errorf("Unknown entity ID") — linux/amd64

+ var ImageSourceProtocol = map[int]string — linux/amd64

+ var NodeSpecificNetworkConfig = []string — linux/amd64

+ var NodeSpecificStorageConfig = []string — linux/amd64

+ var StoragePoolVolumeTypeNames = map[int]string — linux/amd64

+ var StorageRemoteDriverNames func() []string — linux/amd64

+ func ClusterGroupToAPI(clusterGroup *cluster.ClusterGroup, nodes []string) *api.ClusterGroup — linux/amd64

+ func CreateInstanceConfig(tx *sql.Tx, id int, config map[string]string) error — linux/amd64

+ func DqliteLatestSegment() (string, error) — linux/amd64

+ func ExpandInstanceConfig(config map[string]string, profiles []api.Profile) map[string]string — linux/amd64

+ func ExpandInstanceDevices(devices deviceConfig.Devices, profiles []api.Profile) deviceConfig.Devices — linux/amd64

+ func NetworkStateToAPIStatus(state NetworkState) string — linux/amd64

+ func NewTestDqliteServer(t *testing.T) (string, driver.NodeStore, func()) — linux/amd64

+ func StoragePoolStateToAPIStatus(state StoragePoolState) string — linux/amd64

+ func TxCommit(tx *sql.Tx) error — linux/amd64

+ func UpdateInstance(tx *sql.Tx, id int, description string, architecture int, ephemeral bool, ...) error — linux/amd64

+ type Cluster struct — linux/amd64

+ func ForLocalInspection(db *sql.DB) *Cluster

+ func ForLocalInspectionWithPreparedStmts(db *sql.DB) (*Cluster, error)

+ func NewTestCluster(t *testing.T) (*Cluster, func())

+ func OpenCluster(closingCtx context.Context, name string, store driver.NodeStore, ...) (*Cluster, error)

+ func (c *Cluster) AddImageToLocalNode(project, fingerprint string) error

+ func (c *Cluster) Begin() (*sql.Tx, error)

+ func (c *Cluster) Close() error

+ func (c *Cluster) CopyDefaultImageProfiles(id int, newID int) error

+ func (c *Cluster) CreateImage(project string, fp string, fname string, sz int64, public bool, ...) error

+ func (c *Cluster) CreateImageSource(id int, server string, protocol string, certificate string, alias string) error

+ func (c *Cluster) CreateInstanceBackup(args InstanceBackup) error

+ func (c *Cluster) CreateNetwork(projectName string, name string, description string, netType NetworkType, ...) (int64, error)

+ func (c *Cluster) CreateNetworkACL(projectName string, info *api.NetworkACLsPost) (int64, error)

+ func (c *Cluster) CreateNetworkForward(networkID int64, memberSpecific bool, info *api.NetworkForwardsPost) (int64, error)

+ func (c *Cluster) CreateNetworkLoadBalancer(networkID int64, memberSpecific bool, info *api.NetworkLoadBalancersPost) (int64, error)

+ func (c *Cluster) CreateNetworkPeer(networkID int64, info *api.NetworkPeersPost) (int64, bool, error)

+ func (c *Cluster) CreateNetworkZone(projectName string, info *api.NetworkZonesPost) (int64, error)

+ func (c *Cluster) CreateNetworkZoneRecord(zone int64, info api.NetworkZoneRecordsPost) (int64, error)

+ func (c *Cluster) CreateStoragePool(poolName string, poolDescription string, poolDriver string, ...) (int64, error)

+ func (c *Cluster) CreateStoragePoolBucket(ctx context.Context, poolID int64, projectName string, memberSpecific bool, ...) (int64, error)

+ func (c *Cluster) CreateStoragePoolBucketKey(ctx context.Context, bucketID int64, info api.StorageBucketKeysPost) (int64, error)

+ func (c *Cluster) CreateStoragePoolVolume(projectName string, volumeName string, volumeDescription string, ...) (int64, error)

+ func (c *Cluster) CreateStoragePoolVolumeBackup(args StoragePoolVolumeBackup) error

+ func (c *Cluster) CreateStorageVolumeSnapshot(projectName string, volumeName string, volumeDescription string, ...) (int64, error)

+ func (c *Cluster) DB() *sql.DB

+ func (c *Cluster) DeleteImage(id int) error

+ func (c *Cluster) DeleteInstance(project, name string) error

+ func (c *Cluster) DeleteInstanceBackup(name string) error

+ func (c *Cluster) DeleteInstanceConfigKey(id int, key string) error

+ func (c *Cluster) DeleteNetwork(project string, name string) error

+ func (c *Cluster) DeleteNetworkACL(id int64) error

+ func (c *Cluster) DeleteNetworkForward(networkID int64, forwardID int64) error

+ func (c *Cluster) DeleteNetworkLoadBalancer(networkID int64, loadBalancerID int64) error

+ func (c *Cluster) DeleteNetworkPeer(networkID int64, peerID int64) error

+ func (c *Cluster) DeleteNetworkZone(id int64) error

+ func (c *Cluster) DeleteNetworkZoneRecord(id int64) error

+ func (c *Cluster) DeleteReadyStateFromLocalInstances() error

+ func (c *Cluster) DeleteStoragePoolBucket(ctx context.Context, poolID int64, bucketID int64) error

+ func (c *Cluster) DeleteStoragePoolBucketKey(ctx context.Context, bucketID int64, keyID int64) error

+ func (c *Cluster) DeleteStoragePoolVolumeBackup(name string) error

+ func (c *Cluster) EnterExclusive() error

+ func (c *Cluster) ExitExclusive(ctx context.Context, f func(context.Context, *ClusterTx) error) error

+ func (c *Cluster) GetCreatedNetworks(project string) ([]string, error)

+ func (c *Cluster) GetCreatedStoragePoolNames() ([]string, error)

+ func (c *Cluster) GetExpiredInstanceBackups() ([]InstanceBackup, error)

+ func (c *Cluster) GetImage(fingerprintPrefix string, filter cluster.ImageFilter) (int, *api.Image, error)

+ func (c *Cluster) GetImageFromAnyProject(fingerprint string) (int, *api.Image, error)

+ func (c *Cluster) GetImages() (map[string][]string, error)

+ func (c *Cluster) GetImagesOnLocalNode() (map[string][]string, error)

+ func (c *Cluster) GetImagesOnNode(id int64) (map[string][]string, error)

+ func (c *Cluster) GetInstanceBackup(projectName string, name string) (InstanceBackup, error)

+ func (c *Cluster) GetInstanceBackupWithID(backupID int) (InstanceBackup, error)

+ func (c *Cluster) GetInstanceBackups(projectName string, name string) ([]string, error)

+ func (c *Cluster) GetInstanceConfig(id int, key string) (string, error)

+ func (c *Cluster) GetInstanceID(project, name string) (int, error)

+ func (c *Cluster) GetInstancePool(project, instanceName string) (string, error)

+ func (c *Cluster) GetInstanceProjectAndName(id int) (string, string, error)

+ func (c *Cluster) GetInstanceSnapshotID(project, instance, name string) (int, error)

+ func (c *Cluster) GetInstanceSnapshotsNames(project, name string) ([]string, error)

+ func (c *Cluster) GetInstancesWithProfile(project, profile string) (map[string][]string, error)

+ func (c *Cluster) GetLocalStoragePoolVolumeSnapshotsWithType(projectName string, volumeName string, volumeType int, poolID int64) ([]StorageVolumeArgs, error)

+ func (c *Cluster) GetNetworkACL(projectName string, name string) (int64, *api.NetworkACL, error)

+ func (c *Cluster) GetNetworkACLIDsByNames(project string) (map[string]int64, error)

+ func (c *Cluster) GetNetworkACLNameAndProjectWithID(networkACLID int) (string, string, error)

+ func (c *Cluster) GetNetworkACLs(project string) ([]string, error)

+ func (c *Cluster) GetNetworkForward(ctx context.Context, networkID int64, memberSpecific bool, ...) (int64, *api.NetworkForward, error)

+ func (c *Cluster) GetNetworkForwardListenAddresses(networkID int64, memberSpecific bool) (map[int64]string, error)

+ func (c *Cluster) GetNetworkForwards(ctx context.Context, networkID int64, memberSpecific bool, ...) (map[int64]*api.NetworkForward, error)

+ func (c *Cluster) GetNetworkInAnyState(projectName string, networkName string) (int64, *api.Network, map[int64]NetworkNode, error)

+ func (c *Cluster) GetNetworkLoadBalancer(ctx context.Context, networkID int64, memberSpecific bool, ...) (int64, *api.NetworkLoadBalancer, error)

+ func (c *Cluster) GetNetworkLoadBalancerListenAddresses(networkID int64, memberSpecific bool) (map[int64]string, error)

+ func (c *Cluster) GetNetworkLoadBalancers(ctx context.Context, networkID int64, memberSpecific bool, ...) (map[int64]*api.NetworkLoadBalancer, error)

+ func (c *Cluster) GetNetworkNameAndProjectWithID(networkID int) (string, string, error)

+ func (c *Cluster) GetNetworkPeer(networkID int64, peerName string) (int64, *api.NetworkPeer, error)

+ func (c *Cluster) GetNetworkPeerNames(networkID int64) (map[int64]string, error)

+ func (c *Cluster) GetNetworkPeers(networkID int64) (map[int64]*api.NetworkPeer, error)

+ func (c *Cluster) GetNetworkPeersTargetNetworkIDs(projectName string, networkType NetworkType) (map[NetworkPeer]int64, error)

+ func (c *Cluster) GetNetworkWithInterface(devName string) (int64, *api.Network, error)

+ func (c *Cluster) GetNetworkZone(name string) (int64, string, *api.NetworkZone, error)

+ func (c *Cluster) GetNetworkZoneByProject(projectName string, name string) (int64, *api.NetworkZone, error)

+ func (c *Cluster) GetNetworkZoneKeys() (map[string]string, error)

+ func (c *Cluster) GetNetworkZoneRecord(zone int64, name string) (int64, *api.NetworkZoneRecord, error)

+ func (c *Cluster) GetNetworkZoneRecordNames(zone int64) ([]string, error)

+ func (c *Cluster) GetNetworkZonesByProject(project string) ([]string, error)

+ func (c *Cluster) GetNetworks(project string) ([]string, error)

+ func (c *Cluster) GetNextInstanceSnapshotIndex(project string, name string, pattern string) int

+ func (c *Cluster) GetNextStorageVolumeSnapshotIndex(pool, name string, typ int, pattern string) int

+ func (c *Cluster) GetNodeID() int64

+ func (c *Cluster) GetNodesWithImage(fingerprint string) ([]string, error)

+ func (c *Cluster) GetNodesWithImageAndAutoUpdate(fingerprint string, autoUpdate bool) ([]string, error)

+ func (c *Cluster) GetNodesWithoutImage(fingerprint string) ([]string, error)

+ func (c *Cluster) GetPoolNamesFromIDs(poolIDs []int64) ([]string, error)

+ func (c *Cluster) GetPoolsWithImage(imageFingerprint string) ([]int64, error)

+ func (c *Cluster) GetProfile(project, name string) (int64, *api.Profile, error)

+ func (c *Cluster) GetProfileNames(project string) ([]string, error)

+ func (c *Cluster) GetProfiles(projectName string, profileNames []string) ([]api.Profile, error)

+ func (c *Cluster) GetStoragePool(poolName string) (int64, *api.StoragePool, map[int64]StoragePoolNode, error)

+ func (c *Cluster) GetStoragePoolDrivers() ([]string, error)

+ func (c *Cluster) GetStoragePoolID(poolName string) (int64, error)

+ func (c *Cluster) GetStoragePoolInAnyState(poolName string) (int64, *api.StoragePool, map[int64]StoragePoolNode, error)

+ func (c *Cluster) GetStoragePoolNames() ([]string, error)

+ func (c *Cluster) GetStoragePoolNodeVolumeID(projectName string, volumeName string, volumeType int, poolID int64) (int64, error)

+ func (c *Cluster) GetStoragePoolVolumeBackup(projectName string, poolName string, backupName string) (StoragePoolVolumeBackup, error)

+ func (c *Cluster) GetStoragePoolVolumeBackupWithID(backupID int) (StoragePoolVolumeBackup, error)

+ func (c *Cluster) GetStoragePoolVolumeBackups(projectName string, volumeName string, poolID int64) ([]StoragePoolVolumeBackup, error)

+ func (c *Cluster) GetStoragePoolVolumeBackupsNames(projectName string, volumeName string, poolID int64) ([]string, error)

+ func (c *Cluster) GetStoragePoolWithID(poolID int) (int64, *api.StoragePool, map[int64]StoragePoolNode, error)

+ func (c *Cluster) GetStoragePools(ctx context.Context, state *StoragePoolState, poolNames ...string) (map[int64]api.StoragePool, map[int64]map[int64]StoragePoolNode, error)

+ func (c *Cluster) GetStorageVolumeSnapshotExpiry(volumeID int64) (time.Time, error)

+ func (c *Cluster) GetStorageVolumeSnapshotWithID(snapshotID int) (StorageVolumeArgs, error)

+ func (c *Cluster) GetURIFromEntity(entityType int, entityID int) (string, error)

+ func (c *Cluster) ImageExists(project string, fingerprint string) (bool, error)

+ func (c *Cluster) ImageIsReferencedByOtherProjects(project string, fingerprint string) (bool, error)

+ func (c *Cluster) InstanceList(ctx context.Context, ...) error

+ func (c *Cluster) IsRemoteStorage(poolID int64) (bool, error)

+ func (c *Cluster) LocalNodeIsEvacuated() bool

+ func (c *Cluster) LocateImage(fingerprint string) (string, error)

+ func (c *Cluster) MoveImageAlias(source int, destination int) error

+ func (c *Cluster) NodeID(id int64)

+ func (c *Cluster) RemoveStoragePool(poolName string) (*api.StoragePool, error)

+ func (c *Cluster) RemoveStoragePoolVolume(projectName string, volumeName string, volumeType int, poolID int64) error

+ func (c *Cluster) RemoveUnreferencedProfiles() error

+ func (c *Cluster) RenameImageAlias(id int, name string) error

+ func (c *Cluster) RenameInstanceBackup(oldName, newName string) error

+ func (c *Cluster) RenameNetwork(project string, oldName string, newName string) error

+ func (c *Cluster) RenameNetworkACL(id int64, newName string) error

+ func (c *Cluster) RenameStoragePoolVolume(projectName string, oldVolumeName string, newVolumeName string, volumeType int, ...) error

+ func (c *Cluster) RenameVolumeBackup(oldName, newName string) error

+ func (c *Cluster) SetImageCachedAndLastUseDate(projectName string, fingerprint string, lastUsed time.Time) error

+ func (c *Cluster) Transaction(ctx context.Context, f func(context.Context, *ClusterTx) error) error

+ func (c *Cluster) UpdateImage(id int, fname string, sz int64, public bool, autoUpdate bool, ...) error

+ func (c *Cluster) UpdateInstanceSnapshotCreationDate(instanceID int, date time.Time) error

+ func (c *Cluster) UpdateInstanceStatefulFlag(id int, stateful bool) error

+ func (c *Cluster) UpdateNetwork(project string, name, description string, config map[string]string) error

+ func (c *Cluster) UpdateNetworkACL(id int64, config *api.NetworkACLPut) error

+ func (c *Cluster) UpdateNetworkForward(networkID int64, forwardID int64, info *api.NetworkForwardPut) error

+ func (c *Cluster) UpdateNetworkLoadBalancer(networkID int64, loadBalancerID int64, info *api.NetworkLoadBalancerPut) error

+ func (c *Cluster) UpdateNetworkPeer(networkID int64, peerID int64, info *api.NetworkPeerPut) error

+ func (c *Cluster) UpdateNetworkZone(id int64, config *api.NetworkZonePut) error

+ func (c *Cluster) UpdateNetworkZoneRecord(id int64, config api.NetworkZoneRecordPut) error

+ func (c *Cluster) UpdateStoragePool(poolName, description string, poolConfig map[string]string) error

+ func (c *Cluster) UpdateStoragePoolBucket(ctx context.Context, poolID int64, bucketID int64, info *api.StorageBucketPut) error

+ func (c *Cluster) UpdateStoragePoolBucketKey(ctx context.Context, bucketID int64, bucketKeyID int64, ...) error

+ func (c *Cluster) UpdateStoragePoolVolume(projectName string, volumeName string, volumeType int, poolID int64, ...) error

+ func (c *Cluster) UpdateStorageVolumeSnapshot(projectName string, volumeName string, volumeType int, poolID int64, ...) error

+ func (c *Cluster) UpsertWarning(nodeName string, projectName string, entityTypeCode int, entityID int, ...) error

+ func (c *Cluster) UpsertWarningLocalNode(projectName string, entityTypeCode int, entityID int, ...) error

+ type ClusterRole string — linux/amd64

+ type ClusterTx struct — linux/amd64

+ func NewTestClusterTx(t *testing.T) (*ClusterTx, func())

+ func (c *ClusterTx) AddNodeToClusterGroup(ctx context.Context, groupName string, nodeName string) error

+ func (c *ClusterTx) BootstrapNode(name string, address string) error

+ func (c *ClusterTx) ClearNode(ctx context.Context, id int64) error

+ func (c *ClusterTx) Config(ctx context.Context) (map[string]string, error)

+ func (c *ClusterTx) CreateImageAlias(ctx context.Context, projectName, aliasName string, imageID int, desc string) error

+ func (c *ClusterTx) CreateInstanceConfig(id int, config map[string]string) error

+ func (c *ClusterTx) CreateNetworkConfig(networkID, nodeID int64, config map[string]string) error

+ func (c *ClusterTx) CreateNode(name string, address string) (int64, error)

+ func (c *ClusterTx) CreateNodeWithArch(name string, address string, arch int) (int64, error)

+ func (c *ClusterTx) CreatePendingNetwork(ctx context.Context, node string, projectName string, name string, ...) error

+ func (c *ClusterTx) CreatePendingStoragePool(ctx context.Context, node string, name string, driver string, ...) error

+ func (c *ClusterTx) CreateStoragePoolConfig(poolID, nodeID int64, config map[string]string) error

+ func (c *ClusterTx) DeleteImageAlias(ctx context.Context, projectName string, name string) error

+ func (c *ClusterTx) DeleteInstanceConfigKey(id int64, key string) error

+ func (c *ClusterTx) GetAllNodesWithOperations(ctx context.Context) ([]string, error)

+ func (c *ClusterTx) GetCachedImageSourceFingerprint(ctx context.Context, server string, protocol string, alias string, ...) (string, error)

+ func (c *ClusterTx) GetCandidateMembers(ctx context.Context, allMembers []NodeInfo, targetArchitectures []int, ...) ([]NodeInfo, error)

+ func (c *ClusterTx) GetClusterGroupNodes(ctx context.Context, groupName string) ([]string, error)

+ func (c *ClusterTx) GetClusterGroupURIs(ctx context.Context, filter cluster.ClusterGroupFilter) ([]string, error)

+ func (c *ClusterTx) GetClusterGroupsWithNode(ctx context.Context, nodeName string) ([]string, error)

+ func (c *ClusterTx) GetCreatedNetworks(ctx context.Context) (map[string]map[int64]api.Network, error)

+ func (c *ClusterTx) GetCreatedNetworksByProject(ctx context.Context, projectName string) (map[int64]api.Network, error)

+ func (c *ClusterTx) GetCustomVolumesInProject(ctx context.Context, project string) ([]StorageVolumeArgs, error)

+ func (c *ClusterTx) GetExpiredStorageVolumeBackups(ctx context.Context) ([]StoragePoolVolumeBackup, error)

+ func (c *ClusterTx) GetExpiredStorageVolumeSnapshots(ctx context.Context, memberSpecific bool) ([]StorageVolumeArgs, error)

+ func (c *ClusterTx) GetFailureDomainsNames(ctx context.Context) (map[uint64]string, error)

+ func (c *ClusterTx) GetImageAlias(ctx context.Context, projectName string, imageName string, ...) (int, api.ImageAliasesEntry, error)

+ func (c *ClusterTx) GetImageAliases(ctx context.Context, projectName string) ([]string, error)

+ func (c *ClusterTx) GetImageByFingerprintPrefix(ctx context.Context, fingerprintPrefix string, filter cluster.ImageFilter) (int, *api.Image, error)

+ func (c *ClusterTx) GetImageSource(ctx context.Context, imageID int) (int, api.ImageSource, error)

+ func (c *ClusterTx) GetImagesFingerprints(ctx context.Context, projectName string, publicOnly bool) ([]string, error)

+ func (c *ClusterTx) GetInstanceNames(ctx context.Context, project string) ([]string, error)

+ func (c *ClusterTx) GetInstancePool(ctx context.Context, projectName string, instanceName string) (string, error)

+ func (c *ClusterTx) GetInstanceSnapshotsWithName(ctx context.Context, project string, name string) ([]cluster.Instance, error)

+ func (c *ClusterTx) GetInstancesByMemberAddress(ctx context.Context, offlineThreshold time.Duration, projects []string, ...) (map[string][]Instance, error)

+ func (c *ClusterTx) GetLocalExpiredInstanceSnapshots(ctx context.Context) ([]cluster.InstanceSnapshot, error)

+ func (c *ClusterTx) GetLocalImagesFingerprints(ctx context.Context) ([]string, error)

+ func (c *ClusterTx) GetLocalInstanceWithVsockID(ctx context.Context, vsockID int) (*cluster.Instance, error)

+ func (c *ClusterTx) GetLocalInstancesInProject(ctx context.Context, filter cluster.InstanceFilter) ([]cluster.Instance, error)

+ func (c *ClusterTx) GetLocalNodeAddress(ctx context.Context) (string, error)

+ func (c *ClusterTx) GetLocalNodeName(ctx context.Context) (string, error)

+ func (c *ClusterTx) GetNetworkACLURIs(ctx context.Context, projectID int, project string) ([]string, error)

+ func (c *ClusterTx) GetNetworkID(ctx context.Context, projectName string, name string) (int64, error)

+ func (c *ClusterTx) GetNetworkURIs(ctx context.Context, projectID int, project string) ([]string, error)

+ func (c *ClusterTx) GetNetworkZones(ctx context.Context) (map[string]string, error)

+ func (c *ClusterTx) GetNetworksLocalConfig(ctx context.Context) (map[string]map[string]string, error)

+ func (c *ClusterTx) GetNodeAddressOfInstance(ctx context.Context, project string, name string, instType instancetype.Type) (string, error)

+ func (c *ClusterTx) GetNodeByAddress(ctx context.Context, address string) (NodeInfo, error)

+ func (c *ClusterTx) GetNodeByName(ctx context.Context, name string) (NodeInfo, error)

+ func (c *ClusterTx) GetNodeFailureDomain(ctx context.Context, id int64) (string, error)

+ func (c *ClusterTx) GetNodeID() int64

+ func (c *ClusterTx) GetNodeMaxVersion(ctx context.Context) ([2]int, error)

+ func (c *ClusterTx) GetNodeOfflineThreshold(ctx context.Context) (time.Duration, error)

+ func (c *ClusterTx) GetNodeWithID(ctx context.Context, nodeID int) (NodeInfo, error)

+ func (c *ClusterTx) GetNodeWithLeastInstances(ctx context.Context, members []NodeInfo) (*NodeInfo, error)

+ func (c *ClusterTx) GetNodes(ctx context.Context) ([]NodeInfo, error)

+ func (c *ClusterTx) GetNodesCount(ctx context.Context) (int, error)

+ func (c *ClusterTx) GetNodesFailureDomains(ctx context.Context) (map[string]uint64, error)

+ func (c *ClusterTx) GetNodesWithOperations(ctx context.Context, project string) ([]string, error)

+ func (c *ClusterTx) GetNonPendingNetworkIDs(ctx context.Context) (map[string]map[string]int64, error)

+ func (c *ClusterTx) GetNonPendingStoragePoolsNamesToIDs(ctx context.Context) (map[string]int64, error)

+ func (c *ClusterTx) GetOperationsOfType(ctx context.Context, projectName string, opType operationtype.Type) ([]cluster.Operation, error)

+ func (c *ClusterTx) GetPendingNodeByAddress(ctx context.Context, address string) (NodeInfo, error)

+ func (c *ClusterTx) GetProjectNetworkForwardListenAddressesByUplink(ctx context.Context, uplinkNetworkName string, memberSpecific bool) (map[string]map[string][]string, error)

+ func (c *ClusterTx) GetProjectNetworkForwardListenAddressesOnMember(ctx context.Context) (map[string]map[int64][]string, error)

+ func (c *ClusterTx) GetProjectNetworkLoadBalancerListenAddressesByUplink(ctx context.Context, uplinkNetworkName string, memberSpecific bool) (map[string]map[string][]string, error)

+ func (c *ClusterTx) GetProjectNetworkLoadBalancerListenAddressesOnMember(ctx context.Context) (map[string]map[int64][]string, error)

+ func (c *ClusterTx) GetProjectsUsingImage(ctx context.Context, fingerprint string) ([]string, error)

+ func (c *ClusterTx) GetStoragePoolBucket(ctx context.Context, poolID int64, projectName string, memberSpecific bool, ...) (*StorageBucket, error)

+ func (c *ClusterTx) GetStoragePoolBucketKey(ctx context.Context, bucketID int64, keyName string) (*StorageBucketKey, error)

+ func (c *ClusterTx) GetStoragePoolBucketKeys(ctx context.Context, bucketID int64, filters ...StorageBucketKeyFilter) ([]*StorageBucketKey, error)

+ func (c *ClusterTx) GetStoragePoolBuckets(ctx context.Context, memberSpecific bool, filters ...StorageBucketFilter) ([]*StorageBucket, error)

+ func (c *ClusterTx) GetStoragePoolDriver(ctx context.Context, id int64) (string, error)

+ func (c *ClusterTx) GetStoragePoolID(ctx context.Context, name string) (int64, error)

+ func (c *ClusterTx) GetStoragePoolLocalBucket(ctx context.Context, bucketName string) (*StorageBucket, error)

+ func (c *ClusterTx) GetStoragePoolLocalBucketByAccessKey(ctx context.Context, accessKey string) (*StorageBucket, error)

+ func (c *ClusterTx) GetStoragePoolNodeConfigs(ctx context.Context, poolID int64) (map[string]map[string]string, error)

+ func (c *ClusterTx) GetStoragePoolVolume(ctx context.Context, poolID int64, projectName string, volumeType int, ...) (*StorageVolume, error)

+ func (c *ClusterTx) GetStoragePoolVolumeWithID(ctx context.Context, volumeID int) (StorageVolumeArgs, error)

+ func (c *ClusterTx) GetStoragePoolVolumes(ctx context.Context, poolID int64, memberSpecific bool, ...) ([]*StorageVolume, error)

+ func (c *ClusterTx) GetStoragePoolVolumesWithType(ctx context.Context, volumeType int, memberSpecific bool) ([]StorageVolumeArgs, error)

+ func (c *ClusterTx) GetStoragePoolsLocalConfig(ctx context.Context) (map[string]map[string]string, error)

+ func (c *ClusterTx) GetStorageVolumeNodes(ctx context.Context, poolID int64, projectName string, volumeName string, ...) ([]NodeInfo, error)

+ func (c *ClusterTx) GetStorageVolumeURIs(ctx context.Context, project string) ([]string, error)

+ func (c *ClusterTx) InstancesToInstanceArgs(ctx context.Context, fillProfiles bool, instances ...cluster.Instance) (map[int]InstanceArgs, error)

+ func (c *ClusterTx) NetworkCreated(project string, name string) error

+ func (c *ClusterTx) NetworkErrored(project string, name string) error

+ func (c *ClusterTx) NetworkNodeConfigs(ctx context.Context, networkID int64) (map[string]map[string]string, error)

+ func (c *ClusterTx) NetworkNodeCreated(networkID int64) error

+ func (c *ClusterTx) NetworkNodeJoin(networkID, nodeID int64) error

+ func (c *ClusterTx) NetworkNodes(ctx context.Context, networkID int64) (map[int64]NetworkNode, error)

+ func (c *ClusterTx) NodeID(id int64)

+ func (c *ClusterTx) NodeIsEmpty(ctx context.Context, id int64) (string, error)

+ func (c *ClusterTx) NodeIsOutdated(ctx context.Context) (bool, error)

+ func (c *ClusterTx) RemoveNode(id int64) error

+ func (c *ClusterTx) RemoveNodeFromClusterGroup(ctx context.Context, groupName string, nodeName string) error

+ func (c *ClusterTx) RenameNode(ctx context.Context, old string, new string) error

+ func (c *ClusterTx) SetDescription(id int64, description string) error

+ func (c *ClusterTx) SetNodeHeartbeat(address string, heartbeat time.Time) error

+ func (c *ClusterTx) SetNodePendingFlag(id int64, pending bool) error

+ func (c *ClusterTx) SetNodeVersion(id int64, version [2]int) error

+ func (c *ClusterTx) StoragePoolCreated(name string) error

+ func (c *ClusterTx) StoragePoolErrored(name string) error

+ func (c *ClusterTx) StoragePoolNodeCreated(poolID int64) error

+ func (c *ClusterTx) Tx() *sql.Tx

+ func (c *ClusterTx) UpdateCephStoragePoolAfterNodeJoin(ctx context.Context, poolID int64, nodeID int64) error

+ func (c *ClusterTx) UpdateClusterConfig(values map[string]string) error

+ func (c *ClusterTx) UpdateImageAlias(ctx context.Context, aliasID int, imageID int, desc string) error

+ func (c *ClusterTx) UpdateImageLastUseDate(ctx context.Context, projectName string, fingerprint string, ...) error

+ func (c *ClusterTx) UpdateInstanceConfig(id int, values map[string]string) error

+ func (c *ClusterTx) UpdateInstanceLastUsedDate(id int, date time.Time) error

+ func (c *ClusterTx) UpdateInstanceNode(ctx context.Context, project string, oldName string, newName string, ...) error

+ func (c *ClusterTx) UpdateInstancePowerState(id int, state string) error

+ func (c *ClusterTx) UpdateInstanceSnapshot(id int, description string, expiryDate time.Time) error

+ func (c *ClusterTx) UpdateInstanceSnapshotConfig(id int, values map[string]string) error

+ func (c *ClusterTx) UpdateNetwork(id int64, description string, config map[string]string) error

+ func (c *ClusterTx) UpdateNodeClusterGroups(ctx context.Context, id int64, groups []string) error

+ func (c *ClusterTx) UpdateNodeConfig(ctx context.Context, id int64, config map[string]string) error

+ func (c *ClusterTx) UpdateNodeFailureDomain(ctx context.Context, id int64, domain string) error

+ func (c *ClusterTx) UpdateNodeRoles(id int64, roles []ClusterRole) error

+ func (c *ClusterTx) UpdateNodeStatus(id int64, state int) error

+ func (c *ClusterTx) UpdateStoragePoolAfterNodeJoin(poolID, nodeID int64) error

+ func (c *ClusterTx) UpdateWarningState(UUID string, message string, status warningtype.Status) error

+ func (c *ClusterTx) UpdateWarningStatus(UUID string, status warningtype.Status) error

+ type DB struct — linux/amd64

+ Cluster *Cluster

+ Node *Node

+ func (db *DB) GetProject(ctx context.Context, projectName string) (*cluster.Project, error)

+ func (db *DB) UpdateCertificate(ctx context.Context, fingerprint string, cert cluster.Certificate, ...) error

+ type Instance struct — linux/amd64

+ ID int64

+ Location string

+ Name string

+ Project string

+ Type instancetype.Type

+ type InstanceArgs struct — linux/amd64

+ Architecture int

+ BaseImage string

+ Config map[string]string

+ CreationDate time.Time

+ Description string

+ Devices deviceConfig.Devices

+ Ephemeral bool

+ ExpiryDate time.Time

+ ID int

+ LastUsedDate time.Time

+ Name string

+ Node string

+ Profiles []api.Profile

+ Project string

+ Snapshot bool

+ Stateful bool

+ Type instancetype.Type

+ type InstanceBackup struct — linux/amd64

+ CompressionAlgorithm string

+ CreationDate time.Time

+ ExpiryDate time.Time

+ ID int

+ InstanceID int

+ InstanceOnly bool

+ Name string

+ OptimizedStorage bool

+ type NetworkNode struct — linux/amd64

+ ID int64

+ Name string

+ State NetworkState

+ type NetworkPeer struct — linux/amd64

+ NetworkName string

+ PeerName string

+ type NetworkState int — linux/amd64

+ type NetworkType int — linux/amd64

+ const NetworkTypeBridge

+ const NetworkTypeMacvlan

+ const NetworkTypeOVN

+ const NetworkTypePhysical

+ const NetworkTypeSriov

+ type Node struct — linux/amd64

+ func DirectAccess(db *sql.DB) *Node

+ func NewTestNode(t *testing.T) (*Node, func())

+ func OpenNode(dir string, fresh func(*Node) error) (*Node, error)

+ func (n *Node) Close() error

+ func (n *Node) DB() *sql.DB

+ func (n *Node) Dir() string

+ func (n *Node) GetAppliedPatches() ([]string, error)

+ func (n *Node) MarkPatchAsApplied(patch string) error

+ func (n *Node) Transaction(ctx context.Context, f func(context.Context, *NodeTx) error) error

+ type NodeInfo struct — linux/amd64

+ APIExtensions int

+ Address string

+ Architecture int

+ Config map[string]string

+ Description string

+ Groups []string

+ Heartbeat time.Time

+ ID int64

+ Name string

+ Roles []ClusterRole

+ Schema int

+ State int

+ func (n NodeInfo) IsOffline(threshold time.Duration) bool

+ func (n NodeInfo) ToAPI(ctx context.Context, tx *ClusterTx, args NodeInfoArgs) (*api.ClusterMember, error)

+ func (n NodeInfo) Version() [2]int

+ type NodeInfoArgs struct — linux/amd64

+ FailureDomains map[uint64]string

+ LeaderAddress string

+ MaxMemberVersion [2]int

+ MemberFailureDomains map[string]uint64

+ OfflineThreshold time.Duration

+ RaftNodes []RaftNode

+ type NodeTx struct — linux/amd64

+ func NewTestNodeTx(t *testing.T) (*NodeTx, func())

+ func (n *NodeTx) Config(ctx context.Context) (map[string]string, error)

+ func (n *NodeTx) CreateFirstRaftNode(address string, name string) error

+ func (n *NodeTx) CreateRaftNode(address string, name string) (int64, error)

+ func (n *NodeTx) GetCertificates(ctx context.Context) ([]cluster.Certificate, error)

+ func (n *NodeTx) GetRaftNodeAddress(ctx context.Context, id int64) (string, error)

+ func (n *NodeTx) GetRaftNodeAddresses(ctx context.Context) ([]string, error)

+ func (n *NodeTx) GetRaftNodes(ctx context.Context) ([]RaftNode, error)

+ func (n *NodeTx) RemoveRaftNode(id int64) error

+ func (n *NodeTx) ReplaceCertificates(certs []cluster.Certificate) error

+ func (n *NodeTx) ReplaceRaftNodes(nodes []RaftNode) error

+ func (n *NodeTx) UpdateConfig(values map[string]string) error

+ type RaftNode struct — linux/amd64

+ Name string

+ type RaftRole = client.NodeRole — linux/amd64

+ type StorageBucket struct — linux/amd64

+ ID int64

+ PoolID int64

+ PoolName string

+ Project string

+ type StorageBucketFilter struct — linux/amd64

+ Name *string

+ PoolID *int64

+ PoolName *string

+ Project *string

+ type StorageBucketKey struct — linux/amd64

+ ID int64

+ type StorageBucketKeyFilter struct — linux/amd64

+ Name *string

+ type StoragePoolNode struct — linux/amd64

+ ID int64

+ Name string

+ State StoragePoolState

+ type StoragePoolState int — linux/amd64

+ const StoragePoolCreated

+ const StoragePoolPending

+ type StoragePoolVolumeBackup struct — linux/amd64

+ CompressionAlgorithm string

+ CreationDate time.Time

+ ExpiryDate time.Time

+ ID int

+ Name string

+ OptimizedStorage bool

+ VolumeID int64

+ VolumeOnly bool

+ type StorageVolume struct — linux/amd64

+ ID int64

+ type StorageVolumeArgs struct — linux/amd64

+ Config map[string]string

+ ContentType string

+ CreationDate time.Time

+ Description string

+ ExpiryDate time.Time

+ ID int64

+ Name string

+ NodeID int64

+ PoolID int64

+ PoolName string

+ ProjectID int64

+ ProjectName string

+ Snapshot bool

+ Type int

+ TypeName string

+ type StorageVolumeFilter struct — linux/amd64

+ Name *string

+ Project *string

+ Type *int

Other modules containing this package

github.com/lxc/incus/v6

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL