healer

Documentation

Index

• func ListHealingHistory(filter string) ([]types.HealingEvent, error)
• func MigrateHealingToEvents() error
• type AppLocker
• type ContainerHealer
  • func NewContainerHealer(args ContainerHealerArgs) *ContainerHealer
  • func (h *ContainerHealer) RunContainerHealer()
  • func (h *ContainerHealer) Shutdown(ctx context.Context) error
  • func (h *ContainerHealer) String() string
• type ContainerHealerArgs
• type DockerProvisioner

Functions

func ListHealingHistory

func ListHealingHistory(filter string) ([]types.HealingEvent, error)

func MigrateHealingToEvents

func MigrateHealingToEvents() error

Types

type AppLocker

type AppLocker interface {
	Lock(appName string) bool
	Unlock(appName string)
}

type ContainerHealer

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

func NewContainerHealer

func NewContainerHealer(args ContainerHealerArgs) *ContainerHealer

func (*ContainerHealer) RunContainerHealer

func (h *ContainerHealer) RunContainerHealer()

func (*ContainerHealer) Shutdown

func (h *ContainerHealer) Shutdown(ctx context.Context) error

func (*ContainerHealer) String

func (h *ContainerHealer) String() string

type ContainerHealerArgs

type ContainerHealerArgs struct {
	Provisioner         DockerProvisioner
	MaxUnresponsiveTime time.Duration
	Done                chan bool
	Locker              AppLocker
}

type DockerProvisioner

type DockerProvisioner interface {
	ClusterClient() provision.BuilderDockerClient
	Cluster() *cluster.Cluster
	ActionLimiter() provision.ActionLimiter
	MoveOneContainer(container.Container, string, chan error, *sync.WaitGroup, io.Writer, container.AppLocker) container.Container
	MoveContainers(fromHost, toHost string, w io.Writer) error
	HandleMoveErrors(errors chan error, w io.Writer) error
	GetContainer(id string) (*container.Container, error)
	ListContainers(query bson.M) ([]container.Container, error)
}