azure

package
v1.1.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 22, 2021 License: Apache-2.0 Imports: 35 Imported by: 1

Documentation

Index

Constants

View Source 
const NameserverIP = "168.63.129.16"

Variables

This section is empty.

Functions

func CheckConnection 

func CheckConnection(subscriptionID string) error

func GetMetadata 

func GetMetadata(p string) (string, error)

This function grabs the azuremetadata for the local machine that milpa is running on. Times out after a couple of seconds

func RetryDelete 

func RetryDelete(timeout time.Duration, f func() error) error

Types

type AzureClient 

type AzureClient struct {
	// contains filtered or unexported fields
}

func NewAzureClient 

func NewAzureClient(controllerID, nametag, subscriptionID, region, vNetName, subnetName, resourceGroup string) (*AzureClient, error)

func (*AzureClient) AddIAMPermissions added in v0.0.15 

func (az *AzureClient) AddIAMPermissions(node *api.Node, permissions string) error

func (*AzureClient) AddInstanceParameter added in v1.0.5 

func (az *AzureClient) AddInstanceParameter(instanceID, name, value string, isSecret bool) error

func (*AzureClient) AddInstanceTags 

func (az *AzureClient) AddInstanceTags(iid string, labels map[string]string) error

func (*AzureClient) AddRoute 

func (az *AzureClient) AddRoute(destinationCIDR, instanceID string) error

func (*AzureClient) AttachSecurityGroups 

func (az *AzureClient) AttachSecurityGroups(node *api.Node, groups []string) error

func (*AzureClient) ConnectWithPublicIPs 

func (az *AzureClient) ConnectWithPublicIPs() bool

func (*AzureClient) CreateSGName 

func (az *AzureClient) CreateSGName(svcName string) string

func (*AzureClient) DeleteInstanceParameter added in v1.0.5 

func (az *AzureClient) DeleteInstanceParameter(instanceID, name string) error

func (*AzureClient) DeleteResourceGroup 

func (az *AzureClient) DeleteResourceGroup(groupID string) error

func (*AzureClient) EnsureContainerInstanceCluster 

func (az *AzureClient) EnsureContainerInstanceCluster() error

func (*AzureClient) EnsureMilpaNSG 

func (az *AzureClient) EnsureMilpaNSG() error

func (*AzureClient) EnsureMilpaSecurityGroups 

func (az *AzureClient) EnsureMilpaSecurityGroups(extraCIDRs, extraGroupIDs []string) error

func (*AzureClient) EnsureSecurityGroup 

func (az *AzureClient) EnsureSecurityGroup(sgName string, ports []cloud.InstancePort, sourceRanges []string) (*cloud.SecurityGroup, error)

func (*AzureClient) GetAttributes 

func (az *AzureClient) GetAttributes() cloud.CloudAttributes

func (*AzureClient) GetAvailabilityZones 

func (az *AzureClient) GetAvailabilityZones() ([]string, error)

func (*AzureClient) GetBootSecurityGroupIDs 

func (az *AzureClient) GetBootSecurityGroupIDs() []string

func (*AzureClient) GetContainerInstancesStatuses 

func (az *AzureClient) GetContainerInstancesStatuses(instIDs []string) (map[string][]api.UnitStatus, error)

func (*AzureClient) GetDNSInfo 

func (az *AzureClient) GetDNSInfo() ([]string, []string, error)

func (*AzureClient) GetImage added in v0.0.3 

func (az *AzureClient) GetImage(spec cloud.BootImageSpec) (cloud.Image, error)

func (*AzureClient) GetRegistryAuth 

func (az *AzureClient) GetRegistryAuth(image string) (string, string, error)

func (*AzureClient) GetVMNetworks 

func (az *AzureClient) GetVMNetworks(vmResourceGroup, vmName string) (vNets, subnetNames []string)

Well this turned into an ugly hunk of poop... Thanks Azure! VNetNames look like <resourceGroup>/<vNetName> SubnetNames look like <subnet_name> without the resource group

func (*AzureClient) GetVPCCIDRs 

func (az *AzureClient) GetVPCCIDRs() []string

