models

package

Go to main page

Versions in this module

v0

v0.0.22

Nov 29, 2024

v0.0.21-pre-02

Nov 29, 2024

v0.0.21-pre-01

Nov 29, 2024

v0.0.20

Nov 29, 2024

Changes in this version

+ var GCPResourceTypeIAMPolicy = ResourceType

+ var GCPResourceTypeServiceAccount = ResourceType

+ type AWSConfig struct

+ DefaultCountPerRegion int

+ DefaultDiskSizeGB int32

+ DefaultMachineType string

+ DefaultRegion string

+ Region string

+ SubnetID string

+ VPCID string

type CloudSpecificInfo

+ SpotMarketOptions *ec2Types.InstanceMarketOptionsRequest

type Deployment

+ AWS *AWSConfig

type DisplayStatus

+ CustomScript ServiceState

+ StageComplete bool

type Machine

+ Failed bool

+ ImageID string

+ func (mach *Machine) GetImageID() string

+ func (mach *Machine) GetSpotMarketOptions() *ec2Types.InstanceMarketOptionsRequest

+ func (mach *Machine) IsFailed() bool

+ func (mach *Machine) SetFailed(failed bool)

+ func (mach *Machine) SetImageID(imageID string)

+ func (mach *Machine) SetSpotMarketOptions(options *ec2Types.InstanceMarketOptionsRequest)

type Machiner

+ BacalhauEnabled func() bool

+ CustomScriptEnabled func() bool

+ DockerEnabled func() bool

+ GetImageID func() string

+ GetSpotMarketOptions func() *ec2Types.InstanceMarketOptionsRequest

+ IsFailed func() bool

+ SSHEnabled func() bool

+ SetFailed func(bool)

+ SetImageID func(id string)

+ SetSpotMarketOptions func(options *ec2Types.InstanceMarketOptionsRequest)

+ type NodeInfo struct

+ BacalhauInstalled bool

+ CustomScript bool

+ DockerInstalled bool

+ Name string

+ NodeIP string

+ OrchestratorIP string

+ SSHKeyPath string

+ SSHUsername string

+ func (n *NodeInfo) Validate() error

+ type NodeInfoList struct

+ Nodes []NodeInfo

+ type NodeStore struct

+ func NewNodeStore(filepath string) *NodeStore

+ func (s *NodeStore) AddNode(node NodeInfo) error

+ func (s *NodeStore) GetNodes() ([]NodeInfo, error)

+ type ProvisionProgress struct

+ CompletedSteps []*ProvisionStep

+ CurrentStep *ProvisionStep

+ TotalSteps int

+ func NewProvisionProgress() *ProvisionProgress

+ func (p *ProvisionProgress) AddStep(step *ProvisionStep)

+ func (p *ProvisionProgress) GetProgress() float64

+ func (p *ProvisionProgress) SetCurrentStep(step *ProvisionStep)

+ type ProvisionStep struct

+ Description string

+ Error error

+ Name string

+ Status string

+ type ProvisionStepStatus string

+ const ProvisionStepStatusCompleted

+ const ProvisionStepStatusFailed

+ const ProvisionStepStatusPending

+ const ProvisionStepStatusRunning

v0.0.19

Oct 19, 2024

v0.0.18

Oct 16, 2024

v0.0.16

Oct 14, 2024

v0.0.15

Oct 14, 2024

v0.0.14

Oct 14, 2024

Changes in this version

+ const MachineResourceTypeEC2Instance

+ var AWSResourceTypeInstance = ResourceType

+ var AWSResourceTypeSecurityGroup = ResourceType

+ var AWSResourceTypeSubnet = ResourceType

+ var AWSResourceTypeVPC = ResourceType

+ var AWSResourceTypeVolume = ResourceType

+ var RequiredAWSResources = []ResourceType

+ func IsValidAWSResource(resource string) bool

+ type AWSResourceState int

+ const AWSResourceStatePending

+ const AWSResourceStateRunning

+ const AWSResourceStateShuttingDown

