core

Jul 12, 2018

Changes in this version

+ const HelmInstallTimeout

type Core

+ HelmClient func(*model.Kube) (helm.Interface, error)

+ KubeClient func(*model.Kube) (kclient.Interface, error)

type Settings

+ SupportPassword string

Jun 21, 2017

Changes in this version

type Core

+ PACKProvider func(map[string]string) Provider

Jan 27, 2017

Changes in this version

type Core

+ HelmCharts *HelmCharts

+ HelmReleases *HelmReleases

+ HelmRepos *HelmRepos

+ K8SProvider Provider

+ LoadBalancers *LoadBalancers

+ type HelmCharts struct

+ func (c *HelmCharts) Get(id *int64, m *model.HelmChart) error

+ func (c *HelmCharts) Populate() error

+ type HelmReleases struct

+ func (c *HelmReleases) Create(m *model.HelmRelease) error

+ func (c *HelmReleases) Delete(id *int64, m *model.HelmRelease) ActionInterface

+ func (c *HelmReleases) Populate() error

+ type HelmRepos struct

+ func (c *HelmRepos) Delete(id *int64, m *model.HelmRepo) ActionInterface

type KubeResources

+ func (c *KubeResources) Populate() error

type KubeResourcesInterface

+ Populate func() error

+ type LoadBalancers struct

+ func (c *LoadBalancers) Create(m *model.LoadBalancer) error

+ func (c *LoadBalancers) Delete(id *int64, m *model.LoadBalancer) ActionInterface

+ func (c *LoadBalancers) Provision(id *int64, m *model.LoadBalancer) ActionInterface

+ func (c *LoadBalancers) Update(id *int64, oldM *model.LoadBalancer, m *model.LoadBalancer) error

type Provider

+ CreateLoadBalancer func(*model.LoadBalancer, *Action) error

+ DeleteLoadBalancer func(*model.LoadBalancer, *Action) error

+ UpdateLoadBalancer func(*model.LoadBalancer, *Action) error

type Settings

+ HelmJobStartTimeout time.Duration

Jan 18, 2017

Changes in this version

type Core

+ GCEProvider func(map[string]string) Provider

Oct 18, 2016

Changes in this version

type Core

+ OSProvider func(map[string]string) Provider

Oct 5, 2016

Changes in this version

type EntrypointListeners

+ func (c *EntrypointListeners) Provision(id *int64, m *model.EntrypointListener) ActionInterface

type EntrypointListenersInterface

+ Provision func(*int64, *model.EntrypointListener) ActionInterface

type Entrypoints

+ func (c *Entrypoints) Provision(id *int64, m *model.Entrypoint) ActionInterface

type Kubes

+ func (c *Kubes) Provision(id *int64, m *model.Kube) ActionInterface

type Nodes

+ func (c *Nodes) Provision(id *int64, m *model.Node) ActionInterface

type NodesInterface

+ Provision func(*int64, *model.Node) ActionInterface

type Procedure

+ Action *Action

type VolumesInterface

+ Provision func(*int64, *model.Volume) ActionInterface

Oct 4, 2016

Changes in this version

type CapacityService

+ Core *Core

+ WaitBeforeScale time.Duration

type Core

+ APIClient func(authType string, authToken string) *client.Client

+ Version string

+ type NodesInterface interface

+ Create func(*model.Node) error

+ Delete func(*int64, *model.Node) ActionInterface

+ Get func(*int64, model.Model) error

+ GetWithIncludes func(*int64, model.Model, []string) error

+ Update func(*int64, model.Model, model.Model) error

+ type SessionsInterface interface

+ Client func(id string) *client.Client

+ Create func(*model.Session) error

+ Delete func(id string) error

+ Get func(id string, m *model.Session) error

+ List func() []*model.Session

Sep 28, 2016

Changes in this version

type Action

+ CancelExisting bool

+ Core *Core

+ Fn func(*Action) error

+ ID *int64

