core

Jul 1, 2016

Changes in this version

type Action

+ func NewAction(core *Core, r Resource, name string) *Action

+ func (a *Action) CancelTasks() *Action

type AppResource

+ Collection *AppCollection

type ComponentResource

+ Collection ComponentsInterface

type InstanceCollection

+ func (c *InstanceCollection) DeleteVolumes(r *InstanceResource) error

type InstanceResource

+ Collection InstancesInterface

type InstancesInterface

+ DeleteVolumes func(*InstanceResource) error

type TaskCollection

+ func (c *TaskCollection) DeleteByResource(l Locatable) error

type TaskResource

+ func (r *TaskResource) IsRunning() bool

+ func (r *TaskResource) ResourceLocation() string

type TasksInterface

+ DeleteByResource func(l Locatable) error

Jun 22, 2016

Changes in this version

type InstanceResource

+ func (r *InstanceResource) DefaultContainerName() string

Jun 16, 2016

Changes in this version

+ type ServiceSet struct

Jun 10, 2016

Changes in this version

+ type Port struct

May 27, 2016

Changes in this version

type Core

+ AppsInterface AppsInterface

+ EntrypointsInterface EntrypointsInterface

+ ImageRegistriesInterface ImageRegistriesInterface

+ NodesInterface NodesInterface

+ TasksInterface TasksInterface

type InstanceCollection

+ func (c *InstanceCollection) App() *AppResource

+ func (c *InstanceCollection) Component() *ComponentResource

+ func (c *InstanceCollection) Delete(r *InstanceResource) (err error)

type InstancesInterface

+ App func() *AppResource

+ Component func() *ComponentResource

+ Delete func(*InstanceResource) error

+ Release func() *ReleaseResource

May 6, 2016

Changes in this version

type AppCollection

+ func (c *AppCollection) Patch(name common.ID, r *AppResource) error

type AppResource

+ func (r *AppResource) Patch() error

type AppsInterface

+ Patch func(common.ID, *AppResource) error

type ComponentCollection

+ func (c *ComponentCollection) Patch(name common.ID, r *ComponentResource) error

type ComponentResource

+ func (r *ComponentResource) Patch() error

type ComponentsInterface

+ Patch func(common.ID, *ComponentResource) error

type EntrypointCollection

+ func (c *EntrypointCollection) Patch(name common.ID, r *EntrypointResource) error

type EntrypointResource

+ func (r *EntrypointResource) Patch() error

type EntrypointsInterface

+ Patch func(common.ID, *EntrypointResource) error

type ImageRegistriesInterface

+ Patch func(common.ID, *ImageRegistryResource) error

type ImageRegistryCollection

+ func (c *ImageRegistryCollection) Patch(name common.ID, r *ImageRegistryResource) error

type ImageRegistryResource

+ func (r *ImageRegistryResource) Patch() error

type ImageRepoCollection

+ func (c *ImageRepoCollection) Patch(name common.ID, r *ImageRepoResource) error

type ImageRepoResource

+ func (r *ImageRepoResource) Patch() error

type ImageReposInterface

+ Patch func(common.ID, *ImageRepoResource) error

type NodeCollection

+ func (c *NodeCollection) Patch(name common.ID, r *NodeResource) error

type NodeResource

+ func (r *NodeResource) Patch() error

type NodesInterface

+ Patch func(common.ID, *NodeResource) error

type ReleaseCollection

+ func (c *ReleaseCollection) Patch(name common.ID, r *ReleaseResource) error

type ReleaseResource

+ func (r *ReleaseResource) Patch() error

type ReleasesInterface

+ Patch func(common.ID, *ReleaseResource) error

type TaskCollection

+ func (c *TaskCollection) Patch(name common.ID, r *TaskResource) error

type TaskResource

+ func (r *TaskResource) Patch() error

type TasksInterface

+ Patch func(common.ID, *TaskResource) error

Apr 26, 2016

Changes in this version

