operations

package

Go to main page

Versions in this module

v22

v22.11.9

May 30, 2023

Changes in this version

+ func LoadTerraformBucket(inctx context.Context, svc iaas.Service, ref string) (resources.Bucket, fail.Error)

+ func LoadTerraformHost(inctx context.Context, svc iaas.Service, ref string) (resources.Host, fail.Error)

+ func LoadTerraformHosts(inctx context.Context, svc iaas.Service) ([]resources.Host, fail.Error)

type ClassicCluster

+ func NewClassicCluster(inctx context.Context, svc iaas.Service) (_ *ClassicCluster, ferr fail.Error)

+ type ClusterCreationParameters struct

+ Cidr string

+ Complexity uint

+ CreationDate string

+ DefaultGateway string

+ Flavor uint

+ GwDiskSize uint

+ GwOsOffer string

+ GwOsPublisher string

+ GwOsSku string

+ GwOsVersion string

+ GwTemplate string

+ Identity string

+ MasterDiskSize uint

+ MasterOsOffer string

+ MasterOsPublisher string

+ MasterOsSku string

+ MasterOsVersion string

+ MasterTemplate string

+ Masters uint

+ Name string

+ NodeDiskSize uint

+ NodeOsOffer string

+ NodeOsPublisher string

+ NodeOsSku string

+ NodeOsVersion string

+ NodeTemplate string

+ Nodes uint

+ OperatorUsername string

+ Region string

+ type ClusterSizing struct

+ NumGateways uint

+ NumMasters uint

+ NumNodes uint

+ SizingGateway *abstract.HostSizingRequirements

+ SizingMaster *abstract.HostSizingRequirements

+ SizingNode *abstract.HostSizingRequirements

+ type Config struct

+ LogLevel string

+ type ConfigInt struct

+ Threshold int

+ type InitScriptParameters struct

+ Cidr string

+ DefaultGateway string

+ Masters uint

+ Name string

+ Nodes uint

+ OperatorUsername string

+ Region string

+ type KeyValueTag struct

+ Id string

+ Key string

+ Value *string

+ WithDefaultValue bool

+ func NewTfLabel(key string, value string) (*KeyValueTag, error)

+ func NewTfTag(key string) (*KeyValueTag, error)

+ func (t *KeyValueTag) GetId() string

+ func (t *KeyValueTag) GetKey() string

+ func (t *KeyValueTag) GetValue() (string, error)

+ func (t *KeyValueTag) HasDefaultValue() bool

+ type NetworkCreationParameters struct

+ Cidr string

+ CreationDate string

+ DefaultGateway string

+ GwDiskSize uint

+ GwOsOffer string

+ GwOsPublisher string

+ GwOsSku string

+ GwOsVersion string

+ GwTemplate string

+ Identity string

+ MasterDiskSize uint

+ MasterOsOffer string

+ MasterOsPublisher string

+ MasterOsSku string

+ MasterOsVersion string

+ MasterTemplate string

+ Masters uint

+ Name string

+ OperatorUsername string

+ Region string

+ type Option func(clu *resources.Cluster) error

+ type ResourcesRepository interface

+ Create func(ctx context.Context, data T) error

+ Delete func(ctx context.Context, id string) error

+ Read func(ctx context.Context, id string) (*T, error)

+ Update func(ctx context.Context, id string, data T) error

+ type ResourcesRepositoryImpl struct

+ func (r ResourcesRepositoryImpl[T]) Create(ctx context.Context, data T) error

+ func (r ResourcesRepositoryImpl[T]) Delete(ctx context.Context, id string) error

+ func (r ResourcesRepositoryImpl[T]) Read(ctx context.Context, id string) (*T, error)

+ func (r ResourcesRepositoryImpl[T]) Update(ctx context.Context, id string, data T) error

+ type SubnetCreationParameters struct

+ Cidr string

+ CreationDate string

+ DefaultGateway string

+ GwDiskSize uint

+ GwOsOffer string

+ GwOsPublisher string

+ GwOsSku string

+ GwOsVersion string

+ GwTemplate string

+ Identity string

+ MasterDiskSize uint

+ MasterOsOffer string

+ MasterOsPublisher string

+ MasterOsSku string

+ MasterOsVersion string

+ MasterTemplate string

+ Masters uint

+ Name string

+ NodeDiskSize uint

+ NodeOsOffer string

+ NodeOsPublisher string

+ NodeOsSku string

+ NodeOsVersion string

+ NodeTemplate string

+ Nodes uint

+ OperatorUsername string

+ Region string

+ type TerraformCluster struct

+ Complexity clustercomplexity.Enum

+ Flavor clusterflavor.Enum

+ Identity string

+ Name string

+ func LoadTerraformCluster(inctx context.Context, svc iaas.Service, name string) (_ *TerraformCluster, ferr fail.Error)

+ func NewTerraformCluster(svc iaas.Service) (*TerraformCluster, fail.Error)

+ func NewTfCluster(inctx context.Context, svc iaas.Service) (_ *TerraformCluster, ferr fail.Error)

+ func (t *TerraformCluster) Create(ctx context.Context, req abstract.ClusterRequest) fail.Error

+ func (t TerraformCluster) AddFeature(ctx context.Context, name string, vars data.Map, ...) (resources.Results, fail.Error)

+ func (t TerraformCluster) AddNodes(ctx context.Context, name string, count uint, ...) ([]resources.Host, fail.Error)

+ func (t TerraformCluster) Alter(ctx context.Context, callback resources.Callback) fail.Error

+ func (t TerraformCluster) Browse(ctx context.Context, callback func(*abstract.ClusterIdentity) fail.Error) fail.Error

+ func (t TerraformCluster) BrowseFolder(ctx context.Context, callback func(buf []byte) fail.Error) fail.Error

+ func (t TerraformCluster) CheckFeature(ctx context.Context, name string, vars data.Map, ...) (resources.Results, fail.Error)

+ func (t TerraformCluster) ComplementFeatureParameters(ctx context.Context, v data.Map) fail.Error

+ func (t TerraformCluster) Delete(ctx context.Context, force bool) fail.Error

+ func (t TerraformCluster) DeleteSpecificNode(ctx context.Context, hostID string, selectedMasterID string) fail.Error

+ func (t TerraformCluster) Deserialize(ctx context.Context, buf []byte) fail.Error

+ func (t TerraformCluster) Exists(ctx context.Context) (bool, fail.Error)

+ func (t TerraformCluster) FindAvailableMaster(ctx context.Context) (resources.Host, fail.Error)

+ func (t TerraformCluster) GetAdminPassword(ctx context.Context) (string, fail.Error)

+ func (t TerraformCluster) GetComplexity(ctx context.Context) (clustercomplexity.Enum, fail.Error)

+ func (t TerraformCluster) GetFlavor(ctx context.Context) (clusterflavor.Enum, fail.Error)

+ func (t TerraformCluster) GetID() (string, error)

+ func (t TerraformCluster) GetIdentity(ctx context.Context) (abstract.ClusterIdentity, fail.Error)

+ func (t TerraformCluster) GetKeyPair(ctx context.Context) (*abstract.KeyPair, fail.Error)

+ func (t TerraformCluster) GetName() string

+ func (t TerraformCluster) GetNetworkConfig(ctx context.Context) (*propertiesv3.ClusterNetwork, fail.Error)

+ func (t TerraformCluster) GetState(ctx context.Context) (clusterstate.Enum, fail.Error)

+ func (t TerraformCluster) Inspect(ctx context.Context, callback resources.Callback) fail.Error

+ func (t TerraformCluster) InstallMethods(ctx context.Context) (map[uint8]installmethod.Enum, fail.Error)

+ func (t TerraformCluster) InstalledFeatures(ctx context.Context) ([]string, fail.Error)

+ func (t TerraformCluster) IsFeatureInstalled(ctx context.Context, name string) (found bool, ferr fail.Error)

+ func (t TerraformCluster) IsNull() bool

+ func (t TerraformCluster) ListEligibleFeatures(ctx context.Context) ([]resources.Feature, fail.Error)

+ func (t TerraformCluster) ListInstalledFeatures(ctx context.Context) ([]resources.Feature, fail.Error)

+ func (t TerraformCluster) ListMasters(ctx context.Context) (resources.IndexedListOfClusterNodes, fail.Error)

+ func (t TerraformCluster) ListNodes(ctx context.Context) (resources.IndexedListOfClusterNodes, fail.Error)

+ func (t TerraformCluster) Read(ctx context.Context, ref string) fail.Error

+ func (t TerraformCluster) ReadByID(ctx context.Context, id string) fail.Error

+ func (t TerraformCluster) RegisterFeature(ctx context.Context, feat resources.Feature, requiredBy resources.Feature, ...) fail.Error

+ func (t TerraformCluster) Reload(ctx context.Context) fail.Error

+ func (t TerraformCluster) RemoveFeature(ctx context.Context, name string, vars data.Map, ...) (resources.Results, fail.Error)

+ func (t TerraformCluster) Sdump(ctx context.Context) (string, fail.Error)

+ func (t TerraformCluster) Service() iaas.Service

