framework

Documentation

Index

• Variables
• func NewBootStrap(jobName string, etcdURLs []string, ln net.Listener, logger *log.Logger) taskgraph.Bootstrap
• func NewMasterBoot(job string, etcdURL []string, ln net.Listener, logger *log.Logger, ...) taskgraph.Bootup
• func NewWorkerBoot(job string, etcdURL []string, ln net.Listener, logger *log.Logger, ...) taskgraph.Bootup

Variables

var (
	ErrEpochMismatch = fmt.Errorf("server epoch mismatch")
)

Functions

func NewBootStrap

func NewBootStrap(jobName string, etcdURLs []string, ln net.Listener, logger *log.Logger) taskgraph.Bootstrap

One need to pass in at least these two for framework to start.

func NewMasterBoot

func NewMasterBoot(job string, etcdURL []string, ln net.Listener, logger *log.Logger, task taskgraph.MasterTask, workerNum uint64) taskgraph.Bootup

func NewWorkerBoot

func NewWorkerBoot(job string, etcdURL []string, ln net.Listener, logger *log.Logger, task taskgraph.WorkerTask, id uint64) taskgraph.Bootup