+ func ZeroPrivateFields(r Resource)

+ func ZeroReadonlyFields(r Resource)

Apr 25, 2016

Changes in this version

type Core

+ CapacityServiceEnabled bool

Apr 20, 2016

Changes in this version

+ func ResourceLocation(location Locatable) (path string)

+ type Action struct

+ ActionName string

+ ResourceLocation string

+ func (a *Action) ID() common.ID

+ func (a *Action) Perform() error

+ func (a *Action) Supervise() error

+ type ActionPerformer func(r Resource) error

type AppResource

+ func (r *AppResource) Action(name string) *Action

+ type AppsInterface interface

+ Create func(*AppResource) error

+ Delete func(Resource) error

+ Get func(common.ID) (*AppResource, error)

+ List func() (*AppList, error)

+ New func() *AppResource

+ Update func(common.ID, *AppResource) error

type ComponentCollection

+ func (c *ComponentCollection) Deploy(ri Resource) (err error)

type ComponentResource

+ func (r *ComponentResource) Action(name string) *Action

type ComponentsInterface

+ Deploy func(Resource) error

type Core

+ func (c *Core) ImageRegistries() ImageRegistriesInterface

+ func (c *Core) Nodes() NodesInterface

type EntrypointResource

+ func (r *EntrypointResource) Action(name string) *Action

+ type EntrypointsInterface interface

+ Create func(*EntrypointResource) error

+ Delete func(*EntrypointResource) error

+ Get func(common.ID) (*EntrypointResource, error)

+ List func() (*EntrypointList, error)

+ New func() *EntrypointResource

+ Update func(common.ID, *EntrypointResource) error

+ type ImageRegistriesInterface interface

+ Create func(*ImageRegistryResource) error

+ Delete func(*ImageRegistryResource) error

+ Get func(common.ID) (*ImageRegistryResource, error)

+ List func() (*ImageRegistryList, error)

+ New func() *ImageRegistryResource

+ Update func(common.ID, *ImageRegistryResource) error

+ type ImageRegistryCollection struct

+ func (c *ImageRegistryCollection) Create(r *ImageRegistryResource) error

+ func (c *ImageRegistryCollection) Delete(r *ImageRegistryResource) error

+ func (c *ImageRegistryCollection) Get(name common.ID) (*ImageRegistryResource, error)

+ func (c *ImageRegistryCollection) List() (*ImageRegistryList, error)

+ func (c *ImageRegistryCollection) New() *ImageRegistryResource

+ func (c *ImageRegistryCollection) Update(name common.ID, r *ImageRegistryResource) error

+ type ImageRegistryList struct

+ Items []*ImageRegistryResource

+ type ImageRegistryResource struct

+ ImageReposInterface ImageReposInterface

+ func (r *ImageRegistryResource) Action(name string) *Action

+ func (r *ImageRegistryResource) Delete() error

+ func (r *ImageRegistryResource) ImageRepos() ImageReposInterface

+ func (r *ImageRegistryResource) Update() error

type ImageRepoResource

+ func (r *ImageRepoResource) Action(name string) *Action

+ type ImageReposInterface interface

+ Create func(*ImageRepoResource) error

+ Delete func(*ImageRepoResource) error

+ Get func(common.ID) (*ImageRepoResource, error)

+ List func() (*ImageRepoList, error)

+ New func() *ImageRepoResource

+ Update func(common.ID, *ImageRepoResource) error

type InstanceCollection

+ func (c *InstanceCollection) Start(ri Resource) error

+ func (c *InstanceCollection) Stop(ri Resource) error

type InstanceResource

+ func (r *InstanceResource) Action(name string) *Action

+ type InstancesInterface interface

+ Get func(common.ID) (*InstanceResource, error)

+ List func() *InstanceList

+ New func(common.ID) *InstanceResource

+ Start func(Resource) error

+ Stop func(Resource) error

+ type Locatable interface

+ type NodeCollection struct

