kubernetes

Documentation

Index

• type KubernetesScopeHandler
  • func GetGlobalKubernetesHandler() *KubernetesScopeHandler
  • func (k KubernetesScopeHandler) CheckAlive(ctx context.Context, injectObject model.AtomicObject) error
  • func (k KubernetesScopeHandler) ConvertSelector(ctx context.Context, spec *v1alpha1.ExperimentSpec) ([]model.AtomicObject, error)
  • func (k KubernetesScopeHandler) ExecuteInject(ctx context.Context, injectObject model.AtomicObject, UID string, ...) (string, error)
  • func (k KubernetesScopeHandler) ExecuteRecover(ctx context.Context, injectObject model.AtomicObject, UID, backup string, ...) error
  • func (k KubernetesScopeHandler) GetInjectObject(ctx context.Context, exp *v1alpha1.ExperimentCommon, objectName string) (model.AtomicObject, error)
  • func (k KubernetesScopeHandler) QueryExperiment(ctx context.Context, injectObject model.AtomicObject, UID, backup string, ...) (*model.SubExpInfo, error)

Types

type KubernetesScopeHandler

type KubernetesScopeHandler struct {
}

func GetGlobalKubernetesHandler

func GetGlobalKubernetesHandler() *KubernetesScopeHandler

func (KubernetesScopeHandler) CheckAlive

func (k KubernetesScopeHandler) CheckAlive(ctx context.Context, injectObject model.AtomicObject) error

func (KubernetesScopeHandler) ConvertSelector

func (k KubernetesScopeHandler) ConvertSelector(ctx context.Context, spec *v1alpha1.ExperimentSpec) ([]model.AtomicObject, error)

func (KubernetesScopeHandler) ExecuteInject

func (k KubernetesScopeHandler) ExecuteInject(ctx context.Context, injectObject model.AtomicObject, UID string, expArgs *v1alpha1.ExperimentCommon) (string, error)

func (KubernetesScopeHandler) ExecuteRecover

func (k KubernetesScopeHandler) ExecuteRecover(ctx context.Context, injectObject model.AtomicObject, UID, backup string, expArgs *v1alpha1.ExperimentCommon) error

func (KubernetesScopeHandler) GetInjectObject

func (k KubernetesScopeHandler) GetInjectObject(ctx context.Context, exp *v1alpha1.ExperimentCommon, objectName string) (model.AtomicObject, error)

func (KubernetesScopeHandler) QueryExperiment

func (k KubernetesScopeHandler) QueryExperiment(ctx context.Context, injectObject model.AtomicObject, UID, backup string, expArgs *v1alpha1.ExperimentCommon, phase v1alpha1.PhaseType) (*model.SubExpInfo, error)