handler

Documentation

Index

• Constants
• type AppliedCase
• type Processor
  • func NewProcessor(cfgDir string, timeout int, storage Storage, logger logr.Logger) (*Processor, error)
  • func (s *Processor) CasesRunnerHandler(w http.ResponseWriter, r *http.Request)
  • func (s *Processor) Check(testID string, timeout time.Duration, expReg pkg.ExpctationReg) (*TResponse, error)
  • func (s *Processor) Clean(applied AppliedCase) error
  • func (s *Processor) DisplayClusterHandler(w http.ResponseWriter, r *http.Request)
  • func (s *Processor) DisplayExpectationHandler(w http.ResponseWriter, r *http.Request)
  • func (s *Processor) DisplayStagesHandler(w http.ResponseWriter, r *http.Request)
  • func (s *Processor) DisplayTestCasesHandler(w http.ResponseWriter, r *http.Request)
  • func (s *Processor) ExpectationCheckerHandler(w http.ResponseWriter, r *http.Request)
  • func (s *Processor) HelperHandler(w http.ResponseWriter, r *http.Request)
  • func (s *Processor) ReloadClusterReg()
  • func (s *Processor) Run(testID string, tc pkg.TestCasesReg) (AppliedCase, error)
  • func (st *Processor) RunStage(groupID string, timeout time.Duration, sRunner StageRunner) *TResponse
  • func (s *Processor) StageRunnerHandler(w http.ResponseWriter, r *http.Request)
• type StageRunner
• type Storage
• type TResponse
  • func (tr *TResponse) String() string

Constants

const (
	Unknown    = "unknown"
	Succeed    = "succeed"
	Failed     = "failed"
	InfoLevel  = 0
	DebugLevel = 1
)

const (
	Apply  ocCommand = "apply"
	Delete ocCommand = "delete"
)

Types

type AppliedCase

type AppliedCase struct {
	Tc  pkg.TestCase
	Cfg string
}

type Processor

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

func NewProcessor

func NewProcessor(cfgDir string, timeout int, storage Storage, logger logr.Logger) (*Processor, error)

func (*Processor) CasesRunnerHandler

func (s *Processor) CasesRunnerHandler(w http.ResponseWriter, r *http.Request)

func (*Processor) Check

func (s *Processor) Check(testID string, timeout time.Duration, expReg pkg.ExpctationReg) (*TResponse, error)

func (*Processor) Clean

func (s *Processor) Clean(applied AppliedCase) error

func (*Processor) DisplayClusterHandler

func (s *Processor) DisplayClusterHandler(w http.ResponseWriter, r *http.Request)

func (*Processor) DisplayExpectationHandler

func (s *Processor) DisplayExpectationHandler(w http.ResponseWriter, r *http.Request)

func (*Processor) DisplayStagesHandler

func (s *Processor) DisplayStagesHandler(w http.ResponseWriter, r *http.Request)

func (*Processor) DisplayTestCasesHandler

func (s *Processor) DisplayTestCasesHandler(w http.ResponseWriter, r *http.Request)

func (*Processor) ExpectationCheckerHandler

func (s *Processor) ExpectationCheckerHandler(w http.ResponseWriter, r *http.Request)

func (*Processor) HelperHandler

func (s *Processor) HelperHandler(w http.ResponseWriter, r *http.Request)

func (*Processor) ReloadClusterReg

func (s *Processor) ReloadClusterReg()

func (*Processor) Run

func (s *Processor) Run(testID string, tc pkg.TestCasesReg) (AppliedCase, error)

func (*Processor) RunStage

func (st *Processor) RunStage(groupID string, timeout time.Duration, sRunner StageRunner) *TResponse

func (*Processor) StageRunnerHandler

func (s *Processor) StageRunnerHandler(w http.ResponseWriter, r *http.Request)

type StageRunner

type StageRunner interface {
	Run(id string, caseReg pkg.TestCasesReg) (AppliedCase, error)
	Check(id string, timeout time.Duration, expReg pkg.ExpctationReg) (*TResponse, error)
	Clean(AppliedCase) error
}

type Storage

type Storage interface {
	LoadTestCases() (pkg.TestCasesReg, error)
	LoadExpectations() (pkg.ExpctationReg, error)
	LoadStages() (pkg.StageReg, error)
}

type TResponse

type TResponse struct {
	TestID  string      `json:"test_id"`
	Name    string      `json:"name"`
	Status  string      `json:"run_status"`
	Error   string      `json:"error"`
	Details interface{} `json:"details"`
}

func (*TResponse) String

func (tr *TResponse) String() string