awsk8s

Documentation

Index

• type ClusterNodes
  • func (c ClusterNodes) Len() int
  • func (c ClusterNodes) Less(i, j int) bool
  • func (c ClusterNodes) Swap(i, j int)
• type CreateDeploymentResponse
• type DeploymentLoadBalancers
• type InClusterK8SDeployer
  • func NewInClusterDeployer(config *viper.Viper, deployment *apis.Deployment) (*InClusterK8SDeployer, error)
  • func (deployer *InClusterK8SDeployer) CreateDeployment(uploadedFiles map[string]string) (interface{}, error)
  • func (deployer *InClusterK8SDeployer) DeleteDeployment() error
  • func (deployer *InClusterK8SDeployer) DeployExtensions(extensions *apis.Deployment, newDeployment *apis.Deployment) error
  • func (deployer *InClusterK8SDeployer) GetServiceAddress(serviceName string) (*apis.ServiceAddress, error)
  • func (deployer *InClusterK8SDeployer) GetServiceMappings() (map[string]interface{}, error)
  • func (deployer *InClusterK8SDeployer) GetServiceUrl(serviceName string) (string, error)
  • func (deployer *InClusterK8SDeployer) GetStoreInfo() interface{}
  • func (deployer *InClusterK8SDeployer) NewStoreInfo() interface{}
  • func (deployer *InClusterK8SDeployer) ReloadClusterState(storeInfo interface{}) error
  • func (deployer *InClusterK8SDeployer) UpdateDeployment(deployment *apis.Deployment) error
• type K8SDeployer
  • func NewDeployer(config *viper.Viper, cluster clusters.Cluster, deployment *apis.Deployment) (*K8SDeployer, error)
  • func (deployer *K8SDeployer) CheckClusterState() error
  • func (deployer *K8SDeployer) CreateDeployment(uploadedFiles map[string]string) (interface{}, error)
  • func (deployer *K8SDeployer) DeleteDeployment() error
  • func (deployer *K8SDeployer) DeployExtensions(extensions *apis.Deployment, newDeployment *apis.Deployment) error
  • func (deployer *K8SDeployer) DownloadKubeConfig() error
  • func (deployer *K8SDeployer) GetCluster() clusters.Cluster
  • func (deployer *K8SDeployer) GetKubeConfigPath() (string, error)
  • func (deployer *K8SDeployer) GetLog() *log.FileLog
  • func (deployer *K8SDeployer) GetScheduler() *job.Scheduler
  • func (deployer *K8SDeployer) GetServiceAddress(serviceName string) (*apis.ServiceAddress, error)
  • func (deployer *K8SDeployer) GetServiceMappings() (map[string]interface{}, error)
  • func (deployer *K8SDeployer) GetServiceUrl(serviceName string) (string, error)
  • func (deployer *K8SDeployer) GetStoreInfo() interface{}
  • func (deployer *K8SDeployer) NewStoreInfo() interface{}
  • func (deployer *K8SDeployer) ReloadClusterState(storeInfo interface{}) error
  • func (deployer *K8SDeployer) SetScheduler(sheduler *job.Scheduler)
  • func (deployer *K8SDeployer) UpdateDeployment(deployment *apis.Deployment) error
  • func (deployer *K8SDeployer) UploadSshKeyToBastion() error
• type StoreInfo

Types

type ClusterNodes

type ClusterNodes []v1.Node

func (ClusterNodes) Len

func (c ClusterNodes) Len() int

func (ClusterNodes) Less

func (c ClusterNodes) Less(i, j int) bool

func (ClusterNodes) Swap

func (c ClusterNodes) Swap(i, j int)

type CreateDeploymentResponse

type CreateDeploymentResponse struct {
	Name      string                               `json:"name"`
	Services  map[string]kubernetes.ServiceMapping `json:"services"`
	BastionIp string                               `json:"bastionIp"`
	MasterIp  string                               `json:"masterIp"`
}

type DeploymentLoadBalancers

type DeploymentLoadBalancers struct {
	StackName             string
	ApiServerBalancerName string
	LoadBalancerNames     []string
}

type InClusterK8SDeployer

type InClusterK8SDeployer struct {
	K8SDeployer

	AutoScalingGroup *autoscaling.Group
	StackName        string
}

func NewInClusterDeployer

func NewInClusterDeployer(
	config *viper.Viper,
	deployment *apis.Deployment) (*InClusterK8SDeployer, error)

func (*InClusterK8SDeployer) CreateDeployment

func (deployer *InClusterK8SDeployer) CreateDeployment(uploadedFiles map[string]string) (interface{}, error)

CreateDeployment start a deployment

func (*InClusterK8SDeployer) DeleteDeployment

func (deployer *InClusterK8SDeployer) DeleteDeployment() error

DeleteDeployment clean up the cluster from kubenetes.

func (*InClusterK8SDeployer) DeployExtensions

