core

type Action interface {
	//Execute(executionContext ExecutionContext, cancellation chan struct{}) ExecutionResult
	Execute(ctx context.Context, executionContext ExecutionContext) ExecutionResult
}

type Assertion interface {
	Assert(ExecutionResult) AssertionResult
}

type AssertionResult map[string]interface{}

type ByteStat struct {
	Min   int64 `json:"min"`
	Max   int64 `json:"max"`
	Mean  int64 `json:"mean"`
	Total int64 `json:"total"`
}

type ByteSummary struct {
	Received ByteStat `json:"received"`
	Sent     ByteStat `json:"sent"`
}

type ExecutionActionParser interface {
	Parse(input map[string]interface{}) Action
	Key() string
}

type ExecutionAssertionParser interface {
	Parse(input map[string]interface{}) (Assertion, error)
	Key() string
}

type ExecutionContext map[string]interface{}

type ExecutionExtractorParser interface {
	Parse(input map[string]interface{}) (Extractor, error)
	Key() string
}

type ExecutionResult map[string]interface{}

type ExecutionResultProcessor interface {
	Process(result ExecutionResult, registry metrics.Registry)
}

type ExecutionSummary struct {
	TotalRequests          float64          `json:"totalRequests"`
	TotalErrors            float64          `json:"totalErrors"`
	Availability           float64          `json:"availability"`
	RunningTime            time.Duration    `json:"runningTime"`
	Throughput             float64          `json:"throughput"`
	ResponseTime           ResponseTimeStat `json:"responseTime"`
	TotalAssertions        int64            `json:"totalAssertions"`
	TotalAssertionFailures int64            `json:"totalAssertionFailures"`
	Bytes                  ByteSummary      `json:"bytes"`
}

type ExtractionResult map[string]interface{}

type Extractor interface {
	Extract(ExecutionResult) ExtractionResult
}

type HashMapList map[string][]map[string]interface{}

type Job struct {
	ID      int
	Name    string
	Steps   []Step
	Context map[string]interface{}
	Before  []Action
	After   []Action
}

type Plan struct {
	Iterations int
	Random     bool
	Workers    int
	Name       string
	WaitTime   time.Duration
	Duration   time.Duration
	Jobs       []Job
	Context    map[string]interface{}
	Before     []Action
	After      []Action
}

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

type Registry struct {
	AssertionParsers []ExecutionAssertionParser
	ActionParsers    []ExecutionActionParser
	ResultProcessors []ExecutionResultProcessor
	ExtractorParsers []ExecutionExtractorParser
}

type ResponseTimeStat struct {
	Min  float64 `json:"min"`
	Max  float64 `json:"max"`
	Mean float64 `json:"mean"`
}

type Step struct {
	ID         int
	JobID      int
	Name       string
	Action     Action
	Assertions []Assertion
	Extractors []Extractor
	Before     []Action
	After      []Action
}

type SummaryBuilder interface {
	Write(summary ExecutionSummary)
}

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

type Urn struct {
	Connector string
	Metric    string
	Names     []interface{}
}