model

Apr 29, 2022

Changes in this version

+ func GetChaosBladeDaemonsetPodName(nodeName string, client *channel.Client) (string, error)

+ type CommonExecutor struct

+ Client *channel.Client

+ func (e *CommonExecutor) Exec(uid string, ctx context.Context, expModel *spec.ExpModel) *spec.Response

+ func (e *CommonExecutor) Name() string

+ func (e *CommonExecutor) SetChannel(channel spec.Channel)

Dec 1, 2021

Changes in this version

+ var IsDockerNetworkFlag = &spec.ExpFlag

+ var UseSidecarContainerNetworkFlag = &spec.ExpFlag

+ func GetNetworkFlags() []spec.ExpFlagSpec

type ContainerObjectMeta

+ ContainerRuntime string

Aug 4, 2021

Changes in this version

+ var ChaosBladeDeployModeFlag = &spec.ExpFlag

+ var ChaosBladeDownloadUrlFlag = &spec.ExpFlag

+ var ChaosBladePathFlag = &spec.ExpFlag

+ var CopyMode = "copy"

+ var DownloadMode = "download"

type CopyOptions

+ func (o *CopyOptions) DeployToPod(experimentId, src, dest string) error

+ type DeployMode interface

+ DeployToPod func(experimentId, src, dest string) error

+ type DeployOptions struct

+ Container string

+ Namespace string

+ PodName string

+ func (o *DeployOptions) CheckFileExists(dest string) error

+ func (o *DeployOptions) CreateDir(dir string) error

+ type DownloadOptions struct

+ func (d *DownloadOptions) DeployToPod(experimentId, src, dest string) error

May 31, 2021

Changes in this version

+ func ParallelizeExec(workCount int, doWork DoWorkFunc)

+ type DoWorkFunc func(workID int)

type ExperimentIdentifierInPod

+ Code int32

Mar 5, 2021

Changes in this version

+ const CategorySystemContainer

Nov 2, 2020

Changes in this version

+ func MapContains(bigMap map[string]string, subMap map[string]string) bool

+ func ParseLabels(labels string) map[string]string

Sep 28, 2020

Changes in this version

+ const ContainerObjectMetaListKey

+ const ExperimentIdKey

+ var ChaosBladeDeployedPathFlag = &spec.ExpFlag

+ var ContainerIndexFlag = &spec.ExpFlag

+ func GetChaosBladeFlags() []spec.ExpFlagSpec

+ func GetExperimentIdFromContext(ctx context.Context) string

+ func SetContainerObjectMetaListToContext(ctx context.Context, containerMatchedList ContainerMatchedList) context.Context

+ func SetExperimentIdToContext(ctx context.Context, experimentId string) context.Context

+ type ContainerMatchedList []ContainerObjectMeta

+ func GetContainerObjectMetaListFromContext(ctx context.Context) (ContainerMatchedList, error)

type ContainerObjectMeta

+ ContainerId string

+ ContainerName string

+ Id string

+ Namespace string

+ func ParseIdentifier(identifier string) ContainerObjectMeta

+ func (c *ContainerObjectMeta) GetIdentifier() string

+ type CopyOptions struct

+ Container string

+ Namespace string

+ PodName string

+ func (o *CopyOptions) CheckFileExists(dest string) error

+ func (o *CopyOptions) CopyToPod(src, dest string) error

+ func (o *CopyOptions) CreateDir(dir string) error

type ExecCommandInPodExecutor

+ func (e *ExecCommandInPodExecutor) GetChaosBladeDaemonsetPodName(nodeName string) (string, error)

+ type ExperimentIdentifierInPod struct

+ ChaosBladeContainerName string

+ ChaosBladeNamespace string

+ ChaosBladePodName string

+ Command string

+ Error string

+ type OSSubResourceModelSpec struct

type SubResourceExpModelSpec

+ func NewOSSubResourceModelSpec() SubResourceExpModelSpec

Feb 7, 2020

Changes in this version

+ const DefaultNamespace

+ const NameKey

+ const NodeNameContainerObjectMetasMapKey

+ const NodeNameExpObjectMetaMapKey

+ const NodeNameUidMapKey

+ const PodObjectMetaListKey

+ const UidKey

+ var ContainerIdsFlag = &spec.ExpFlag

+ var ContainerNamesFlag = &spec.ExpFlag

+ var ResourceCountFlag = &spec.ExpFlag

+ var ResourceGroupKeyFlag = &spec.ExpFlag

+ var ResourceLabelsFlag = &spec.ExpFlag

+ var ResourceNamesFlag = &spec.ExpFlag

+ var ResourceNamespaceFlag = &spec.ExpFlag

+ var ResourcePercentFlag = &spec.ExpFlag

+ func CheckFlags(flags map[string]string) error

+ func CheckPodFlags(flags map[string]string) error

+ func CreateDestroyedStatus(oldExpStatus v1alpha1.ExperimentStatus) v1alpha1.ExperimentStatus

+ func CreateErrorStatus(errorMsgs []string, oldExpStatus v1alpha1.ExperimentStatus) v1alpha1.ExperimentStatus

+ func ExcludeKeyFunc() func() map[string]spec.Empty

+ func ExtractExpModelFromExperimentSpec(experimentSpec v1alpha1.ExperimentSpec) *spec.ExpModel

