util

Documentation

Index

• Constants
• func HelmTool(args ...string) (string, error)
• func KubectlTool(args ...string) (string, error)
• type Config
  • func NewConfig(configFilePath string) (*Config, error)
  • func (c *Config) ParseManifest(t kvrocksv1alpha1.KVRocksType) (*kvrocksv1alpha1.KVRocks, error)
• type Experiment
• type KubernetesEnv
  • func Start(config *Config) *KubernetesEnv
  • func (env *KubernetesEnv) CreateExperiment(chaos client.Object) *Experiment
  • func (env *KubernetesEnv) GetConfig(field string) (interface{}, error)
  • func (env *KubernetesEnv) ParseManifest(t kvrocksv1alpha1.KVRocksType) (*kvrocksv1alpha1.KVRocks, error)
  • func (env *KubernetesEnv) ScheduleInjectPodKill(target chaosmeshv1alpha1.PodSelectorSpec, schedule string, ...) *Experiment

Constants

const (
	DefaultClusterName   = "e2e-test"
	DefaultNamespace     = "kvrocks"
	DefaultKruiseVersion = "1.4.0"
	DefaultMinikubeShell = "start_minikube_cluster.sh"
	DefaulManifestDir    = "../../../examples/"
)

const (
	ChaosMeshNamespace = "chaos-mesh"
)

Functions

func HelmTool

func HelmTool(args ...string) (string, error)

func KubectlTool

func KubectlTool(args ...string) (string, error)

Types

type Config

type Config struct {
	KruiseVersion    string `yaml:"kruiseVersion"`
	ClusterName      string `yaml:"clusterName"`
	Namespace        string `yaml:"namespace"`
	KubeConfig       string `yaml:"kubeConfig"`
	ChaosMeshEnabled bool   `yaml:"chaosMeshEnabled"`
	ManifestDir      string `yaml:"manifestDir"`
}

func NewConfig

func NewConfig(configFilePath string) (*Config, error)

func (*Config) ParseManifest

func (c *Config) ParseManifest(t kvrocksv1alpha1.KVRocksType) (*kvrocksv1alpha1.KVRocks, error)

type Experiment

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

type KubernetesEnv

type KubernetesEnv struct {
	Client               client.Client
	ChaosMeshExperiments []Experiment
	Clean                func() error
	// contains filtered or unexported fields
}

func Start

func Start(config *Config) *KubernetesEnv

func (*KubernetesEnv) CreateExperiment

func (env *KubernetesEnv) CreateExperiment(chaos client.Object) *Experiment

func (*KubernetesEnv) GetConfig

func (env *KubernetesEnv) GetConfig(field string) (interface{}, error)

func (*KubernetesEnv) ParseManifest

func (env *KubernetesEnv) ParseManifest(t kvrocksv1alpha1.KVRocksType) (*kvrocksv1alpha1.KVRocks, error)

func (*KubernetesEnv) ScheduleInjectPodKill

func (env *KubernetesEnv) ScheduleInjectPodKill(target chaosmeshv1alpha1.PodSelectorSpec, schedule string, mode chaosmeshv1alpha1.SelectorMode) *Experiment