client

Documentation

Index

• Constants
• type ExecuteOptions
  • func NewExecuteOptions() ExecuteOptions
• type Executor
• type HTTPClient
• type JobExecutor
  • func NewJobExecutor(repo result.Repository, initImage, jobTemplate string) (client JobExecutor, err error)
  • func (c JobExecutor) Abort(id string) error
  • func (c JobExecutor) Execute(execution testkube.Execution, options ExecuteOptions) (result testkube.ExecutionResult, err error)
  • func (c JobExecutor) ExecuteSync(execution testkube.Execution, options ExecuteOptions) (result testkube.ExecutionResult, err error)
  • func (c JobExecutor) Get(id string) (execution testkube.ExecutionResult, err error)
  • func (c JobExecutor) Logs(id string) (out chan output.Output, err error)
  • func (c JobExecutor) Watch(id string) (events chan ResultEvent)
• type ResultEvent

Constants

const (
	WatchInterval = time.Second
)

Types

type ExecuteOptions

type ExecuteOptions struct {
	ID           string
	TestName     string
	TestSpec     testsv2.TestSpec
	ExecutorName string
	ExecutorSpec executorv1.ExecutorSpec
	Request      testkube.ExecutionRequest
	Sync         bool
	HasSecrets   bool
}

func NewExecuteOptions

func NewExecuteOptions() ExecuteOptions

type Executor

type Executor interface {
	// Watch returns ExecuteEvents stream
	Watch(id string) (events chan ResultEvent)

	// Get synnchronous request to executor to get testkubeExecution
	Get(id string) (execution testkube.ExecutionResult, err error)

	// 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) (err error)

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

Executor abstraction to implement new executors

type HTTPClient

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

HTTPClient interface for getting REST based requests

type JobExecutor

type JobExecutor struct {
	Client     *jobs.JobClient
	Repository result.Repository
	Log        *zap.SugaredLogger
}

func NewJobExecutor

func NewJobExecutor(repo result.Repository, initImage, jobTemplate string) (client JobExecutor, err error)

func (JobExecutor) Abort

func (c JobExecutor) Abort(id string) error

func (JobExecutor) Execute

func (c JobExecutor) 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 asynchronously client can check later for results

func (JobExecutor) ExecuteSync

func (c JobExecutor) ExecuteSync(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 will be blocked

func (JobExecutor) Get

func (c JobExecutor) Get(id string) (execution testkube.ExecutionResult, err error)

func (JobExecutor) Logs

func (c JobExecutor) Logs(id string) (out chan output.Output, err error)

Logs returns job logs using kubernetes api

func (JobExecutor) Watch

func (c JobExecutor) Watch(id string) (events chan ResultEvent)

Watch will get valid execution after async Execute, execution will be returned when success or error occurs Worker should set valid state for success or error after test completion TODO add timeout

type ResultEvent

type ResultEvent struct {
	Result testkube.ExecutionResult
	Error  error
}

ResultEvent event passed when watching execution changes