cloud

package

Go to main page

Versions in this module

v1

v1.1.3

Apr 22, 2021

v1.1.2

Apr 7, 2021

v1.1.1

Mar 25, 2021

v1.1.0

Feb 17, 2021

Changes in this version

type CloudClient

+ ReleaseDedicatedHosts func() error

+ StartDedicatedNode func(*api.Node, Image, string, string) (string, error)

type Image

+ VolumeIops *int64

+ VolumeThroughput *int64

+ VolumeType string

+ type InsufficientCapacityError struct

+ InstanceType string

+ OriginalError string

+ func (e *InsufficientCapacityError) Error() string

type MockCloudClient

+ DedicatedStarter func(node *api.Node, image Image, metadata, iamPermissions string) (string, error)

+ Releaser func() error

+ func (m *MockCloudClient) ReleaseDedicatedHosts() error

+ func (m *MockCloudClient) StartDedicatedNode(node *api.Node, image Image, metadata, iamPermissions string) (string, error)

v1.0.6

Dec 19, 2020

v1.0.5

Dec 16, 2020

Changes in this version

+ const AWSUserIDTagKey

+ const InstanceParameterCertificate

type CloudClient

+ AddInstanceParameter func(instanceID, key, value string, isSecret bool) error

+ DeleteInstanceParameter func(instanceID, key string) error

type MockCloudClient

+ InstanceParameterAdder func(instanceID, key, value string, isSecret bool) error

+ InstanceParameterRemover func(instanceID, key string) error

+ func (m *MockCloudClient) AddInstanceParameter(instanceID, key, value string, isSecret bool) error

+ func (m *MockCloudClient) DeleteInstanceParameter(instanceID, key string) error

v1.0.4

Nov 19, 2020

v1.0.3

Nov 2, 2020

v1.0.2

Sep 28, 2020

Changes in this version

type Image

+ VolumeDiskSize int32

v1.0.1

Sep 16, 2020

v1.0.0

Aug 4, 2020

Changes in this version

type MockCloudClient

+ Subnet SubnetAttributes

v0

v0.0.17

Jul 17, 2020

v0.0.16

Jul 16, 2020

v0.0.15

Jul 9, 2020

Changes in this version

type CloudClient

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

type MockCloudClient

+ func (m *MockCloudClient) AddIAMPermissions(node *api.Node, permissions string) error

v0.0.14

Jul 7, 2020

v0.0.13

Jul 3, 2020

v0.0.12

Jul 3, 2020

v0.0.11

Jul 2, 2020

v0.0.10

Jul 2, 2020

v0.0.9

Jun 27, 2020

v0.0.8

Jun 25, 2020

v0.0.7

Jun 16, 2020

v0.0.6

Jun 8, 2020

v0.0.5

May 20, 2020

v0.0.4

May 20, 2020

v0.0.3

May 20, 2020

Changes in this version

type CloudAttributes

+ Zone string

type CloudClient

+ GetImage func(spec BootImageSpec) (Image, error)

type Image

+ RootDevice string

type MockCloudClient

+ ImageGetter func(BootImageSpec) (Image, error)

+ func (m *MockCloudClient) GetImage(spec BootImageSpec) (Image, error)

v0.0.2

Apr 27, 2020

Changes in this version

+ const ControllerTagKey

+ const MilpaAPISGName

+ const NameTagKey

+ const NamespaceTagKey

+ const NametagTagKey

+ const PodNameTagKey

+ const ProviderAWS

+ const ProviderAzure

+ const ProviderGCE

+ const PublicCIDR

+ const RestAPIPort

+ func MergeSecurityGroups(cloudSG SecurityGroup, specPorts []InstancePort, specSourceRanges []string) ([]IngressRule, []IngressRule)

+ func SortImagesByCreationTime(images []Image)

+ func ToSaneVolumeSize(volSizeSpec string) int32

+ type AZSubnetStatus struct

+ func NewAZSubnetStatus(client CloudClient) (*AZSubnetStatus, error)

+ func (s *AZSubnetStatus) AddUnavailableInstance(instanceType string, spot bool)