+ func (t TerraformCluster) Shrink(ctx context.Context, name string, count uint) ([]*propertiesv3.ClusterNode, fail.Error)

+ func (t TerraformCluster) Start(ctx context.Context) fail.Error

+ func (t TerraformCluster) Stop(ctx context.Context) fail.Error

+ func (t TerraformCluster) TargetType() featuretargettype.Enum

+ func (t TerraformCluster) ToProtocol(ctx context.Context) (*protocol.ClusterResponse, fail.Error)

+ func (t TerraformCluster) UnregisterFeature(ctx context.Context, feat string) fail.Error

+ type TfBucket struct

+ Identity string

+ Name string

+ StorageAccount string

+ func ListTerraformBuckets(inctx context.Context, svc iaas.Service) ([]*TfBucket, fail.Error)

+ func NewTerraformBucket(svc iaas.Service) (*TfBucket, fail.Error)

+ func (t *TfBucket) Create(ctx context.Context, name string) fail.Error

+ func (t TfBucket) Alter(ctx context.Context, callback resources.Callback) fail.Error

+ func (t TfBucket) Browse(ctx context.Context, ...) fail.Error

+ func (t TfBucket) BrowseFolder(ctx context.Context, callback func(buf []byte) fail.Error) fail.Error

+ func (t TfBucket) Delete(ctx context.Context) fail.Error

+ func (t TfBucket) Deserialize(ctx context.Context, buf []byte) fail.Error

+ func (t TfBucket) Exists(ctx context.Context) (bool, fail.Error)

+ func (t TfBucket) GetID() (string, error)

+ func (t TfBucket) GetName() string

+ func (t TfBucket) Inspect(ctx context.Context, callback resources.Callback) fail.Error

+ func (t TfBucket) IsNull() bool

+ func (t TfBucket) Mount(ctx context.Context, hostname string, path string) fail.Error

+ func (t TfBucket) Read(ctx context.Context, ref string) fail.Error

+ func (t TfBucket) ReadByID(ctx context.Context, id string) fail.Error

+ func (t TfBucket) Reload(ctx context.Context) fail.Error

+ func (t TfBucket) Sdump(ctx context.Context) (string, fail.Error)

+ func (t TfBucket) Service() iaas.Service

+ func (t TfBucket) ToProtocol(ctx context.Context) (*protocol.BucketResponse, fail.Error)

+ func (t TfBucket) Unmount(ctx context.Context, hostname string) fail.Error

+ type TfHost struct

+ DiskSizeInGb int32

+ Gw2SSHConfig *ssh.CommonConfig

+ GwSSHConfig *ssh.CommonConfig

+ ID string

+ InternalTerraformID string

+ Name string

+ Network string

+ NetworkIDs []string

+ Nics []string

+ Operator string

+ Password string

+ PrivateIP string

+ PrivateKey string

+ PublicIP string

+ SSHPort uint32

+ SubnetID string

+ Tags map[string]string

+ TemplateSize string

+ VmIdentity string

+ func LoadTerraformHostObject(ctx context.Context, svc iaas.Service, hostName string) (*TfHost, error)

+ func NewTerraformHost(svc iaas.Service) (*TfHost, fail.Error)

+ func (t *TfHost) BindLabel(inctx context.Context, labelInstance resources.Label, value string) fail.Error

+ func (t *TfHost) Create(ctx context.Context, hostReq abstract.HostRequest, ...) (*userdata.Content, fail.Error)

+ func (t *TfHost) UnbindLabel(inctx context.Context, labelInstance resources.Label) fail.Error

+ func (t *TfHost) UpdateLabel(inctx context.Context, labelInstance resources.Label, value string) fail.Error

+ func (t TfHost) Alter(ctx context.Context, callback resources.Callback) fail.Error

+ func (t TfHost) BindSecurityGroup(ctx context.Context, sg resources.SecurityGroup, ...) fail.Error

+ func (t TfHost) Browse(ctx context.Context, callback func(*abstract.HostCore) fail.Error) fail.Error

+ func (t TfHost) BrowseFolder(ctx context.Context, callback func(buf []byte) fail.Error) fail.Error

+ func (t TfHost) ComplementFeatureParameters(ctx context.Context, v data.Map) fail.Error

+ func (t TfHost) Delete(ctx context.Context) fail.Error

+ func (t TfHost) Deserialize(ctx context.Context, buf []byte) fail.Error

+ func (t TfHost) DisableSecurityGroup(ctx context.Context, sg resources.SecurityGroup) fail.Error

+ func (t TfHost) EnableSecurityGroup(ctx context.Context, sg resources.SecurityGroup) fail.Error

+ func (t TfHost) Exists(ctx context.Context) (bool, fail.Error)

+ func (t TfHost) ForceGetState(ctx context.Context) (hoststate.Enum, fail.Error)

+ func (t TfHost) GetAccessIP(ctx context.Context) (string, fail.Error)

+ func (t TfHost) GetDefaultSubnet(ctx context.Context) (resources.Subnet, fail.Error)

+ func (t TfHost) GetID() (string, error)

+ func (t TfHost) GetMounts(ctx context.Context) (*propertiesv1.HostMounts, fail.Error)

+ func (t TfHost) GetName() string

+ func (t TfHost) GetPrivateIP(ctx context.Context) (string, fail.Error)

+ func (t TfHost) GetPrivateIPOnSubnet(ctx context.Context, subnetID string) (string, fail.Error)

+ func (t TfHost) GetPublicIP(ctx context.Context) (string, fail.Error)

+ func (t TfHost) GetSSHConfig(ctx context.Context) (sshapi.Config, fail.Error)

+ func (t TfHost) GetShare(ctx context.Context, shareRef string) (*propertiesv1.HostShare, fail.Error)

+ func (t TfHost) GetShares(ctx context.Context) (*propertiesv1.HostShares, fail.Error)

+ func (t TfHost) GetState(ctx context.Context) (hoststate.Enum, fail.Error)

+ func (t TfHost) GetVolumes(ctx context.Context) (*propertiesv1.HostVolumes, fail.Error)

+ func (t TfHost) Inspect(ctx context.Context, callback resources.Callback) fail.Error

+ func (t TfHost) InstallMethods(ctx context.Context) (map[uint8]installmethod.Enum, fail.Error)

+ func (t TfHost) InstalledFeatures(ctx context.Context) ([]string, fail.Error)

+ func (t TfHost) IsClusterMember(ctx context.Context) (bool, fail.Error)

+ func (t TfHost) IsFeatureInstalled(ctx context.Context, name string) (bool, fail.Error)

+ func (t TfHost) IsGateway(ctx context.Context) (bool, fail.Error)

+ func (t TfHost) IsNull() bool

+ func (t TfHost) IsSingle(ctx context.Context) (bool, fail.Error)

+ func (t TfHost) ListEligibleFeatures(ctx context.Context) ([]resources.Feature, fail.Error)

+ func (t TfHost) ListInstalledFeatures(ctx context.Context) ([]resources.Feature, fail.Error)

+ func (t TfHost) ListLabels(ctx context.Context) (list map[string]string, err fail.Error)

+ func (t TfHost) ListSecurityGroups(ctx context.Context, state securitygroupstate.Enum) ([]*propertiesv1.SecurityGroupBond, fail.Error)

+ func (t TfHost) Pull(ctx context.Context, target, source string, timeout time.Duration) (int, string, string, fail.Error)

+ func (t TfHost) Push(ctx context.Context, source, target, owner, mode string, timeout time.Duration) (int, string, string, fail.Error)

+ func (t TfHost) PushStringToFileWithOwnership(ctx context.Context, content string, filename string, owner, mode string) fail.Error

+ func (t TfHost) Read(ctx context.Context, ref string) fail.Error

+ func (t TfHost) ReadByID(ctx context.Context, id string) fail.Error

+ func (t TfHost) Reboot(ctx context.Context, soft bool) fail.Error

+ func (t TfHost) RegisterFeature(ctx context.Context, feat resources.Feature, requiredBy resources.Feature, ...) fail.Error

+ func (t TfHost) Reload(ctx context.Context) fail.Error

+ func (t TfHost) ResetLabel(ctx context.Context, labelInstance resources.Label) fail.Error

+ func (t TfHost) Run(ctx context.Context, cmd string, outs outputs.Enum, ...) (int, string, string, fail.Error)

+ func (t TfHost) Sdump(ctx context.Context) (string, fail.Error)

+ func (t TfHost) Service() iaas.Service

+ func (t TfHost) Start(ctx context.Context) fail.Error

+ func (t TfHost) Stop(ctx context.Context) fail.Error

+ func (t TfHost) TargetType() featuretargettype.Enum

+ func (t TfHost) ToProtocol(ctx context.Context) (*protocol.Host, fail.Error)

+ func (t TfHost) UnbindSecurityGroup(ctx context.Context, sg resources.SecurityGroup) fail.Error

+ func (t TfHost) UnregisterFeature(ctx context.Context, feat string) fail.Error

+ func (t TfHost) WaitSSHReady(ctx context.Context, timeout time.Duration) (status string, err fail.Error)

+ type TfLabel struct

+ func LoadTerraformLabel(inctx context.Context, svc iaas.Service, ref string) (*TfLabel, fail.Error)