+ Model model.Model

+ ResourceID string

+ Scope DBInterface

+ func (a *Action) GetStatus() *model.ActionStatus

+ type ActionInterface interface

+ Async func() error

+ CancellableWaitFor func(string, time.Duration, time.Duration, func() (bool, error)) error

+ GetStatus func() *model.ActionStatus

+ Now func() error

type Collection

+ Core *Core

type Core

+ DefaultProvisioner Provisioner

+ EntrypointListeners EntrypointListenersInterface

+ KubeResources KubeResourcesInterface

+ PodProvisioner Provisioner

+ ServiceProvisioner Provisioner

type DB

+ func (db *DB) Count(value interface{}) error

+ func (db *DB) Model(value interface{}) DBInterface

+ func (db *DB) Update(attrs ...interface{}) error

+ type DBInterface interface

+ Count func(interface{}) error

+ Create func(model.Model) error

+ Delete func(m model.Model) error

+ Find func(out interface{}, where ...interface{}) error

+ First func(out interface{}, where ...interface{}) error

+ Limit func(limit interface{}) DBInterface

+ Model func(value interface{}) DBInterface

+ Offset func(offset interface{}) DBInterface

+ Preload func(column string, conditions ...interface{}) DBInterface

+ Save func(model.Model) error

+ Update func(attrs ...interface{}) error

+ Where func(query interface{}, args ...interface{}) DBInterface

+ type DefaultProvisioner struct

+ Core *Core

+ func (p *DefaultProvisioner) IsRunning(kubeResource *model.KubeResource) (bool, error)

+ func (p *DefaultProvisioner) Provision(kubeResource *model.KubeResource) error

+ func (p *DefaultProvisioner) Teardown(kubeResource *model.KubeResource) error

+ type EntrypointListeners struct

+ func (c *EntrypointListeners) Create(m *model.EntrypointListener) error

+ func (c *EntrypointListeners) Delete(id *int64, m *model.EntrypointListener) ActionInterface

+ type EntrypointListenersInterface interface

+ Create func(*model.EntrypointListener) error

+ Delete func(*int64, *model.EntrypointListener) ActionInterface

+ Get func(*int64, model.Model) error

+ GetWithIncludes func(*int64, model.Model, []string) error

+ Update func(*int64, model.Model, model.Model) error

+ type ErrorMissingRequiredParent struct

+ func (err *ErrorMissingRequiredParent) Error() string

+ type ErrorValidationFailed struct

+ func (err *ErrorValidationFailed) Error() string

+ type KubeResourceObserver struct

+ func (s *KubeResourceObserver) Perform() (err error)

+ type KubeResources struct

+ func (c *KubeResources) Create(m *model.KubeResource) error

+ func (c *KubeResources) Delete(id *int64, m *model.KubeResource) ActionInterface

+ func (c *KubeResources) Refresh(m *model.KubeResource) (err error)

+ func (c *KubeResources) Start(id *int64, m *model.KubeResource) ActionInterface

+ func (c *KubeResources) Stop(id *int64, m *model.KubeResource) ActionInterface

+ func (c *KubeResources) Update(id *int64, oldM *model.KubeResource, m *model.KubeResource) error

+ type KubeResourcesInterface interface

+ Create func(*model.KubeResource) error

+ Delete func(*int64, *model.KubeResource) ActionInterface

+ Get func(*int64, model.Model) error

+ GetWithIncludes func(*int64, model.Model, []string) error

+ Refresh func(*model.KubeResource) error

+ Start func(*int64, *model.KubeResource) ActionInterface

+ Stop func(*int64, *model.KubeResource) ActionInterface

+ Update func(*int64, *model.KubeResource, *model.KubeResource) error

+ type PodProvisioner struct

+ Core *Core

+ func (p *PodProvisioner) IsRunning(kubeResource *model.KubeResource) (bool, error)

+ func (p *PodProvisioner) Provision(kubeResource *model.KubeResource) error