+ func (s *AZSubnetStatus) AddUnavailableSubnet(instanceType string, spot bool, subnetID string)

+ func (s *AZSubnetStatus) AddUnavailableZone(instanceType string, spot bool, zone string)

+ func (s *AZSubnetStatus) Dump() []byte

+ func (s *AZSubnetStatus) GetAllAvailabilityZones() []string

+ func (s *AZSubnetStatus) GetAllSubnets() []SubnetAttributes

+ func (s *AZSubnetStatus) GetAvailableSubnets(instanceType string, spot, privateIP bool) []SubnetAttributes

+ func (s *AZSubnetStatus) GetAvailableZones(instanceType string, spot bool, privateIP bool) []string

+ func (s *AZSubnetStatus) IsUnavailableSubnet(instanceType string, spot bool, subnetID string) bool

+ func (s *AZSubnetStatus) IsUnavailableZone(instanceType string, spot, privateIP bool, az string) bool

+ func (s *AZSubnetStatus) Start()

+ func (s *AZSubnetStatus) Stop()

+ func (s *AZSubnetStatus) SupportsAvailabilityZones() bool

+ type BootImageSpec map[string]string

+ func (bis *BootImageSpec) String() string

+ type CloudAttributes struct

+ DiskProductName api.StorageType

+ FixedSizeVolume bool

+ MaxInstanceSecurityGroups int

+ Provider string

+ Region string

+ type CloudClient interface

+ AddInstanceTags func(string, map[string]string) error

+ AddRoute func(string, string) error

+ AssignInstanceProfile func(node *api.Node, instanceProfile string) error

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

+ CloudStatusKeeper func() StatusKeeper

+ ConnectWithPublicIPs func() bool

+ EnsureMilpaSecurityGroups func([]string, []string) error

+ GetAttributes func() CloudAttributes

+ GetAvailabilityZones func() ([]string, error)

+ GetBootSecurityGroupIDs func() []string

+ GetDNSInfo func() ([]string, []string, error)

+ GetImageID func(spec BootImageSpec) (string, error)

+ GetRegistryAuth func() (string, string, error)

+ GetSubnets func() ([]SubnetAttributes, error)

+ GetVPCCIDRs func() []string

+ IsAvailable func() (bool, error)

+ ListInstances func() ([]CloudInstance, error)

+ ListInstancesFilterID func([]string) ([]CloudInstance, error)

+ ModifySourceDestinationCheck func(string, bool) error

+ RemoveRoute func(string, string) error

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

+ SetBootSecurityGroupIDs func([]string)

+ SetSustainedCPU func(*api.Node, bool) error

+ StartNode func(*api.Node, string) (*StartNodeResult, error)

+ StartSpotNode func(*api.Node, string) (*StartNodeResult, error)

+ StopInstance func(instanceID string) error

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

+ type CloudInstance struct

+ ID string

+ NodeName string

+ type ContainerInstance struct

+ ID string

+ type Image struct

+ CreationTime *time.Time

+ ID string

+ Name string

+ type IngressRule struct

+ Port int

+ PortRangeSize int

+ Protocol api.Protocol

+ Source string

+ func MakeIngressRules(ports []InstancePort, sourceRanges []string) []IngressRule

+ func NewIngressRule(port InstancePort, source string) IngressRule

+ type InstancePort struct

+ Name string

+ Port int

+ PortRangeSize int

+ Protocol api.Protocol

+ type LinkedAZSubnetStatus struct

+ func NewLinkedAZSubnetStatus(client CloudClient) (*LinkedAZSubnetStatus, error)

+ func (s *LinkedAZSubnetStatus) AddUnavailableInstance(instanceType string, spot bool)

+ func (s *LinkedAZSubnetStatus) AddUnavailableSubnet(instanceType string, spot bool, subnetID string)

+ func (s *LinkedAZSubnetStatus) AddUnavailableZone(instanceType string, spot bool, zone string)

+ func (s *LinkedAZSubnetStatus) Dump() []byte

+ func (s *LinkedAZSubnetStatus) GetAllAZSubnets(zone string, privateIP bool) []SubnetAttributes

+ func (s *LinkedAZSubnetStatus) GetAllSubnets() []SubnetAttributes