+ func LoadTerraformLabels(inctx context.Context, svc iaas.Service) ([]*TfLabel, fail.Error)

+ func NewTerraformLabel(svc iaas.Service) (*TfLabel, fail.Error)

+ func (t *TfLabel) Create(ctx context.Context, name string, hasDefault bool, defaultValue string) fail.Error

+ func (t TfLabel) Alter(ctx context.Context, callback resources.Callback) fail.Error

+ func (t TfLabel) BindToHost(ctx context.Context, hostInstance resources.Host, value string) fail.Error

+ func (t TfLabel) Browse(ctx context.Context, callback func(*abstract.Label) fail.Error) fail.Error

+ func (t TfLabel) BrowseFolder(ctx context.Context, callback func(buf []byte) fail.Error) fail.Error

+ func (t TfLabel) DefaultValue(ctx context.Context) (string, fail.Error)

+ func (t TfLabel) Delete(ctx context.Context) fail.Error

+ func (t TfLabel) Deserialize(ctx context.Context, buf []byte) fail.Error

+ func (t TfLabel) GetID() (string, error)

+ func (t TfLabel) GetName() string

+ func (t TfLabel) Inspect(ctx context.Context, callback resources.Callback) fail.Error

+ func (t TfLabel) IsNull() bool

+ func (t TfLabel) IsTag(ctx context.Context) (bool, fail.Error)

+ func (t TfLabel) Read(ctx context.Context, ref string) fail.Error

+ func (t TfLabel) ReadByID(ctx context.Context, id string) fail.Error

+ func (t TfLabel) Reload(ctx context.Context) fail.Error

+ func (t TfLabel) Sdump(ctx context.Context) (string, fail.Error)

+ func (t TfLabel) Service() iaas.Service

+ func (t TfLabel) ToProtocol(ctx context.Context, withHosts bool) (*protocol.LabelInspectResponse, fail.Error)

+ func (t TfLabel) UnbindFromHost(ctx context.Context, hostInstance resources.Host) fail.Error

+ type TfNetwork struct

+ CIDR string

+ Identity string

+ Name string

+ SubnetCidr string

+ SubnetId string

+ SubnetName string

+ Tags map[string]string

+ func ListTerraformClusters(inctx context.Context, svc iaas.Service) (_ []*TfNetwork, ferr fail.Error)

+ func ListTerraformNetworks(inctx context.Context, svc iaas.Service) (_ []*TfNetwork, ferr fail.Error)

+ func LoadTerraformNetwork(inctx context.Context, svc iaas.Service, name string) (_ *TfNetwork, ferr fail.Error)

+ func NewTerraformNetwork(svc iaas.Service) (*TfNetwork, fail.Error)

+ func (t *TfNetwork) Create(ctx context.Context, req *abstract.NetworkRequest, ...) fail.Error

+ func (t TfNetwork) AbandonSubnet(ctx context.Context, subnetID string) fail.Error

+ func (t TfNetwork) AdoptSubnet(ctx context.Context, subnet resources.Subnet) fail.Error

+ func (t TfNetwork) Alter(ctx context.Context, callback resources.Callback) fail.Error

+ func (t TfNetwork) Browse(ctx context.Context, callback func(*abstract.Network) fail.Error) fail.Error

+ func (t TfNetwork) BrowseFolder(ctx context.Context, callback func(buf []byte) fail.Error) fail.Error

+ func (t TfNetwork) Delete(ctx context.Context) fail.Error

+ func (t TfNetwork) Deserialize(ctx context.Context, buf []byte) fail.Error

+ func (t TfNetwork) Exists(ctx context.Context) (bool, fail.Error)

+ func (t TfNetwork) GetID() (string, error)

+ func (t TfNetwork) GetName() string

+ func (t TfNetwork) Inspect(ctx context.Context, callback resources.Callback) fail.Error

+ func (t TfNetwork) InspectSubnet(ctx context.Context, subnetRef string) (resources.Subnet, fail.Error)

+ func (t TfNetwork) IsNull() bool

+ func (t TfNetwork) Read(ctx context.Context, ref string) fail.Error

+ func (t TfNetwork) ReadByID(ctx context.Context, id string) fail.Error

+ func (t TfNetwork) Reload(ctx context.Context) fail.Error

+ func (t TfNetwork) Sdump(ctx context.Context) (string, fail.Error)

+ func (t TfNetwork) Service() iaas.Service

+ func (t TfNetwork) ToProtocol(ctx context.Context) (*protocol.Network, fail.Error)

+ type TfNic struct

+ Identity string

+ Name string

+ type TfSecurityGroup struct

+ Identity string

+ Location string

+ Name string

+ Rules []map[string]interface{}

+ Tags map[string]string

+ func ListTerraformSGs(inctx context.Context, svc iaas.Service) ([]*TfSecurityGroup, fail.Error)

+ func LoadTerraformSecurityGroup(inctx context.Context, svc iaas.Service, ref string) (*TfSecurityGroup, fail.Error)

+ func NewTerraformSecurityGroup(svc iaas.Service) (*TfSecurityGroup, fail.Error)

+ func (t *TfSecurityGroup) Create(ctx context.Context, networkID, name, description string, ...) fail.Error

+ func (t TfSecurityGroup) AddRule(ctx context.Context, rule *abstract.SecurityGroupRule) fail.Error

+ func (t TfSecurityGroup) AddRules(ctx context.Context, rules abstract.SecurityGroupRules) fail.Error

+ func (t TfSecurityGroup) Alter(ctx context.Context, callback resources.Callback) fail.Error

+ func (t TfSecurityGroup) BindToHost(ctx context.Context, host resources.Host, ...) fail.Error

+ func (t TfSecurityGroup) BindToSubnet(ctx context.Context, subnet resources.Subnet, ...) fail.Error

+ func (t TfSecurityGroup) Browse(ctx context.Context, callback func(*abstract.SecurityGroup) fail.Error) fail.Error

+ func (t TfSecurityGroup) BrowseFolder(ctx context.Context, callback func(buf []byte) fail.Error) fail.Error

+ func (t TfSecurityGroup) Clear(ctx context.Context) fail.Error

+ func (t TfSecurityGroup) Delete(ctx context.Context, force bool) fail.Error

+ func (t TfSecurityGroup) DeleteRule(ctx context.Context, rule *abstract.SecurityGroupRule) fail.Error

+ func (t TfSecurityGroup) Deserialize(ctx context.Context, buf []byte) fail.Error

+ func (t TfSecurityGroup) Exists(ctx context.Context) (bool, fail.Error)

+ func (t TfSecurityGroup) GetBoundHosts(ctx context.Context) ([]*propertiesv1.SecurityGroupBond, fail.Error)

+ func (t TfSecurityGroup) GetBoundSubnets(ctx context.Context) ([]*propertiesv1.SecurityGroupBond, fail.Error)

+ func (t TfSecurityGroup) GetID() (string, error)

+ func (t TfSecurityGroup) GetName() string

+ func (t TfSecurityGroup) Inspect(ctx context.Context, callback resources.Callback) fail.Error

+ func (t TfSecurityGroup) IsNull() bool

+ func (t TfSecurityGroup) Read(ctx context.Context, ref string) fail.Error

+ func (t TfSecurityGroup) ReadByID(ctx context.Context, id string) fail.Error

+ func (t TfSecurityGroup) Reload(ctx context.Context) fail.Error

+ func (t TfSecurityGroup) Reset(ctx context.Context) fail.Error

+ func (t TfSecurityGroup) Sdump(ctx context.Context) (string, fail.Error)

+ func (t TfSecurityGroup) Service() iaas.Service

+ func (t TfSecurityGroup) ToProtocol(ctx context.Context) (*protocol.SecurityGroupResponse, fail.Error)

+ func (t TfSecurityGroup) UnbindFromHost(ctx context.Context, host resources.Host) fail.Error

+ func (t TfSecurityGroup) UnbindFromHostByReference(ctx context.Context, s string) fail.Error

+ func (t TfSecurityGroup) UnbindFromSubnet(ctx context.Context, subnet resources.Subnet) fail.Error

+ func (t TfSecurityGroup) UnbindFromSubnetByReference(ctx context.Context, s string) fail.Error

+ type TfShare struct

+ func NewTerraformShare(svc iaas.Service) (*TfShare, fail.Error)

+ func (t TfShare) Alter(ctx context.Context, callback resources.Callback) fail.Error

+ func (t TfShare) Browse(ctx context.Context, callback func(hostName string, shareID string) fail.Error) fail.Error

+ func (t TfShare) BrowseFolder(ctx context.Context, callback func(buf []byte) fail.Error) fail.Error

+ func (t TfShare) Create(ctx context.Context, shareName string, host resources.Host, path string, ...) fail.Error

+ func (t TfShare) Delete(ctx context.Context) fail.Error

+ func (t TfShare) Deserialize(ctx context.Context, buf []byte) fail.Error

+ func (t TfShare) Exists(ctx context.Context) (bool, fail.Error)

+ func (t TfShare) GetID() (string, error)

+ func (t TfShare) GetName() string

+ func (t TfShare) GetServer(ctx context.Context) (resources.Host, fail.Error)