+ const AWSResourceStateStopped

+ const AWSResourceStateStopping

+ const AWSResourceStateTerminated

+ const AWSResourceStateUnknown

+ func ConvertFromStringToAWSResourceState(s string) AWSResourceState

type ResourceType

+ func GetAWSResourceType(resource string) ResourceType

+ func GetAllAWSResources() []ResourceType

v0.0.13

Oct 14, 2024

v0.0.12

Oct 14, 2024

v0.0.11

Oct 14, 2024

v0.0.10

Oct 14, 2024

v0.0.9

Oct 13, 2024

v0.0.8

Oct 9, 2024

v0.0.7

Oct 9, 2024

v0.0.6

Oct 8, 2024

v0.0.5

Oct 7, 2024

Changes in this version

+ const BacalhauNodeTypeCompute

+ const BacalhauNodeTypeOrchestrator

type Machine

+ NodeType string

+ func (mach *Machine) GetNodeType() string

+ func (mach *Machine) SetNodeType(nodeType string)

type Machiner

+ GetNodeType func() string

+ SetNodeType func(nodeType string)

v0.0.4

Oct 6, 2024

v0.0.3

Oct 6, 2024

v0.0.2

Oct 2, 2024

Changes in this version

+ const DisplayEmojiBacalhau

+ const DisplayEmojiCreating

+ const DisplayEmojiDocker

+ const DisplayEmojiFailed

+ const DisplayEmojiNotStarted

+ const DisplayEmojiOrchestrator

+ const DisplayEmojiOrchestratorNode

+ const DisplayEmojiQuestion

+ const DisplayEmojiSSH

+ const DisplayEmojiSuccess

+ const DisplayEmojiWaiting

+ const DisplayEmojiWorkerNode

+ const DisplayTextBacalhau

+ const DisplayTextCreating

+ const DisplayTextCustomScript

+ const DisplayTextDocker

+ const DisplayTextFailed

+ const DisplayTextInProgress

+ const DisplayTextNotStarted

+ const DisplayTextOrchestrator

+ const DisplayTextOrchestratorNode

+ const DisplayTextSSH

+ const DisplayTextSuccess

+ const DisplayTextUnknown

+ const DisplayTextWaiting

+ const DisplayTextWorkerNode

+ const MachineResourceTypeComputeInstance

+ const MaximumGCPProjectIDLength

+ const MaximumGCPUniqueProjectIDLength

+ const NumberOfSimultaneousProvisionings

+ var AzureResourceTypeDISK = ResourceType

+ var AzureResourceTypeGuestAttestation = ResourceType

+ var AzureResourceTypeIP = ResourceType

+ var AzureResourceTypeNIC = ResourceType

+ var AzureResourceTypeNSG = ResourceType

+ var AzureResourceTypeSNET = ResourceType

+ var AzureResourceTypeVM = ResourceType

+ var AzureResourceTypeVNET = ResourceType

+ var AzureSkippedResourceTypes = []string

+ var GCPResourceTypeDisk = ResourceType

+ var GCPResourceTypeFirewall = ResourceType

+ var GCPResourceTypeInstance = ResourceType

+ var GCPResourceTypeProject = ResourceType

+ var GCPResourceTypeVPC = ResourceType

+ var RequiredAzureResources = []ResourceType

+ var RequiredGCPResources = []ResourceType

+ var RequiredServices = []ServiceType

+ var ServiceTypeBacalhau = ServiceType

+ var ServiceTypeCorePackages = ServiceType

+ var ServiceTypeDocker = ServiceType

+ var ServiceTypeSSH = ServiceType

+ var ServiceTypeScript = ServiceType

+ var SkippedResourceTypes = []string

+ func CreateStateMessage(resource ResourceType, resourceState MachineResourceState, resourceName string) string

+ func CreateStateMessageWithText(resource ResourceType, resourceState MachineResourceState, resourceName string, ...) string

+ func GetLocationFromResourceName(id string) string

+ func GetMachineNameFromResourceName(id string) string

