Versions in this module Expand all Collapse all v1 v1.15.1 Feb 17, 2020 v1.15.0 Feb 17, 2020 Changes in this version + const ENV_VAR_CNI_ASSET_HASH_STRING + const ENV_VAR_CNI_VERSION_URL + const KEY_NAME + const KEY_TYPE + const PlaceholderIP + const PlaceholderTTL + const PlaceholderTTLDigitialOcean + const TargetCloudformation + const TargetDirect + const TargetDryRun + const TargetTerraform + var AlphaAllowALI = featureflag.New("AlphaAllowALI", featureflag.Bool(false)) + var AlphaAllowBareMetal = featureflag.New("AlphaAllowBareMetal", featureflag.Bool(false)) + var AlphaAllowDO = featureflag.New("AlphaAllowDO", featureflag.Bool(false)) + var AlphaAllowGCE = featureflag.New("AlphaAllowGCE", featureflag.Bool(false)) + var AlphaAllowVsphere = featureflag.New("AlphaAllowVsphere", featureflag.Bool(false)) + var CloudupModels = []string + var EtcdClusters = []string + var Phases = sets.NewString(string(PhaseStageAssets), string(PhaseSecurity), string(PhaseNetwork), ...) + func BaseUrl() (*url.URL, error) + func BuildCloud(cluster *kops.Cluster) (fi.Cloud, error) + func ChannelForCluster(c *kops.Cluster) (*kops.Channel, error) + func FindDNSHostedZone(dns dnsprovider.Interface, clusterDNSName string, dnsType kops.DNSType) (string, error) + func FindLatestKubernetesVersion() (string, error) + func KopsFileUrl(file string, assetBuilder *assets.AssetBuilder) (*url.URL, *hashing.Hash, error) + func PerformAssignments(c *kops.Cluster) error + func PopulateClusterSpec(clientset simple.Clientset, cluster *api.Cluster, ...) (*api.Cluster, error) + func PopulateInstanceGroupSpec(cluster *kops.Cluster, input *kops.InstanceGroup, channel *kops.Channel) (*kops.InstanceGroup, error) + func ProtokubeImageSource(assetsBuilder *assets.AssetBuilder) (*url.URL, *hashing.Hash, error) + func SetKopsAssetsLocations(assetsBuilder *assets.AssetBuilder) error + type ApplyClusterCmd struct + Assets []*MirroredAsset + Clientset simple.Clientset + Cluster *kops.Cluster + DryRun bool + InstanceGroups []*kops.InstanceGroup + LifecycleOverrides map[string]fi.Lifecycle + Models []string + NodeUpHash string + NodeUpSource string + OutDir string + Phase Phase + RunTasksOptions *fi.RunTasksOptions + Target fi.Target + TargetName string + TaskMap map[string]fi.Task + func (c *ApplyClusterCmd) AddFileAssets(assetBuilder *assets.AssetBuilder) error + func (c *ApplyClusterCmd) BuildNodeUpConfig(assetBuilder *assets.AssetBuilder, ig *kops.InstanceGroup) (*nodeup.Config, error) + func (c *ApplyClusterCmd) Run() error + type BootstrapChannelBuilder struct + Lifecycle *fi.Lifecycle + func (b *BootstrapChannelBuilder) Build(c *fi.ModelBuilderContext) error + type ByZone []*kops.ClusterSubnetSpec + func (a ByZone) Len() int + func (a ByZone) Less(i, j int) bool + func (a ByZone) Swap(i, j int) + type Loader struct + Builders []fi.ModelBuilder + Cluster *api.Cluster + ModelStore vfs.Path + Resources map[string]fi.Resource + Tags sets.String + TemplateFunctions template.FuncMap + WorkDir string + func (l *Loader) AddTypes(types map[string]interface{}) + func (l *Loader) BuildTasks(modelStore vfs.Path, models []string, assetBuilder *assets.AssetBuilder, ...) (map[string]fi.Task, error) + func (l *Loader) Init() + type MirroredAsset struct + Hash *hashing.Hash + Locations []string + func BuildMirroredAsset(u *url.URL, hash *hashing.Hash) *MirroredAsset + func NodeUpAsset(assetsBuilder *assets.AssetBuilder) (*MirroredAsset, error) + func (a *MirroredAsset) CompactString() string + type Phase string + const PhaseCluster + const PhaseNetwork + const PhaseSecurity + const PhaseStageAssets + type SpecBuilder struct + OptionsLoader *loader.OptionsLoader + Tags sets.String + func (l *SpecBuilder) BuildCompleteSpec(clusterSpec *api.ClusterSpec) (*api.ClusterSpec, error) + type TemplateFunctions struct + func (tf *TemplateFunctions) AddTo(dest template.FuncMap, secretStore fi.SecretStore) (err error) + func (tf *TemplateFunctions) DnsControllerArgv() ([]string, error) + func (tf *TemplateFunctions) EtcdScheme() string + func (tf *TemplateFunctions) ExternalDnsArgv() ([]string, error) + func (tf *TemplateFunctions) GetInstanceGroup(name string) (*kops.InstanceGroup, error) + func (tf *TemplateFunctions) HasTag(tag string) bool + func (tf *TemplateFunctions) ProxyEnv() map[string]string + func (tf *TemplateFunctions) SharedVPC() bool + func (tf *TemplateFunctions) ToJSON(data interface{}) string