func (deployer *InClusterK8SDeployer) DeployExtensions(
	extensions *apis.Deployment,
	newDeployment *apis.Deployment) error

func (*InClusterK8SDeployer) GetServiceAddress

func (deployer *InClusterK8SDeployer) GetServiceAddress(serviceName string) (*apis.ServiceAddress, error)

GetServiceAddress return ServiceAddress object

func (*InClusterK8SDeployer) GetServiceMappings

func (deployer *InClusterK8SDeployer) GetServiceMappings() (map[string]interface{}, error)

func (*InClusterK8SDeployer) GetServiceUrl

func (deployer *InClusterK8SDeployer) GetServiceUrl(serviceName string) (string, error)

func (*InClusterK8SDeployer) GetStoreInfo

func (deployer *InClusterK8SDeployer) GetStoreInfo() interface{}

func (*InClusterK8SDeployer) NewStoreInfo

func (deployer *InClusterK8SDeployer) NewStoreInfo() interface{}

func (*InClusterK8SDeployer) ReloadClusterState

func (deployer *InClusterK8SDeployer) ReloadClusterState(storeInfo interface{}) error

func (*InClusterK8SDeployer) UpdateDeployment

func (deployer *InClusterK8SDeployer) UpdateDeployment(deployment *apis.Deployment) error

UpdateDeployment start a deployment on EC2 is ready

type K8SDeployer

type K8SDeployer struct {
	Config     *viper.Viper
	AWSCluster *aws.AWSCluster

	DeploymentLog *log.FileLog
	Deployment    *apis.Deployment
	Scheduler     *job.Scheduler

	BastionIp              string
	MasterIp               string
	KubeConfigPath         string
	Services               map[string]kubernetes.ServiceMapping
	KubeConfig             *rest.Config
	VpcPeeringConnectionId string
}

func NewDeployer

func NewDeployer(
	config *viper.Viper,
	cluster clusters.Cluster,
	deployment *apis.Deployment) (*K8SDeployer, error)

NewDeployer return the K8S of Deployer

func (*K8SDeployer) CheckClusterState

func (deployer *K8SDeployer) CheckClusterState() error

CheckClusterState check kubernetes cluster state is exist

func (*K8SDeployer) CreateDeployment

func (deployer *K8SDeployer) CreateDeployment(uploadedFiles map[string]string) (interface{}, error)

CreateDeployment start a deployment

func (*K8SDeployer) DeleteDeployment

func (deployer *K8SDeployer) DeleteDeployment() error

DeleteDeployment clean up the cluster from kubenetes.

func (*K8SDeployer) DeployExtensions

func (deployer *K8SDeployer) DeployExtensions(
	extensions *apis.Deployment,
	newDeployment *apis.Deployment) error

func (*K8SDeployer) DownloadKubeConfig

func (deployer *K8SDeployer) DownloadKubeConfig() error

DownloadKubeConfig is Use SSHProxyCommand download k8s master node's kubeconfig

func (*K8SDeployer) GetCluster

func (deployer *K8SDeployer) GetCluster() clusters.Cluster

func (*K8SDeployer) GetKubeConfigPath

func (deployer *K8SDeployer) GetKubeConfigPath() (string, error)

func (*K8SDeployer) GetLog

func (deployer *K8SDeployer) GetLog() *log.FileLog

func (*K8SDeployer) GetScheduler

func (deployer *K8SDeployer) GetScheduler() *job.Scheduler

func (*K8SDeployer) GetServiceAddress

func (deployer *K8SDeployer) GetServiceAddress(serviceName string) (*apis.ServiceAddress, error)

GetServiceAddress return ServiceAddress object

func (*K8SDeployer) GetServiceMappings

func (deployer *K8SDeployer) GetServiceMappings() (map[string]interface{}, error)

func (*K8SDeployer) GetServiceUrl

func (deployer *K8SDeployer) GetServiceUrl(serviceName string) (string, error)

func (*K8SDeployer) GetStoreInfo

func (deployer *K8SDeployer) GetStoreInfo() interface{}

func (*K8SDeployer) NewStoreInfo

func (deployer *K8SDeployer) NewStoreInfo() interface{}

func (*K8SDeployer) ReloadClusterState

func (deployer *K8SDeployer) ReloadClusterState(storeInfo interface{}) error

ReloadClusterState reloads kubernetes cluster state

func (*K8SDeployer) SetScheduler

func (deployer *K8SDeployer) SetScheduler(sheduler *job.Scheduler)

func (*K8SDeployer) UpdateDeployment

func (deployer *K8SDeployer) UpdateDeployment(deployment *apis.Deployment) error

UpdateDeployment start a deployment on EC2 is ready

func (*K8SDeployer) UploadSshKeyToBastion

func (deployer *K8SDeployer) UploadSshKeyToBastion() error

UploadSshKeyToBastion upload sshKey to bastion-host

type StoreInfo

type StoreInfo struct {
	BastionIp              string
	MasterIp               string
	VpcPeeringConnectionId string
}