15.performance-monitoring.yml

---
apiVersion: frisbee.dev/v1alpha1
kind: Template
metadata:
  name: iperf.server
spec:
  service:
    decorators: # Add support for Telemetry22
      telemetry: [ frisbee.system.telemetry.resources ]
    containers:
      - name: main
        image: czero/iperf2
        ports:
          - name: listen
            containerPort: 5001
        resources:
          limits:
            cpu: "0.2"
            memory: "500Mi"
        command:
          - /bin/sh   # Run shell
          - -c        # Read from string
          - |         # Multi-line str
            set -eum
            cut -d ' ' -f 4 /proc/self/stat > /dev/shm/app # Sidecar: use it for entering the cgroup
            
            iperf -s -f m -i 5


---
apiVersion: frisbee.dev/v1alpha1
kind: Template
metadata:
  name: iperf.client
spec:
  inputs:
    parameters:
      target: localhost
  service:
    decorators:
      telemetry: # Register Telemetry Agents
        - frisbee.system.telemetry.resources  # Collect Generic System's Metrics
        - frisbee.apps.iperf2.client.telemetry # Collect App Specific Metrics
    containers:
      - name: main
        image: czero/iperf2
        command:
          - /bin/sh   # Run shell
          - -c        # Read from string
          - |         # Multi-line str
            set -eum
            cut -d ' ' -f 4 /proc/self/stat > /dev/shm/app # Sidecar: use it for entering the cgroup
            
            iperf -c {{.inputs.parameters.target}} -t 1000 > /dev/shm/pipe


---
apiVersion: frisbee.dev/v1alpha1
kind: Scenario
metadata:
  name: performance-monitoring
spec:
  actions:
    - action: Service
      name: server
      service:
        templateRef: iperf.server

    # Create a first cluster
    - action: Cluster
      name: group-a
      depends: { running: [ server ] }
      cluster:
        templateRef: iperf.client
        instances: 3
        inputs:
          - { target: server }

    # Create a second cluster
    - action: Cluster
      name: group-b
      depends: { running: [ server ] }
      cluster:
        templateRef: iperf.client
        instances: 3
        inputs:
          - { target: server }

    # Delete the second cluster.
    - action: Delete
      name: delete-group-b
      depends: { running: [ group-b ],  after: "120s" }
      delete: # referenced jobs should be actions.
        jobs: [ group-b ]

    # When all actions are done, delete looping servers to gracefully exit the experiment
    - action: Delete
      name: teardown
      depends: { running: [ server ], success: [ delete-group-b,  group-a ] }
      delete:
        jobs: [ server ]