kutil

package

Go to main page

Versions in this module

v1

v1.4.4

Dec 21, 2016

v1.4.3

Dec 14, 2016

v1.4.2

Dec 13, 2016

v1.4.1

Oct 10, 2016

Changes in this version

type ConvertKubeupCluster

+ Clientset simple.Clientset

type DeleteInstanceGroup

+ Clientset simple.Clientset

type ImportCluster

+ Clientset simple.Clientset

v1.4.0

Oct 2, 2016

Changes in this version

+ const TypeAutoscalingLaunchConfig

+ func AddSSHIdentity(sshConfig *ssh.ClientConfig, p string) error

+ func DeleteAutoScalingGroup(cloud fi.Cloud, r *ResourceTracker) error

+ func DeleteAutoscalingLaunchConfiguration(cloud fi.Cloud, r *ResourceTracker) error

+ func DeleteDhcpOptions(cloud fi.Cloud, r *ResourceTracker) error

+ func DeleteELB(cloud fi.Cloud, r *ResourceTracker) error

+ func DeleteElasticIP(cloud fi.Cloud, t *ResourceTracker) error

+ func DeleteIAMInstanceProfile(cloud fi.Cloud, r *ResourceTracker) error

+ func DeleteIAMRole(cloud fi.Cloud, r *ResourceTracker) error

+ func DeleteInstance(cloud fi.Cloud, t *ResourceTracker) error

+ func DeleteInternetGateway(cloud fi.Cloud, r *ResourceTracker) error

+ func DeleteKeypair(cloud fi.Cloud, r *ResourceTracker) error

+ func DeleteRouteTable(cloud fi.Cloud, r *ResourceTracker) error

+ func DeleteSecurityGroup(cloud fi.Cloud, t *ResourceTracker) error

+ func DeleteSubnet(cloud fi.Cloud, tracker *ResourceTracker) error

+ func DeleteVPC(cloud fi.Cloud, r *ResourceTracker) error

+ func DeleteVolume(cloud fi.Cloud, r *ResourceTracker) error

+ func DescribeDhcpOptions(cloud fi.Cloud) ([]*ec2.DhcpOptions, error)

+ func DescribeELBs(cloud fi.Cloud) ([]*elb.LoadBalancerDescription, map[string][]*elb.Tag, error)

+ func DescribeInternetGateways(cloud fi.Cloud) ([]*ec2.InternetGateway, error)

+ func DescribeInternetGatewaysIgnoreTags(cloud fi.Cloud) ([]*ec2.InternetGateway, error)

+ func DescribeSecurityGroups(cloud fi.Cloud) ([]*ec2.SecurityGroup, error)

+ func DescribeSubnets(cloud fi.Cloud) ([]*ec2.Subnet, error)

+ func DescribeVolumes(cloud fi.Cloud) ([]*ec2.Volume, error)

+ func FindASGName(tags []*autoscaling.TagDescription) string

+ func FindCloudInstanceGroups(cloud fi.Cloud, cluster *api.Cluster, instancegroups []*api.InstanceGroup, ...) (map[string]*CloudInstanceGroup, error)

+ func FindELBName(tags []*elb.Tag) string

+ func FindName(tags []*ec2.Tag) string

+ func GetInstanceUserData(cloud awsup.AWSCloud, instanceID string) ([]byte, error)

+ func IsDependencyViolation(err error) bool

+ func UserDataToString(userData []byte) (string, error)

+ type CloudInstanceGroup struct

+ ASGName string

+ InstanceGroup *api.InstanceGroup

+ NeedUpdate []*CloudInstanceGroupInstance

+ Ready []*CloudInstanceGroupInstance

+ Status string

+ func (c *CloudInstanceGroup) MaxSize() int

+ func (c *CloudInstanceGroup) MinSize() int

+ func (g *CloudInstanceGroup) Delete(cloud fi.Cloud) error

+ func (n *CloudInstanceGroup) RollingUpdate(cloud fi.Cloud, force bool, interval time.Duration, ...) error

+ func (n *CloudInstanceGroup) String() string

+ type CloudInstanceGroupInstance struct

+ ASGInstance *autoscaling.Instance

+ Node *v1.Node

+ type ConvertKubeupCluster struct

+ Channel *api.Channel

+ Cloud fi.Cloud

+ ClusterConfig *api.Cluster

+ ClusterRegistry *api.ClusterRegistry

+ InstanceGroups []*api.InstanceGroup

+ NewClusterName string

+ OldClusterName string

+ func (x *ConvertKubeupCluster) Upgrade() error

+ type CreateKubecfg struct

+ ClusterName string

+ KeyStore fi.CAStore

+ MasterPublicName string

+ SecretStore fi.SecretStore

+ func (c *CreateKubecfg) Close()

+ func (c *CreateKubecfg) WriteKubecfg() error

+ type DeleteCluster struct

+ Cloud fi.Cloud

+ ClusterName string