+ func (s *LinkedAZSubnetStatus) GetAvailableAZSubnets(instanceType, zone string, spot, privateIP bool) []SubnetAttributes

+ func (s *LinkedAZSubnetStatus) GetAvailableSubnets(instanceType string, spot, privateIP bool) []SubnetAttributes

+ func (s *LinkedAZSubnetStatus) GetAvailableZones(instanceType string, spot bool, privateIP bool) []string

+ func (s *LinkedAZSubnetStatus) IsUnavailableSubnet(instanceType string, spot bool, subnetID string) bool

+ func (s *LinkedAZSubnetStatus) IsUnavailableZone(instanceType string, spot, privateIP bool, az string) bool

+ func (s *LinkedAZSubnetStatus) Start()

+ func (s *LinkedAZSubnetStatus) Stop()

+ func (s *LinkedAZSubnetStatus) SupportsAvailabilityZones() bool

+ type LoadBalancer struct

+ Annotations map[string]string

+ DNSName string

+ IPAddress string

+ Instances sets.String

+ Internal bool

+ LoadBalancerName string

+ Ports []InstancePort

+ SecurityGroupID string

+ ServiceName string

+ Type string

+ type MockCloudClient struct

+ AZGetter func() ([]string, error)

+ AvailabilityChecker func() (bool, error)

+ ContainerAuthorizer func() (string, string, error)

+ ContainerClusterEnsurer func() error

+ ContainerInstanceLister func() ([]ContainerInstance, error)

+ ContainerInstanceListerFilter func(instIDs []string) ([]ContainerInstance, error)

+ ContainerInstanceRunner func(*api.Pod) (string, error)

+ ContainerInstanceStopper func(string) error

+ ContainerInstanceWaiter func(*api.Pod) (*api.Pod, error)

+ ContainerInstances map[string]ContainerInstance

+ ContainerInstancesStatusesGetter func(instIDs []string) (map[string][]api.UnitStatus, error)

+ ControllerID string

+ DNSInfoGetter func() ([]string, []string, error)

+ ImageIDGetter func(BootImageSpec) (string, error)

+ InsideVPC bool

+ InstanceLister func() ([]CloudInstance, error)

+ InstanceListerFilter func([]string) ([]CloudInstance, error)

+ Instances map[string]CloudInstance

+ Lister func() ([]CloudInstance, error)

+ Resizer func(node *api.Node, size int64) (error, bool)

+ RouteAdder func(string, string) error

+ RouteRemover func(string, string) error

+ SpotStarter func(node *api.Node, metadata string) (*StartNodeResult, error)

+ Starter func(node *api.Node, metadata string) (*StartNodeResult, error)

+ StatusKeeperGetter func() StatusKeeper

+ Stopper func(instanceID string) error

+ SubnetGetter func() ([]SubnetAttributes, error)

+ Subnets []SubnetAttributes

+ VPCCIDRs []string

+ Waiter func(node *api.Node) ([]api.NetworkAddress, error)

+ func NewMockClient() *MockCloudClient

+ func (c *MockCloudClient) CloudStatusKeeper() StatusKeeper

+ func (c *MockCloudClient) EnsureMilpaSecurityGroups([]string, []string) error

+ func (c *MockCloudClient) GetAvailabilityZones() ([]string, error)

+ func (c *MockCloudClient) GetSubnets() ([]SubnetAttributes, error)

+ func (c *MockCloudClient) IsAvailable() (bool, error)

+ func (c *MockCloudClient) ListInstances() ([]CloudInstance, error)

+ func (c *MockCloudClient) ListInstancesFilterID(iid []string) ([]CloudInstance, error)

+ func (e *MockCloudClient) AddInstances(insts ...CloudInstance)

+ func (e *MockCloudClient) AddRoute(destinationCIDR, instanceID string) error

+ func (e *MockCloudClient) ConnectWithPublicIPs() bool

+ func (e *MockCloudClient) CreateSGName(svcName string) string

+ func (e *MockCloudClient) GetDNSInfo() ([]string, []string, error)

+ func (e *MockCloudClient) GetVPCCIDRs() []string

