Documentation
¶
Index ¶
- func AddOptionsFromDefinition(odef metadata.ObjectDefinition) []p2plab.AddOption
- func Benchmark(ctx context.Context, lset p2plab.LabeledSet, benchmark metadata.ScenarioStage) error
- func LabeledSetToNodes(lset p2plab.LabeledSet) ([]p2plab.Node, error)
- func Parse(filename string) (metadata.ScenarioDefinition, error)
- func Plan(ctx context.Context, sdef metadata.ScenarioDefinition, ...) (plan metadata.ScenarioPlan, queries map[string][]string, err error)
- func Seed(ctx context.Context, lset p2plab.LabeledSet, seed metadata.ScenarioStage, ...) error
- type Execution
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AddOptionsFromDefinition ¶
func AddOptionsFromDefinition(odef metadata.ObjectDefinition) []p2plab.AddOption
func Benchmark ¶
func Benchmark(ctx context.Context, lset p2plab.LabeledSet, benchmark metadata.ScenarioStage) error
func LabeledSetToNodes ¶
func LabeledSetToNodes(lset p2plab.LabeledSet) ([]p2plab.Node, error)
func Plan ¶
func Plan(ctx context.Context, sdef metadata.ScenarioDefinition, ts *transformers.Transformers, peer p2plab.Peer, lset p2plab.LabeledSet) (plan metadata.ScenarioPlan, queries map[string][]string, err error)
func Seed ¶
func Seed(ctx context.Context, lset p2plab.LabeledSet, seed metadata.ScenarioStage, seederAddrs []string) error
Types ¶
type Execution ¶
type Execution struct {
Start time.Time
End time.Time
Report map[string]metadata.ReportNode
Span opentracing.Span
}
func Run ¶
func Run(ctx context.Context, lset p2plab.LabeledSet, plan metadata.ScenarioPlan, seederAddrs []string) (*Execution, error)
func Session ¶
func Session(ctx context.Context, lset p2plab.LabeledSet, benchmark metadata.ScenarioStage) (*Execution, error)
Source Files
Click to show internal directories.
Click to hide internal directories.