+ func (c *DeleteCluster) DeleteResources(resources map[string]*ResourceTracker) error

+ func (c *DeleteCluster) ListResources() (map[string]*ResourceTracker, error)

+ type DeleteInstanceGroup struct

+ Cloud fi.Cloud

+ Cluster *api.Cluster

+ InstanceGroupRegistry *api.InstanceGroupRegistry

+ func (c *DeleteInstanceGroup) DeleteInstanceGroup(group *api.InstanceGroup) error

+ type ImportCluster struct

+ Cloud fi.Cloud

+ ClusterName string

+ ClusterRegistry *api.ClusterRegistry

+ func (x *ImportCluster) ImportAWSCluster() error

+ type KubeconfigBuilder struct

+ CACert string

+ Context string

+ KubeBearerToken string

+ KubeMasterIP string

+ KubePassword string

+ KubeUser string

+ KubecfgCert string

+ KubecfgKey string

+ KubeconfigPath string

+ KubectlPath string

+ func (c *KubeconfigBuilder) Init()

+ func (c *KubeconfigBuilder) WriteKubecfg() error

+ type Kubectl struct

+ KubectlPath string

+ func (k *Kubectl) GetConfig(minify bool) (*KubectlConfig, error)

+ func (k *Kubectl) GetCurrentContext() (string, error)

+ type KubectlCluster struct

+ Server string

+ type KubectlClusterWithName struct

+ Cluster KubectlCluster

+ Name string

+ type KubectlConfig struct

+ ApiVersion string

+ Clusters []*KubectlClusterWithName

+ Contexts []*KubectlContextWithName

+ CurrentContext string

+ Kind string

+ Users []*KubectlUserWithName

+ type KubectlContext struct

+ Cluster string

+ User string

+ type KubectlContextWithName struct

+ Context KubectlContext

+ Name string

+ type KubectlUser struct

+ ClientCertificateData string

+ ClientKeyData string

+ Password string

+ Username string

+ type KubectlUserWithName struct

+ Name string

+ User KubectlUser

+ type NodeSSH struct

+ Hostname string

+ SSHConfig ssh.ClientConfig

+ func (m *NodeSSH) GetSSHClient() (*ssh.Client, error)

+ func (m *NodeSSH) Root() (*vfs.SSHPath, error)

+ type ResourceTracker struct

+ ID string

+ Name string

+ Type string

+ func ListAutoScalingGroups(cloud fi.Cloud, clusterName string) ([]*ResourceTracker, error)

+ func ListAutoScalingLaunchConfigurations(cloud fi.Cloud, clusterName string) ([]*ResourceTracker, error)

+ func ListDhcpOptions(cloud fi.Cloud, clusterName string) ([]*ResourceTracker, error)

+ func ListELBs(cloud fi.Cloud, clusterName string) ([]*ResourceTracker, error)

+ func ListIAMInstanceProfiles(cloud fi.Cloud, clusterName string) ([]*ResourceTracker, error)

+ func ListIAMRoles(cloud fi.Cloud, clusterName string) ([]*ResourceTracker, error)

+ func ListInstances(cloud fi.Cloud, clusterName string) ([]*ResourceTracker, error)

+ func ListInternetGateways(cloud fi.Cloud, clusterName string) ([]*ResourceTracker, error)

+ func ListKeypairs(cloud fi.Cloud, clusterName string) ([]*ResourceTracker, error)

+ func ListRoute53Records(cloud fi.Cloud, clusterName string) ([]*ResourceTracker, error)

+ func ListRouteTables(cloud fi.Cloud, clusterName string) ([]*ResourceTracker, error)

+ func ListSecurityGroups(cloud fi.Cloud, clusterName string) ([]*ResourceTracker, error)

+ func ListSubnets(cloud fi.Cloud, clusterName string) ([]*ResourceTracker, error)

+ func ListVPCs(cloud fi.Cloud, clusterName string) ([]*ResourceTracker, error)

+ func ListVolumes(cloud fi.Cloud, clusterName string) ([]*ResourceTracker, error)

+ type RollingUpdateCluster struct

+ Cloud fi.Cloud

+ Force bool

+ MasterInterval time.Duration

+ NodeInterval time.Duration

+ func (c *RollingUpdateCluster) RollingUpdate(groups map[string]*CloudInstanceGroup, k8sClient *release_1_3.Clientset) error

+ type UserDataConfiguration struct

+ Settings map[string]string

+ Version string

+ func ParseUserDataConfiguration(raw []byte) (*UserDataConfiguration, error)

+ func (u *UserDataConfiguration) ParseBool(key string) *bool

+ func (u *UserDataConfiguration) ParseCert(key string) (*fi.Certificate, error)

+ func (u *UserDataConfiguration) ParseInt(key string) (*int, error)

+ func (u *UserDataConfiguration) ParseKey(key string) (*fi.PrivateKey, error)

v1.4.0-alpha.1

Sep 8, 2016

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