Documentation
¶
Index ¶
- func CheckConnection(subscriptionID string) error
- func GetMetadata(p string) (string, error)
- func RetryDelete(timeout time.Duration, f func() error) error
- type AzureClient
- func (az *AzureClient) AddIAMPermissions(node *api.Node, permissions string) error
- func (az *AzureClient) AddInstanceTags(iid string, labels map[string]string) error
- func (az *AzureClient) AddRoute(destinationCIDR, instanceID string) error
- func (az *AzureClient) AttachSecurityGroups(node *api.Node, groups []string) error
- func (az *AzureClient) CloudStatusKeeper() cloud.StatusKeeper
- func (az *AzureClient) ConnectWithPublicIPs() bool
- func (az *AzureClient) CreateSGName(svcName string) string
- func (az *AzureClient) DeleteResourceGroup(groupID string) error
- func (az *AzureClient) EnsureContainerInstanceCluster() error
- func (az *AzureClient) EnsureMilpaNSG() error
- func (az *AzureClient) EnsureMilpaSecurityGroups(extraCIDRs, extraGroupIDs []string) error
- func (az *AzureClient) EnsureSecurityGroup(sgName string, ports []cloud.InstancePort, sourceRanges []string) (*cloud.SecurityGroup, error)
- func (az *AzureClient) GetAttributes() cloud.CloudAttributes
- func (az *AzureClient) GetAvailabilityZones() ([]string, error)
- func (az *AzureClient) GetBootSecurityGroupIDs() []string
- func (az *AzureClient) GetContainerInstancesStatuses(instIDs []string) (map[string][]api.UnitStatus, error)
- func (az *AzureClient) GetDNSInfo() ([]string, []string, error)
- func (az *AzureClient) GetImage(spec cloud.BootImageSpec) (cloud.Image, error)
- func (az *AzureClient) GetRegistryAuth() (string, string, error)
- func (az *AzureClient) GetSubnets() ([]cloud.SubnetAttributes, error)
- func (az *AzureClient) GetVMNetworks(vmResourceGroup, vmName string) (vNets, subnetNames []string)
- func (az *AzureClient) GetVPCCIDRs() []string
- func (az *AzureClient) IsAvailable() (bool, error)
- func (az *AzureClient) ListContainerInstances() ([]cloud.ContainerInstance, error)
- func (az *AzureClient) ListContainerInstancesFilterID(instIDs []string) ([]cloud.ContainerInstance, error)
- func (az *AzureClient) ListInstances() (insts []cloud.CloudInstance, err error)
- func (az *AzureClient) ListInstancesFilterID(ids []string) ([]cloud.CloudInstance, error)
- func (az *AzureClient) ListNodeResourceGroups() ([]string, error)
- func (az *AzureClient) ModifySourceDestinationCheck(instanceID string, isEnabled bool) error
- func (az *AzureClient) RemoveRoute(destinationCIDR, instanceID string) error
- func (az *AzureClient) ResizeVolume(node *api.Node, size int64) (error, bool)
- func (az *AzureClient) SetBootSecurityGroupIDs(ids []string)
- func (az *AzureClient) SetSustainedCPU(node *api.Node, enabled bool) error
- func (az *AzureClient) StartContainerInstance(pod *api.Pod) (string, error)
- func (az *AzureClient) StartNode(node *api.Node, image cloud.Image, metadata string) (*cloud.StartNodeResult, error)
- func (az *AzureClient) StartSpotNode(node *api.Node, image cloud.Image, metadata string) (*cloud.StartNodeResult, error)
- func (az *AzureClient) StopContainerInstance(instID string) error
- func (az *AzureClient) StopInstance(instanceID string) error
- func (az *AzureClient) WaitForContainerInstanceRunning(pod *api.Pod) (*api.Pod, error)
- func (az *AzureClient) WaitForRunning(node *api.Node) ([]api.NetworkAddress, error)
- type ImageController
- func (ic *ImageController) CreateStorageAccount() (storage.Account, error)
- func (ic *ImageController) Dump() []byte
- func (ic *ImageController) FullSyncLoop(quit <-chan struct{}, wg *sync.WaitGroup)
- func (ic *ImageController) Start(quit <-chan struct{}, wg *sync.WaitGroup)
- func (ic *ImageController) WaitForAvailable()
- type NSGRule
- type VirtualNetworkAttributes
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CheckConnection ¶
func GetMetadata ¶
This function grabs the azuremetadata for the local machine that milpa is running on. Times out after a couple of seconds
Types ¶
type AzureClient ¶
type AzureClient struct {
// contains filtered or unexported fields
}
func NewAzureClient ¶
func NewAzureClient(controllerID, nametag, subscriptionID, region, vNetName, subnetName string) (*AzureClient, error)
func (*AzureClient) AddIAMPermissions ¶ added in v0.0.15
func (az *AzureClient) AddIAMPermissions(node *api.Node, permissions string) 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) CloudStatusKeeper ¶
func (az *AzureClient) CloudStatusKeeper() cloud.StatusKeeper
func (*AzureClient) ConnectWithPublicIPs ¶
func (az *AzureClient) ConnectWithPublicIPs() bool
func (*AzureClient) CreateSGName ¶
func (az *AzureClient) CreateSGName(svcName string) string
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() (string, string, error)
func (*AzureClient) GetSubnets ¶
func (az *AzureClient) GetSubnets() ([]cloud.SubnetAttributes, 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) RemoveRoute ¶
func (az *AzureClient) RemoveRoute(destinationCIDR, instanceID string) error
func (*AzureClient) ResizeVolume ¶
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) StartNode ¶
func (az *AzureClient) StartNode(node *api.Node, image cloud.Image, metadata string) (*cloud.StartNodeResult, error)
func (*AzureClient) StartSpotNode ¶
func (az *AzureClient) StartSpotNode(node *api.Node, image cloud.Image, metadata string) (*cloud.StartNodeResult, 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 (*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()
Click to show internal directories.
Click to hide internal directories.