+ func ExtractExpModelFromExperimentStatus(experimentStatus v1alpha1.ExperimentStatus) *spec.ExpModel

+ func GetChaosBladePodListOptions() *client.ListOptions

+ func GetContainerFlags() []spec.ExpFlagSpec

+ func GetOneAvailableContainerIdFromPod(pod v1.Pod) (string, error)

+ func GetResourceCommonFlags() []spec.ExpFlagSpec

+ func GetResourceCount(resourceCount int, flags map[string]string) (int, error)

+ func GetResourceCoverageFlags() []spec.ExpFlagSpec

+ func GetResourceFlagNames() map[string]spec.Empty

+ func TruncateContainerObjectMetaUid(uid string) string

+ type BaseExperimentController struct

+ Client *channel.Client

+ ResourceModelSpec ResourceExpModelSpec

+ func (b *BaseExperimentController) Destroy(ctx context.Context, expSpec v1alpha1.ExperimentSpec, ...) *spec.Response

+ func (b *BaseExperimentController) Exec(ctx context.Context, expModel *spec.ExpModel) *spec.Response

+ func (b *BaseExperimentController) GetMatchedPodResources(expModel spec.ExpModel) ([]v1.Pod, error)

+ type BaseResourceExpModelSpec struct

+ Client *channel.Client

+ ExpModelSpecs map[string]spec.ExpModelCommandSpec

+ ScopeName string

+ func NewBaseResourceExpModelSpec(scopeName string, client *channel.Client) BaseResourceExpModelSpec

+ func (b *BaseResourceExpModelSpec) ExpModels() map[string]spec.ExpModelCommandSpec

+ func (b *BaseResourceExpModelSpec) GetExpActionModelSpec(target, actionName string) spec.ExpActionCommandSpec

+ func (b *BaseResourceExpModelSpec) RegisterExpModels(expModel ...spec.ExpModelCommandSpec)

+ func (b *BaseResourceExpModelSpec) Scope() string

+ type BaseSubResourceExpModelSpec struct

+ ExpExecutor spec.Executor

+ ExpModelSpecs []spec.ExpModelCommandSpec

+ func (b *BaseSubResourceExpModelSpec) Executor() spec.Executor

+ func (b *BaseSubResourceExpModelSpec) ExpModels() []spec.ExpModelCommandSpec

+ type ContainerObjectMeta struct

+ Name string

+ NodeName string

+ PodName string

+ PodUid string

+ Uid string

+ type ExecCommandInPodExecutor struct

+ Client *channel.Client

+ CommandFunc func(ctx context.Context, model *spec.ExpModel, ...) ([]ExperimentIdentifier, error)

+ func (e *ExecCommandInPodExecutor) Exec(uid string, ctx context.Context, expModel *spec.ExpModel) *spec.Response

+ func (e *ExecCommandInPodExecutor) Name() string

+ func (e *ExecCommandInPodExecutor) SetChannel(channel spec.Channel)

+ type ExpController interface

+ Create func(bladeName string, expSpec v1alpha1.ExperimentSpec) v1alpha1.ExperimentStatus

+ Destroy func(bladeName string, expSpec v1alpha1.ExperimentSpec, ...) v1alpha1.ExperimentStatus

+ Name func() string

+ type ExpObjectMeta struct

+ Id string

+ Name string

+ Uid string

+ type ExperimentController interface

+ Create func(ctx context.Context, expSpec v1alpha1.ExperimentSpec) *spec.Response

+ Destroy func(ctx context.Context, expSpec v1alpha1.ExperimentSpec, ...) *spec.Response

+ Name func() string

+ type ExperimentIdentifier struct

+ Command string

+ Error string

+ Id string

+ Name string

+ Uid string

+ func NewExperimentIdentifier(id, uid, name, command string) ExperimentIdentifier

+ func NewExperimentIdentifierWithError(id, uid, name, error string) ExperimentIdentifier

+ type NodeNameContainerObjectMetasMap map[string][]ContainerObjectMeta

+ func ExtractNodeNameContainerMetasMapFromContext(ctx context.Context) (NodeNameContainerObjectMetasMap, error)

+ type NodeNameExpObjectMetasMap map[string][]ExpObjectMeta

+ func ExtractNodeNameExpObjectMetasMapFromContext(ctx context.Context) (NodeNameExpObjectMetasMap, error)

+ type NodeNameUidMap map[string]string

+ func ExtractNodeNameUidMapFromContext(ctx context.Context) (NodeNameUidMap, error)

+ type PodListOption client.ListOptions

+ type PodObjectMeta struct

+ Name string

+ Namespace string

+ NodeName string

+ Uid string

+ type PodObjectMetaList []PodObjectMeta

+ func ExtractPodObjectMetasFromContext(ctx context.Context) (PodObjectMetaList, error)

+ type ResourceExpModelSpec interface

+ ExpModels func() map[string]spec.ExpModelCommandSpec

+ GetExpActionModelSpec func(target, action string) spec.ExpActionCommandSpec

+ Scope func() string

+ type ResourceIdentifier struct

+ NodeName string

+ NodeUid string

+ func NewResourceIdentifier(nodeName, nodeUid string) *ResourceIdentifier

+ type SubResourceExpModelSpec interface

+ Executor func() spec.Executor

+ ExpModels func() []spec.ExpModelCommandSpec