+ func (p *PodProvisioner) Teardown(kubeResource *model.KubeResource) error

type Provider

+ CreateEntrypointListener func(*model.EntrypointListener) error

+ DeleteEntrypointListener func(*model.EntrypointListener) error

+ type Provisioner interface

+ IsRunning func(*model.KubeResource) (bool, error)

+ Provision func(*model.KubeResource) error

+ Teardown func(*model.KubeResource) error

+ type ServiceProvisioner struct

+ Core *Core

+ func (p *ServiceProvisioner) IsRunning(kubeResource *model.KubeResource) (bool, error)

+ func (p *ServiceProvisioner) Provision(kubeResource *model.KubeResource) error

+ func (p *ServiceProvisioner) Teardown(kubeResource *model.KubeResource) error

type Settings

+ KubeResourceStartTimeout time.Duration

type Volumes

+ func (c *Volumes) Create(m *model.Volume) error

+ func (c *Volumes) Update(id *int64, oldM *model.Volume, m *model.Volume) error

+ type VolumesInterface interface

+ Create func(*model.Volume) error

+ Delete func(*int64, *model.Volume) ActionInterface

+ Get func(*int64, model.Model) error

+ GetWithIncludes func(*int64, model.Model, []string) error

+ Resize func(*int64, *model.Volume) ActionInterface

+ Update func(*int64, *model.Volume, *model.Volume) error

+ WaitForAvailable func(*int64, *model.Volume) error

Sep 20, 2016

Changes in this version

type DB

+ func (db *DB) Limit(limit interface{}) *DB

+ func (db *DB) Offset(offset interface{}) *DB

Sep 16, 2016

Changes in this version

type Core

+ DOProvider func(map[string]string) Provider

+ type Procedure struct

+ Core *Core

+ Model model.Model

+ Name string

+ func (p *Procedure) AddStep(desc string, fn func() error)

+ func (p *Procedure) Run() error

type Provider

+ KubernetesVolumeDefinition func(*model.Volume) *guber.Volume

type Settings

+ CapacityServiceEnabled bool

+ type Step struct

Sep 5, 2016

Changes in this version

+ const SessionCookieName

+ var ErrorBadLogin = errors.New("Invalid credentials")

type Action

+ func (a *Action) CancellableWaitFor(desc string, d time.Duration, i time.Duration, fn func() (bool, error)) error

type Core

+ AWSProvider func(map[string]string) Provider

+ Sessions *Sessions

+ Users *Users

+ func (c *Core) APIURL() string

+ func (c *Core) HTTPSURL() string

+ func (c *Core) HTTPURL() string

+ func (c *Core) InitializeBackground()

+ func (c *Core) InitializeForeground() error

+ func (c *Core) UIURL() string

+ type SafeMap struct

+ func NewSafeMap(core *Core) *SafeMap

+ func (m *SafeMap) Delete(desc string, key string)

+ func (m *SafeMap) Get(key string) interface{}

+ func (m *SafeMap) List() []interface{}

+ func (m *SafeMap) Put(desc string, key string, value interface{})

+ type SessionExpirer struct

+ func (s *SessionExpirer) Perform() error

+ type Sessions struct

+ func NewSessions(core *Core) *Sessions

+ func (c *Sessions) Client(id string) *client.Client

+ func (c *Sessions) Create(m *model.Session) error

+ func (c *Sessions) Delete(id string) error

+ func (c *Sessions) Get(id string, m *model.Session) error

+ func (c *Sessions) List() (items []*model.Session)

type Settings

+ ConfigFilePath string

+ SQLiteFile string

+ UIEnabled bool

+ type Users struct

+ func (c *Users) RegenerateAPIToken(id *int64, m *model.User) error

Aug 31, 2016

Changes in this version

type Core

+ func (c *Core) BaseURL() string

+ func (c *Core) SSLEnabled() bool

type Settings

+ HTTPSPort string

+ PublishHost string