+ func (c *NodeCollection) Create(r *NodeResource) error

+ func (c *NodeCollection) Delete(r *NodeResource) error

+ func (c *NodeCollection) Get(id common.ID) (*NodeResource, error)

+ func (c *NodeCollection) List() (*NodeList, error)

+ func (c *NodeCollection) New() *NodeResource

+ func (c *NodeCollection) Update(id common.ID, r *NodeResource) error

+ type NodeList struct

+ Items []*NodeResource

+ type NodeResource struct

+ func (r *NodeResource) Action(name string) *Action

+ func (r *NodeResource) Delete() error

+ func (r *NodeResource) Update() error

+ type NodesInterface interface

+ Create func(*NodeResource) error

+ Delete func(*NodeResource) error

+ Get func(common.ID) (*NodeResource, error)

+ List func() (*NodeList, error)

+ New func() *NodeResource

+ Update func(common.ID, *NodeResource) error

type ReleaseResource

+ InstancesInterface InstancesInterface

+ func (r *ReleaseResource) Action(name string) *Action

type Resource

+ func LocateResource(coreLoc Locatable, path string) Resource

+ Action func(string) *Action

+ type Supervisor struct

+ func NewSupervisor(c *Core, workers int) *Supervisor

+ func (s *Supervisor) Run()

type TaskCollection

+ func (c *TaskCollection) Delete(r *TaskResource) error

+ func (c *TaskCollection) Update(id common.ID, r *TaskResource) error

type TaskResource

+ func (r *TaskResource) Action(name string) *Action

+ func (r *TaskResource) ToAction() *Action

+ type TasksInterface interface

+ Create func(*TaskResource) error

+ Delete func(*TaskResource) error

+ Get func(common.ID) (*TaskResource, error)

+ List func() (*TaskList, error)

+ New func() *TaskResource

+ Start func(*Action) (*TaskResource, error)

+ Update func(common.ID, *TaskResource) error

Apr 15, 2016

Changes in this version

type AppCollection

+ func (c *AppCollection) Delete(r *AppResource) error

+ func (c *AppCollection) Update(name common.ID, r *AppResource) error

type AppResource

+ ComponentsInterface ComponentsInterface

+ func (r *AppResource) Update() error

type ComponentCollection

+ func (c *ComponentCollection) Delete(r *ComponentResource) error

+ func (c *ComponentCollection) Update(name common.ID, r *ComponentResource) error

type ComponentResource

+ ReleasesInterface ReleasesInterface

+ func (r *ComponentResource) Update() error

+ type ComponentsInterface interface

+ App func() *AppResource

+ Create func(*ComponentResource) error

+ Delete func(*ComponentResource) error

+ Get func(common.ID) (*ComponentResource, error)

+ List func() (*ComponentList, error)

+ New func() *ComponentResource

+ Update func(common.ID, *ComponentResource) error

type Core

+ AwsAZ string

+ AwsAccessKey string

+ AwsRegion string

+ AwsSecretKey string

+ AwsSgID string

+ AwsSubnetID string

+ EtcdEndpoints []string

+ K8sHost string

+ K8sInsecureHTTPS bool

+ K8sPass string

+ K8sUser string

+ func (c *Core) Initialize()

type EntrypointCollection

+ func (c *EntrypointCollection) Delete(r *EntrypointResource) error

+ func (c *EntrypointCollection) Update(domain common.ID, r *EntrypointResource) error

type EntrypointResource

+ func (r *EntrypointResource) Update() error

type ImageRepoCollection

+ func (c *ImageRepoCollection) Delete(r *ImageRepoResource) error

+ func (c *ImageRepoCollection) Update(name common.ID, r *ImageRepoResource) error

type ImageRepoResource

+ func (r *ImageRepoResource) Update() error

type ReleaseCollection

+ func (c *ReleaseCollection) Delete(r *ReleaseResource) error

+ func (c *ReleaseCollection) Update(name common.ID, r *ReleaseResource) error

