aws

package
v0.1.1 Latest Latest
Warning

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

 Go to latest Published: Sep 27, 2018 License: Apache-2.0 Imports: 31 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	AnnotationKeyNodePoolAutoscalingGroupName = "node-pool.aws.cloud-provider.lattice.mlab.com/autoscaling-group-name"
	AnnotationKeyNodePoolSecurityGroupID      = "node-pool.aws.cloud-provider.lattice.mlab.com/security-group-id"
)
View Source 
const (
	AnnotationKeyAddressServiceLoadBalancerDNSName = "service-load-balancer.address.aws.cloud-provider.lattice.mlab.com/dns-name"
)
View Source 
const (
	AnnotationKeyLoadBalancerDNSName = "load-balancer.aws.cloud-provider.lattice.mlab.com/dns-name"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type DefaultAWSCloudProvider 

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

func NewCloudProvider 

func NewCloudProvider(
	namespacePrefix string,
	kubeClient kubeclientset.Interface,
	kubeInformerFactory kubeinformers.SharedInformerFactory,
	latticeInformerFactory latticeinformers.SharedInformerFactory,
	options *Options,
) (*DefaultAWSCloudProvider, error)

func (*DefaultAWSCloudProvider) BootstrapSystemResources 

func (cp *DefaultAWSCloudProvider) BootstrapSystemResources(resources *bootstrapper.SystemResources)

func (*DefaultAWSCloudProvider) ComponentBuildWorkDirectoryVolumeSource 

func (cp *DefaultAWSCloudProvider) ComponentBuildWorkDirectoryVolumeSource(jobName string) corev1.VolumeSource

func (*DefaultAWSCloudProvider) DNSARecordNeedsUpdate 

func (cp *DefaultAWSCloudProvider) DNSARecordNeedsUpdate(latticeID v1.LatticeID, name, value string) (bool, error)

func (*DefaultAWSCloudProvider) DestroyDNSRecord 

func (cp *DefaultAWSCloudProvider) DestroyDNSRecord(latticeID v1.LatticeID, name string) error

func (*DefaultAWSCloudProvider) DestroyNodePoolEpoch 

func (cp *DefaultAWSCloudProvider) DestroyNodePoolEpoch(
	latticeID v1.LatticeID,
	nodePool *latticev1.NodePool,
	epoch latticev1.NodePoolEpoch,
) error

func (*DefaultAWSCloudProvider) DestroyServiceAddressLoadBalancer 

func (cp *DefaultAWSCloudProvider) DestroyServiceAddressLoadBalancer(
	latticeID v1.LatticeID,
	address *latticev1.Address,
) error

func (*DefaultAWSCloudProvider) EnsureDNSARecord 

func (cp *DefaultAWSCloudProvider) EnsureDNSARecord(latticeID v1.LatticeID, name, value string) error

func (*DefaultAWSCloudProvider) EnsureDNSCNAMERecord 

func (cp *DefaultAWSCloudProvider) EnsureDNSCNAMERecord(latticeID v1.LatticeID, name, value string) error

func (*DefaultAWSCloudProvider) EnsureNodePoolEpoch 

func (cp *DefaultAWSCloudProvider) EnsureNodePoolEpoch(
	latticeID v1.LatticeID,
	nodePool *latticev1.NodePool,
	epoch latticev1.NodePoolEpoch,
) error

func (*DefaultAWSCloudProvider) EnsureServiceAddressLoadBalancer 

func (cp *DefaultAWSCloudProvider) EnsureServiceAddressLoadBalancer(
	latticeID v1.LatticeID,
	address *latticev1.Address,
	service *latticev1.Service,
	serviceMeshPorts map[int32]int32,
) error

func (*DefaultAWSCloudProvider) IsDeploymentSpecUpdated 

func (cp *DefaultAWSCloudProvider) IsDeploymentSpecUpdated(
	service *latticev1.Service,
	current, desired, untransformed *appsv1.DeploymentSpec,
) (bool, string, *appsv1.DeploymentSpec)

func (*DefaultAWSCloudProvider) NodePoolAddAnnotations 

func (cp *DefaultAWSCloudProvider) NodePoolAddAnnotations(
	latticeID v1.LatticeID,
	nodePool *latticev1.NodePool,
	annotations map[string]string,
	epoch latticev1.NodePoolEpoch,
) error

func (*DefaultAWSCloudProvider) NodePoolEpochStatus 

func (cp *DefaultAWSCloudProvider) NodePoolEpochStatus(
	latticeID v1.LatticeID,
	nodePool *latticev1.NodePool,
	epoch latticev1.NodePoolEpoch,
	epochSpec *latticev1.NodePoolSpec,
) (*latticev1.NodePoolStatusEpochStatus, error)

func (*DefaultAWSCloudProvider) NodePoolNeedsNewEpoch 

func (cp *DefaultAWSCloudProvider) NodePoolNeedsNewEpoch(nodePool *latticev1.NodePool) (bool, error)

func (*DefaultAWSCloudProvider) ServiceAddressLoadBalancerAddAnnotations 

func (cp *DefaultAWSCloudProvider) ServiceAddressLoadBalancerAddAnnotations(
	latticeID v1.LatticeID,
	address *latticev1.Address,
	service *latticev1.Service,
	serviceMeshPorts map[int32]int32,
	annotations map[string]string,
) error

func (*DefaultAWSCloudProvider) ServiceAddressLoadBalancerNeedsUpdate 

func (cp *DefaultAWSCloudProvider) ServiceAddressLoadBalancerNeedsUpdate(
	latticeID v1.LatticeID,
	address *latticev1.Address,
	service *latticev1.Service,
	serviceMeshPorts map[int32]int32,
) (bool, error)

func (*DefaultAWSCloudProvider) ServiceAddressLoadBalancerPorts 

func (cp *DefaultAWSCloudProvider) ServiceAddressLoadBalancerPorts(
	latticeID v1.LatticeID,
	address *latticev1.Address,
	service *latticev1.Service,
	serviceMeshPorts map[int32]int32,
) (map[int32]string, error)

func (*DefaultAWSCloudProvider) TransformComponentBuildJobSpec 

func (cp *DefaultAWSCloudProvider) TransformComponentBuildJobSpec(spec *batchv1.JobSpec) *batchv1.JobSpec

func (*DefaultAWSCloudProvider) TransformPodTemplateSpec 

func (cp *DefaultAWSCloudProvider) TransformPodTemplateSpec(spec *corev1.PodTemplateSpec) *corev1.PodTemplateSpec

type Options 

type Options struct {
	Region    string
	AccountID string
	VPCID     string

	Route53PrivateZoneID      string
	SubnetIDs                 []string
	MasterNodeSecurityGroupID string

	WorkerNodeAMIID string
	KeyName         string

	TerraformModulePath     string
	TerraformBackendOptions *terraform.BackendOptions
}

func Flags 

func Flags() (cli.Flags, *Options)

func NewOptions 

func NewOptions(staticOptions *Options, dynamicConfig *latticev1.ConfigCloudProviderAWS) (*Options, error)

Source Files

View all Source files

Directories

Path Synopsis

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.