local

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: 27 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type DefaultLocalCloudProvider 

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

func NewCloudProvider 

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

func (*DefaultLocalCloudProvider) BootstrapSystemResources 

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

func (*DefaultLocalCloudProvider) ComponentBuildWorkDirectoryVolumeSource 

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

func (*DefaultLocalCloudProvider) DNSARecordNeedsUpdate 

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

func (*DefaultLocalCloudProvider) DestroyDNSRecord 

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

func (*DefaultLocalCloudProvider) DestroyNodePoolEpoch 

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

func (*DefaultLocalCloudProvider) DestroyServiceAddressLoadBalancer 

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

func (*DefaultLocalCloudProvider) EnsureDNSARecord 

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

func (*DefaultLocalCloudProvider) EnsureDNSCNAMERecord 

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

func (*DefaultLocalCloudProvider) EnsureNodePoolEpoch 

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

func (*DefaultLocalCloudProvider) EnsureServiceAddressLoadBalancer 

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

func (*DefaultLocalCloudProvider) IP 

func (cp *DefaultLocalCloudProvider) IP() string

func (*DefaultLocalCloudProvider) IsDeploymentSpecUpdated 

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

func (*DefaultLocalCloudProvider) NodePoolAddAnnotations 

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

func (*DefaultLocalCloudProvider) NodePoolCurrentEpochState 

func (cp *DefaultLocalCloudProvider) NodePoolCurrentEpochState(
	latticeID v1.LatticeID,
	nodePool *latticev1.NodePool,
) (latticev1.NodePoolState, error)

func (*DefaultLocalCloudProvider) NodePoolEpochStatus 

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

func (*DefaultLocalCloudProvider) NodePoolNeedsNewEpoch 

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

func (*DefaultLocalCloudProvider) ServiceAddressLoadBalancerAddAnnotations 

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

func (*DefaultLocalCloudProvider) ServiceAddressLoadBalancerNeedsUpdate 

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

func (*DefaultLocalCloudProvider) ServiceAddressLoadBalancerPorts 

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

func (*DefaultLocalCloudProvider) TransformComponentBuildJobSpec 

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

func (*DefaultLocalCloudProvider) TransformPodTemplateSpec 

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

type DefaultLocalLatticeProvisioner 

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

func NewLatticeProvisioner 

func NewLatticeProvisioner(workingDir string) (*DefaultLocalLatticeProvisioner, error)

func (*DefaultLocalLatticeProvisioner) Deprovision 

func (p *DefaultLocalLatticeProvisioner) Deprovision(name string, force bool) error

func (*DefaultLocalLatticeProvisioner) Provision 

func (p *DefaultLocalLatticeProvisioner) Provision(id v1.LatticeID, containerChannel string, apiAuthKey string) (string, error)

type Options 

type Options struct {
	IP string
}

func Flags 

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

func NewOptions 

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

Source Files

View all Source files

Directories

Path Synopsis
dns
controller

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.