+ func (e *MockCloudClient) ModifySourceDestinationCheck(iid string, enable bool) error

+ func (e *MockCloudClient) RemoveRoute(destinationCIDR, nextHop string) error

+ func (m *MockCloudClient) AddInstanceTags(string, map[string]string) error

+ func (m *MockCloudClient) AssignInstanceProfile(node *api.Node, instanceProfile string) error

+ func (m *MockCloudClient) AttachSecurityGroups(node *api.Node, groups []string) error

+ func (m *MockCloudClient) EnsureContainerInstanceCluster() error

+ func (m *MockCloudClient) GetAttributes() CloudAttributes

+ func (m *MockCloudClient) GetBootSecurityGroupIDs() []string

+ func (m *MockCloudClient) GetContainerInstancesStatuses(instIDs []string) (map[string][]api.UnitStatus, error)

+ func (m *MockCloudClient) GetImageID(spec BootImageSpec) (string, error)

+ func (m *MockCloudClient) GetRegistryAuth() (string, string, error)

+ func (m *MockCloudClient) ListContainerInstances() ([]ContainerInstance, error)

+ func (m *MockCloudClient) ListContainerInstancesFilterID(insts []string) ([]ContainerInstance, error)

+ func (m *MockCloudClient) ResizeVolume(node *api.Node, size int64) (error, bool)

+ func (m *MockCloudClient) SetBootSecurityGroupIDs([]string)

+ func (m *MockCloudClient) SetSustainedCPU(n *api.Node, enabled bool) error

+ func (m *MockCloudClient) StartContainerInstance(pod *api.Pod) (string, error)

+ func (m *MockCloudClient) StartNode(node *api.Node, metadata string) (*StartNodeResult, error)

+ func (m *MockCloudClient) StartSpotNode(node *api.Node, metadata string) (*StartNodeResult, error)

+ func (m *MockCloudClient) StopContainerInstance(instID string) error

+ func (m *MockCloudClient) StopInstance(instanceID string) error

+ func (m *MockCloudClient) WaitForContainerInstanceRunning(pod *api.Pod) (*api.Pod, error)

+ func (m *MockCloudClient) WaitForRunning(node *api.Node) ([]api.NetworkAddress, error)

+ type NoCapacityError struct

+ AZ string

+ OriginalError string

+ SubnetID string

+ func (e *NoCapacityError) Error() string

+ type SecurityGroup struct

+ ID string

+ Name string

+ Ports []InstancePort

+ SourceRanges []string

+ func NewSecurityGroup(id, name string, ports []InstancePort, sources []string) SecurityGroup

+ type SecurityGroupIdentifier struct

+ ID string

+ Name string

+ type SortableSliceOfPorts []InstancePort

+ func (p SortableSliceOfPorts) Len() int

+ func (p SortableSliceOfPorts) Less(i, j int) bool

+ func (p SortableSliceOfPorts) Swap(i, j int)

+ type StartNodeResult struct

+ AvailabilityZone string

+ InstanceID string

+ type StatusKeeper interface

+ AddUnavailableInstance func(instanceType string, spot bool)

+ AddUnavailableSubnet func(instanceType string, spot bool, subnetID string)

+ AddUnavailableZone func(instanceType string, spot bool, zone string)

+ Dump func() []byte

+ GetAllSubnets func() []SubnetAttributes

+ GetAvailableSubnets func(instanceType string, spot, privateIP bool) []SubnetAttributes

+ GetAvailableZones func(instanceType string, spot bool, privateIP bool) []string

+ IsUnavailableZone func(instanceType string, spot, privateIP bool, az string) bool

+ Start func()

+ Stop func()

+ SupportsAvailabilityZones func() bool

+ type SubnetAddressAffinity string

+ const AnyAddress

+ const PrivateAddress

+ const PublicAddress

+ type SubnetAttributes struct

+ AZ string

+ AddressAffinity SubnetAddressAffinity

+ AvailableAddresses int

+ CIDR string

+ ID string

+ Name string

+ type UnsupportedInstanceError struct

+ OriginalError string

+ func (e *UnsupportedInstanceError) Error() string

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