type ReleaseResource

+ func (r *ReleaseResource) Update() error

+ type ReleasesInterface interface

+ Component func() *ComponentResource

+ Create func(*ReleaseResource) error

+ Delete func(*ReleaseResource) error

+ Get func(common.ID) (*ReleaseResource, error)

+ List func() (*ReleaseList, error)

+ MergeCreate func(*ReleaseResource) error

+ New func() *ReleaseResource

+ Update func(common.ID, *ReleaseResource) error

type TaskResource

+ func (r *TaskResource) Update() error

Apr 11, 2016

Changes in this version

type ReleaseCollection

+ func (c *ReleaseCollection) MergeCreate(r *ReleaseResource) (*ReleaseResource, error)

Apr 11, 2016

Changes in this version

+ var Log = logrus.New()

+ func SetLogLevel(level string)

Apr 9, 2016

Changes in this version

+ func RunCustomDeployment(core *Core, component *ComponentResource) error

type AppResource

+ func (r *AppResource) Save() error

type InstanceResource

+ func (r *InstanceResource) Log() (string, error)

Apr 6, 2016

Changes in this version

type AwsVolume

+ func (m *AwsVolume) Create() error

+ func (m *AwsVolume) Exists() (bool, error)

Apr 5, 2016

Changes in this version

+ type ExternalPort struct

+ func NewExternalPort(p *types.Port, r *ReleaseResource, e *EntrypointResource) *ExternalPort

+ func (ep *ExternalPort) AddToELB() error

+ func (ep *ExternalPort) Address() *types.PortAddress

+ func (ep *ExternalPort) RemoveFromELB() error

+ type InternalPort struct

+ func NewInternalPort(p *types.Port, r *ReleaseResource) *InternalPort

+ func (ip *InternalPort) Address() *types.PortAddress

type ReleaseResource

+ ExternalService *guber.Service

+ InternalService *guber.Service

+ func (newR *ReleaseResource) AddNewPorts(oldR *ReleaseResource) error

+ func (newR *ReleaseResource) RemoveOldPorts(oldR *ReleaseResource) error

+ func (r *ReleaseResource) ExternalPorts() (ports []*ExternalPort)

+ func (r *ReleaseResource) ExternalServiceName() string

+ func (r *ReleaseResource) InternalPorts() (ports []*InternalPort)

+ func (r *ReleaseResource) InternalServiceName() string

Apr 1, 2016

Changes in this version

type ReleaseResource

+ func (r *ReleaseResource) Save() error

Apr 1, 2016

Changes in this version

type AwsVolume

+ func (m *AwsVolume) NeedsResize() bool

+ func (m *AwsVolume) Resize() error

type TaskResource

+ func (r *TaskResource) TypeName() string

Mar 31, 2016

Changes in this version

+ var AwsAZ string

+ var AwsRegion string

+ var AwsSgID string

+ var AwsSubnetID string

+ var EtcdEndpoints []string

+ var K8sHost string

+ var K8sPass string

+ var K8sUser string

+ func ImageRepoName(m *types.ContainerBlueprint) string

+ type AppCollection struct

+ func (c *AppCollection) Create(r *AppResource) (*AppResource, error)

+ func (c *AppCollection) EtcdKey(name types.ID) string

+ func (c *AppCollection) Get(name types.ID) (*AppResource, error)

+ func (c *AppCollection) InitializeResource(r Resource)

+ func (c *AppCollection) List() (*AppList, error)

+ func (c *AppCollection) New() *AppResource

+ type AppList struct

+ Items []*AppResource

+ type AppResource struct

+ func (r *AppResource) Components() *ComponentCollection

+ func (r *AppResource) Delete() error

+ func (r *AppResource) PersistableObject() interface{}

+ func (r *AppResource) ProvisionSecret(repo *ImageRepoResource) error

+ type AwsVolume struct

+ Blueprint *types.VolumeBlueprint

