exec

Documentation

Index

• Constants
• type Supervisor
  • func NewSupervisor(workspace string) (*Supervisor, error)
  • func (sup *Supervisor) AgentStateChangeFeed() <-chan *supervisor.AgentStateChange
  • func (sup *Supervisor) CloseAgentStateChangeFeed()
  • func (sup *Supervisor) Install(alias string, repo string, ctx supervisor.ActionContext) (*data.Agent, error)
  • func (sup *Supervisor) Kill(alias string, ctx supervisor.ActionContext) error
  • func (sup *Supervisor) Remove(agent *data.Agent, ctx supervisor.ActionContext) error
  • func (sup *Supervisor) Restart(agent *data.Agent, ctx supervisor.ActionContext) error
  • func (sup *Supervisor) Start(agent *data.Agent, ctx supervisor.ActionContext) error
  • func (sup *Supervisor) Status(alias string, ctx supervisor.ActionContext) (status string, err error)
  • func (sup *Supervisor) Statuses(ctx supervisor.ActionContext) (statuses map[string]string, err error)
  • func (sup *Supervisor) Stop(alias string, ctx supervisor.ActionContext) error
  • func (sup *Supervisor) StopWithTimeout(alias string, ctx supervisor.ActionContext, timeout time.Duration) error
  • func (sup *Supervisor) Terminate(timeout time.Duration)
  • func (sup *Supervisor) Upgrade(agent *data.Agent, ctx supervisor.ActionContext) error

Constants

const DefaultKillTimeout = 5 * time.Second

Types

type Supervisor

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

func NewSupervisor

func NewSupervisor(workspace string) (*Supervisor, error)

func (*Supervisor) AgentStateChangeFeed

func (sup *Supervisor) AgentStateChangeFeed() <-chan *supervisor.AgentStateChange

func (*Supervisor) CloseAgentStateChangeFeed

func (sup *Supervisor) CloseAgentStateChangeFeed()

func (*Supervisor) Install

func (sup *Supervisor) Install(alias string, repo string, ctx supervisor.ActionContext) (*data.Agent, error)

func (*Supervisor) Kill

func (sup *Supervisor) Kill(alias string, ctx supervisor.ActionContext) error

func (*Supervisor) Remove

func (sup *Supervisor) Remove(agent *data.Agent, ctx supervisor.ActionContext) error

func (*Supervisor) Restart

func (sup *Supervisor) Restart(agent *data.Agent, ctx supervisor.ActionContext) error

func (*Supervisor) Start

func (sup *Supervisor) Start(agent *data.Agent, ctx supervisor.ActionContext) error

func (*Supervisor) Status

func (sup *Supervisor) Status(alias string, ctx supervisor.ActionContext) (status string, err error)

func (*Supervisor) Statuses

func (sup *Supervisor) Statuses(ctx supervisor.ActionContext) (statuses map[string]string, err error)

func (*Supervisor) Stop

func (sup *Supervisor) Stop(alias string, ctx supervisor.ActionContext) error

func (*Supervisor) StopWithTimeout

func (sup *Supervisor) StopWithTimeout(alias string, ctx supervisor.ActionContext, timeout time.Duration) error

func (*Supervisor) Terminate

func (sup *Supervisor) Terminate(timeout time.Duration)

func (*Supervisor) Upgrade

func (sup *Supervisor) Upgrade(agent *data.Agent, ctx supervisor.ActionContext) error