+ func GetMachinesInLocation(resourceName string, machines map[string]Machiner) ([]string, error)

+ func GetProviderAbbreviation(provider string) string

+ func IsValidAzureResource(resource string) bool

+ func IsValidGCPResource(resource string) bool

+ func IsValidLocation(deploymentType DeploymentType, location string) bool

+ func MachineConfigToWrite(machine Machiner) map[string]interface

+ type AzureConfig struct

+ DefaultCountPerZone int

+ DefaultDiskSizeGB int32

+ DefaultLocation string

+ DefaultVMSize string

+ ResourceGroupLocation string

+ ResourceGroupName string

+ SubscriptionID string

+ Tags map[string]string

+ type AzureEvent struct

+ Message string

+ ResourceID string

+ Type string

+ type BacalhauSettings struct

+ Key string

+ Value interface{}

+ func ReadBacalhauSettingsFromViper() ([]BacalhauSettings, error)

+ type CloudSpecificInfo struct

+ Region string

+ ResourceGroupName string

+ Zone string

+ type ClusterDetails struct

+ DeploymentType DeploymentType

+ KubernetesVersion string

+ Name string

+ NodeCount int

+ NodeTypes []string

+ type Deployment struct

+ AllowedPorts []int

+ Azure *AzureConfig

+ BacalhauSettings []BacalhauSettings

+ CustomScriptPath string

+ DeploymentType DeploymentType

+ EndTime time.Time

+ GCP *GCPConfig

+ Locations []string

+ Machines map[string]Machiner

+ Name string

+ OrchestratorIP string

+ ProjectServiceAccounts map[string]ServiceAccountInfo

+ SSHPort int

+ SSHPrivateKeyMaterial string

+ SSHPrivateKeyPath string

+ SSHPublicKeyMaterial string

+ SSHPublicKeyPath string

+ SSHUser string

+ StartTime time.Time

+ Tags map[string]string

+ UniqueID string

+ ViperPath string

+ func NewDeployment() (*Deployment, error)

+ func (d *Deployment) CreateMachine(name string, machine Machiner)

+ func (d *Deployment) GetCloudConfig(cloudType DeploymentType) interface{}

+ func (d *Deployment) GetCloudResources(cloudType DeploymentType) interface{}

+ func (d *Deployment) GetMachine(name string) Machiner

+ func (d *Deployment) GetMachines() map[string]Machiner

+ func (d *Deployment) GetProjectID() string

+ func (d *Deployment) SetLocations(locations map[string]bool)

+ func (d *Deployment) SetMachine(name string, machine Machiner)

+ func (d *Deployment) SetMachines(machines map[string]Machiner)

+ func (d *Deployment) SetProjectID(projectID string)

+ func (d *Deployment) ToMap() map[string]interface{}

+ func (d *Deployment) UpdateMachine(name string, updater func(Machiner)) error

+ func (d *Deployment) UpdateViperConfig() error

+ type DeploymentStatus string

+ const DeploymentStatusFailed

+ const DeploymentStatusInProgress

+ const DeploymentStatusNotStarted

+ const DeploymentStatusSucceeded

+ const DeploymentStatusUnknown

+ type DeploymentType string

+ const DeploymentTypeAWS

+ const DeploymentTypeAzure

+ const DeploymentTypeGCP

+ const DeploymentTypeUnknown

+ type Disk struct

+ ID string

+ Name string

+ SizeGB int32

+ State armcompute.DiskState

+ type DisplayStatus struct

+ Bacalhau ServiceState

+ CorePackages ServiceState

+ DetailedStatus string

+ Docker ServiceState

+ ElapsedTime time.Duration

+ HighlightCycles int

+ ID string

+ InstanceID string

+ Location string

+ Name string

+ Orchestrator bool

+ PrivateIP string

+ Progress int

+ PublicIP string

+ SSH ServiceState

+ StartTime time.Time

+ StatusMessage string

+ Type ResourceType