+ SSLCertFile string

+ SSLKeyFile string

Aug 30, 2016

Changes in this version

+ type AWSProvider struct

+ Credentials map[string]string

+ func (p *AWSProvider) AddPortToEntrypoint(m *models.Entrypoint, lbPort int64, nodePort int64) error

+ func (p *AWSProvider) CreateEntrypoint(m *models.Entrypoint, action *Action) error

+ func (p *AWSProvider) CreateKube(m *models.Kube, action *Action) error

+ func (p *AWSProvider) CreateNode(m *models.Node, action *Action) error

+ func (p *AWSProvider) CreateVolume(m *models.Volume, action *Action) error

+ func (p *AWSProvider) DeleteEntrypoint(m *models.Entrypoint) error

+ func (p *AWSProvider) DeleteKube(m *models.Kube) error

+ func (p *AWSProvider) DeleteNode(m *models.Node) error

+ func (p *AWSProvider) DeleteVolume(m *models.Volume) error

+ func (p *AWSProvider) RemovePortFromEntrypoint(m *models.Entrypoint, lbPort int64) error

+ func (p *AWSProvider) ResizeVolume(m *models.Volume, action *Action) error

+ func (p *AWSProvider) ValidateAccount(m *models.CloudAccount) error

+ func (p *AWSProvider) WaitForVolumeAvailable(m *models.Volume, action *Action) error

+ type NodeSize struct

+ CPUCores float64

+ Name string

+ RAMGIB float64

+ type Provider interface

+ AddPortToEntrypoint func(*models.Entrypoint, int64, int64) error

+ CreateEntrypoint func(*models.Entrypoint, *Action) error

+ CreateKube func(*models.Kube, *Action) error

+ CreateNode func(*models.Node, *Action) error

+ CreateVolume func(*models.Volume, *Action) error

+ DeleteEntrypoint func(*models.Entrypoint) error

+ DeleteKube func(*models.Kube) error

+ DeleteNode func(*models.Node) error

+ DeleteVolume func(*models.Volume) error

+ RemovePortFromEntrypoint func(*models.Entrypoint, int64) error

+ ResizeVolume func(*models.Volume, *Action) error

+ ValidateAccount func(*models.CloudAccount) error

+ WaitForVolumeAvailable func(*models.Volume, *Action) error

type Settings

+ NodeSizes map[string][]*NodeSize

type Volumes

+ func (c *Volumes) WaitForAvailable(id *int64, m *models.Volume) error

Aug 24, 2016

Changes in this version

+ type Settings struct

+ HTTPBasicPass string

+ HTTPBasicUser string

+ HTTPPort string

+ LogLevel string

+ LogPath string

+ PsqlDb string

+ PsqlHost string

+ PsqlPass string

+ PsqlUser string

Aug 22, 2016

Changes in this version

+ var AWSMasterAMIs = map[string]string

+ func RunCustomDeployment(core *Core, component *models.Component) error

+ type Action struct

+ Status *models.ActionStatus

+ func (a *Action) Async() error

+ func (a *Action) Now() error

+ type Apps struct

+ func (c *Apps) Create(m *models.App) error

+ func (c *Apps) Delete(id *int64, m *models.App) *Action

+ type CapacityService struct

+ func (s *CapacityService) Perform() error

+ type CloudAccounts struct

+ func (c *CloudAccounts) Create(m *models.CloudAccount) error

+ func (c *CloudAccounts) Delete(id *int64, m *models.CloudAccount) error

+ type Collection struct

+ func (c *Collection) Create(m models.Model) error

+ func (c *Collection) Delete(id *int64, m models.Model) error

+ func (c *Collection) Get(id *int64, m models.Model) error

+ func (c *Collection) GetWithIncludes(id *int64, m models.Model, includes []string) error

+ func (c *Collection) Update(id *int64, oldM models.Model, m models.Model) error

+ type Components struct

+ func (c *Components) Delete(id *int64, m *models.Component) *Action