+ func (t TfShare) Inspect(ctx context.Context, callback resources.Callback) fail.Error

+ func (t TfShare) IsNull() bool

+ func (t TfShare) Mount(ctx context.Context, host resources.Host, path string, withCache bool) (*propertiesv1.HostRemoteMount, fail.Error)

+ func (t TfShare) Read(ctx context.Context, ref string) fail.Error

+ func (t TfShare) ReadByID(ctx context.Context, id string) fail.Error

+ func (t TfShare) Reload(ctx context.Context) fail.Error

+ func (t TfShare) Sdump(ctx context.Context) (string, fail.Error)

+ func (t TfShare) Service() iaas.Service

+ func (t TfShare) ToProtocol(ctx context.Context) (*protocol.ShareMountList, fail.Error)

+ func (t TfShare) Unmount(ctx context.Context, host resources.Host) fail.Error

+ type TfSubnet struct

+ CIDR string

+ GatewayIDS []string

+ Identity string

+ Name string

+ NetworkID string

+ NetworkName string

+ Tags map[string]string

+ func ListTerraformSubnets(inctx context.Context, svc iaas.Service, networkRef, sunetRef string, all bool) ([]*TfSubnet, fail.Error)

+ func LoadTerraformSubnet(inctx context.Context, svc iaas.Service, networkRef, sunetRef string) (*TfSubnet, fail.Error)

+ func NewTerraformSubnet(svc iaas.Service) (*TfSubnet, fail.Error)

+ func (t *TfSubnet) Create(ctx context.Context, req abstract.SubnetRequest, gwname string, ...) fail.Error

+ func (t TfSubnet) Alter(ctx context.Context, callback resources.Callback) fail.Error

+ func (t TfSubnet) AttachHost(ctx context.Context, host resources.Host) fail.Error

+ func (t TfSubnet) BindSecurityGroup(ctx context.Context, group resources.SecurityGroup, ...) fail.Error

+ func (t TfSubnet) Browse(ctx context.Context, callback func(*abstract.Subnet) fail.Error) fail.Error

+ func (t TfSubnet) BrowseFolder(ctx context.Context, callback func(buf []byte) fail.Error) fail.Error

+ func (t TfSubnet) Delete(ctx context.Context) fail.Error

+ func (t TfSubnet) Deserialize(ctx context.Context, buf []byte) fail.Error

+ func (t TfSubnet) DetachHost(ctx context.Context, hostID string) fail.Error

+ func (t TfSubnet) DisableSecurityGroup(ctx context.Context, group resources.SecurityGroup) fail.Error

+ func (t TfSubnet) EnableSecurityGroup(ctx context.Context, group resources.SecurityGroup) fail.Error

+ func (t TfSubnet) Exists(ctx context.Context) (bool, fail.Error)

+ func (t TfSubnet) GetCIDR(ctx context.Context) (string, fail.Error)

+ func (t TfSubnet) GetDefaultRouteIP(ctx context.Context) (string, fail.Error)

+ func (t TfSubnet) GetEndpointIP(ctx context.Context) (string, fail.Error)

+ func (t TfSubnet) GetGatewayPublicIP(ctx context.Context, primary bool) (string, fail.Error)

+ func (t TfSubnet) GetGatewayPublicIPs(ctx context.Context) ([]string, fail.Error)

+ func (t TfSubnet) GetID() (string, error)

+ func (t TfSubnet) GetName() string

+ func (t TfSubnet) GetState(ctx context.Context) (subnetstate.Enum, fail.Error)

+ func (t TfSubnet) HasVirtualIP(ctx context.Context) (bool, fail.Error)

+ func (t TfSubnet) Inspect(ctx context.Context, callback resources.Callback) fail.Error

+ func (t TfSubnet) InspectGateway(ctx context.Context, primary bool) (resources.Host, fail.Error)

+ func (t TfSubnet) InspectGatewaySecurityGroup(ctx context.Context) (resources.SecurityGroup, fail.Error)

+ func (t TfSubnet) InspectInternalSecurityGroup(ctx context.Context) (resources.SecurityGroup, fail.Error)

+ func (t TfSubnet) InspectNetwork(ctx context.Context) (resources.Network, fail.Error)

+ func (t TfSubnet) InspectPublicIPSecurityGroup(ctx context.Context) (resources.SecurityGroup, fail.Error)

+ func (t TfSubnet) IsNull() bool

+ func (t TfSubnet) ListHosts(ctx context.Context) ([]resources.Host, fail.Error)

+ func (t TfSubnet) ListSecurityGroups(ctx context.Context, state securitygroupstate.Enum) ([]*propertiesv1.SecurityGroupBond, fail.Error)

+ func (t TfSubnet) Read(ctx context.Context, ref string) fail.Error

+ func (t TfSubnet) ReadByID(ctx context.Context, id string) fail.Error

+ func (t TfSubnet) Reload(ctx context.Context) fail.Error

+ func (t TfSubnet) Sdump(ctx context.Context) (string, fail.Error)

+ func (t TfSubnet) Service() iaas.Service

+ func (t TfSubnet) ToProtocol(ctx context.Context) (*protocol.Subnet, fail.Error)

+ func (t TfSubnet) UnbindSecurityGroup(ctx context.Context, group resources.SecurityGroup) fail.Error

+ type TfVolume struct

+ Identity string

+ Location string

+ Name string

+ Size int32

+ Tags map[string]string

+ func ListTerraformVolumes(inctx context.Context, svc iaas.Service) ([]*TfVolume, fail.Error)

+ func LoadTerraformVolume(inctx context.Context, svc iaas.Service, ref string) (*TfVolume, fail.Error)

+ func NewTerraformVolume(svc iaas.Service) (*TfVolume, fail.Error)

+ func (t *TfVolume) Create(ctx context.Context, req abstract.VolumeRequest) fail.Error

+ func (t TfVolume) Alter(ctx context.Context, callback resources.Callback) fail.Error

+ func (t TfVolume) Attach(ctx context.Context, host resources.Host, path, format string, ...) fail.Error

+ func (t TfVolume) Browse(ctx context.Context, callback func(*abstract.Volume) fail.Error) fail.Error

+ func (t TfVolume) BrowseFolder(ctx context.Context, callback func(buf []byte) fail.Error) fail.Error

+ func (t TfVolume) Delete(ctx context.Context) fail.Error

+ func (t TfVolume) Deserialize(ctx context.Context, buf []byte) fail.Error

+ func (t TfVolume) Detach(ctx context.Context, host resources.Host) fail.Error

+ func (t TfVolume) Exists(ctx context.Context) (bool, fail.Error)

+ func (t TfVolume) GetAttachments(ctx context.Context) (*propertiesv1.VolumeAttachments, fail.Error)

+ func (t TfVolume) GetID() (string, error)

+ func (t TfVolume) GetName() string

+ func (t TfVolume) GetSize(ctx context.Context) (int, fail.Error)

+ func (t TfVolume) GetSpeed(ctx context.Context) (volumespeed.Enum, fail.Error)

+ func (t TfVolume) Inspect(ctx context.Context, callback resources.Callback) fail.Error

+ func (t TfVolume) IsNull() bool

+ func (t TfVolume) Read(ctx context.Context, ref string) fail.Error

+ func (t TfVolume) ReadByID(ctx context.Context, id string) fail.Error

+ func (t TfVolume) Reload(ctx context.Context) fail.Error

+ func (t TfVolume) Sdump(ctx context.Context) (string, fail.Error)

+ func (t TfVolume) Service() iaas.Service

+ func (t TfVolume) ToProtocol(ctx context.Context) (*protocol.VolumeInspectResponse, fail.Error)

+ type TfVolumeAttachment struct

+ AttachedDiskId string

+ AttachedHostId string

+ Identity string

+ Name string

v22.11.8

May 22, 2023

Changes in this version

+ type ClassicCluster struct

+ func (instance *ClassicCluster) AddFeature(ctx context.Context, name string, vars data.Map, ...) (resources.Results, fail.Error)

+ func (instance *ClassicCluster) AddNodes(ctx context.Context, cluName string, count uint, ...) (_ []resources.Host, ferr fail.Error)

+ func (instance *ClassicCluster) Browse(inctx context.Context, callback func(*abstract.ClusterIdentity) fail.Error) (ferr fail.Error)

+ func (instance *ClassicCluster) CheckFeature(ctx context.Context, name string, vars data.Map, ...) (resources.Results, fail.Error)

+ func (instance *ClassicCluster) ComplementFeatureParameters(inctx context.Context, v data.Map) (ferr fail.Error)

+ func (instance *ClassicCluster) Create(inctx context.Context, req abstract.ClusterRequest) fail.Error

+ func (instance *ClassicCluster) Delete(ctx context.Context, force bool) (ferr fail.Error)

+ func (instance *ClassicCluster) DeleteSpecificNode(ctx context.Context, hostID string, selectedMasterID string) (ferr fail.Error)

+ func (instance *ClassicCluster) Deserialize(_ context.Context, buf []byte) (ferr fail.Error)

+ func (instance *ClassicCluster) ExecuteScript(inctx context.Context, tmplName string, variables data.Map, ...) (_ int, _ string, _ string, ferr fail.Error)

