e2e

type Environment interface {
	BuildTarget(ctx context.Context) *action_kit_api.Target
	FindProcessIds(ctx context.Context, command string) []int
	ExecuteProcess(ctx context.Context, command string, parameters ...string) (string, error)
	StartAndAwaitProcess(ctx context.Context, command string, awaitFn func(string) bool, parameters ...string) (func(), error)
	StopProcess(ctx context.Context, commandOrPid string) error
}

type Extension interface {
	Client() *resty.Client
	DiscoverTargets(discoveryId string) ([]discovery_kit_api.Target, error)
	DiscoverEnrichmentData(discoveryId string) ([]discovery_kit_api.EnrichmentData, error)
	RunAction(actionId string, target *action_kit_api.Target, config interface{}, executionContext *action_kit_api.ExecutionContext) (aclient.ActionExecution, error)
	RunActionWithFiles(actionId string, target *action_kit_api.Target, config interface{}, executionContext *action_kit_api.ExecutionContext, files []aclient.File) (aclient.ActionExecution, error)
	PollForTarget(ctx context.Context, targetId string, predicate func(target discovery_kit_api.Target) bool) (discovery_kit_api.Target, error)
	PollForEnrichmentData(ctx context.Context, targetId string, predicate func(target discovery_kit_api.EnrichmentData) bool) (discovery_kit_api.EnrichmentData, error)
}

type ExtensionFactory interface {
	Create(ctx context.Context, environment Environment) error
	Start(ctx context.Context, environment Environment) (Extension, error)
	Stop(ctx context.Context, environment Environment, extension Extension) error
}

type HttpNetperf struct {
	Ip   string
	Port int
	// contains filtered or unexported fields
}

type Iperf struct {
	Ip   string
	Port int
	// contains filtered or unexported fields
}

type LocalEnvironment struct {
	Profile string
}

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

type LocalExtensionFactory struct {
	Name       string
	Port       int
	Executable string
	Command    *exec.Cmd
	ExtraArgs  func() []string
	ExtraEnv   func() map[string]string
}

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

type R struct {
	// The number of current attempt.
	Attempt int
	Failed  bool
	Log     *bytes.Buffer
}

type WithTestCase struct {
	Name string
	Test func(t *testing.T, environment Environment, extension Extension)
}