Documentation ¶
Index ¶
- type ClusterNodes
- type CreateDeploymentResponse
- type DeploymentLoadBalancers
- type InClusterK8SDeployer
- 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 (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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ClusterNodes ¶
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 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