apiVersion: argoproj.io/v1alpha1
kind: Workflow
metadata:
  name: network-cpu-workflow
  namespace: chaosmeta
spec:
  serviceAccountName: chaosmeta-inject-controller-manager
  entrypoint: main
  templates:
    - name: experiment-inject
      inputs:
        parameters:
        - name: experiment
      resource:
        action: create
        failureCondition: status.status == failed
        successCondition: status.phase == recover,status.status == success
        manifest: "{{inputs.parameters.experiment}}"
    - name: raw-suspend
      inputs:
        parameters:
        - name: time
      suspend:
        duration: "{{inputs.parameters.time}}"
    - name: experiment-recover
      inputs:
        parameters:
        - name: experiment
      resource:
        action: patch
        failureCondition: status.phase == recover,status.status == failed
        successCondition: status.phase == recover,status.status == success
        mergeStrategy: json
        flags:
        - experiments.inject.chaosmeta.io
        - "{{inputs.parameters.experiment}}"
        manifest: |
          - op: replace
            path: /spec/targetPhase
            value: recover
    - name: main
      dag:
        tasks:
        - name: before-wait
          template: raw-suspend
          arguments:
            parameters: [{name: time, value: "5s"}]
        - name: pod-network-experiment-inject
          hooks:
            exit:
              template: experiment-recover
              arguments:
                parameters: [{name: experiment, value: "pod-network-experiment"}]
          dependencies: [before-wait]
          template: experiment-inject
          arguments:
            parameters: 
              - name: experiment
                value: |
                  apiVersion: inject.chaosmeta.io/v1alpha1
                  kind: Experiment
                  metadata:
                    name: pod-network-experiment
                    namespace: chaosmeta
                  spec:
                    scope: pod
                    targetPhase: inject
                    experiment:
                      target: network
                      fault: delay
                      duration: 5m
                      args:
                        - key: interface
                          value: 'eth0'
                          valueType: string
                        - key: latency
                          value: '2s'
                          valueType: string
                    selector:
                      - namespace: default
                        name:
                          - nginx-75c57b6fd7-hldwd
        - name: inject-wait
          dependencies: [before-wait]
          template: raw-suspend
          arguments:
            parameters: [{name: time, value: "30s"}]
        - name: inject-wait-2
          dependencies: [inject-wait]
          template: raw-suspend
          arguments:
            parameters: [{name: time, value: "5s"}]
        - name: after-wait
          dependencies: [pod-network-experiment-inject,inject-wait-2]
          template: raw-suspend
          arguments:
            parameters: [{name: time, value: "5s"}]

apiVersion: apiextensions.k8s.io/v1
kind: CustomResourceDefinition
metadata:
  annotations:
    controller-gen.kubebuilder.io/version: v0.11.1
  name: experiments.inject.chaosmeta.io
spec:
  conversion:
    strategy: Webhook
    webhook:
      clientConfig:
        service:
          name: chaosmeta-inject-webhook-service
          namespace: chaosmeta
          path: /convert
      conversionReviewVersions:
        - v1
  group: inject.chaosmeta.io
  names:
    kind: Experiment
    listKind: ExperimentList
    plural: experiments
    singular: experiment
  scope: Namespaced
  versions:
    - name: v1alpha1
      schema:
        openAPIV3Schema:
          description: Experiment is the Schema for the experiments API
          properties:
            apiVersion:
              description: 'APIVersion defines the versioned schema of this representation of an object. Servers should convert recognized schemas to the latest internal value, and may reject unrecognized values. More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#resources'
              type: string
            kind:
              description: 'Kind is a string value representing the REST resource this object represents. Servers may infer this from the endpoint the client submits requests to. Cannot be updated. In CamelCase. More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#types-kinds'
              type: string
            metadata:
              type: object
            spec:
              description: ExperimentSpec defines the desired state of Experiment
              properties:
                experiment:
                  properties:
                    args:
                      items:
                        properties:
                          key:
                            type: string
                          value:
                            type: string
                          valueType:
                            type: string
                        required:
                          - key
                          - value
                        type: object
                      type: array
                    duration:
                      description: Duration support "h", "m", "s"
                      type: string
                    fault:
                      type: string
                    target:
                      type: string
                  required:
                    - fault
                    - target
                  type: object
                rangeMode:
                  properties:
                    type:
                      description: 'Type Optional: all、percent、count'
                      type: string
                    value:
                      type: integer
                  required:
                    - type
                  type: object
                scope:
                  description: 'Scope Optional: node, pod. type of experiment object'
                  type: string
                selector:
                  description: Selector The internal part of unit is "AND", and the external part is "OR" and de-duplication
                  items:
                    properties:
                      ip:
                        items:
                          type: string
                        type: array
                      label:
                        additionalProperties:
                          type: string
                        type: object
                      name:
                        items:
                          type: string
                        type: array
                      namespace:
                        type: string
                    type: object
                  type: array
                targetPhase:
                  type: string
              required:
                - experiment
                - scope
                - targetPhase
              type: object
            status:
              description: ExperimentStatus defines the observed state of Experiment
              properties:
                createTime:
                  type: string
                detail:
                  properties:
                    inject:
                      items:
                        properties:
                          backup:
                            type: string
                          injectObjectName:
                            type: string
                          message:
                            type: string
                          startTime:
                            type: string
                          status:
                            type: string
                          uid:
                            description: InjectObjectInfo string     `json:"injectObjectInfo,omitempty"`
                            type: string
                          updateTime:
                            type: string
                        type: object
                      type: array
                    recover:
                      items:
                        properties:
                          backup:
                            type: string
                          injectObjectName:
                            type: string
                          message:
                            type: string
                          startTime:
                            type: string
                          status:
                            type: string
                          uid:
                            description: InjectObjectInfo string     `json:"injectObjectInfo,omitempty"`
                            type: string
                          updateTime:
                            type: string
                        type: object
                      type: array
                  type: object
                message:
                  type: string
                phase:
                  type: string
                status:
                  type: string
                updateTime:
                  type: string
              required:
                - createTime
                - detail
                - message
                - phase
                - status
                - updateTime
              type: object
          type: object
      served: true
      storage: true
      subresources:
        status: {}