+ Instance *InstanceResource

+ func (m *AwsVolume) Delete() error

+ func (m *AwsVolume) Provision() error

+ func (m *AwsVolume) WaitForAvailable() error

+ type Collection interface

+ EtcdKey func(id types.ID) string

+ InitializeResource func(r Resource)

+ type ComponentCollection struct

+ App *AppResource

+ func (c *ComponentCollection) Create(r *ComponentResource) (*ComponentResource, error)

+ func (c *ComponentCollection) EtcdKey(name types.ID) string

+ func (c *ComponentCollection) Get(name types.ID) (*ComponentResource, error)

+ func (c *ComponentCollection) InitializeResource(r Resource)

+ func (c *ComponentCollection) List() (*ComponentList, error)

+ func (c *ComponentCollection) New() *ComponentResource

+ type ComponentList struct

+ Items []*ComponentResource

+ type ComponentResource struct

+ func (r *ComponentResource) App() *AppResource

+ func (r *ComponentResource) CurrentRelease() (*ReleaseResource, error)

+ func (r *ComponentResource) Delete() error

+ func (r *ComponentResource) PersistableObject() interface{}

+ func (r *ComponentResource) Releases() *ReleaseCollection

+ func (r *ComponentResource) Save() error

+ func (r *ComponentResource) TargetRelease() (*ReleaseResource, error)

+ type Core struct

+ AutoScaling *autoscaling.AutoScaling

+ DB *DB

+ EC2 *ec2.EC2

+ ELB *elb.ELB

+ K8S *guber.Client

+ func New() *Core

+ func (c *Core) Apps() *AppCollection

+ func (c *Core) Entrypoints() *EntrypointCollection

+ func (c *Core) ImageRepos() *ImageRepoCollection

+ func (c *Core) Tasks() *TaskCollection

+ type DB struct

+ func NewDB(endpoints []string) *DB

+ func (db *DB) CompareAndSwap(r Collection, id types.ID, old Resource, new Resource) error

+ func (db *DB) Create(r Collection, id types.ID, m Resource) error

+ func (db *DB) CreateDir(key string) (*etcd.Response, error)

+ func (db *DB) CreateInOrder(r Collection, m OrderedResource) error

+ func (db *DB) Delete(r Collection, id types.ID) error

+ func (db *DB) Get(r Collection, id types.ID, out Resource) error

+ func (db *DB) List(r Collection, out interface{}) error

+ func (db *DB) ListInOrder(r Collection, out interface{}) error

+ func (db *DB) Update(r Collection, id types.ID, m Resource) error

+ type EntrypointCollection struct

+ func (c *EntrypointCollection) Create(r *EntrypointResource) (*EntrypointResource, error)

+ func (c *EntrypointCollection) EtcdKey(domain types.ID) string

+ func (c *EntrypointCollection) Get(domain types.ID) (*EntrypointResource, error)

+ func (c *EntrypointCollection) InitializeResource(r Resource)

+ func (c *EntrypointCollection) List() (*EntrypointList, error)

+ func (c *EntrypointCollection) New() *EntrypointResource

+ type EntrypointList struct

+ Items []*EntrypointResource

+ type EntrypointResource struct

+ func (r *EntrypointResource) AddPort(elbPort int, instancePort int) error

+ func (r *EntrypointResource) Delete() error

+ func (r *EntrypointResource) PersistableObject() interface{}

+ func (r *EntrypointResource) RemovePort(elbPort int) error

+ func (r *EntrypointResource) Save() error

+ type ImageRepoCollection struct

+ func (c *ImageRepoCollection) Create(r *ImageRepoResource) (*ImageRepoResource, error)

+ func (c *ImageRepoCollection) EtcdKey(name types.ID) string

+ func (c *ImageRepoCollection) Get(name types.ID) (*ImageRepoResource, error)

+ func (c *ImageRepoCollection) InitializeResource(r Resource)

