aws

package

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

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/mlab-lattice/lattice

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
type DefaultAWSCloudProvider
- func NewCloudProvider(namespacePrefix string, kubeClient kubeclientset.Interface, ...) (*DefaultAWSCloudProvider, error)
type Options
- func Flags() (cli.Flags, *Options)
- func NewOptions(staticOptions *Options, dynamicConfig *latticev1.ConfigCloudProviderAWS) (*Options, error)

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
terraform

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