+ func (instance *ClassicCluster) Exists(ctx context.Context) (_ bool, ferr fail.Error)

+ func (instance *ClassicCluster) FindAvailableMaster(ctx context.Context) (master resources.Host, ferr fail.Error)

+ func (instance *ClassicCluster) GetAdminPassword(_ context.Context) (adminPassword string, ferr fail.Error)

+ func (instance *ClassicCluster) GetComplexity(ctx context.Context) (_ clustercomplexity.Enum, ferr fail.Error)

+ func (instance *ClassicCluster) GetFlavor(ctx context.Context) (flavor clusterflavor.Enum, ferr fail.Error)

+ func (instance *ClassicCluster) GetIdentity(ctx context.Context) (clusterIdentity abstract.ClusterIdentity, ferr fail.Error)

+ func (instance *ClassicCluster) GetKeyPair(_ context.Context) (keyPair *abstract.KeyPair, ferr fail.Error)

+ func (instance *ClassicCluster) GetNetworkConfig(ctx context.Context) (config *propertiesv3.ClusterNetwork, ferr fail.Error)

+ func (instance *ClassicCluster) GetState(ctx context.Context) (state clusterstate.Enum, ferr fail.Error)

+ func (instance *ClassicCluster) InstallMethods(ctx context.Context) (map[uint8]installmethod.Enum, fail.Error)

+ func (instance *ClassicCluster) InstalledFeatures(ctx context.Context) ([]string, fail.Error)

+ func (instance *ClassicCluster) IsFeatureInstalled(inctx context.Context, name string) (_ bool, _ fail.Error)

+ func (instance *ClassicCluster) IsNull() bool

+ func (instance *ClassicCluster) ListEligibleFeatures(ctx context.Context) (_ []resources.Feature, ferr fail.Error)

+ func (instance *ClassicCluster) ListInstalledFeatures(ctx context.Context) (_ []resources.Feature, ferr fail.Error)

+ func (instance *ClassicCluster) ListMasters(ctx context.Context) (list resources.IndexedListOfClusterNodes, ferr fail.Error)

+ func (instance *ClassicCluster) ListNodeNames(ctx context.Context) (list data.IndexedListOfStrings, ferr fail.Error)

+ func (instance *ClassicCluster) ListNodes(ctx context.Context) (list resources.IndexedListOfClusterNodes, ferr fail.Error)

+ func (instance *ClassicCluster) RegisterFeature(ctx context.Context, feat resources.Feature, requiredBy resources.Feature, ...) (ferr fail.Error)

+ func (instance *ClassicCluster) RemoveFeature(ctx context.Context, name string, vars data.Map, ...) (resources.Results, fail.Error)

+ func (instance *ClassicCluster) Sdump(ctx context.Context) (_ string, ferr fail.Error)

+ func (instance *ClassicCluster) Shrink(ctx context.Context, cluName string, count uint) (_ []*propertiesv3.ClusterNode, ferr fail.Error)

+ func (instance *ClassicCluster) Start(ctx context.Context) (ferr fail.Error)

+ func (instance *ClassicCluster) Stop(ctx context.Context) (ferr fail.Error)

+ func (instance *ClassicCluster) TargetType() featuretargettype.Enum

+ func (instance *ClassicCluster) ToProtocol(ctx context.Context) (_ *protocol.ClusterResponse, ferr fail.Error)

+ func (instance *ClassicCluster) UnregisterFeature(inctx context.Context, feat string) (ferr fail.Error)

v22.11.7

Mar 1, 2023

v22.11.6

Feb 15, 2023

Changes in this version

type Tenant

+ func LoadTenant(ctx context.Context, tenantName string) (*Tenant, error)

v22.11.5

Feb 1, 2023

v22.11.4

Jan 31, 2023

v22.11.3

Jan 24, 2023

Changes in this version

+ func RenderFeature(inctx context.Context, feat Feature) (string, fail.Error)

type Feature

+ func (instance *Feature) ConditionParameters(ctx context.Context, externals data.Map, target resources.Targetable) fail.Error

+ func (instance Feature) PrepareParameters(ctx context.Context, externals data.Map, target resources.Targetable) (data.Map, fail.Error)

v22.11.2

Jan 3, 2023

Changes in this version

+ var MINTIMINGS = &temporal.MutableTimings

v22.11.1

Dec 19, 2022

Changes in this version

+ var FUCKING_TIMINGS = &temporal.MutableTimings

v22.11.0

Dec 2, 2022

Changes in this version

+ const FirstMetadataVersion

+ const MinimumMetadataVersion

+ const MustUpgradeBinaries

+ const MustUpgradeMessage

+ const NOTFOUND

+ var CurrentNetworkAbstractContextKey = "current_network_abstract"

+ var CurrentNetworkPropertiesContextKey = "current_network_properties"

+ func ActionFromError(err error) string

+ func CheckMetadataVersion(ctx context.Context, svc iaas.Service) (string, fail.Error)

+ func ExtractFeatureParameters(params []string) data.Map

+ func FilterBondsByKind(bonds map[string]*propertiesv1.SecurityGroupBond, ...) []*propertiesv1.SecurityGroupBond

+ func FreeCIDRForSingleHost(ctx context.Context, network resources.Network, index uint) fail.Error

+ func ListSubnets(ctx context.Context, svc iaas.Service, networkID string, all bool) (_ []*abstract.Subnet, ferr fail.Error)

+ func LoadBucket(inctx context.Context, svc iaas.Service, name string) (resources.Bucket, fail.Error)

+ func LoadCluster(inctx context.Context, svc iaas.Service, name string, ...) (_ resources.Cluster, ferr fail.Error)

+ func LoadHost(inctx context.Context, svc iaas.Service, ref string, ...) (resources.Host, fail.Error)

+ func LoadLabel(inctx context.Context, svc iaas.Service, ref string, ...) (resources.Label, fail.Error)

+ func LoadNetwork(inctx context.Context, svc iaas.Service, ref string, ...) (resources.Network, fail.Error)

+ func LoadShare(inctx context.Context, svc iaas.Service, ref string, ...) (resources.Share, fail.Error)

+ func LoadVolume(inctx context.Context, svc iaas.Service, ref string, ...) (resources.Volume, fail.Error)

+ func NewBucket(svc iaas.Service) (resources.Bucket, fail.Error)

+ func NewEmbeddedFeature(ctx context.Context, svc iaas.Service, name string) (_ resources.Feature, ferr fail.Error)

+ func NewFeature(ctx context.Context, svc iaas.Service, name string) (_ resources.Feature, ferr fail.Error)

+ func NewLabel(svc iaas.Service) (_ resources.Label, ferr fail.Error)

+ func NewNetwork(svc iaas.Service) (resources.Network, fail.Error)

+ func NewShare(svc iaas.Service) (resources.Share, fail.Error)

+ func NewVolume(svc iaas.Service) (_ resources.Volume, ferr fail.Error)

+ func ReserveCIDRForSingleHost(ctx context.Context, networkInstance resources.Network) (_ string, _ uint, ferr fail.Error)

+ func SetCurrentTenant(ctx context.Context, tenantName string) error

+ func Stack() []byte

+ func StartFeatureFileWatcher()

+ type Cluster struct

+ func NewCluster(inctx context.Context, svc iaas.Service) (_ *Cluster, ferr fail.Error)

+ func (instance *Cluster) AddFeature(ctx context.Context, name string, vars data.Map, ...) (resources.Results, fail.Error)

+ func (instance *Cluster) AddNodes(ctx context.Context, cluName string, count uint, ...) (_ []resources.Host, ferr fail.Error)

+ func (instance *Cluster) Browse(inctx context.Context, callback func(*abstract.ClusterIdentity) fail.Error) (ferr fail.Error)

+ func (instance *Cluster) CheckFeature(ctx context.Context, name string, vars data.Map, ...) (resources.Results, fail.Error)

+ func (instance *Cluster) ComplementFeatureParameters(inctx context.Context, v data.Map) (ferr fail.Error)

+ func (instance *Cluster) Create(inctx context.Context, req abstract.ClusterRequest) fail.Error

+ func (instance *Cluster) Delete(ctx context.Context, force bool) (ferr fail.Error)

+ func (instance *Cluster) DeleteSpecificNode(ctx context.Context, hostID string, selectedMasterID string) (ferr fail.Error)

+ func (instance *Cluster) Deserialize(_ context.Context, buf []byte) (ferr fail.Error)

+ func (instance *Cluster) ExecuteScript(inctx context.Context, tmplName string, variables data.Map, ...) (_ int, _ string, _ string, ferr fail.Error)

+ func (instance *Cluster) Exists(ctx context.Context) (_ bool, ferr fail.Error)

+ func (instance *Cluster) FindAvailableMaster(ctx context.Context) (master resources.Host, ferr fail.Error)

+ func (instance *Cluster) FindAvailableNode(ctx context.Context) (node resources.Host, ferr fail.Error)

+ func (instance *Cluster) GetAdminPassword(ctx context.Context) (adminPassword string, ferr fail.Error)

+ func (instance *Cluster) GetComplexity(ctx context.Context) (_ clustercomplexity.Enum, ferr fail.Error)