+ func (c *ImageRepoCollection) List() (*ImageRepoList, error)

+ func (c *ImageRepoCollection) New() *ImageRepoResource

+ type ImageRepoList struct

+ Items []*ImageRepoResource

+ type ImageRepoResource struct

+ func (r *ImageRepoResource) Delete() error

+ func (r *ImageRepoResource) PersistableObject() interface{}

+ type InstanceCollection struct

+ Release *ReleaseResource

+ func (c *InstanceCollection) Get(id types.ID) (*InstanceResource, error)

+ func (c *InstanceCollection) List() *InstanceList

+ func (c *InstanceCollection) New(id types.ID) *InstanceResource

+ type InstanceList struct

+ Items []*InstanceResource

+ type InstanceResource struct

+ func (r *InstanceResource) App() *AppResource

+ func (r *InstanceResource) Component() *ComponentResource

+ func (r *InstanceResource) Delete() (err error)

+ func (r *InstanceResource) DeleteVolumes() error

+ func (r *InstanceResource) IsStarted() bool

+ func (r *InstanceResource) IsStopped() bool

+ func (r *InstanceResource) Release() *ReleaseResource

+ func (r *InstanceResource) Start() error

+ func (r *InstanceResource) Stop() error

+ func (r *InstanceResource) Volumes() (vols []*AwsVolume)

+ type OrderedResource interface

+ PersistableObject func() interface{}

+ SetID func(id types.ID)

+ type ReleaseCollection struct

+ Component *ComponentResource

+ func (c *ReleaseCollection) Create(r *ReleaseResource) (*ReleaseResource, error)

+ func (c *ReleaseCollection) EtcdKey(timestamp types.ID) string

+ func (c *ReleaseCollection) Get(id types.ID) (*ReleaseResource, error)

+ func (c *ReleaseCollection) InitializeResource(r Resource)

+ func (c *ReleaseCollection) List() (*ReleaseList, error)

+ func (c *ReleaseCollection) New() *ReleaseResource

+ type ReleaseList struct

+ Items []*ReleaseResource

+ type ReleaseResource struct

+ func (r *ReleaseResource) App() *AppResource

+ func (r *ReleaseResource) Component() *ComponentResource

+ func (r *ReleaseResource) Delete() error

+ func (r *ReleaseResource) ExternalAddresses() (pAddrs []*types.PortAddress)

+ func (r *ReleaseResource) ImagePullSecrets() (pullSecrets []*guber.ImagePullSecret, err error)

+ func (r *ReleaseResource) Instances() *InstanceCollection

+ func (r *ReleaseResource) InternalAddresses() (pAddrs []*types.PortAddress)

+ func (r *ReleaseResource) IsStarted() bool

+ func (r *ReleaseResource) IsStopped() bool

+ func (r *ReleaseResource) PersistableObject() interface{}

+ func (r *ReleaseResource) Provision() error

+ type Resource interface

+ PersistableObject func() interface{}

+ type TaskCollection struct

+ func (c *TaskCollection) Create(r *TaskResource) (*TaskResource, error)

+ func (c *TaskCollection) EtcdKey(id types.ID) string

+ func (c *TaskCollection) Get(id types.ID) (*TaskResource, error)

+ func (c *TaskCollection) InitializeResource(r Resource)

+ func (c *TaskCollection) List() (*TaskList, error)

+ func (c *TaskCollection) New() *TaskResource

+ func (c *TaskCollection) Start(t types.TaskType, msg interface{}) (*TaskResource, error)

+ type TaskList struct

+ Items []*TaskResource

+ type TaskResource struct

+ ID types.ID

+ func (r *TaskResource) Claim() error

+ func (r *TaskResource) Delete() error

+ func (r *TaskResource) IsQueued() bool

+ func (r *TaskResource) PersistableObject() interface{}

+ func (r *TaskResource) RecordError(err error) error

+ func (r *TaskResource) Save() error

+ func (r *TaskResource) SetID(id types.ID)