manager

Documentation

Index

• type Deployer
  • func (p *Deployer) Create(topoName string, templatePath string, inputs map[string]interface{}) (uint, error)
  • func (p *Deployer) Install(topoId uint) error
  • func (p *Deployer) Migrate(topoId uint, inputs map[string]interface{}) (uint, error)
  • func (p *Deployer) Reload(topoId uint) error
  • func (p *Deployer) Restart(topoId uint) error
  • func (p *Deployer) Setup(topoId uint) error
  • func (p *Deployer) Start(topoId uint) error
  • func (p *Deployer) Stop(topoId uint) error
  • func (p *Deployer) Uninstall(topoId uint) error
• type Monitor
  • func (p *Monitor) Start(topo *topology.Topology) error
  • func (p *Monitor) Stop(topo *topology.Topology) error
• type PerformStatus

Types

type Deployer

type Deployer struct {
	DBService   *db.DBService                  `inject:""`
	TemplateRep templaterep.TemplateRepository `inject:""`
	ClassRep    classrep.ClassRepository       `inject:""`
	Executor    operation.Executor             `inject:""`
}

Deployer execute the deployment task.

func (*Deployer) Create

func (p *Deployer) Create(topoName string, templatePath string, inputs map[string]interface{}) (uint, error)

Create a topology in db

func (*Deployer) Install

func (p *Deployer) Install(topoId uint) error

func (*Deployer) Migrate

func (p *Deployer) Migrate(topoId uint, inputs map[string]interface{}) (uint, error)

Migrate a topology with topoId to a new topology. Update all inputs but continue to have the template of source topology.

func (*Deployer) Reload

func (p *Deployer) Reload(topoId uint) error

Reload configuration after setup when the topology has been started.

func (*Deployer) Restart

func (p *Deployer) Restart(topoId uint) error

Restart the topology

func (*Deployer) Setup

func (p *Deployer) Setup(topoId uint) error

Setup the topology

func (*Deployer) Start

func (p *Deployer) Start(topoId uint) error

Start the topology

func (*Deployer) Stop

func (p *Deployer) Stop(topoId uint) error

Stop the topology

func (*Deployer) Uninstall

func (p *Deployer) Uninstall(topoId uint) error

Uninstall the topology

type Monitor

type Monitor struct {
}

Monitor manage the task of topology monitoring

func (*Monitor) Start

func (p *Monitor) Start(topo *topology.Topology) error

Start monitoring for topology

func (*Monitor) Stop

func (p *Monitor) Stop(topo *topology.Topology) error

Stop monitoring

type PerformStatus

type PerformStatus struct {
	Node    *topology.Node
	Done    <-chan error
	Timeout <-chan bool
}

PerformStatus trace the status of node executing