+ func (instance *Cluster) GetFlavor(ctx context.Context) (flavor clusterflavor.Enum, ferr fail.Error)

+ func (instance *Cluster) GetIdentity(ctx context.Context) (clusterIdentity abstract.ClusterIdentity, ferr fail.Error)

+ func (instance *Cluster) GetKeyPair(ctx context.Context) (keyPair *abstract.KeyPair, ferr fail.Error)

+ func (instance *Cluster) GetNetworkConfig(ctx context.Context) (config *propertiesv3.ClusterNetwork, ferr fail.Error)

+ func (instance *Cluster) GetState(ctx context.Context) (state clusterstate.Enum, ferr fail.Error)

+ func (instance *Cluster) InstallMethods(ctx context.Context) (map[uint8]installmethod.Enum, fail.Error)

+ func (instance *Cluster) InstalledFeatures(ctx context.Context) ([]string, fail.Error)

+ func (instance *Cluster) IsFeatureInstalled(inctx context.Context, name string) (_ bool, _ fail.Error)

+ func (instance *Cluster) IsNull() bool

+ func (instance *Cluster) ListEligibleFeatures(ctx context.Context) (_ []resources.Feature, ferr fail.Error)

+ func (instance *Cluster) ListInstalledFeatures(ctx context.Context) (_ []resources.Feature, ferr fail.Error)

+ func (instance *Cluster) ListMasters(ctx context.Context) (list resources.IndexedListOfClusterNodes, ferr fail.Error)

+ func (instance *Cluster) ListNodeNames(ctx context.Context) (list data.IndexedListOfStrings, ferr fail.Error)

+ func (instance *Cluster) ListNodes(ctx context.Context) (list resources.IndexedListOfClusterNodes, ferr fail.Error)

+ func (instance *Cluster) LookupNode(ctx context.Context, ref string) (found bool, ferr fail.Error)

+ func (instance *Cluster) RegisterFeature(ctx context.Context, feat resources.Feature, requiredBy resources.Feature, ...) (ferr fail.Error)

+ func (instance *Cluster) RemoveFeature(ctx context.Context, name string, vars data.Map, ...) (resources.Results, fail.Error)

+ func (instance *Cluster) Sdump(ctx context.Context) (_ string, ferr fail.Error)

+ func (instance *Cluster) Shrink(ctx context.Context, cluName string, count uint) (_ []*propertiesv3.ClusterNode, ferr fail.Error)

+ func (instance *Cluster) Start(ctx context.Context) (ferr fail.Error)

+ func (instance *Cluster) Stop(ctx context.Context) (ferr fail.Error)

+ func (instance *Cluster) TargetType() featuretargettype.Enum

+ func (instance *Cluster) ToProtocol(ctx context.Context) (_ *protocol.ClusterResponse, ferr fail.Error)

+ func (instance *Cluster) UnregisterFeature(inctx context.Context, feat string) (ferr fail.Error)

+ type ConditionedFeatureParameter struct

+ func NewConditionedFeatureParameter(parameter FeatureParameter, value *string) (ConditionedFeatureParameter, fail.Error)

+ func (cfp ConditionedFeatureParameter) Value() string

+ type ConditionedFeatureParameters map[string]ConditionedFeatureParameter

+ func (cfp ConditionedFeatureParameters) ToMap() data.Map

+ type Feature struct

+ func (instance *Feature) Add(ctx context.Context, target resources.Targetable, v data.Map, ...) (_ resources.Results, ferr fail.Error)

+ func (instance *Feature) Applicable(ctx context.Context, tg resources.Targetable) (bool, fail.Error)

+ func (instance *Feature) Check(ctx context.Context, target resources.Targetable, v data.Map, ...) (_ resources.Results, ferr fail.Error)

+ func (instance *Feature) Clone() (data.Clonable, error)

+ func (instance *Feature) ClusterSizingRequirements() (map[string]interface{}, fail.Error)

+ func (instance *Feature) ClusterSizingRequirementsForFlavor(flavor string) (map[string]interface{}, fail.Error)

+ func (instance *Feature) Dependencies(ctx context.Context) (map[string]struct{}, fail.Error)

+ func (instance *Feature) GetDisplayFilename(ctx context.Context) string

+ func (instance *Feature) GetFilename(ctx context.Context) (string, fail.Error)

+ func (instance *Feature) GetID() (string, error)

+ func (instance *Feature) GetName() string

+ func (instance *Feature) InstanciateInstallerOfMethod(m installmethod.Enum) Installer

+ func (instance *Feature) IsNull() bool

+ func (instance *Feature) Remove(ctx context.Context, target resources.Targetable, v data.Map, ...) (_ resources.Results, ferr fail.Error)

+ func (instance *Feature) Replace(p data.Clonable) (data.Clonable, error)

+ func (instance *Feature) Specs() *viper.Viper

+ func (instance Feature) ListParametersWithControl(ctx context.Context) []string

+ func (instance Feature) ToProtocol(ctx context.Context) *protocol.FeatureResponse

+ type FeatureFile struct

+ func LoadFeatureFile(inctx context.Context, svc iaas.Service, name string, embeddedOnly bool) (*FeatureFile, fail.Error)

+ func (ff *FeatureFile) Clone() (data.Clonable, error)

+ func (ff *FeatureFile) DisplayFilename() string

+ func (ff *FeatureFile) Filename() string

+ func (ff *FeatureFile) GetID() (string, error)

+ func (ff *FeatureFile) GetName() string

+ func (ff *FeatureFile) IsNull() bool

+ func (ff *FeatureFile) Replace(p data.Clonable) (data.Clonable, error)

+ func (ff *FeatureFile) Specs() *viper.Viper

+ type FeatureParameter struct

+ func NewFeatureParameter(name, description string, hasDefault bool, defaultValue string, ...) (FeatureParameter, fail.Error)

+ func (fp FeatureParameter) DefaultValue() (string, bool)

+ func (fp FeatureParameter) Description() string

+ func (fp FeatureParameter) HasDefaultValue() bool

+ func (fp FeatureParameter) HasValueControl() bool

+ func (fp FeatureParameter) Name() string

+ func (fp FeatureParameter) ValueControlCode() (string, bool)

+ type FolderDecoderCallback func([]byte) fail.Error

+ type Host struct

+ func NewHost(svc iaas.Service) (_ *Host, ferr fail.Error)

+ func (instance *Host) AddFeature(ctx context.Context, name string, vars data.Map, ...) (outcomes resources.Results, ferr fail.Error)

+ func (instance *Host) BindLabel(ctx context.Context, labelInstance resources.Label, value string) (ferr fail.Error)

+ func (instance *Host) BindSecurityGroup(ctx context.Context, sgInstance resources.SecurityGroup, ...) (ferr fail.Error)

+ func (instance *Host) Browse(ctx context.Context, callback func(*abstract.HostCore) fail.Error) (ferr fail.Error)

+ func (instance *Host) CheckFeature(ctx context.Context, name string, vars data.Map, ...) (_ resources.Results, ferr fail.Error)

+ func (instance *Host) ComplementFeatureParameters(ctx context.Context, v data.Map) (ferr fail.Error)

+ func (instance *Host) Create(inctx context.Context, hostReq abstract.HostRequest, ...) (_ *userdata.Content, ferr fail.Error)

+ func (instance *Host) Delete(ctx context.Context) (ferr fail.Error)

+ func (instance *Host) DeleteFeature(inctx context.Context, name string, vars data.Map, ...) (_ resources.Results, ferr fail.Error)

+ func (instance *Host) DisableSecurityGroup(ctx context.Context, sgInstance resources.SecurityGroup) (ferr fail.Error)

+ func (instance *Host) EnableSecurityGroup(ctx context.Context, sg resources.SecurityGroup) (ferr fail.Error)

+ func (instance *Host) Exists(ctx context.Context) (_ bool, ferr fail.Error)

+ func (instance *Host) ForceGetState(ctx context.Context) (state hoststate.Enum, ferr fail.Error)

+ func (instance *Host) GetAccessIP(ctx context.Context) (_ string, ferr fail.Error)

+ func (instance *Host) GetDefaultSubnet(ctx context.Context) (subnetInstance resources.Subnet, ferr fail.Error)

+ func (instance *Host) GetMounts(ctx context.Context) (mounts *propertiesv1.HostMounts, ferr fail.Error)

+ func (instance *Host) GetPrivateIP(ctx context.Context) (_ string, ferr fail.Error)

+ func (instance *Host) GetPrivateIPOnSubnet(ctx context.Context, subnetID string) (_ string, ferr fail.Error)

+ func (instance *Host) GetPublicIP(ctx context.Context) (_ string, ferr fail.Error)

+ func (instance *Host) GetSSHConfig(ctx context.Context) (_ sshapi.Config, ferr fail.Error)

+ func (instance *Host) GetShare(ctx context.Context, shareRef string) (_ *propertiesv1.HostShare, ferr fail.Error)

+ func (instance *Host) GetShares(ctx context.Context) (shares *propertiesv1.HostShares, ferr fail.Error)

+ func (instance *Host) GetState(ctx context.Context) (hoststate.Enum, fail.Error)