func (*AzureClient) IsAvailable 

func (az *AzureClient) IsAvailable() (bool, error)

func (*AzureClient) ListContainerInstances 

func (az *AzureClient) ListContainerInstances() ([]cloud.ContainerInstance, error)

func (*AzureClient) ListContainerInstancesFilterID 

func (az *AzureClient) ListContainerInstancesFilterID(instIDs []string) ([]cloud.ContainerInstance, error)

func (*AzureClient) ListInstances 

func (az *AzureClient) ListInstances() (insts []cloud.CloudInstance, err error)

func (*AzureClient) ListInstancesFilterID 

func (az *AzureClient) ListInstancesFilterID(ids []string) ([]cloud.CloudInstance, error)

func (*AzureClient) ListNodeResourceGroups 

func (az *AzureClient) ListNodeResourceGroups() ([]string, error)

func (*AzureClient) ModifySourceDestinationCheck 

func (az *AzureClient) ModifySourceDestinationCheck(instanceID string, isEnabled bool) error

func (*AzureClient) ReleaseDedicatedHosts added in v1.1.0 

func (az *AzureClient) ReleaseDedicatedHosts() error

func (*AzureClient) RemoveRoute 

func (az *AzureClient) RemoveRoute(destinationCIDR, instanceID string) error

func (*AzureClient) ResizeVolume 

func (az *AzureClient) ResizeVolume(node *api.Node, size int64) (error, bool)

Todo: need to figure out what to do with this

func (*AzureClient) SetBootSecurityGroupIDs 

func (az *AzureClient) SetBootSecurityGroupIDs(ids []string)

func (*AzureClient) SetSustainedCPU 

func (az *AzureClient) SetSustainedCPU(node *api.Node, enabled bool) error

func (*AzureClient) StartContainerInstance 

func (az *AzureClient) StartContainerInstance(pod *api.Pod) (string, error)

func (*AzureClient) StartDedicatedNode added in v1.1.0 

func (az *AzureClient) StartDedicatedNode(node *api.Node, image cloud.Image, metadata, iamPermissions string) (string, error)

func (*AzureClient) StartNode 

func (az *AzureClient) StartNode(node *api.Node, image cloud.Image, metadata, iamPermissions string) (string, error)

func (*AzureClient) StartSpotNode 

func (az *AzureClient) StartSpotNode(node *api.Node, image cloud.Image, metadata, iamPermissions string) (string, error)

func (*AzureClient) StopContainerInstance 

func (az *AzureClient) StopContainerInstance(instID string) error

func (*AzureClient) StopInstance 

func (az *AzureClient) StopInstance(instanceID string) error

func (*AzureClient) WaitForContainerInstanceRunning 

func (az *AzureClient) WaitForContainerInstanceRunning(pod *api.Pod) (*api.Pod, error)

func (*AzureClient) WaitForRunning 

func (az *AzureClient) WaitForRunning(node *api.Node) ([]api.NetworkAddress, error)

type ImageController 

type ImageController struct {
	// contains filtered or unexported fields
}

func NewImageController 

func NewImageController(controllerID string, bootImageSpec cloud.BootImageSpec, azureClient *AzureClient) *ImageController

func (*ImageController) CreateStorageAccount 

func (ic *ImageController) CreateStorageAccount() (storage.Account, error)

func (*ImageController) Dump 

func (ic *ImageController) Dump() []byte

func (*ImageController) FullSyncLoop 

func (ic *ImageController) FullSyncLoop(quit <-chan struct{}, wg *sync.WaitGroup)

func (*ImageController) Start 

func (ic *ImageController) Start(quit <-chan struct{}, wg *sync.WaitGroup)

func (*ImageController) WaitForAvailable 

func (ic *ImageController) WaitForAvailable()

type NSGRule 

type NSGRule struct {
	// contains filtered or unexported fields
}

////////////////////////////////////////////////////////////////////

type VirtualNetworkAttributes 

type VirtualNetworkAttributes struct {
	Name          string
	ID            string
	ResourceGroup string
	CIDRs         []string
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.