Skip to content

Commit

Permalink
docs: added scaling examples
Browse files Browse the repository at this point in the history
  • Loading branch information
alexec committed May 20, 2021
1 parent f3ba148 commit 122acc3
Show file tree
Hide file tree
Showing 3 changed files with 28 additions and 3 deletions.
4 changes: 2 additions & 2 deletions docs/EXAMPLES.md
Original file line number Diff line number Diff line change
Expand Up @@ -61,7 +61,7 @@ They have a single variable, `msg`, which is a byte array.
kubectl apply -f https://raw.githubusercontent.com/argoproj-labs/argo-dataflow/main/examples/102-map-pipeline.yaml
```

### [Using replicas and auto-scaling](https://raw.githubusercontent.com/argoproj-labs/argo-dataflow/main/examples/103-replicas-pipeline.yaml)
### [Using replicas and auto-scaling](https://raw.githubusercontent.com/argoproj-labs/argo-dataflow/main/examples/103-autoscaling-pipeline.yaml)

This is an example of having multiple replicas for a single step.

Expand Down Expand Up @@ -95,7 +95,7 @@ of replicas re-calculated.


```
kubectl apply -f https://raw.githubusercontent.com/argoproj-labs/argo-dataflow/main/examples/103-replicas-pipeline.yaml
kubectl apply -f https://raw.githubusercontent.com/argoproj-labs/argo-dataflow/main/examples/103-autoscaling-pipeline.yaml
```

### [Go 1.16 handler](https://raw.githubusercontent.com/argoproj-labs/argo-dataflow/main/examples/104-go1-16-pipeline.yaml)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -34,7 +34,7 @@ metadata:
of replicas re-calculated.
dataflow.argoproj.io/name: Using replicas and auto-scaling
creationTimestamp: null
name: replicas
name: autoscaling
spec:
steps:
- cat: {}
Expand Down
25 changes: 25 additions & 0 deletions examples/103-scaling-pipeline.yaml
Original file line number Diff line number Diff line change
@@ -0,0 +1,25 @@
apiVersion: dataflow.argoproj.io/v1alpha1
kind: Pipeline
metadata:
annotations:
dataflow.argoproj.io/description: |
This is an example of having multiple replicas for a single step.
Steps can be manually scaled using `kubectl`:
```
kubectl scale step/stepName --replicas 2
```
creationTimestamp: null
name: scaling
spec:
steps:
- cat: {}
name: main
replicas: 2
sinks:
- kafka:
topic: output-topic
sources:
- kafka:
topic: input-topic

0 comments on commit 122acc3

Please sign in to comment.