Skip to content

Commit

Permalink
cloud output: update docs
Browse files Browse the repository at this point in the history
  • Loading branch information
yorugac committed May 13, 2022
1 parent 5bc7ceb commit 515daa7
Show file tree
Hide file tree
Showing 3 changed files with 6 additions and 2 deletions.
4 changes: 3 additions & 1 deletion README.md
Original file line number Diff line number Diff line change
Expand Up @@ -158,7 +158,9 @@ Defines options for the starter pod. This includes:
#### k6 Cloud output
k6 supports [output to its Cloud](https://k6.io/docs/results-visualization/cloud) with `k6 run --out cloud script.js` command. To use this option in k6-operator, set the argument in yaml:
k6 supports [output to its Cloud](https://k6.io/docs/results-visualization/cloud) with `k6 run --out cloud script.js` command. This feature is available in k6-operator as well for subscribed users. Note that it supports only `parallelism: 20` or less.

To use this option in k6-operator, set the argument in yaml:

```yaml
...
Expand Down
2 changes: 2 additions & 0 deletions controllers/k6_controller.go
Original file line number Diff line number Diff line change
Expand Up @@ -63,6 +63,8 @@ func (r *K6Reconciler) Reconcile(req ctrl.Request) (ctrl.Result, error) {
return InitializeJobs(ctx, log, k6, r)
case "initialization":
// here we're just waiting until initialize is done
// Note: it is present as a separate stage to ensure there's only one
// initialization job at a time
return ctrl.Result{}, nil
case "initialized":
return CreateJobs(ctx, log, k6, r)
Expand Down
2 changes: 1 addition & 1 deletion controllers/k6_initialize.go
Original file line number Diff line number Diff line change
Expand Up @@ -156,7 +156,7 @@ func InitializeJobs(ctx context.Context, log logr.Logger, k6 *v1alpha1.K6, r *K6
var inspectOutput cloud.InspectOutput

if err := json.Unmarshal(buf.Bytes(), &inspectOutput); err != nil {
// this shouldn't normally happen to if it does, let's log output by default
// this shouldn't normally happen but if it does, let's log output by default
log.Error(err, fmt.Sprintf("unable to marshal: `%s`", buf.String()))
return true, err
}
Expand Down

0 comments on commit 515daa7

Please sign in to comment.