+ func ConvertFromRawResourceToStatus(resourceMap map[string]interface{}, deployment *Deployment) ([]DisplayStatus, error)

+ func NewDisplayStatus(machineName string, resourceID string, resourceType ResourceType, ...) *DisplayStatus

+ func NewDisplayStatusWithText(resourceID string, resourceType ResourceType, state MachineResourceState, ...) *DisplayStatus

+ func NewDisplayVMStatus(machineName string, state MachineResourceState) *DisplayStatus

+ func UpdateOnlyChangedStatus(status *DisplayStatus, newStatus *DisplayStatus) *DisplayStatus

+ type GCPConfig struct

+ BillingAccountID string

+ DefaultCountPerZone int

+ DefaultDiskSizeGB int32

+ DefaultMachineType string

+ DefaultRegion string

+ DefaultZone string

+ OrganizationID string

+ ProjectID string

+ ProjectServiceAccounts map[string]ServiceAccountInfo

+ ServiceAccountEmail string

+ Tags map[string]string

+ type GCPResourceState int

+ const GCPResourceStateProvisioning

+ const GCPResourceStateRepairing

+ const GCPResourceStateRunning

+ const GCPResourceStateStopping

+ const GCPResourceStateSuspended

+ const GCPResourceStateTerminated

+ const GCPResourceStateUnknown

+ func ConvertFromStringToGCPResourceState(s string) GCPResourceState

+ type Machine struct

+ BacalhauEndTime time.Time

+ BacalhauStartTime time.Time

+ CloudProvider DeploymentType

+ CloudSpecific CloudSpecificInfo

+ CreationEndTime time.Time

+ CreationStartTime time.Time

+ CustomScriptExecuted bool

+ DeploymentEndTime time.Time

+ DeploymentType DeploymentType

+ DiskImageFamily string

+ DiskImageURL string

+ DiskSizeGB int

+ DockerEndTime time.Time

+ DockerStartTime time.Time

+ ElapsedTime time.Duration

+ ID string

+ Location string

+ Name string

+ Orchestrator bool

+ OrchestratorIP string

+ Parameters Parameters

+ PrivateIP string

+ PublicIP string

+ Region string

+ SSHEndTime time.Time

+ SSHPort int

+ SSHPrivateKeyMaterial []byte

+ SSHPrivateKeyPath string

+ SSHPublicKeyMaterial []byte

+ SSHPublicKeyPath string

+ SSHStartTime time.Time

+ SSHUser string

+ StartTime time.Time

+ StatusMessage string

+ Type ResourceType

+ VMSize string

+ Zone string

+ func (mach *Machine) BacalhauEnabled() bool

+ func (mach *Machine) CloudType() DeploymentType

+ func (mach *Machine) Complete() bool

+ func (mach *Machine) CustomScriptEnabled() bool

+ func (mach *Machine) DockerEnabled() bool

+ func (mach *Machine) EnsureMachineServices() error

+ func (mach *Machine) GetDeploymentEndTime() time.Time

+ func (mach *Machine) GetDiskImageFamily() string

+ func (mach *Machine) GetDiskImageURL() string

+ func (mach *Machine) GetDiskSizeGB() int

+ func (mach *Machine) GetElapsedTime() time.Duration

+ func (mach *Machine) GetID() string

+ func (mach *Machine) GetLocation() string

+ func (mach *Machine) GetMachineResource(resourceType string) MachineResource

+ func (mach *Machine) GetMachineResourceState(resourceName string) MachineResourceState

+ func (mach *Machine) GetMachineResources() map[string]MachineResource

+ func (mach *Machine) GetMachineServices() map[string]ServiceType

+ func (mach *Machine) GetName() string

+ func (mach *Machine) GetOrchestratorIP() string

+ func (mach *Machine) GetPrivateIP() string

+ func (mach *Machine) GetPublicIP() string

+ func (mach *Machine) GetRegion() string

+ func (mach *Machine) GetSSHPort() int

+ func (mach *Machine) GetSSHPrivateKeyMaterial() []byte