+ func (c *Components) Deploy(id *int64, m *models.Component) *Action

+ type Core struct

+ Actions map[string]*Action

+ Apps *Apps

+ CloudAccounts *CloudAccounts

+ Components *Components

+ DB *DB

+ Entrypoints *Entrypoints

+ HTTPBasicPass string

+ HTTPBasicUser string

+ HTTPPort string

+ Instances *Instances

+ Kubes *Kubes

+ Log *logrus.Logger

+ LogLevel string

+ LogPath string

+ Nodes *Nodes

+ PrivateImageKeys *PrivateImageKeys

+ PsqlDb string

+ PsqlHost string

+ PsqlPass string

+ PsqlUser string

+ Releases *Releases

+ Volumes *Volumes

+ func (c *Core) Initialize()

+ func (c *Core) K8S(m *models.Kube) guber.Client

+ func (c *Core) NewAPIClient() *client.Client

+ func (c *Core) SetResourceActionStatus(m models.Model)

+ type DB struct

+ func (db *DB) Create(m models.Model) error

+ func (db *DB) Delete(m models.Model) error

+ func (db *DB) Find(out interface{}, where ...interface{}) error

+ func (db *DB) First(out interface{}, where ...interface{}) error

+ func (db *DB) Preload(column string, conditions ...interface{}) *DB

+ func (db *DB) Save(m models.Model) error

+ func (db *DB) Where(query interface{}, args ...interface{}) *DB

+ type Entrypoints struct

+ func (c *Entrypoints) Create(m *models.Entrypoint) error

+ func (c *Entrypoints) Delete(id *int64, m *models.Entrypoint) *Action

+ func (c *Entrypoints) RemovePort(id *int64, m *models.Entrypoint, elbPort int) error

+ func (c *Entrypoints) SetPort(id *int64, m *models.Entrypoint, elbPort int, instancePort int) error

+ type InstanceObserver struct

+ func (s *InstanceObserver) Perform() error

+ type Instances struct

+ func (c *Instances) CreateVolumes(id *int64, m *models.Instance) error

+ func (c *Instances) Delete(id *int64, m *models.Instance) *Action

+ func (c *Instances) Log(m *models.Instance) (string, error)

+ func (c *Instances) Start(id *int64, m *models.Instance) *Action

+ func (c *Instances) Stop(id *int64, m *models.Instance) *Action

+ type KubeScaler struct

+ func (s *KubeScaler) Scale() error

+ type Kubes struct

+ func (c *Kubes) Create(m *models.Kube) error

+ func (c *Kubes) Delete(id *int64, m *models.Kube) *Action

+ type NodeObserver struct

+ func (s *NodeObserver) Perform() error

+ type NodeSynchronizer struct

+ func (s *NodeSynchronizer) Perform() error

+ type Nodes struct

+ func (c *Nodes) Create(m *models.Node) error

+ func (c *Nodes) Delete(id *int64, m *models.Node) *Action

+ type PodNotFoundError struct

+ InstanceID *int64

+ func (err *PodNotFoundError) Error() string

+ type Port struct

+ type PrivateImageKeys struct

+ func (c *PrivateImageKeys) Create(m *models.PrivateImageKey) error

+ type RecurringService struct

+ func (s *RecurringService) Run()

+ type Releases struct

+ func (c *Releases) Create(m *models.Release) error

+ type RepeatedActionError struct

+ ResourceID string

+ func (err *RepeatedActionError) Error() string

+ type Service interface

+ Perform func() error

+ type ServiceSet struct

+ func NewServiceSet(core *Core, component *models.Component, release *models.Release, ...) (*ServiceSet, error)

+ type Volumes struct

+ func (c *Volumes) Delete(id *int64, m *models.Volume) *Action

+ func (c *Volumes) Provision(id *int64, m *models.Volume) *Action

+ func (c *Volumes) Resize(id *int64, m *models.Volume) *Action