+ func (instance *Host) GetView(ctx context.Context) (*abstract.HostCore, *serialize.JSONProperties, fail.Error)

+ func (instance *Host) GetVolumes(ctx context.Context) (_ *propertiesv1.HostVolumes, ferr fail.Error)

+ func (instance *Host) InstallMethods(ctx context.Context) (map[uint8]installmethod.Enum, fail.Error)

+ func (instance *Host) InstalledFeatures(ctx context.Context) ([]string, fail.Error)

+ func (instance *Host) IsClusterMember(ctx context.Context) (yes bool, ferr fail.Error)

+ func (instance *Host) IsFeatureInstalled(ctx context.Context, name string) (found bool, ferr fail.Error)

+ func (instance *Host) IsGateway(ctx context.Context) (_ bool, ferr fail.Error)

+ func (instance *Host) IsNull() bool

+ func (instance *Host) IsSingle(ctx context.Context) (_ bool, ferr fail.Error)

+ func (instance *Host) ListEligibleFeatures(ctx context.Context) (_ []resources.Feature, ferr fail.Error)

+ func (instance *Host) ListInstalledFeatures(ctx context.Context) (_ []resources.Feature, ferr fail.Error)

+ func (instance *Host) ListLabels(ctx context.Context) (_ map[string]string, ferr fail.Error)

+ func (instance *Host) ListSecurityGroups(ctx context.Context, state securitygroupstate.Enum) (list []*propertiesv1.SecurityGroupBond, ferr fail.Error)

+ func (instance *Host) Pull(ctx context.Context, target, source string, timeout time.Duration) (_ int, _ string, _ string, ferr fail.Error)

+ func (instance *Host) Push(ctx context.Context, source, target, owner, mode string, timeout time.Duration) (_ int, _ string, _ string, ferr fail.Error)

+ func (instance *Host) PushStringToFileWithOwnership(ctx context.Context, content string, filename string, owner, mode string) (ferr fail.Error)

+ func (instance *Host) Reboot(ctx context.Context, soft bool) (ferr fail.Error)

+ func (instance *Host) RegisterFeature(ctx context.Context, feat resources.Feature, requiredBy resources.Feature, ...) (ferr fail.Error)

+ func (instance *Host) RelaxedDeleteHost(ctx context.Context) (ferr fail.Error)

+ func (instance *Host) Reload(ctx context.Context) (ferr fail.Error)

+ func (instance *Host) ResetLabel(ctx context.Context, labelInstance resources.Label) (ferr fail.Error)

+ func (instance *Host) Run(ctx context.Context, cmd string, outs outputs.Enum, ...) (_ int, _ string, _ string, ferr fail.Error)

+ func (instance *Host) Start(ctx context.Context) (ferr fail.Error)

+ func (instance *Host) Stop(ctx context.Context) (ferr fail.Error)

+ func (instance *Host) Sync(ctx context.Context) (ferr fail.Error)

+ func (instance *Host) TargetType() featuretargettype.Enum

+ func (instance *Host) ToProtocol(ctx context.Context) (ph *protocol.Host, ferr fail.Error)

+ func (instance *Host) UnbindLabel(ctx context.Context, labelInstance resources.Label) (ferr fail.Error)

+ func (instance *Host) UnbindSecurityGroup(ctx context.Context, sgInstance resources.SecurityGroup) (ferr fail.Error)

+ func (instance *Host) UnregisterFeature(ctx context.Context, feat string) (ferr fail.Error)

+ func (instance *Host) UpdateLabel(ctx context.Context, labelInstance resources.Label, value string) (ferr fail.Error)

+ func (instance *Host) WaitSSHReady(ctx context.Context, timeout time.Duration) (_ string, ferr fail.Error)

+ type Installer interface

+ Add func(context.Context, resources.Feature, resources.Targetable, data.Map, ...) (resources.Results, fail.Error)

+ Check func(context.Context, resources.Feature, resources.Targetable, data.Map, ...) (resources.Results, fail.Error)

+ Remove func(context.Context, resources.Feature, resources.Targetable, data.Map, ...) (resources.Results, fail.Error)

+ type Item struct

+ Local string

+ Remote string

+ RemoteOwner string

+ RemoteRights string

+ func (rfc Item) RemoveRemote(ctx context.Context, host resources.Host) fail.Error

+ func (rfc Item) Upload(ctx context.Context, host resources.Host) (ferr fail.Error)

+ func (rfc Item) UploadString(ctx context.Context, content string, host resources.Host) fail.Error

+ type KongController struct

+ func NewKongController(ctx context.Context, svc iaas.Service, subnet resources.Subnet, ...) (*KongController, fail.Error)

+ func (k *KongController) Apply(ctx context.Context, rule map[interface{}]interface{}, values *data.Map) (string, fail.Error)

+ func (k *KongController) GetHostname() string

+ type MetadataCore struct

+ func NewCore(svc iaas.Service, kind string, path string, instance data.Clonable) (_ *MetadataCore, ferr fail.Error)

+ func (myself *MetadataCore) Alter(inctx context.Context, callback resources.Callback, ...) (rerr fail.Error)

+ func (myself *MetadataCore) BrowseFolder(inctx context.Context, callback func(buf []byte) fail.Error) (_ fail.Error)

+ func (myself *MetadataCore) Carry(inctx context.Context, clonable data.Clonable) (rerr fail.Error)

+ func (myself *MetadataCore) Delete(inctx context.Context) (_ fail.Error)

+ func (myself *MetadataCore) Deserialize(inctx context.Context, buf []byte) fail.Error

+ func (myself *MetadataCore) GetID() (string, error)

+ func (myself *MetadataCore) GetKind() string

+ func (myself *MetadataCore) GetName() string

+ func (myself *MetadataCore) Inspect(inctx context.Context, callback resources.Callback) (rerr fail.Error)

+ func (myself *MetadataCore) IsNull() bool

+ func (myself *MetadataCore) IsTaken() bool

+ func (myself *MetadataCore) IsValid() (bool, fail.Error)

+ func (myself *MetadataCore) Read(inctx context.Context, ref string) (_ fail.Error)

+ func (myself *MetadataCore) ReadByID(inctx context.Context, id string) (_ fail.Error)

+ func (myself *MetadataCore) Reload(inctx context.Context) (ferr fail.Error)

+ func (myself *MetadataCore) Review(inctx context.Context, callback resources.Callback) (rerr fail.Error)

+ func (myself *MetadataCore) Sdump(inctx context.Context) (string, fail.Error)

+ func (myself *MetadataCore) Service() iaas.Service

+ type MetadataFolder struct

+ func NewMetadataFolder(svc iaas.Service, path string) (MetadataFolder, fail.Error)

+ func (instance *MetadataFolder) IsNull() bool

+ func (instance MetadataFolder) Browse(ctx context.Context, path string, callback FolderDecoderCallback) fail.Error

+ func (instance MetadataFolder) Delete(ctx context.Context, path string, name string) fail.Error

+ func (instance MetadataFolder) GetBucket(ctx context.Context) (abstract.ObjectStorageBucket, fail.Error)

+ func (instance MetadataFolder) Lookup(ctx context.Context, path string, name string) fail.Error

+ func (instance MetadataFolder) Path() string

+ func (instance MetadataFolder) Read(ctx context.Context, path string, name string, ...) fail.Error

+ func (instance MetadataFolder) Service() iaas.Service

+ func (instance MetadataFolder) Write(ctx context.Context, path string, name string, content []byte, ...) fail.Error

+ type MetadataFolderLike interface

+ Browse func(ctx context.Context, path string, callback FolderDecoderCallback) fail.Error

+ Delete func(ctx context.Context, path string, name string) fail.Error

+ GetBucket func(ctx context.Context) (abstract.ObjectStorageBucket, fail.Error)

+ IsNull func() bool

+ Lookup func(ctx context.Context, path string, name string) fail.Error

+ Path func() string

+ Read func(ctx context.Context, path string, name string, ...) fail.Error

+ Service func() iaas.Service

+ Write func(ctx context.Context, path string, name string, content []byte, ...) fail.Error

+ type Network struct

+ func (instance *Network) AbandonSubnet(ctx context.Context, subnetID string) (ferr fail.Error)

+ func (instance *Network) AdoptSubnet(ctx context.Context, subnet resources.Subnet) (ferr fail.Error)

+ func (instance *Network) Browse(ctx context.Context, callback func(*abstract.Network) fail.Error) (ferr fail.Error)

+ func (instance *Network) Create(inctx context.Context, req abstract.NetworkRequest) (_ fail.Error)

+ func (instance *Network) Delete(inctx context.Context) (ferr fail.Error)

+ func (instance *Network) Exists(ctx context.Context) (_ bool, ferr fail.Error)

+ func (instance *Network) GetCIDR(ctx context.Context) (cidr string, ferr fail.Error)

+ func (instance *Network) Import(ctx context.Context, ref string) (ferr fail.Error)

+ func (instance *Network) InspectSubnet(ctx context.Context, ref string) (_ resources.Subnet, ferr fail.Error)

+ func (instance *Network) IsNull() bool

