kutil

package

Go to main page

Versions in this module

v1

v1.10.0

Aug 16, 2018

Changes in this version

+ func NewClientConfig(clientConfig *restclient.Config, namespace string) clientcmd.ClientConfig

type Kubectl

+ func (k *Kubectl) Apply(context string, data []byte) error

+ type SimpleClientConfig struct

+ func (c *SimpleClientConfig) ClientConfig() (*restclient.Config, error)

+ func (c *SimpleClientConfig) ConfigAccess() clientcmd.ConfigAccess

+ func (c *SimpleClientConfig) Namespace() (string, bool, error)

+ func (c *SimpleClientConfig) RawConfig() (clientcmdapi.Config, error)

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