gcpgke

Documentation

Index

• type CreateDeploymentResponse
• type GCPDeployer
  • func NewDeployer(config *viper.Viper, cluster clusters.Cluster, deployment *apis.Deployment) (*GCPDeployer, error)
  • func NewSharedDeployer(config *viper.Viper, deployment *apis.Deployment) (*GCPDeployer, error)
  • func (deployer *GCPDeployer) CheckClusterState() error
  • func (deployer *GCPDeployer) CreateDeployment(uploadedFiles map[string]string) (interface{}, error)
  • func (deployer *GCPDeployer) DeleteDeployment() error
  • func (deployer *GCPDeployer) DeployExtensions(extensions *apis.Deployment, newDeployment *apis.Deployment) error
  • func (deployer *GCPDeployer) DownloadKubeConfig() error
  • func (deployer *GCPDeployer) DownloadSSHKey() error
  • func (deployer *GCPDeployer) GetCluster() clusters.Cluster
  • func (deployer *GCPDeployer) GetKubeConfigPath() (string, error)
  • func (deployer *GCPDeployer) GetLog() *log.FileLog
  • func (deployer *GCPDeployer) GetScheduler() *job.Scheduler
  • func (deployer *GCPDeployer) GetServiceAddress(serviceName string) (*apis.ServiceAddress, error)
  • func (deployer *GCPDeployer) GetServiceMappings() (map[string]interface{}, error)
  • func (deployer *GCPDeployer) GetServiceUrl(serviceName string) (string, error)
  • func (deployer *GCPDeployer) GetStoreInfo() interface{}
  • func (deployer *GCPDeployer) NewStoreInfo() interface{}
  • func (deployer *GCPDeployer) ReloadClusterState(storeInfo interface{}) error
  • func (deployer *GCPDeployer) SetScheduler(sheduler *job.Scheduler)
  • func (deployer *GCPDeployer) UpdateDeployment(deployment *apis.Deployment) error
• type StoreInfo

Types

type CreateDeploymentResponse

type CreateDeploymentResponse struct {
	Name      string                               `json:"name"`
	ClusterId string                               `json:"clusterId"`
	Services  map[string]kubernetes.ServiceMapping `json:"services"`
}

type GCPDeployer

type GCPDeployer struct {
	Config     *viper.Viper
	GCPCluster *gcp.GCPCluster

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

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

func NewDeployer

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

NewDeployer return the GCP of Deployer

func NewSharedDeployer

func NewSharedDeployer(config *viper.Viper, deployment *apis.Deployment) (*GCPDeployer, error)

func (*GCPDeployer) CheckClusterState

func (deployer *GCPDeployer) CheckClusterState() error

CheckClusterState check kubernetes cluster state is exist

func (*GCPDeployer) CreateDeployment

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

CreateDeployment start a deployment

func (*GCPDeployer) DeleteDeployment

func (deployer *GCPDeployer) DeleteDeployment() error

DeleteDeployment clean up the cluster from kubenetes.

func (*GCPDeployer) DeployExtensions

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

func (*GCPDeployer) DownloadKubeConfig

func (deployer *GCPDeployer) DownloadKubeConfig() error

func (*GCPDeployer) DownloadSSHKey

func (deployer *GCPDeployer) DownloadSSHKey() error

func (*GCPDeployer) GetCluster

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

func (*GCPDeployer) GetKubeConfigPath

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

func (*GCPDeployer) GetLog

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

func (*GCPDeployer) GetScheduler

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

func (*GCPDeployer) GetServiceAddress

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

GetServiceAddress return ServiceAddress object

func (*GCPDeployer) GetServiceMappings

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

func (*GCPDeployer) GetServiceUrl

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

func (*GCPDeployer) GetStoreInfo

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

func (*GCPDeployer) NewStoreInfo

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

func (*GCPDeployer) ReloadClusterState

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

ReloadClusterState reloads kubernetes cluster state

func (*GCPDeployer) SetScheduler

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

func (*GCPDeployer) UpdateDeployment

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

UpdateDeployment start a deployment on GCP is ready

type StoreInfo

type StoreInfo struct {
	ClusterId string
}