deploy

type CacheRedisConfigure struct {
	StatusPublisher StatusPublisher
	// contains filtered or unexported fields
}

type Client interface {
	CreateConfigMap(ns string, cm *k8api.ConfigMap) (*k8api.ConfigMap, error)
	UpdateConfigMap(ns string, cm *k8api.ConfigMap) (*k8api.ConfigMap, error)
	CreateServiceInNamespace(ns string, svc *k8api.Service) (*k8api.Service, error)
	CreateRouteInNamespace(ns string, r *roapi.Route) (*roapi.Route, error)
	CreateImageStream(ns string, i *image.ImageStream) (*image.ImageStream, error)
	CreateBuildConfigInNamespace(namespace string, b *bc.BuildConfig) (*bc.BuildConfig, error)
	CreateDeployConfigInNamespace(namespace string, d *dc.DeploymentConfig) (*dc.DeploymentConfig, error)
	CreateSecretInNamespace(namespace string, s *k8api.Secret) (*k8api.Secret, error)
	CreatePersistentVolumeClaim(namespace string, claim *k8api.PersistentVolumeClaim) (*k8api.PersistentVolumeClaim, error)
	CreateJobToWatch(j *batch.Job, ns string) (watch.Interface, error)
	CreatePod(ns string, p *k8api.Pod) (*k8api.Pod, error)
	UpdateBuildConfigInNamespace(namespace string, b *bc.BuildConfig) (*bc.BuildConfig, error)
	UpdateDeployConfigInNamespace(ns string, d *dc.DeploymentConfig) (*dc.DeploymentConfig, error)
	UpdateRouteInNamespace(ns string, r *roapi.Route) (*roapi.Route, error)
	InstantiateBuild(ns, buildName string) (*bc.Build, error)
	FindDeploymentConfigsByLabel(ns string, searchLabels map[string]string) ([]dc.DeploymentConfig, error)
	FindServiceByLabel(ns string, searchLabels map[string]string) ([]k8api.Service, error)
	FindJobByName(ns, name string) (*batch.Job, error)
	FindRouteByName(ns, name string) (*route.Route, error)
	FindConfigMapByName(ns, name string) (*k8api.ConfigMap, error)
	FindBuildConfigByLabel(ns string, searchLabels map[string]string) (*bc.BuildConfig, error)
	GetDeploymentConfigByName(ns, deploymentName string) (*dc.DeploymentConfig, error)
	DeployLogURL(ns, dc string) string
	BuildConfigLogURL(ns, dc string) string
	BuildURL(ns, bc, id string) string
	GetDeployLogs(ns, deployName string) (string, error)
}

type Configuration struct {
	DeploymentName string
	NameSpace      string
	Action         string
	InstanceID     string
}

type ConfigurationFactory struct {
	StatusPublisher StatusPublisher
	TemplateLoader  TemplateLoader
	Logger          log.Logger
}

type Configurer interface {
	Configure(client Client, deployment *dc.DeploymentConfig, namespace string) (*dc.DeploymentConfig, error)
}

type Controller struct {
	TemplateDecoder         TemplateDecoder
	Logger                  log.Logger
	ConfigurationController *EnvironmentServiceConfigController
	// contains filtered or unexported fields
}

type DataMongoConfigure struct {
	StatusPublisher StatusPublisher

	TemplateLoader TemplateLoader
	// contains filtered or unexported fields
}

type DataMysqlConfigure struct {
	StatusPublisher StatusPublisher

	TemplateLoader TemplateLoader
	// contains filtered or unexported fields
}

type Dispatched struct {
	// WatchURL is the url used to watch and stream the logs of a deployment or build
	WatchURL string       `json:"watchURL"`
	Route    *roapi.Route `json:"route"`
	// BuildURL is the url used to get the status of a build
	BuildURL string `json:"buildURL"`

	DeploymentName   string            `json:"deploymentName"`
	DeploymentLabels map[string]string `json:"deploymentLabels"`
	//instanceID is used to identify a particular service instance. It is set as the namespace + deploymentName for the service
	InstanceID string `json:"instanceID"`
	//Operation can be provision/deprovision/update/
	Operation string `json:"operation"`
}

type EnvVar struct {
	Name  string `json:"name"`
	Value string `json:"value"`
}

type EnvironmentServiceConfigController struct {
	ConfigurationFactory ServiceConfigFactory
	StatusPublisher      StatusPublisher
	// contains filtered or unexported fields
}

type ErrInvalid struct {
	// contains filtered or unexported fields
}

type Payload struct {
	ServiceName  string                 `json:"serviceName"`
	Route        string                 `json:"route"`
	ProjectGUID  string                 `json:"projectGuid"`
	CloudAppGUID string                 `json:"cloudAppGuid"`
	Domain       string                 `json:"domain"`
	Env          string                 `json:"env"`
	Replicas     int                    `json:"replicas"`
	EnvVars      []*EnvVar              `json:"envVars"`
	Repo         *Repo                  `json:"repo"`
	Target       *Target                `json:"target"`
	Options      map[string]interface{} `json:"options"`
}

type PushApplication struct {
	PushApplicationID string `json:"pushApplicationID"`
	MasterSecret      string `json:"masterSecret"`
	Name              string `json:"name"`
}

type PushUpsConfigure struct {
	StatusPublisher StatusPublisher
	TemplateLoader  TemplateLoader

	PushLister func(host, user, password string) ([]*PushApplication, error)
	// contains filtered or unexported fields
}

type Repo struct {
	Loc  string `json:"loc"`
	Ref  string `json:"ref"`
	Auth struct {
		AuthType string `json:"authType"` //basic or ssh
		User     string `json:"user"`
		Key      string `json:"key"`
	} `json:"auth"`
}

type ServiceConfigFactory interface {
	Factory(serviceName string, config *Configuration, wait *sync.WaitGroup) Configurer
	Publisher(publisher StatusPublisher)
}

type StatusPublisher interface {
	Publish(key string, status, description string) error
	Clear(key string) error
}

type Target struct {
	Host  string `json:"host"`
	Token string `json:"token"`
}

type Template struct {
	*api.Template
}

type TemplateDecoder interface {
	Decode(template []byte) (*Template, error)
}

type TemplateLoader interface {
	Load(name string) (*template.Template, error)
	ListServices() ([]*Template, error)
	FindInTemplate(t *api.Template, resource string) (interface{}, error)
}