+ func (instance *Network) ToProtocol(ctx context.Context) (out *protocol.Network, ferr fail.Error)

+ type RemoteFilesHandler struct

+ func (rfh *RemoteFilesHandler) Add(file *Item)

+ func (rfh *RemoteFilesHandler) Cleanup(ctx context.Context, host resources.Host) fail.Error

+ func (rfh *RemoteFilesHandler) Count() uint

+ func (rfh *RemoteFilesHandler) Upload(ctx context.Context, host resources.Host) fail.Error

+ type SecurityGroup struct

+ func LoadSecurityGroup(inctx context.Context, svc iaas.Service, ref string, ...) (*SecurityGroup, fail.Error)

+ func NewSecurityGroup(svc iaas.Service) (*SecurityGroup, fail.Error)

+ func (instance *SecurityGroup) AddRule(ctx context.Context, rule *abstract.SecurityGroupRule) (ferr fail.Error)

+ func (instance *SecurityGroup) AddRules(ctx context.Context, rules abstract.SecurityGroupRules) (ferr fail.Error)

+ func (instance *SecurityGroup) BindToHost(ctx context.Context, hostInstance resources.Host, ...) (ferr fail.Error)

+ func (instance *SecurityGroup) BindToSubnet(ctx context.Context, subnetInstance resources.Subnet, ...) (ferr fail.Error)

+ func (instance *SecurityGroup) Browse(ctx context.Context, callback func(*abstract.SecurityGroup) fail.Error) (ferr fail.Error)

+ func (instance *SecurityGroup) CheckConsistency(_ context.Context) fail.Error

+ func (instance *SecurityGroup) Clear(ctx context.Context) (ferr fail.Error)

+ func (instance *SecurityGroup) Create(inctx context.Context, networkID, name, description string, ...) (_ fail.Error)

+ func (instance *SecurityGroup) Delete(ctx context.Context, force bool) (ferr fail.Error)

+ func (instance *SecurityGroup) DeleteRule(ctx context.Context, rule *abstract.SecurityGroupRule) (ferr fail.Error)

+ func (instance *SecurityGroup) Exists(ctx context.Context) (_ bool, ferr fail.Error)

+ func (instance *SecurityGroup) GetBoundHosts(ctx context.Context) (_ []*propertiesv1.SecurityGroupBond, ferr fail.Error)

+ func (instance *SecurityGroup) GetBoundSubnets(ctx context.Context) (list []*propertiesv1.SecurityGroupBond, ferr fail.Error)

+ func (instance *SecurityGroup) IsNull() bool

+ func (instance *SecurityGroup) Reset(ctx context.Context) (ferr fail.Error)

+ func (instance *SecurityGroup) ToProtocol(ctx context.Context) (_ *protocol.SecurityGroupResponse, ferr fail.Error)

+ func (instance *SecurityGroup) UnbindFromHost(ctx context.Context, hostInstance resources.Host) (ferr fail.Error)

+ func (instance *SecurityGroup) UnbindFromHostByReference(ctx context.Context, hostRef string) (ferr fail.Error)

+ func (instance *SecurityGroup) UnbindFromSubnet(ctx context.Context, subnetInstance resources.Subnet) (ferr fail.Error)

+ func (instance *SecurityGroup) UnbindFromSubnetByReference(ctx context.Context, subnetRef string) (ferr fail.Error)

+ type Share struct

+ func (instance *Share) Browse(ctx context.Context, callback func(string, string) fail.Error) (ferr fail.Error)

+ func (instance *Share) Create(ctx context.Context, shareName string, server resources.Host, spath string, ...) (ferr fail.Error)

+ func (instance *Share) Delete(ctx context.Context) (ferr fail.Error)

+ func (instance *Share) Exists(ctx context.Context) (bool, fail.Error)

+ func (instance *Share) GetServer(ctx context.Context) (_ resources.Host, ferr fail.Error)

+ func (instance *Share) IsNull() bool

+ func (instance *Share) Mount(ctx context.Context, target resources.Host, spath string, withCache bool) (_ *propertiesv1.HostRemoteMount, ferr fail.Error)

+ func (instance *Share) ToProtocol(ctx context.Context) (_ *protocol.ShareMountList, ferr fail.Error)

+ func (instance *Share) Unmount(ctx context.Context, target resources.Host) (ferr fail.Error)

+ type ShareIdentity struct

+ HostID string

+ HostName string

+ ShareID string

+ ShareName string

+ func (si *ShareIdentity) Deserialize(buf []byte) (ferr fail.Error)

+ func (si *ShareIdentity) IsNull() bool

+ func (si *ShareIdentity) Replace(p data.Clonable) (data.Clonable, error)

+ func (si ShareIdentity) Clone() (data.Clonable, error)

+ func (si ShareIdentity) GetID() (string, error)

+ func (si ShareIdentity) GetName() string

+ func (si ShareIdentity) Serialize() ([]byte, fail.Error)

+ type StdResult struct

+ Content interface{}

+ Err error

+ ToBeDeleted bool

+ type Subnet struct

+ func LoadSubnet(inctx context.Context, svc iaas.Service, networkRef, subnetRef string, ...) (*Subnet, fail.Error)

+ func NewSubnet(svc iaas.Service) (_ *Subnet, ferr fail.Error)

+ func (instance *Subnet) AttachHost(ctx context.Context, host resources.Host) (ferr fail.Error)

+ func (instance *Subnet) BindSecurityGroup(ctx context.Context, sgInstance resources.SecurityGroup, ...) (ferr fail.Error)

+ func (instance *Subnet) Browse(ctx context.Context, callback func(*abstract.Subnet) fail.Error) (ferr fail.Error)

+ func (instance *Subnet) Carry(ctx context.Context, clonable data.Clonable) (ferr fail.Error)

+ func (instance *Subnet) Create(ctx context.Context, req abstract.SubnetRequest, gwname string, ...) (ferr fail.Error)

+ func (instance *Subnet) CreateSecurityGroups(ctx context.Context, networkInstance resources.Network, keepOnFailure bool, ...) (subnetGWSG, subnetInternalSG, subnetPublicIPSG resources.SecurityGroup, ...)

+ func (instance *Subnet) CreateSubnetWithoutGateway(ctx context.Context, req abstract.SubnetRequest) (ferr fail.Error)

+ func (instance *Subnet) Delete(inctx context.Context) fail.Error

+ func (instance *Subnet) DetachHost(ctx context.Context, hostID string) (ferr fail.Error)

+ func (instance *Subnet) DisableSecurityGroup(ctx context.Context, sgInstance resources.SecurityGroup) (ferr fail.Error)

+ func (instance *Subnet) EnableSecurityGroup(ctx context.Context, sgInstance resources.SecurityGroup) (ferr fail.Error)

+ func (instance *Subnet) Exists(ctx context.Context) (_ bool, ferr fail.Error)

+ func (instance *Subnet) GetCIDR(ctx context.Context) (cidr string, ferr fail.Error)

+ func (instance *Subnet) GetDefaultRouteIP(ctx context.Context) (ip string, ferr fail.Error)

+ func (instance *Subnet) GetEndpointIP(ctx context.Context) (_ string, ferr fail.Error)

+ func (instance *Subnet) GetGatewayPublicIP(ctx context.Context, primary bool) (_ string, ferr fail.Error)

+ func (instance *Subnet) GetGatewayPublicIPs(ctx context.Context) (_ []string, ferr fail.Error)

+ func (instance *Subnet) GetState(ctx context.Context) (state subnetstate.Enum, ferr fail.Error)

+ func (instance *Subnet) GetVirtualIP(ctx context.Context) (vip *abstract.VirtualIP, ferr fail.Error)

+ func (instance *Subnet) HasVirtualIP(ctx context.Context) (bool, fail.Error)

+ func (instance *Subnet) InspectGateway(ctx context.Context, primary bool) (_ resources.Host, ferr fail.Error)

+ func (instance *Subnet) InspectGatewaySecurityGroup(ctx context.Context) (_ resources.SecurityGroup, ferr fail.Error)

+ func (instance *Subnet) InspectInternalSecurityGroup(ctx context.Context) (_ resources.SecurityGroup, ferr fail.Error)

+ func (instance *Subnet) InspectNetwork(ctx context.Context) (rn resources.Network, ferr fail.Error)

+ func (instance *Subnet) InspectPublicIPSecurityGroup(ctx context.Context) (_ resources.SecurityGroup, ferr fail.Error)

+ func (instance *Subnet) IsNull() bool

+ func (instance *Subnet) ListHosts(ctx context.Context) (_ []resources.Host, ferr fail.Error)

+ func (instance *Subnet) ListSecurityGroups(ctx context.Context, state securitygroupstate.Enum) (list []*propertiesv1.SecurityGroupBond, ferr fail.Error)

+ func (instance *Subnet) ToProtocol(ctx context.Context) (_ *protocol.Subnet, ferr fail.Error)

+ func (instance *Subnet) UnbindSecurityGroup(ctx context.Context, sgInstance resources.SecurityGroup) (ferr fail.Error)

+ type Tenant struct

+ BucketName string

+ Name string

+ Service iaas.Service

+ func CurrentTenant(ctx context.Context) *Tenant

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