controller

Documentation

Index

• type Controller
  • func New(name string, etcd *etcd.Client, numOfTasks uint64, pLinkTypes []string) *Controller
  • func (c *Controller) DestroyEtcdLayout() error
  • func (c *Controller) InitEtcdLayout() error
  • func (c *Controller) Start() error
  • func (c *Controller) Stop() error
  • func (c *Controller) WaitForJobDone() error

Types

type Controller

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

This is the controller of a job. A job needs controller to setup etcd data layout, request cluster containers, etc. to setup framework to run.

func New

func New(name string, etcd *etcd.Client, numOfTasks uint64, pLinkTypes []string) *Controller

func (*Controller) DestroyEtcdLayout

func (c *Controller) DestroyEtcdLayout() error

func (*Controller) InitEtcdLayout

func (c *Controller) InitEtcdLayout() error

func (*Controller) Start

func (c *Controller) Start() error

A controller typical workflow: 1. controller sets up etcd layout before any task starts running. 2. Being ready, controller lets other tasks to run and reports any failure found.

func (*Controller) Stop

func (c *Controller) Stop() error

func (*Controller) WaitForJobDone

func (c *Controller) WaitForJobDone() error