+ func (mach *Machine) GetSSHPrivateKeyPath() string

+ func (mach *Machine) GetSSHPublicKeyMaterial() []byte

+ func (mach *Machine) GetSSHPublicKeyPath() string

+ func (mach *Machine) GetSSHUser() string

+ func (mach *Machine) GetServiceState(serviceName string) ServiceState

+ func (mach *Machine) GetServices() map[string]ServiceType

+ func (mach *Machine) GetStartTime() time.Time

+ func (mach *Machine) GetStatusMessage() string

+ func (mach *Machine) GetType() ResourceType

+ func (mach *Machine) GetVMCount() int

+ func (mach *Machine) GetVMSize() string

+ func (mach *Machine) GetZone() string

+ func (mach *Machine) InstallDockerAndCorePackages(ctx context.Context) error

+ func (mach *Machine) IsComplete() bool

+ func (mach *Machine) IsCustomScriptExecuted() bool

+ func (mach *Machine) IsOrchestrator() bool

+ func (mach *Machine) LogTimingInfo(logger logger.Logger)

+ func (mach *Machine) ResourcesComplete() (int, int)

+ func (mach *Machine) SSHEnabled() bool

+ func (mach *Machine) ServicesComplete() (int, int)

+ func (mach *Machine) SetComplete()

+ func (mach *Machine) SetCustomScriptExecuted(executed bool)

+ func (mach *Machine) SetDeploymentEndTime(endTime time.Time)

+ func (mach *Machine) SetDiskImageFamily(family string)

+ func (mach *Machine) SetDiskImageURL(url string)

+ func (mach *Machine) SetDiskSizeGB(size int)

+ func (mach *Machine) SetElapsedTime(elapsedTime time.Duration)

+ func (mach *Machine) SetLocation(location string) error

+ func (mach *Machine) SetMachineResource(resourceType string, resourceState MachineResourceState)

+ func (mach *Machine) SetMachineResourceState(resourceName string, state MachineResourceState)

+ func (mach *Machine) SetMachineServices(services map[string]ServiceType)

+ func (mach *Machine) SetName(name string)

+ func (mach *Machine) SetOrchestrator(orchestrator bool)

+ func (mach *Machine) SetOrchestratorIP(ip string)

+ func (mach *Machine) SetPrivateIP(ip string)

+ func (mach *Machine) SetPublicIP(ip string)

+ func (mach *Machine) SetSSHPort(port int)

+ func (mach *Machine) SetSSHPrivateKeyMaterial(key []byte)

+ func (mach *Machine) SetSSHPrivateKeyPath(path string)

+ func (mach *Machine) SetSSHPublicKeyMaterial(key []byte)

+ func (mach *Machine) SetSSHPublicKeyPath(path string)

+ func (mach *Machine) SetSSHUser(user string)

+ func (mach *Machine) SetServiceState(serviceName string, state ServiceState)

+ func (mach *Machine) SetStartTime(startTime time.Time)

+ func (mach *Machine) SetStatusMessage(message string)

+ type MachineResource struct

+ ResourceName string

+ ResourceState MachineResourceState

+ ResourceType ResourceType

+ ResourceValue string

+ type MachineResourceState int

+ const ResourceStateFailed

+ const ResourceStateNotStarted

+ const ResourceStatePending

+ const ResourceStateRunning

+ const ResourceStateStopping

+ const ResourceStateSucceeded

+ const ResourceStateTerminated

+ const ResourceStateUnknown

+ func ConvertFromAzureStringToResourceState(s string) MachineResourceState

+ type Machiner interface

+ CloudType func() DeploymentType

+ EnsureMachineServices func() error

+ GetDeploymentEndTime func() time.Time

+ GetDiskImageFamily func() string

+ GetDiskImageURL func() string

+ GetDiskSizeGB func() int

+ GetElapsedTime func() time.Duration

+ GetID func() string

+ GetLocation func() string

+ GetMachineResource func(resourceType string) MachineResource

+ GetMachineResourceState func(resourceName string) MachineResourceState

