client

type ExecuteOptions struct {
	ID             string
	TestName       string
	Namespace      string
	TestSpec       testsv3.TestSpec
	ExecutorName   string
	ExecutorSpec   executorv1.ExecutorSpec
	Request        testkube.ExecutionRequest
	Sync           bool
	HasSecrets     bool
	Labels         map[string]string
	UsernameSecret *testkube.SecretRef
	TokenSecret    *testkube.SecretRef
	ImageOverride  string
}

type ExecutionCounter interface {
	IncExecuteTest(execution testkube.Execution)
}

type Executor interface {
	// Execute starts new external test execution, reads data and returns ID
	// execution is started asynchronously client can check later for results
	Execute(execution *testkube.Execution, options ExecuteOptions) (result testkube.ExecutionResult, err error)

	// Execute starts new external test execution, reads data and returns ID
	// execution is started synchronously client is blocked
	ExecuteSync(execution *testkube.Execution, options ExecuteOptions) (result testkube.ExecutionResult, err error)

	// Abort aborts pending execution, do nothing when there is no pending execution
	Abort(id string) (execution *testkube.ExecutionResult)

	Logs(id string) (logs chan output.Output, err error)
}

type HTTPClient interface {
	Post(url, contentType string, body io.Reader) (resp *http.Response, err error)
	Get(url string) (resp *http.Response, err error)
}

type JobExecutor struct {
	Repository result.Repository
	Log        *zap.SugaredLogger
	ClientSet  *kubernetes.Clientset
	Namespace  string
	Cmd        string

	Emitter *webhook.Emitter
	// contains filtered or unexported fields
}

type JobOptions struct {
	Name           string
	Namespace      string
	Image          string
	ImageOverride  string
	Jsn            string
	TestName       string
	InitImage      string
	JobTemplate    string
	HasSecrets     bool
	SecretEnvs     map[string]string
	HTTPProxy      string
	HTTPSProxy     string
	UsernameSecret *testkube.SecretRef
	TokenSecret    *testkube.SecretRef
}

type ResultEvent struct {
	Result testkube.ExecutionResult
	Error  error
}