backends

type Backend interface {
	// Type must return backend unique type string, called by both Proxy and Controller
	Type() loadTestV1.LoadTestType

	// TransformLoadTestSpec should validate and transform LoadTestSpec, called by Proxy
	TransformLoadTestSpec(spec *loadTestV1.LoadTestSpec) error

	// Sync should create resources if not exists, called by Controller
	Sync(ctx context.Context, loadTest loadTestV1.LoadTest, reportURL string) error
	// Sync should update status with current resource state, called by Controller
	SyncStatus(ctx context.Context, loadTest loadTestV1.LoadTest, loadTestStatus *loadTestV1.LoadTestStatus) error
}

type BackendGetEnvConfig interface {
	// GetEnvConfig get from backend a envConfig struct pointer
	GetEnvConfig() interface{}
}

type BackendSetDefaults interface {
	// SetDefaultValues gives a chance to backend initialize itself
	SetDefaults()
}

type BackendSetKangalClientSet interface {
	// SetKangalClientSet gives backend a kangalClientSet instance
	SetKangalClientSet(clientSetV.Interface)
}

type BackendSetKubeClientSet interface {
	// SetKubeClientSet gives backend a kubeClientSet instance
	SetKubeClientSet(kubernetes.Interface)
}

type BackendSetLogger interface {
	// SetLogger gives backend a logger instance
	SetLogger(*zap.Logger)
}

type BackendSetNamespaceLister interface {
	// SetNamespaceLister gives backend a namespaceLister instance
	SetNamespaceLister(coreListersV1.NamespaceLister)
}

type BackendSetPodAnnotations interface {
	// SetPodAnnotations gives backend annotations to be attached in loadtest pods
	SetPodAnnotations(map[string]string)
}

type BackendSetPodNodeSelector interface {
	// SetPodNodeSelector gives backend node selector to be attached in loadtest pods
	SetPodNodeSelector(map[string]string)
}

type BackendSetPodTolerations interface {
	// SetPodNodeSelector gives backend node selector to be attached in loadtest pods
	SetPodTolerations([]kubeCoreV1.Toleration)
}

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

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

type Option func(*registry)

type Registry interface {
	GetBackend(loadTestType loadTestV1.LoadTestType) (Backend, error)
}

type Resources struct {
	CPULimits      string
	CPURequests    string
	MemoryLimits   string
	MemoryRequests string
}