framework

package
v0.0.0-...-9859055 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 13, 2015 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

View Source
const (
	NumOfIterations uint64 = uint64(10)
)

Variables

This section is empty.

Functions

func NewBootStrap

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

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

Types

type SimpleTaskBuilder

type SimpleTaskBuilder struct {
	GDataChan    chan int32
	FinishChan   chan struct{}
	NodeProducer chan bool
	MasterConfig map[string]string
	SlaveConfig  map[string]string
}

used for testing

func (SimpleTaskBuilder) GetTask

func (tc SimpleTaskBuilder) GetTask(taskID uint64) meritop.Task

This method is called once by framework implementation to get the right task implementation for the node/task. It requires the taskID for current node, and also a global array of tasks.

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL