sriumcp

func newIter8Watcher(autoXConfig config) *iter8Watcher {
	w := &iter8Watcher{
		factories: map[string]dynamicinformer.DynamicSharedInformerFactory{},
	}

	// aggregate all triggers (namespaces and GVR) from the releaseGroupConfig
	// triggers map has namespace as its key and the object GVRs within the namespace that it is watching as its value
	triggers := map[string][]schema.GroupVersionResource{}
	for _, releaseGroupSpec := range autoXConfig.Specs {

sriumcp

{
  "name": "Iter8 user"
}

sriumcp

- provider: newrelic
  uri: /newrelic
  versions:
  - params:
    - name: nrql
      value: "SELECT average\\(duration\\) FROM Sessions WHERE version='v1' SINCE .* sec ago\n"
    metric:
      type: gauge
      shift: 5
      multiplier: 10

sriumcp

- provider: Prometheus # this URI will generate metrics in Prometheus response format
  uri: /promcounter # do not use / for the uri; will lead to unexpected bad things; also make sure URIs are unique
  # every query to this URI needs to have the following headers
  headers:
    user: abcd
    pass: efgh
  # this URI will generate metrics for the following versions
  versions:
  - params: # params for version 1 should match the following; 
    - name: query

sriumcp

apiVersion: iter8.tools/v1alpha1
kind: UniversalExperiment 
# Experiment with any kubernetes entity and its versions on any kubernetes backend.
# Some examples of backends, entities, and versions that are supported are as follows.
# CR in this example focuses on item #2 in the list.
# 1. Backend = k8s. Entity-version = service-deployments
# 2. Backend = k8s + Istio. Entity-version = service-deployments
# 3. Backend = k8s + SMI. Entity-version = service-deployments
# 4. Backend = k8s + linkerd. Entity-version = service-deployments
# 5. Backend = k8s + Gloo. Entity-version = service-deployments. Note: Gloo itself can use multiple backends.

sriumcp

{
  "version": "0.7.0",
  "app": {
    "_id": "jetLpRfQ3BCRGiMxe",
    "userId": "guest",
    "name": "Sample",
    "private": false,
    "selectedDashboardId": "ruHbJhctjLhCYZiof"
  },
  "dashboards": [

sriumcp

{
  "version": "0.7.0",
  "app": {
    "_id": "Q4EnorTFxvG9gyHyB",
    "userId": "guest",
    "name": "Time Series",
    "private": true,
    "selectedDashboardId": "7kGXWA8K4yM55PCji"
  },
  "dashboards": [

sriumcp

[
  1.1693609877053437,
  2.414213562373091,
  5,
  -4.182662140446601,
  -1.6307015302148402,
  -0.8551679169341168,
  -0.4149498750489046,
  -0.07965009291617457,
  0.2394143257845769,

sriumcp

namespace application ;

use com.ibm.streamsx.inet.rest::HTTPTupleView ;
use com.ibm.streamsx.inet.wsserver::WebSocketSend ;

/* This SPL application creates a data stream called 'time', and provides 
* three different ways of accessing it via READ */

composite Main
{

sriumcp

/* Code to initialize the socket -- uses socket.io events; */
let socket = io.connect('http://sockethost:socketport');

/* A thin wrapper to convert socket.io events to Rx events */
/* This piece of code ensures that when there is new data on the socket, that data gets pushed as a new message onto the dataStream, 
which is really an Rx.Observable */
/* dataStream responds to 'data' events on the socket */

let dataStream = Rx.Observable.fromEventPattern(
  function addHandler(dataHandler) {