+ GetMachineResources func() map[string]MachineResource

+ GetName func() string

+ GetOrchestratorIP func() string

+ GetPrivateIP func() string

+ GetPublicIP func() string

+ GetRegion func() string

+ GetSSHPort func() int

+ GetSSHPrivateKeyMaterial func() []byte

+ GetSSHPrivateKeyPath func() string

+ GetSSHPublicKeyMaterial func() []byte

+ GetSSHPublicKeyPath func() string

+ GetSSHUser func() string

+ GetServiceState func(serviceName string) ServiceState

+ GetServices func() map[string]ServiceType

+ GetStartTime func() time.Time

+ GetStatusMessage func() string

+ GetType func() ResourceType

+ GetVMSize func() string

+ GetZone func() string

+ InstallDockerAndCorePackages func(ctx context.Context) error

+ IsComplete func() bool

+ IsOrchestrator func() bool

+ LogTimingInfo func(logger logger.Logger)

+ ResourcesComplete func() (int, int)

+ ServicesComplete func() (int, int)

+ SetComplete func()

+ SetDeploymentEndTime func(endTime time.Time)

+ SetDiskImageFamily func(family string)

+ SetDiskImageURL func(url string)

+ SetDiskSizeGB func(size int)

+ SetElapsedTime func(elapsedTime time.Duration)

+ SetLocation func(location string) error

+ SetMachineResource func(resourceType string, resourceState MachineResourceState)

+ SetMachineResourceState func(resourceName string, state MachineResourceState)

+ SetName func(string)

+ SetOrchestrator func(orchestrator bool)

+ SetOrchestratorIP func(ip string)

+ SetPrivateIP func(ip string)

+ SetPublicIP func(ip string)

+ SetSSHPort func(port int)

+ SetSSHPrivateKeyMaterial func([]byte)

+ SetSSHPrivateKeyPath func(path string)

+ SetSSHPublicKeyMaterial func([]byte)

+ SetSSHPublicKeyPath func(path string)

+ SetSSHUser func(user string)

+ SetServiceState func(serviceName string, state ServiceState)

+ SetStartTime func(startTime time.Time)

+ SetStatusMessage func(message string)

+ func NewMachine(cloudProvider DeploymentType, location string, vmSize string, diskSizeGB int, ...) (Machiner, error)

+ type Parameters struct

+ Count int

+ Orchestrator bool

+ Type string

+ type ProviderAbbreviation string

+ const ProviderAbbreviationAWS

+ const ProviderAbbreviationAzure

+ const ProviderAbbreviationGCP

+ const ProviderAbbreviationUnknown

+ const ProviderAbbreviationVirtual

+ type ResourceType struct

+ ResourceString string

+ ShortResourceName string

+ func GetAllAzureResources() []ResourceType

+ func GetAllGCPResources() []ResourceType

+ func GetAzureResourceType(resource string) ResourceType

+ func GetGCPResourceType(resource string) ResourceType

+ func (a *ResourceType) GetResourceLowerString() string

+ func (a *ResourceType) GetResourceString() string

+ func (a *ResourceType) GetShortResourceName() string

+ type ServiceAccountInfo struct

+ Email string

+ Key string

+ type ServiceState int

+ const ServiceStateCreated

+ const ServiceStateFailed

+ const ServiceStateNotStarted

+ const ServiceStateSucceeded

+ const ServiceStateUnknown

+ const ServiceStateUpdating

+ type ServiceType struct

+ Name string

+ State ServiceState

+ type StatusCode string

+ const StatusCodeFailed

+ const StatusCodeInProgress

+ const StatusCodeNotStarted

+ const StatusCodeSucceeded

+ const StatusCodeUnknown

+ const StatusCreating

+ const StatusDeleting

+ const StatusFailed

+ const StatusSucceeded

+ const StatusUnknown

+ const StatusUpdating

+ type StatusUpdateMsg struct

+ Status *DisplayStatus

+ type TimeUpdateMsg struct

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