runtime

package

v0.4.1 Latest Latest Go to latest Published: Apr 10, 2015 License: MIT Imports: 17 Imported by: 12

Details

This section is empty.

This section is empty.

func EC2PublicHostname() (string, error)

func GetEndpoint() string

type ContainerEvent struct {
	Status              string
	Container           *docker.Container
	ServiceRegistration *registry.ServiceRegistration
}

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

func NewServiceRuntime(serviceRegistry *registry.ServiceRegistry, dns, hostIP string) *ServiceRuntime

func (s *ServiceRuntime) EnvFor(container *docker.Container) map[string]string

func (s *ServiceRuntime) GetImageByName(img string) (*docker.APIImages, error)

func (s *ServiceRuntime) InspectContainer(id string) (*docker.Container, error)

func (s *ServiceRuntime) InspectImage(image string) (*docker.Image, error)

func (s *ServiceRuntime) InstanceCount(app, versionId string) (int, error)

func (s *ServiceRuntime) ManagedContainers() ([]*docker.Container, error)

func (s *ServiceRuntime) NextInstanceSlot(app, versionId string) (int, error)

func (s *ServiceRuntime) Ping() error

func (s *ServiceRuntime) PullImage(version, id string) (*docker.Image, error)

func (s *ServiceRuntime) RegisterAll(env, pool, hostIP string) ([]*registry.ServiceRegistration, error)

func (s *ServiceRuntime) RegisterEvents(env, pool, hostIP string, listener chan ContainerEvent) error

func (s *ServiceRuntime) RunCommand(env string, appCfg *config.AppConfig, cmd []string) (*docker.Container, error)

func (s *ServiceRuntime) Start(env, pool string, appCfg *config.AppConfig) (*docker.Container, error)

func (s *ServiceRuntime) StartIfNotRunning(env, pool string, appCfg *config.AppConfig) (bool, *docker.Container, error)

func (s *ServiceRuntime) StartInteractive(env, pool string, appCfg *config.AppConfig) error

func (s *ServiceRuntime) Stop(appCfg *config.AppConfig) error

func (s *ServiceRuntime) StopAll(env string) error

func (s *ServiceRuntime) StopAllButCurrentVersion(appCfg *config.AppConfig) error

func (s *ServiceRuntime) StopAllButLatest(env string, stopCutoff int64) error

func (s *ServiceRuntime) StopAllButLatestService(name string, stopCutoff int64) error

func (s *ServiceRuntime) StopAllMatching(name string) error

func (s *ServiceRuntime) StopOldVersion(appCfg *config.AppConfig, limit int) error

func (s *ServiceRuntime) UnRegisterAll(env, pool, hostIP string) ([]*docker.Container, error)