testbed

func (*Testbed) RunExecutionWithTarget ¶

func (tb *Testbed) RunExecutionWithTarget(
	tgt *forge_target.Target,
	valueSet *forge_target.ValueSet,
	ts *timestamp.Timestamp,
) (*forge_execution.Execution, error)

RunExecutionWithTarget runs a target using the Execution controller only.

func (*Testbed) RunPassWithTarget ¶

func (tb *Testbed) RunPassWithTarget(
	tgt *forge_target.Target,
	valueSet *forge_target.ValueSet,
	replicas uint32,
	ts *timestamp.Timestamp,
) (*forge_pass.Pass, error)

RunPassWithTarget runs a target using the Pass and Execution controllers.

func (*Testbed) RunWorkerWithTasks ¶

func (tb *Testbed) RunWorkerWithTasks(
	taskMap map[string]*forge_target.Target,
	valueSet *forge_target.ValueSet,
	replicas uint32,
	ts *timestamp.Timestamp,
	jobKey string,
	clusterKey string,
	workerPeer peer.Peer,
) (*forge_job.Job, error)

RunWorkerWithTasks runs a set of Task using the Cluster, Worker, Pass controllers.

If workerPeer is nil, generates a new peer.