task

package

v0.3.8 Latest Latest Go to latest Published: Apr 7, 2016 License: Apache-2.0 Imports: 7 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

DeleteApp implements task.Performable interface

func (j DeleteApp) Perform(data []byte) error

type DeleteAppMessage struct {
	AppName types.ID
}

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

DeleteComponent implements task.Performable interface

func (j DeleteComponent) Perform(data []byte) error

type DeleteComponentMessage struct {
	AppName       types.ID
	ComponentName types.ID
}

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

func (j DeployComponent) Perform(data []byte) error

type DeployComponentMessage struct {
	AppName       types.ID
	ComponentName types.ID
}

type Performable interface {
	Perform(data []byte) error
}

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

StartInstance implements Performable interface

func (j StartInstance) Perform(data []byte) error

type StartInstanceMessage struct {
	AppName          types.ID
	ComponentName    types.ID
	ReleaseTimestamp types.ID
	ID               types.ID
}

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

StopInstance implements Performable interface

func (j StopInstance) Perform(data []byte) error

type StopInstanceMessage struct {
	AppName          types.ID
	ComponentName    types.ID
	ReleaseTimestamp types.ID
	ID               types.ID
}

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

func NewSupervisor(c *core.Core, size int) *Supervisor

func (s *Supervisor) Run()