import io.swagger.client.*;
import io.swagger.client.auth.*;
import io.swagger.client.model.*;
import io.swagger.client.api.Class1SRMServiceAPIV2Api;

import java.io.File;
import java.util.*;

public class Class1SRMServiceAPIV2ApiExample {

    public static void main(String[] args) {
        ApiClient defaultClient = Configuration.getDefaultApiClient();

        // Configure API key authorization: Authorization
        ApiKeyAuth Authorization = (ApiKeyAuth) defaultClient.getAuthentication("Authorization");
        Authorization.setApiKey("YOUR API KEY");
        // Uncomment the following line to set a prefix for the API key, e.g. "Token" (defaults to null)
        //Authorization.setApiKeyPrefix("Token");

        Class1SRMServiceAPIV2Api apiInstance = new Class1SRMServiceAPIV2Api();
        String kafkaClusterId = kafkaClusterId_example; // String | Cluster ID of the Kafka cluster.
        try {
            ClusterInfo result = apiInstance.clusterInfo(kafkaClusterId);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling Class1SRMServiceAPIV2Api#clusterInfo");
            e.printStackTrace();
        }
    }
}

import io.swagger.client.api.Class1SRMServiceAPIV2Api;

public class Class1SRMServiceAPIV2ApiExample {

    public static void main(String[] args) {
        Class1SRMServiceAPIV2Api apiInstance = new Class1SRMServiceAPIV2Api();
        String kafkaClusterId = kafkaClusterId_example; // String | Cluster ID of the Kafka cluster.
        try {
            ClusterInfo result = apiInstance.clusterInfo(kafkaClusterId);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling Class1SRMServiceAPIV2Api#clusterInfo");
            e.printStackTrace();
        }
    }
}

Configuration *apiConfig = [Configuration sharedConfig];
// Configure API key authorization: (authentication scheme: Authorization)
[apiConfig setApiKey:@"YOUR_API_KEY" forApiKeyIdentifier:@"Authorization"];
// Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
//[apiConfig setApiKeyPrefix:@"Bearer" forApiKeyIdentifier:@"Authorization"];
String *kafkaClusterId = kafkaClusterId_example; // Cluster ID of the Kafka cluster.

Class1SRMServiceAPIV2Api *apiInstance = [[Class1SRMServiceAPIV2Api alloc] init];

// Get cluster info for the specified Kafka cluster ID.
[apiInstance clusterInfoWith:kafkaClusterId
              completionHandler: ^(ClusterInfo output, NSError* error) {
                            if (output) {
                                NSLog(@"%@", output);
                            }
                            if (error) {
                                NSLog(@"Error: %@", error);
                            }
                        }];

var SwaggerJsClient = require('swagger-js-client');
var defaultClient = SwaggerJsClient.ApiClient.instance;

// Configure API key authorization: Authorization
var Authorization = defaultClient.authentications['Authorization'];
Authorization.apiKey = "YOUR API KEY"
// Uncomment the following line to set a prefix for the API key, e.g. "Token" (defaults to null)
//Authorization.apiKeyPrefix['Authorization'] = "Token"

var api = new SwaggerJsClient.Class1SRMServiceAPIV2Api()
var kafkaClusterId = kafkaClusterId_example; // {{String}} Cluster ID of the Kafka cluster.

var callback = function(error, data, response) {
  if (error) {
    console.error(error);
  } else {
    console.log('API called successfully. Returned data: ' + data);
  }
};
api.clusterInfo(kafkaClusterId, callback);

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class clusterInfoExample
    {
        public void main()
        {

            // Configure API key authorization: Authorization
            Configuration.Default.ApiKey.Add("Authorization", "YOUR_API_KEY");
            // Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
            // Configuration.Default.ApiKeyPrefix.Add("Authorization", "Bearer");

            var apiInstance = new Class1SRMServiceAPIV2Api();
            var kafkaClusterId = kafkaClusterId_example;  // String | Cluster ID of the Kafka cluster.

            try
            {
                // Get cluster info for the specified Kafka cluster ID.
                ClusterInfo result = apiInstance.clusterInfo(kafkaClusterId);
                Debug.WriteLine(result);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling Class1SRMServiceAPIV2Api.clusterInfo: " + e.Message );
            }
        }
    }
}

<?php
require_once(__DIR__ . '/vendor/autoload.php');

// Configure API key authorization: Authorization
Swagger\Client\Configuration::getDefaultConfiguration()->setApiKey('Authorization', 'YOUR_API_KEY');
// Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
// Swagger\Client\Configuration::getDefaultConfiguration()->setApiKeyPrefix('Authorization', 'Bearer');

$api_instance = new Swagger\Client\ApiClass1SRMServiceAPIV2Api();
$kafkaClusterId = kafkaClusterId_example; // String | Cluster ID of the Kafka cluster.

try {
    $result = $api_instance->clusterInfo($kafkaClusterId);
    print_r($result);
} catch (Exception $e) {
    echo 'Exception when calling Class1SRMServiceAPIV2Api->clusterInfo: ', $e->getMessage(), PHP_EOL;
}
?>

use Data::Dumper;
use WWW::SwaggerClient::Configuration;
use WWW::SwaggerClient::Class1SRMServiceAPIV2Api;

# Configure API key authorization: Authorization
$WWW::SwaggerClient::Configuration::api_key->{'Authorization'} = 'YOUR_API_KEY';
# uncomment below to setup prefix (e.g. Bearer) for API key, if needed
#$WWW::SwaggerClient::Configuration::api_key_prefix->{'Authorization'} = "Bearer";

my $api_instance = WWW::SwaggerClient::Class1SRMServiceAPIV2Api->new();
my $kafkaClusterId = kafkaClusterId_example; # String | Cluster ID of the Kafka cluster.

eval { 
    my $result = $api_instance->clusterInfo(kafkaClusterId => $kafkaClusterId);
    print Dumper($result);
};
if ($@) {
    warn "Exception when calling Class1SRMServiceAPIV2Api->clusterInfo: $@\n";
}

from __future__ import print_statement
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# Configure API key authorization: Authorization
swagger_client.configuration.api_key['Authorization'] = 'YOUR_API_KEY'
# Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
# swagger_client.configuration.api_key_prefix['Authorization'] = 'Bearer'

# create an instance of the API class
api_instance = swagger_client.Class1SRMServiceAPIV2Api()
kafkaClusterId = kafkaClusterId_example # String | Cluster ID of the Kafka cluster.

try: 
    # Get cluster info for the specified Kafka cluster ID.
    api_response = api_instance.cluster_info(kafkaClusterId)
    pprint(api_response)
except ApiException as e:
    print("Exception when calling Class1SRMServiceAPIV2Api->clusterInfo: %s\n" % e)

import io.swagger.client.*;
import io.swagger.client.auth.*;
import io.swagger.client.model.*;
import io.swagger.client.api.Class1SRMServiceAPIV2Api;

import java.io.File;
import java.util.*;

public class Class1SRMServiceAPIV2ApiExample {

    public static void main(String[] args) {
        ApiClient defaultClient = Configuration.getDefaultApiClient();

        // Configure API key authorization: Authorization
        ApiKeyAuth Authorization = (ApiKeyAuth) defaultClient.getAuthentication("Authorization");
        Authorization.setApiKey("YOUR API KEY");
        // Uncomment the following line to set a prefix for the API key, e.g. "Token" (defaults to null)
        //Authorization.setApiKeyPrefix("Token");

        Class1SRMServiceAPIV2Api apiInstance = new Class1SRMServiceAPIV2Api();
        String source = source_example; // String | Cluster alias of the source Kafka cluster.
        String target = target_example; // String | Cluster alias of the target Kafka cluster.
        String metric = metric_example; // String | Metric name.
        Integer minutes = 56; // Integer | Last {x} minutes to limit the query to.
        Integer hours = 56; // Integer | Last {x} hours to limit the query to.
        Long from = 789; // Long | Starting point of the query time range. Specify this value in epoch milli time format.
        Long to = 789; // Long | End point of the query time range. Specify this value in epoch milli time format.
        Integer samples = 56; // Integer | Number of samples to limit the query to.
        try {
            TimeSeriesResponseNumericMetricStats result = apiInstance.clusterMetrics1(source, target, metric, minutes, hours, from, to, samples);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling Class1SRMServiceAPIV2Api#clusterMetrics1");
            e.printStackTrace();
        }
    }
}

import io.swagger.client.api.Class1SRMServiceAPIV2Api;

public class Class1SRMServiceAPIV2ApiExample {

    public static void main(String[] args) {
        Class1SRMServiceAPIV2Api apiInstance = new Class1SRMServiceAPIV2Api();
        String source = source_example; // String | Cluster alias of the source Kafka cluster.
        String target = target_example; // String | Cluster alias of the target Kafka cluster.
        String metric = metric_example; // String | Metric name.
        Integer minutes = 56; // Integer | Last {x} minutes to limit the query to.
        Integer hours = 56; // Integer | Last {x} hours to limit the query to.
        Long from = 789; // Long | Starting point of the query time range. Specify this value in epoch milli time format.
        Long to = 789; // Long | End point of the query time range. Specify this value in epoch milli time format.
        Integer samples = 56; // Integer | Number of samples to limit the query to.
        try {
            TimeSeriesResponseNumericMetricStats result = apiInstance.clusterMetrics1(source, target, metric, minutes, hours, from, to, samples);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling Class1SRMServiceAPIV2Api#clusterMetrics1");
            e.printStackTrace();
        }
    }
}

Configuration *apiConfig = [Configuration sharedConfig];
// Configure API key authorization: (authentication scheme: Authorization)
[apiConfig setApiKey:@"YOUR_API_KEY" forApiKeyIdentifier:@"Authorization"];
// Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
//[apiConfig setApiKeyPrefix:@"Bearer" forApiKeyIdentifier:@"Authorization"];
String *source = source_example; // Cluster alias of the source Kafka cluster.
String *target = target_example; // Cluster alias of the target Kafka cluster.
String *metric = metric_example; // Metric name.
Integer *minutes = 56; // Last {x} minutes to limit the query to. (optional)
Integer *hours = 56; // Last {x} hours to limit the query to. (optional)
Long *from = 789; // Starting point of the query time range. Specify this value in epoch milli time format. (optional)
Long *to = 789; // End point of the query time range. Specify this value in epoch milli time format. (optional)
Integer *samples = 56; // Number of samples to limit the query to. (optional) (default to 1000)

Class1SRMServiceAPIV2Api *apiInstance = [[Class1SRMServiceAPIV2Api alloc] init];

// Get cluster-level metric data of the specified replication.
[apiInstance clusterMetrics1With:source
    target:target
    metric:metric
    minutes:minutes
    hours:hours
    from:from
    to:to
    samples:samples
              completionHandler: ^(TimeSeriesResponseNumericMetricStats output, NSError* error) {
                            if (output) {
                                NSLog(@"%@", output);
                            }
                            if (error) {
                                NSLog(@"Error: %@", error);
                            }
                        }];

var SwaggerJsClient = require('swagger-js-client');
var defaultClient = SwaggerJsClient.ApiClient.instance;

// Configure API key authorization: Authorization
var Authorization = defaultClient.authentications['Authorization'];
Authorization.apiKey = "YOUR API KEY"
// Uncomment the following line to set a prefix for the API key, e.g. "Token" (defaults to null)
//Authorization.apiKeyPrefix['Authorization'] = "Token"

var api = new SwaggerJsClient.Class1SRMServiceAPIV2Api()
var source = source_example; // {{String}} Cluster alias of the source Kafka cluster.
var target = target_example; // {{String}} Cluster alias of the target Kafka cluster.
var metric = metric_example; // {{String}} Metric name.
var opts = { 
  'minutes': 56, // {{Integer}} Last {x} minutes to limit the query to.
  'hours': 56, // {{Integer}} Last {x} hours to limit the query to.
  'from': 789, // {{Long}} Starting point of the query time range. Specify this value in epoch milli time format.
  'to': 789, // {{Long}} End point of the query time range. Specify this value in epoch milli time format.
  'samples': 56 // {{Integer}} Number of samples to limit the query to.
};
var callback = function(error, data, response) {
  if (error) {
    console.error(error);
  } else {
    console.log('API called successfully. Returned data: ' + data);
  }
};
api.clusterMetrics1(source, target, metric, opts, callback);

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class clusterMetrics1Example
    {
        public void main()
        {

            // Configure API key authorization: Authorization
            Configuration.Default.ApiKey.Add("Authorization", "YOUR_API_KEY");
            // Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
            // Configuration.Default.ApiKeyPrefix.Add("Authorization", "Bearer");

            var apiInstance = new Class1SRMServiceAPIV2Api();
            var source = source_example;  // String | Cluster alias of the source Kafka cluster.
            var target = target_example;  // String | Cluster alias of the target Kafka cluster.
            var metric = metric_example;  // String | Metric name.
            var minutes = 56;  // Integer | Last {x} minutes to limit the query to. (optional) 
            var hours = 56;  // Integer | Last {x} hours to limit the query to. (optional) 
            var from = 789;  // Long | Starting point of the query time range. Specify this value in epoch milli time format. (optional) 
            var to = 789;  // Long | End point of the query time range. Specify this value in epoch milli time format. (optional) 
            var samples = 56;  // Integer | Number of samples to limit the query to. (optional)  (default to 1000)

            try
            {
                // Get cluster-level metric data of the specified replication.
                TimeSeriesResponseNumericMetricStats result = apiInstance.clusterMetrics1(source, target, metric, minutes, hours, from, to, samples);
                Debug.WriteLine(result);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling Class1SRMServiceAPIV2Api.clusterMetrics1: " + e.Message );
            }
        }
    }
}

<?php
require_once(__DIR__ . '/vendor/autoload.php');

// Configure API key authorization: Authorization
Swagger\Client\Configuration::getDefaultConfiguration()->setApiKey('Authorization', 'YOUR_API_KEY');
// Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
// Swagger\Client\Configuration::getDefaultConfiguration()->setApiKeyPrefix('Authorization', 'Bearer');

$api_instance = new Swagger\Client\ApiClass1SRMServiceAPIV2Api();
$source = source_example; // String | Cluster alias of the source Kafka cluster.
$target = target_example; // String | Cluster alias of the target Kafka cluster.
$metric = metric_example; // String | Metric name.
$minutes = 56; // Integer | Last {x} minutes to limit the query to.
$hours = 56; // Integer | Last {x} hours to limit the query to.
$from = 789; // Long | Starting point of the query time range. Specify this value in epoch milli time format.
$to = 789; // Long | End point of the query time range. Specify this value in epoch milli time format.
$samples = 56; // Integer | Number of samples to limit the query to.

try {
    $result = $api_instance->clusterMetrics1($source, $target, $metric, $minutes, $hours, $from, $to, $samples);
    print_r($result);
} catch (Exception $e) {
    echo 'Exception when calling Class1SRMServiceAPIV2Api->clusterMetrics1: ', $e->getMessage(), PHP_EOL;
}
?>

use Data::Dumper;
use WWW::SwaggerClient::Configuration;
use WWW::SwaggerClient::Class1SRMServiceAPIV2Api;

# Configure API key authorization: Authorization
$WWW::SwaggerClient::Configuration::api_key->{'Authorization'} = 'YOUR_API_KEY';
# uncomment below to setup prefix (e.g. Bearer) for API key, if needed
#$WWW::SwaggerClient::Configuration::api_key_prefix->{'Authorization'} = "Bearer";

my $api_instance = WWW::SwaggerClient::Class1SRMServiceAPIV2Api->new();
my $source = source_example; # String | Cluster alias of the source Kafka cluster.
my $target = target_example; # String | Cluster alias of the target Kafka cluster.
my $metric = metric_example; # String | Metric name.
my $minutes = 56; # Integer | Last {x} minutes to limit the query to.
my $hours = 56; # Integer | Last {x} hours to limit the query to.
my $from = 789; # Long | Starting point of the query time range. Specify this value in epoch milli time format.
my $to = 789; # Long | End point of the query time range. Specify this value in epoch milli time format.
my $samples = 56; # Integer | Number of samples to limit the query to.

eval { 
    my $result = $api_instance->clusterMetrics1(source => $source, target => $target, metric => $metric, minutes => $minutes, hours => $hours, from => $from, to => $to, samples => $samples);
    print Dumper($result);
};
if ($@) {
    warn "Exception when calling Class1SRMServiceAPIV2Api->clusterMetrics1: $@\n";
}

from __future__ import print_statement
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# Configure API key authorization: Authorization
swagger_client.configuration.api_key['Authorization'] = 'YOUR_API_KEY'
# Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
# swagger_client.configuration.api_key_prefix['Authorization'] = 'Bearer'

# create an instance of the API class
api_instance = swagger_client.Class1SRMServiceAPIV2Api()
source = source_example # String | Cluster alias of the source Kafka cluster.
target = target_example # String | Cluster alias of the target Kafka cluster.
metric = metric_example # String | Metric name.
minutes = 56 # Integer | Last {x} minutes to limit the query to. (optional)
hours = 56 # Integer | Last {x} hours to limit the query to. (optional)
from = 789 # Long | Starting point of the query time range. Specify this value in epoch milli time format. (optional)
to = 789 # Long | End point of the query time range. Specify this value in epoch milli time format. (optional)
samples = 56 # Integer | Number of samples to limit the query to. (optional) (default to 1000)

try: 
    # Get cluster-level metric data of the specified replication.
    api_response = api_instance.cluster_metrics1(source, target, metric, minutes=minutes, hours=hours, from=from, to=to, samples=samples)
    pprint(api_response)
except ApiException as e:
    print("Exception when calling Class1SRMServiceAPIV2Api->clusterMetrics1: %s\n" % e)

import io.swagger.client.*;
import io.swagger.client.auth.*;
import io.swagger.client.model.*;
import io.swagger.client.api.Class1SRMServiceAPIV2Api;

import java.io.File;
import java.util.*;

public class Class1SRMServiceAPIV2ApiExample {

    public static void main(String[] args) {
        ApiClient defaultClient = Configuration.getDefaultApiClient();

        // Configure API key authorization: Authorization
        ApiKeyAuth Authorization = (ApiKeyAuth) defaultClient.getAuthentication("Authorization");
        Authorization.setApiKey("YOUR API KEY");
        // Uncomment the following line to set a prefix for the API key, e.g. "Token" (defaults to null)
        //Authorization.setApiKeyPrefix("Token");

        Class1SRMServiceAPIV2Api apiInstance = new Class1SRMServiceAPIV2Api();
        String source = source_example; // String | Cluster alias of the source Kafka cluster.
        String target = target_example; // String | Cluster alias of the target Kafka cluster.
        Integer minutes = 56; // Integer | Last {x} minutes to limit the query to.
        Integer hours = 56; // Integer | Last {x} hours to limit the query to.
        Long from = 789; // Long | Starting point of the query time range. Specify this value in epoch milli time format.
        Long to = 789; // Long | End point of the query time range. Specify this value in epoch milli time format.
        try {
            map['String', TopicInfo] result = apiInstance.remoteTopics1(source, target, minutes, hours, from, to);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling Class1SRMServiceAPIV2Api#remoteTopics1");
            e.printStackTrace();
        }
    }
}

import io.swagger.client.api.Class1SRMServiceAPIV2Api;

public class Class1SRMServiceAPIV2ApiExample {

    public static void main(String[] args) {
        Class1SRMServiceAPIV2Api apiInstance = new Class1SRMServiceAPIV2Api();
        String source = source_example; // String | Cluster alias of the source Kafka cluster.
        String target = target_example; // String | Cluster alias of the target Kafka cluster.
        Integer minutes = 56; // Integer | Last {x} minutes to limit the query to.
        Integer hours = 56; // Integer | Last {x} hours to limit the query to.
        Long from = 789; // Long | Starting point of the query time range. Specify this value in epoch milli time format.
        Long to = 789; // Long | End point of the query time range. Specify this value in epoch milli time format.
        try {
            map['String', TopicInfo] result = apiInstance.remoteTopics1(source, target, minutes, hours, from, to);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling Class1SRMServiceAPIV2Api#remoteTopics1");
            e.printStackTrace();
        }
    }
}

Configuration *apiConfig = [Configuration sharedConfig];
// Configure API key authorization: (authentication scheme: Authorization)
[apiConfig setApiKey:@"YOUR_API_KEY" forApiKeyIdentifier:@"Authorization"];
// Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
//[apiConfig setApiKeyPrefix:@"Bearer" forApiKeyIdentifier:@"Authorization"];
String *source = source_example; // Cluster alias of the source Kafka cluster.
String *target = target_example; // Cluster alias of the target Kafka cluster.
Integer *minutes = 56; // Last {x} minutes to limit the query to. (optional)
Integer *hours = 56; // Last {x} hours to limit the query to. (optional)
Long *from = 789; // Starting point of the query time range. Specify this value in epoch milli time format. (optional)
Long *to = 789; // End point of the query time range. Specify this value in epoch milli time format. (optional)

Class1SRMServiceAPIV2Api *apiInstance = [[Class1SRMServiceAPIV2Api alloc] init];

// Get topic info about topics replicated from the specified source to the specified target.
[apiInstance remoteTopics1With:source
    target:target
    minutes:minutes
    hours:hours
    from:from
    to:to
              completionHandler: ^(map['String', TopicInfo] output, NSError* error) {
                            if (output) {
                                NSLog(@"%@", output);
                            }
                            if (error) {
                                NSLog(@"Error: %@", error);
                            }
                        }];

var SwaggerJsClient = require('swagger-js-client');
var defaultClient = SwaggerJsClient.ApiClient.instance;

// Configure API key authorization: Authorization
var Authorization = defaultClient.authentications['Authorization'];
Authorization.apiKey = "YOUR API KEY"
// Uncomment the following line to set a prefix for the API key, e.g. "Token" (defaults to null)
//Authorization.apiKeyPrefix['Authorization'] = "Token"

var api = new SwaggerJsClient.Class1SRMServiceAPIV2Api()
var source = source_example; // {{String}} Cluster alias of the source Kafka cluster.
var target = target_example; // {{String}} Cluster alias of the target Kafka cluster.
var opts = { 
  'minutes': 56, // {{Integer}} Last {x} minutes to limit the query to.
  'hours': 56, // {{Integer}} Last {x} hours to limit the query to.
  'from': 789, // {{Long}} Starting point of the query time range. Specify this value in epoch milli time format.
  'to': 789 // {{Long}} End point of the query time range. Specify this value in epoch milli time format.
};
var callback = function(error, data, response) {
  if (error) {
    console.error(error);
  } else {
    console.log('API called successfully. Returned data: ' + data);
  }
};
api.remoteTopics1(source, target, opts, callback);

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class remoteTopics1Example
    {
        public void main()
        {

            // Configure API key authorization: Authorization
            Configuration.Default.ApiKey.Add("Authorization", "YOUR_API_KEY");
            // Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
            // Configuration.Default.ApiKeyPrefix.Add("Authorization", "Bearer");

            var apiInstance = new Class1SRMServiceAPIV2Api();
            var source = source_example;  // String | Cluster alias of the source Kafka cluster.
            var target = target_example;  // String | Cluster alias of the target Kafka cluster.
            var minutes = 56;  // Integer | Last {x} minutes to limit the query to. (optional) 
            var hours = 56;  // Integer | Last {x} hours to limit the query to. (optional) 
            var from = 789;  // Long | Starting point of the query time range. Specify this value in epoch milli time format. (optional) 
            var to = 789;  // Long | End point of the query time range. Specify this value in epoch milli time format. (optional) 

            try
            {
                // Get topic info about topics replicated from the specified source to the specified target.
                map['String', TopicInfo] result = apiInstance.remoteTopics1(source, target, minutes, hours, from, to);
                Debug.WriteLine(result);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling Class1SRMServiceAPIV2Api.remoteTopics1: " + e.Message );
            }
        }
    }
}

<?php
require_once(__DIR__ . '/vendor/autoload.php');

// Configure API key authorization: Authorization
Swagger\Client\Configuration::getDefaultConfiguration()->setApiKey('Authorization', 'YOUR_API_KEY');
// Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
// Swagger\Client\Configuration::getDefaultConfiguration()->setApiKeyPrefix('Authorization', 'Bearer');

$api_instance = new Swagger\Client\ApiClass1SRMServiceAPIV2Api();
$source = source_example; // String | Cluster alias of the source Kafka cluster.
$target = target_example; // String | Cluster alias of the target Kafka cluster.
$minutes = 56; // Integer | Last {x} minutes to limit the query to.
$hours = 56; // Integer | Last {x} hours to limit the query to.
$from = 789; // Long | Starting point of the query time range. Specify this value in epoch milli time format.
$to = 789; // Long | End point of the query time range. Specify this value in epoch milli time format.

try {
    $result = $api_instance->remoteTopics1($source, $target, $minutes, $hours, $from, $to);
    print_r($result);
} catch (Exception $e) {
    echo 'Exception when calling Class1SRMServiceAPIV2Api->remoteTopics1: ', $e->getMessage(), PHP_EOL;
}
?>

use Data::Dumper;
use WWW::SwaggerClient::Configuration;
use WWW::SwaggerClient::Class1SRMServiceAPIV2Api;

# Configure API key authorization: Authorization
$WWW::SwaggerClient::Configuration::api_key->{'Authorization'} = 'YOUR_API_KEY';
# uncomment below to setup prefix (e.g. Bearer) for API key, if needed
#$WWW::SwaggerClient::Configuration::api_key_prefix->{'Authorization'} = "Bearer";

my $api_instance = WWW::SwaggerClient::Class1SRMServiceAPIV2Api->new();
my $source = source_example; # String | Cluster alias of the source Kafka cluster.
my $target = target_example; # String | Cluster alias of the target Kafka cluster.
my $minutes = 56; # Integer | Last {x} minutes to limit the query to.
my $hours = 56; # Integer | Last {x} hours to limit the query to.
my $from = 789; # Long | Starting point of the query time range. Specify this value in epoch milli time format.
my $to = 789; # Long | End point of the query time range. Specify this value in epoch milli time format.

eval { 
    my $result = $api_instance->remoteTopics1(source => $source, target => $target, minutes => $minutes, hours => $hours, from => $from, to => $to);
    print Dumper($result);
};
if ($@) {
    warn "Exception when calling Class1SRMServiceAPIV2Api->remoteTopics1: $@\n";
}

from __future__ import print_statement
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# Configure API key authorization: Authorization
swagger_client.configuration.api_key['Authorization'] = 'YOUR_API_KEY'
# Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
# swagger_client.configuration.api_key_prefix['Authorization'] = 'Bearer'

# create an instance of the API class
api_instance = swagger_client.Class1SRMServiceAPIV2Api()
source = source_example # String | Cluster alias of the source Kafka cluster.
target = target_example # String | Cluster alias of the target Kafka cluster.
minutes = 56 # Integer | Last {x} minutes to limit the query to. (optional)
hours = 56 # Integer | Last {x} hours to limit the query to. (optional)
from = 789 # Long | Starting point of the query time range. Specify this value in epoch milli time format. (optional)
to = 789 # Long | End point of the query time range. Specify this value in epoch milli time format. (optional)

try: 
    # Get topic info about topics replicated from the specified source to the specified target.
    api_response = api_instance.remote_topics1(source, target, minutes=minutes, hours=hours, from=from, to=to)
    pprint(api_response)
except ApiException as e:
    print("Exception when calling Class1SRMServiceAPIV2Api->remoteTopics1: %s\n" % e)

import io.swagger.client.*;
import io.swagger.client.auth.*;
import io.swagger.client.model.*;
import io.swagger.client.api.Class1SRMServiceAPIV2Api;

import java.io.File;
import java.util.*;

public class Class1SRMServiceAPIV2ApiExample {

    public static void main(String[] args) {
        ApiClient defaultClient = Configuration.getDefaultApiClient();

        // Configure API key authorization: Authorization
        ApiKeyAuth Authorization = (ApiKeyAuth) defaultClient.getAuthentication("Authorization");
        Authorization.setApiKey("YOUR API KEY");
        // Uncomment the following line to set a prefix for the API key, e.g. "Token" (defaults to null)
        //Authorization.setApiKeyPrefix("Token");

        Class1SRMServiceAPIV2Api apiInstance = new Class1SRMServiceAPIV2Api();
        array[String] sources = ; // array[String] | Cluster alias(es) of the source Kafka cluster(s).
        array[String] targets = ; // array[String] | Cluster alias(es) of the target Kafka cluster(s).
        Integer minutes = 56; // Integer | Last {x} minutes to limit the query to.
        Integer hours = 56; // Integer | Last {x} hours to limit the query to.
        Long from = 789; // Long | Starting point of the query time range. Specify this value in epoch milli time format.
        Long to = 789; // Long | End point of the query time range. Specify this value in epoch milli time format.
        try {
            map['String', ReplicationInfo] result = apiInstance.replications(sources, targets, minutes, hours, from, to);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling Class1SRMServiceAPIV2Api#replications");
            e.printStackTrace();
        }
    }
}

import io.swagger.client.api.Class1SRMServiceAPIV2Api;

public class Class1SRMServiceAPIV2ApiExample {

    public static void main(String[] args) {
        Class1SRMServiceAPIV2Api apiInstance = new Class1SRMServiceAPIV2Api();
        array[String] sources = ; // array[String] | Cluster alias(es) of the source Kafka cluster(s).
        array[String] targets = ; // array[String] | Cluster alias(es) of the target Kafka cluster(s).
        Integer minutes = 56; // Integer | Last {x} minutes to limit the query to.
        Integer hours = 56; // Integer | Last {x} hours to limit the query to.
        Long from = 789; // Long | Starting point of the query time range. Specify this value in epoch milli time format.
        Long to = 789; // Long | End point of the query time range. Specify this value in epoch milli time format.
        try {
            map['String', ReplicationInfo] result = apiInstance.replications(sources, targets, minutes, hours, from, to);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling Class1SRMServiceAPIV2Api#replications");
            e.printStackTrace();
        }
    }
}

Configuration *apiConfig = [Configuration sharedConfig];
// Configure API key authorization: (authentication scheme: Authorization)
[apiConfig setApiKey:@"YOUR_API_KEY" forApiKeyIdentifier:@"Authorization"];
// Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
//[apiConfig setApiKeyPrefix:@"Bearer" forApiKeyIdentifier:@"Authorization"];
array[String] *sources = ; // Cluster alias(es) of the source Kafka cluster(s). (optional)
array[String] *targets = ; // Cluster alias(es) of the target Kafka cluster(s). (optional)
Integer *minutes = 56; // Last {x} minutes to limit the query to. (optional)
Integer *hours = 56; // Last {x} hours to limit the query to. (optional)
Long *from = 789; // Starting point of the query time range. Specify this value in epoch milli time format. (optional)
Long *to = 789; // End point of the query time range. Specify this value in epoch milli time format. (optional)

Class1SRMServiceAPIV2Api *apiInstance = [[Class1SRMServiceAPIV2Api alloc] init];

// Get replication info about the replications with the specified sources and targets.
[apiInstance replicationsWith:sources
    targets:targets
    minutes:minutes
    hours:hours
    from:from
    to:to
              completionHandler: ^(map['String', ReplicationInfo] output, NSError* error) {
                            if (output) {
                                NSLog(@"%@", output);
                            }
                            if (error) {
                                NSLog(@"Error: %@", error);
                            }
                        }];

var SwaggerJsClient = require('swagger-js-client');
var defaultClient = SwaggerJsClient.ApiClient.instance;

// Configure API key authorization: Authorization
var Authorization = defaultClient.authentications['Authorization'];
Authorization.apiKey = "YOUR API KEY"
// Uncomment the following line to set a prefix for the API key, e.g. "Token" (defaults to null)
//Authorization.apiKeyPrefix['Authorization'] = "Token"

var api = new SwaggerJsClient.Class1SRMServiceAPIV2Api()
var opts = { 
  'sources': , // {{array[String]}} Cluster alias(es) of the source Kafka cluster(s).
  'targets': , // {{array[String]}} Cluster alias(es) of the target Kafka cluster(s).
  'minutes': 56, // {{Integer}} Last {x} minutes to limit the query to.
  'hours': 56, // {{Integer}} Last {x} hours to limit the query to.
  'from': 789, // {{Long}} Starting point of the query time range. Specify this value in epoch milli time format.
  'to': 789 // {{Long}} End point of the query time range. Specify this value in epoch milli time format.
};
var callback = function(error, data, response) {
  if (error) {
    console.error(error);
  } else {
    console.log('API called successfully. Returned data: ' + data);
  }
};
api.replications(opts, callback);

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class replicationsExample
    {
        public void main()
        {

            // Configure API key authorization: Authorization
            Configuration.Default.ApiKey.Add("Authorization", "YOUR_API_KEY");
            // Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
            // Configuration.Default.ApiKeyPrefix.Add("Authorization", "Bearer");

            var apiInstance = new Class1SRMServiceAPIV2Api();
            var sources = new array[String](); // array[String] | Cluster alias(es) of the source Kafka cluster(s). (optional) 
            var targets = new array[String](); // array[String] | Cluster alias(es) of the target Kafka cluster(s). (optional) 
            var minutes = 56;  // Integer | Last {x} minutes to limit the query to. (optional) 
            var hours = 56;  // Integer | Last {x} hours to limit the query to. (optional) 
            var from = 789;  // Long | Starting point of the query time range. Specify this value in epoch milli time format. (optional) 
            var to = 789;  // Long | End point of the query time range. Specify this value in epoch milli time format. (optional) 

            try
            {
                // Get replication info about the replications with the specified sources and targets.
                map['String', ReplicationInfo] result = apiInstance.replications(sources, targets, minutes, hours, from, to);
                Debug.WriteLine(result);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling Class1SRMServiceAPIV2Api.replications: " + e.Message );
            }
        }
    }
}

<?php
require_once(__DIR__ . '/vendor/autoload.php');

// Configure API key authorization: Authorization
Swagger\Client\Configuration::getDefaultConfiguration()->setApiKey('Authorization', 'YOUR_API_KEY');
// Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
// Swagger\Client\Configuration::getDefaultConfiguration()->setApiKeyPrefix('Authorization', 'Bearer');

$api_instance = new Swagger\Client\ApiClass1SRMServiceAPIV2Api();
$sources = ; // array[String] | Cluster alias(es) of the source Kafka cluster(s).
$targets = ; // array[String] | Cluster alias(es) of the target Kafka cluster(s).
$minutes = 56; // Integer | Last {x} minutes to limit the query to.
$hours = 56; // Integer | Last {x} hours to limit the query to.
$from = 789; // Long | Starting point of the query time range. Specify this value in epoch milli time format.
$to = 789; // Long | End point of the query time range. Specify this value in epoch milli time format.

try {
    $result = $api_instance->replications($sources, $targets, $minutes, $hours, $from, $to);
    print_r($result);
} catch (Exception $e) {
    echo 'Exception when calling Class1SRMServiceAPIV2Api->replications: ', $e->getMessage(), PHP_EOL;
}
?>

use Data::Dumper;
use WWW::SwaggerClient::Configuration;
use WWW::SwaggerClient::Class1SRMServiceAPIV2Api;

# Configure API key authorization: Authorization
$WWW::SwaggerClient::Configuration::api_key->{'Authorization'} = 'YOUR_API_KEY';
# uncomment below to setup prefix (e.g. Bearer) for API key, if needed
#$WWW::SwaggerClient::Configuration::api_key_prefix->{'Authorization'} = "Bearer";

my $api_instance = WWW::SwaggerClient::Class1SRMServiceAPIV2Api->new();
my $sources = []; # array[String] | Cluster alias(es) of the source Kafka cluster(s).
my $targets = []; # array[String] | Cluster alias(es) of the target Kafka cluster(s).
my $minutes = 56; # Integer | Last {x} minutes to limit the query to.
my $hours = 56; # Integer | Last {x} hours to limit the query to.
my $from = 789; # Long | Starting point of the query time range. Specify this value in epoch milli time format.
my $to = 789; # Long | End point of the query time range. Specify this value in epoch milli time format.

eval { 
    my $result = $api_instance->replications(sources => $sources, targets => $targets, minutes => $minutes, hours => $hours, from => $from, to => $to);
    print Dumper($result);
};
if ($@) {
    warn "Exception when calling Class1SRMServiceAPIV2Api->replications: $@\n";
}

from __future__ import print_statement
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# Configure API key authorization: Authorization
swagger_client.configuration.api_key['Authorization'] = 'YOUR_API_KEY'
# Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
# swagger_client.configuration.api_key_prefix['Authorization'] = 'Bearer'

# create an instance of the API class
api_instance = swagger_client.Class1SRMServiceAPIV2Api()
sources =  # array[String] | Cluster alias(es) of the source Kafka cluster(s). (optional)
targets =  # array[String] | Cluster alias(es) of the target Kafka cluster(s). (optional)
minutes = 56 # Integer | Last {x} minutes to limit the query to. (optional)
hours = 56 # Integer | Last {x} hours to limit the query to. (optional)
from = 789 # Long | Starting point of the query time range. Specify this value in epoch milli time format. (optional)
to = 789 # Long | End point of the query time range. Specify this value in epoch milli time format. (optional)

try: 
    # Get replication info about the replications with the specified sources and targets.
    api_response = api_instance.replications(sources=sources, targets=targets, minutes=minutes, hours=hours, from=from, to=to)
    pprint(api_response)
except ApiException as e:
    print("Exception when calling Class1SRMServiceAPIV2Api->replications: %s\n" % e)

import io.swagger.client.*;
import io.swagger.client.auth.*;
import io.swagger.client.model.*;
import io.swagger.client.api.Class1SRMServiceAPIV2Api;

import java.io.File;
import java.util.*;

public class Class1SRMServiceAPIV2ApiExample {

    public static void main(String[] args) {
        ApiClient defaultClient = Configuration.getDefaultApiClient();

        // Configure API key authorization: Authorization
        ApiKeyAuth Authorization = (ApiKeyAuth) defaultClient.getAuthentication("Authorization");
        Authorization.setApiKey("YOUR API KEY");
        // Uncomment the following line to set a prefix for the API key, e.g. "Token" (defaults to null)
        //Authorization.setApiKeyPrefix("Token");

        Class1SRMServiceAPIV2Api apiInstance = new Class1SRMServiceAPIV2Api();
        String target = target_example; // String | Cluster alias of the target Kafka cluster.
        String downstreamTopic = downstreamTopic_example; // String | Remote (replicated) topic name. When using the DefaultReplicationPolicy, the topic name you add here must use the following format: "{source cluster alias}{replication policy separator}{upstream topic name}".
        String metric = metric_example; // String | Metric name.
        Integer minutes = 56; // Integer | Last {x} minutes to limit the query to.
        Integer hours = 56; // Integer | Last {x} hours to limit the query to.
        Long from = 789; // Long | Starting point of the query time range. Specify this value in epoch milli time format.
        Long to = 789; // Long | End point of the query time range. Specify this value in epoch milli time format.
        Integer samples = 56; // Integer | Number of samples to limit the query to.
        try {
            TimeSeriesResponseNumericMetricStats result = apiInstance.topicMetricsWithDownstreamTopicName(target, downstreamTopic, metric, minutes, hours, from, to, samples);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling Class1SRMServiceAPIV2Api#topicMetricsWithDownstreamTopicName");
            e.printStackTrace();
        }
    }
}

import io.swagger.client.api.Class1SRMServiceAPIV2Api;

public class Class1SRMServiceAPIV2ApiExample {

    public static void main(String[] args) {
        Class1SRMServiceAPIV2Api apiInstance = new Class1SRMServiceAPIV2Api();
        String target = target_example; // String | Cluster alias of the target Kafka cluster.
        String downstreamTopic = downstreamTopic_example; // String | Remote (replicated) topic name. When using the DefaultReplicationPolicy, the topic name you add here must use the following format: "{source cluster alias}{replication policy separator}{upstream topic name}".
        String metric = metric_example; // String | Metric name.
        Integer minutes = 56; // Integer | Last {x} minutes to limit the query to.
        Integer hours = 56; // Integer | Last {x} hours to limit the query to.
        Long from = 789; // Long | Starting point of the query time range. Specify this value in epoch milli time format.
        Long to = 789; // Long | End point of the query time range. Specify this value in epoch milli time format.
        Integer samples = 56; // Integer | Number of samples to limit the query to.
        try {
            TimeSeriesResponseNumericMetricStats result = apiInstance.topicMetricsWithDownstreamTopicName(target, downstreamTopic, metric, minutes, hours, from, to, samples);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling Class1SRMServiceAPIV2Api#topicMetricsWithDownstreamTopicName");
            e.printStackTrace();
        }
    }
}

Configuration *apiConfig = [Configuration sharedConfig];
// Configure API key authorization: (authentication scheme: Authorization)
[apiConfig setApiKey:@"YOUR_API_KEY" forApiKeyIdentifier:@"Authorization"];
// Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
//[apiConfig setApiKeyPrefix:@"Bearer" forApiKeyIdentifier:@"Authorization"];
String *target = target_example; // Cluster alias of the target Kafka cluster.
String *downstreamTopic = downstreamTopic_example; // Remote (replicated) topic name. When using the DefaultReplicationPolicy, the topic name you add here must use the following format: "{source cluster alias}{replication policy separator}{upstream topic name}".
String *metric = metric_example; // Metric name.
Integer *minutes = 56; // Last {x} minutes to limit the query to. (optional)
Integer *hours = 56; // Last {x} hours to limit the query to. (optional)
Long *from = 789; // Starting point of the query time range. Specify this value in epoch milli time format. (optional)
Long *to = 789; // End point of the query time range. Specify this value in epoch milli time format. (optional)
Integer *samples = 56; // Number of samples to limit the query to. (optional) (default to 1000)

Class1SRMServiceAPIV2Api *apiInstance = [[Class1SRMServiceAPIV2Api alloc] init];

// Get metric data about the specified topic replicated to the specified target. The replication source is derived from the remote (replicated) topic name.
[apiInstance topicMetricsWithDownstreamTopicNameWith:target
    downstreamTopic:downstreamTopic
    metric:metric
    minutes:minutes
    hours:hours
    from:from
    to:to
    samples:samples
              completionHandler: ^(TimeSeriesResponseNumericMetricStats output, NSError* error) {
                            if (output) {
                                NSLog(@"%@", output);
                            }
                            if (error) {
                                NSLog(@"Error: %@", error);
                            }
                        }];

var SwaggerJsClient = require('swagger-js-client');
var defaultClient = SwaggerJsClient.ApiClient.instance;

// Configure API key authorization: Authorization
var Authorization = defaultClient.authentications['Authorization'];
Authorization.apiKey = "YOUR API KEY"
// Uncomment the following line to set a prefix for the API key, e.g. "Token" (defaults to null)
//Authorization.apiKeyPrefix['Authorization'] = "Token"

var api = new SwaggerJsClient.Class1SRMServiceAPIV2Api()
var target = target_example; // {{String}} Cluster alias of the target Kafka cluster.
var downstreamTopic = downstreamTopic_example; // {{String}} Remote (replicated) topic name. When using the DefaultReplicationPolicy, the topic name you add here must use the following format: "{source cluster alias}{replication policy separator}{upstream topic name}".
var metric = metric_example; // {{String}} Metric name.
var opts = { 
  'minutes': 56, // {{Integer}} Last {x} minutes to limit the query to.
  'hours': 56, // {{Integer}} Last {x} hours to limit the query to.
  'from': 789, // {{Long}} Starting point of the query time range. Specify this value in epoch milli time format.
  'to': 789, // {{Long}} End point of the query time range. Specify this value in epoch milli time format.
  'samples': 56 // {{Integer}} Number of samples to limit the query to.
};
var callback = function(error, data, response) {
  if (error) {
    console.error(error);
  } else {
    console.log('API called successfully. Returned data: ' + data);
  }
};
api.topicMetricsWithDownstreamTopicName(target, downstreamTopic, metric, opts, callback);

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class topicMetricsWithDownstreamTopicNameExample
    {
        public void main()
        {

            // Configure API key authorization: Authorization
            Configuration.Default.ApiKey.Add("Authorization", "YOUR_API_KEY");
            // Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
            // Configuration.Default.ApiKeyPrefix.Add("Authorization", "Bearer");

            var apiInstance = new Class1SRMServiceAPIV2Api();
            var target = target_example;  // String | Cluster alias of the target Kafka cluster.
            var downstreamTopic = downstreamTopic_example;  // String | Remote (replicated) topic name. When using the DefaultReplicationPolicy, the topic name you add here must use the following format: "{source cluster alias}{replication policy separator}{upstream topic name}".
            var metric = metric_example;  // String | Metric name.
            var minutes = 56;  // Integer | Last {x} minutes to limit the query to. (optional) 
            var hours = 56;  // Integer | Last {x} hours to limit the query to. (optional) 
            var from = 789;  // Long | Starting point of the query time range. Specify this value in epoch milli time format. (optional) 
            var to = 789;  // Long | End point of the query time range. Specify this value in epoch milli time format. (optional) 
            var samples = 56;  // Integer | Number of samples to limit the query to. (optional)  (default to 1000)

            try
            {
                // Get metric data about the specified topic replicated to the specified target. The replication source is derived from the remote (replicated) topic name.
                TimeSeriesResponseNumericMetricStats result = apiInstance.topicMetricsWithDownstreamTopicName(target, downstreamTopic, metric, minutes, hours, from, to, samples);
                Debug.WriteLine(result);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling Class1SRMServiceAPIV2Api.topicMetricsWithDownstreamTopicName: " + e.Message );
            }
        }
    }
}

<?php
require_once(__DIR__ . '/vendor/autoload.php');

// Configure API key authorization: Authorization
Swagger\Client\Configuration::getDefaultConfiguration()->setApiKey('Authorization', 'YOUR_API_KEY');
// Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
// Swagger\Client\Configuration::getDefaultConfiguration()->setApiKeyPrefix('Authorization', 'Bearer');

$api_instance = new Swagger\Client\ApiClass1SRMServiceAPIV2Api();
$target = target_example; // String | Cluster alias of the target Kafka cluster.
$downstreamTopic = downstreamTopic_example; // String | Remote (replicated) topic name. When using the DefaultReplicationPolicy, the topic name you add here must use the following format: "{source cluster alias}{replication policy separator}{upstream topic name}".
$metric = metric_example; // String | Metric name.
$minutes = 56; // Integer | Last {x} minutes to limit the query to.
$hours = 56; // Integer | Last {x} hours to limit the query to.
$from = 789; // Long | Starting point of the query time range. Specify this value in epoch milli time format.
$to = 789; // Long | End point of the query time range. Specify this value in epoch milli time format.
$samples = 56; // Integer | Number of samples to limit the query to.

try {
    $result = $api_instance->topicMetricsWithDownstreamTopicName($target, $downstreamTopic, $metric, $minutes, $hours, $from, $to, $samples);
    print_r($result);
} catch (Exception $e) {
    echo 'Exception when calling Class1SRMServiceAPIV2Api->topicMetricsWithDownstreamTopicName: ', $e->getMessage(), PHP_EOL;
}
?>

use Data::Dumper;
use WWW::SwaggerClient::Configuration;
use WWW::SwaggerClient::Class1SRMServiceAPIV2Api;

# Configure API key authorization: Authorization
$WWW::SwaggerClient::Configuration::api_key->{'Authorization'} = 'YOUR_API_KEY';
# uncomment below to setup prefix (e.g. Bearer) for API key, if needed
#$WWW::SwaggerClient::Configuration::api_key_prefix->{'Authorization'} = "Bearer";

my $api_instance = WWW::SwaggerClient::Class1SRMServiceAPIV2Api->new();
my $target = target_example; # String | Cluster alias of the target Kafka cluster.
my $downstreamTopic = downstreamTopic_example; # String | Remote (replicated) topic name. When using the DefaultReplicationPolicy, the topic name you add here must use the following format: "{source cluster alias}{replication policy separator}{upstream topic name}".
my $metric = metric_example; # String | Metric name.
my $minutes = 56; # Integer | Last {x} minutes to limit the query to.
my $hours = 56; # Integer | Last {x} hours to limit the query to.
my $from = 789; # Long | Starting point of the query time range. Specify this value in epoch milli time format.
my $to = 789; # Long | End point of the query time range. Specify this value in epoch milli time format.
my $samples = 56; # Integer | Number of samples to limit the query to.

eval { 
    my $result = $api_instance->topicMetricsWithDownstreamTopicName(target => $target, downstreamTopic => $downstreamTopic, metric => $metric, minutes => $minutes, hours => $hours, from => $from, to => $to, samples => $samples);
    print Dumper($result);
};
if ($@) {
    warn "Exception when calling Class1SRMServiceAPIV2Api->topicMetricsWithDownstreamTopicName: $@\n";
}

from __future__ import print_statement
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# Configure API key authorization: Authorization
swagger_client.configuration.api_key['Authorization'] = 'YOUR_API_KEY'
# Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
# swagger_client.configuration.api_key_prefix['Authorization'] = 'Bearer'

# create an instance of the API class
api_instance = swagger_client.Class1SRMServiceAPIV2Api()
target = target_example # String | Cluster alias of the target Kafka cluster.
downstreamTopic = downstreamTopic_example # String | Remote (replicated) topic name. When using the DefaultReplicationPolicy, the topic name you add here must use the following format: "{source cluster alias}{replication policy separator}{upstream topic name}".
metric = metric_example # String | Metric name.
minutes = 56 # Integer | Last {x} minutes to limit the query to. (optional)
hours = 56 # Integer | Last {x} hours to limit the query to. (optional)
from = 789 # Long | Starting point of the query time range. Specify this value in epoch milli time format. (optional)
to = 789 # Long | End point of the query time range. Specify this value in epoch milli time format. (optional)
samples = 56 # Integer | Number of samples to limit the query to. (optional) (default to 1000)

try: 
    # Get metric data about the specified topic replicated to the specified target. The replication source is derived from the remote (replicated) topic name.
    api_response = api_instance.topic_metrics_with_downstream_topic_name(target, downstreamTopic, metric, minutes=minutes, hours=hours, from=from, to=to, samples=samples)
    pprint(api_response)
except ApiException as e:
    print("Exception when calling Class1SRMServiceAPIV2Api->topicMetricsWithDownstreamTopicName: %s\n" % e)

import io.swagger.client.*;
import io.swagger.client.auth.*;
import io.swagger.client.model.*;
import io.swagger.client.api.Class1SRMServiceAPIV2Api;

import java.io.File;
import java.util.*;

public class Class1SRMServiceAPIV2ApiExample {

    public static void main(String[] args) {
        ApiClient defaultClient = Configuration.getDefaultApiClient();

        // Configure API key authorization: Authorization
        ApiKeyAuth Authorization = (ApiKeyAuth) defaultClient.getAuthentication("Authorization");
        Authorization.setApiKey("YOUR API KEY");
        // Uncomment the following line to set a prefix for the API key, e.g. "Token" (defaults to null)
        //Authorization.setApiKeyPrefix("Token");

        Class1SRMServiceAPIV2Api apiInstance = new Class1SRMServiceAPIV2Api();
        String source = source_example; // String | Cluster alias of the source Kafka cluster.
        String target = target_example; // String | Cluster alias of the target Kafka cluster.
        String upstreamTopic = upstreamTopic_example; // String | Source topic name. Use the name of the topic as it is present in the source cluster. Do not use the remote (replicated) topic name present in the target cluster.
        String metric = metric_example; // String | Metric name.
        Integer minutes = 56; // Integer | Last {x} minutes to limit the query to.
        Integer hours = 56; // Integer | Last {x} hours to limit the query to.
        Long from = 789; // Long | Starting point of the query time range. Specify this value in epoch milli time format.
        Long to = 789; // Long | End point of the query time range. Specify this value in epoch milli time format.
        Integer samples = 56; // Integer | Number of samples to limit the query to.
        try {
            TimeSeriesResponseNumericMetricStats result = apiInstance.topicMetricsWithDownstreamTopicName1(source, target, upstreamTopic, metric, minutes, hours, from, to, samples);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling Class1SRMServiceAPIV2Api#topicMetricsWithDownstreamTopicName1");
            e.printStackTrace();
        }
    }
}

import io.swagger.client.api.Class1SRMServiceAPIV2Api;

public class Class1SRMServiceAPIV2ApiExample {

    public static void main(String[] args) {
        Class1SRMServiceAPIV2Api apiInstance = new Class1SRMServiceAPIV2Api();
        String source = source_example; // String | Cluster alias of the source Kafka cluster.
        String target = target_example; // String | Cluster alias of the target Kafka cluster.
        String upstreamTopic = upstreamTopic_example; // String | Source topic name. Use the name of the topic as it is present in the source cluster. Do not use the remote (replicated) topic name present in the target cluster.
        String metric = metric_example; // String | Metric name.
        Integer minutes = 56; // Integer | Last {x} minutes to limit the query to.
        Integer hours = 56; // Integer | Last {x} hours to limit the query to.
        Long from = 789; // Long | Starting point of the query time range. Specify this value in epoch milli time format.
        Long to = 789; // Long | End point of the query time range. Specify this value in epoch milli time format.
        Integer samples = 56; // Integer | Number of samples to limit the query to.
        try {
            TimeSeriesResponseNumericMetricStats result = apiInstance.topicMetricsWithDownstreamTopicName1(source, target, upstreamTopic, metric, minutes, hours, from, to, samples);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling Class1SRMServiceAPIV2Api#topicMetricsWithDownstreamTopicName1");
            e.printStackTrace();
        }
    }
}

Configuration *apiConfig = [Configuration sharedConfig];
// Configure API key authorization: (authentication scheme: Authorization)
[apiConfig setApiKey:@"YOUR_API_KEY" forApiKeyIdentifier:@"Authorization"];
// Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
//[apiConfig setApiKeyPrefix:@"Bearer" forApiKeyIdentifier:@"Authorization"];
String *source = source_example; // Cluster alias of the source Kafka cluster.
String *target = target_example; // Cluster alias of the target Kafka cluster.
String *upstreamTopic = upstreamTopic_example; // Source topic name. Use the name of the topic as it is present in the source cluster. Do not use the remote (replicated) topic name present in the target cluster.
String *metric = metric_example; // Metric name.
Integer *minutes = 56; // Last {x} minutes to limit the query to. (optional)
Integer *hours = 56; // Last {x} hours to limit the query to. (optional)
Long *from = 789; // Starting point of the query time range. Specify this value in epoch milli time format. (optional)
Long *to = 789; // End point of the query time range. Specify this value in epoch milli time format. (optional)
Integer *samples = 56; // Number of samples to limit the query to. (optional) (default to 1000)

Class1SRMServiceAPIV2Api *apiInstance = [[Class1SRMServiceAPIV2Api alloc] init];

// Get metric data about the specified topic replicated from the specified source to the specified target. The replication source is derived from the {source} parameter.
[apiInstance topicMetricsWithDownstreamTopicName1With:source
    target:target
    upstreamTopic:upstreamTopic
    metric:metric
    minutes:minutes
    hours:hours
    from:from
    to:to
    samples:samples
              completionHandler: ^(TimeSeriesResponseNumericMetricStats output, NSError* error) {
                            if (output) {
                                NSLog(@"%@", output);
                            }
                            if (error) {
                                NSLog(@"Error: %@", error);
                            }
                        }];

var SwaggerJsClient = require('swagger-js-client');
var defaultClient = SwaggerJsClient.ApiClient.instance;

// Configure API key authorization: Authorization
var Authorization = defaultClient.authentications['Authorization'];
Authorization.apiKey = "YOUR API KEY"
// Uncomment the following line to set a prefix for the API key, e.g. "Token" (defaults to null)
//Authorization.apiKeyPrefix['Authorization'] = "Token"

var api = new SwaggerJsClient.Class1SRMServiceAPIV2Api()
var source = source_example; // {{String}} Cluster alias of the source Kafka cluster.
var target = target_example; // {{String}} Cluster alias of the target Kafka cluster.
var upstreamTopic = upstreamTopic_example; // {{String}} Source topic name. Use the name of the topic as it is present in the source cluster. Do not use the remote (replicated) topic name present in the target cluster.
var metric = metric_example; // {{String}} Metric name.
var opts = { 
  'minutes': 56, // {{Integer}} Last {x} minutes to limit the query to.
  'hours': 56, // {{Integer}} Last {x} hours to limit the query to.
  'from': 789, // {{Long}} Starting point of the query time range. Specify this value in epoch milli time format.
  'to': 789, // {{Long}} End point of the query time range. Specify this value in epoch milli time format.
  'samples': 56 // {{Integer}} Number of samples to limit the query to.
};
var callback = function(error, data, response) {
  if (error) {
    console.error(error);
  } else {
    console.log('API called successfully. Returned data: ' + data);
  }
};
api.topicMetricsWithDownstreamTopicName1(source, target, upstreamTopic, metric, opts, callback);

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class topicMetricsWithDownstreamTopicName1Example
    {
        public void main()
        {

            // Configure API key authorization: Authorization
            Configuration.Default.ApiKey.Add("Authorization", "YOUR_API_KEY");
            // Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
            // Configuration.Default.ApiKeyPrefix.Add("Authorization", "Bearer");

            var apiInstance = new Class1SRMServiceAPIV2Api();
            var source = source_example;  // String | Cluster alias of the source Kafka cluster.
            var target = target_example;  // String | Cluster alias of the target Kafka cluster.
            var upstreamTopic = upstreamTopic_example;  // String | Source topic name. Use the name of the topic as it is present in the source cluster. Do not use the remote (replicated) topic name present in the target cluster.
            var metric = metric_example;  // String | Metric name.
            var minutes = 56;  // Integer | Last {x} minutes to limit the query to. (optional) 
            var hours = 56;  // Integer | Last {x} hours to limit the query to. (optional) 
            var from = 789;  // Long | Starting point of the query time range. Specify this value in epoch milli time format. (optional) 
            var to = 789;  // Long | End point of the query time range. Specify this value in epoch milli time format. (optional) 
            var samples = 56;  // Integer | Number of samples to limit the query to. (optional)  (default to 1000)

            try
            {
                // Get metric data about the specified topic replicated from the specified source to the specified target. The replication source is derived from the {source} parameter.
                TimeSeriesResponseNumericMetricStats result = apiInstance.topicMetricsWithDownstreamTopicName1(source, target, upstreamTopic, metric, minutes, hours, from, to, samples);
                Debug.WriteLine(result);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling Class1SRMServiceAPIV2Api.topicMetricsWithDownstreamTopicName1: " + e.Message );
            }
        }
    }
}

<?php
require_once(__DIR__ . '/vendor/autoload.php');

// Configure API key authorization: Authorization
Swagger\Client\Configuration::getDefaultConfiguration()->setApiKey('Authorization', 'YOUR_API_KEY');
// Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
// Swagger\Client\Configuration::getDefaultConfiguration()->setApiKeyPrefix('Authorization', 'Bearer');

$api_instance = new Swagger\Client\ApiClass1SRMServiceAPIV2Api();
$source = source_example; // String | Cluster alias of the source Kafka cluster.
$target = target_example; // String | Cluster alias of the target Kafka cluster.
$upstreamTopic = upstreamTopic_example; // String | Source topic name. Use the name of the topic as it is present in the source cluster. Do not use the remote (replicated) topic name present in the target cluster.
$metric = metric_example; // String | Metric name.
$minutes = 56; // Integer | Last {x} minutes to limit the query to.
$hours = 56; // Integer | Last {x} hours to limit the query to.
$from = 789; // Long | Starting point of the query time range. Specify this value in epoch milli time format.
$to = 789; // Long | End point of the query time range. Specify this value in epoch milli time format.
$samples = 56; // Integer | Number of samples to limit the query to.

try {
    $result = $api_instance->topicMetricsWithDownstreamTopicName1($source, $target, $upstreamTopic, $metric, $minutes, $hours, $from, $to, $samples);
    print_r($result);
} catch (Exception $e) {
    echo 'Exception when calling Class1SRMServiceAPIV2Api->topicMetricsWithDownstreamTopicName1: ', $e->getMessage(), PHP_EOL;
}
?>

use Data::Dumper;
use WWW::SwaggerClient::Configuration;
use WWW::SwaggerClient::Class1SRMServiceAPIV2Api;

# Configure API key authorization: Authorization
$WWW::SwaggerClient::Configuration::api_key->{'Authorization'} = 'YOUR_API_KEY';
# uncomment below to setup prefix (e.g. Bearer) for API key, if needed
#$WWW::SwaggerClient::Configuration::api_key_prefix->{'Authorization'} = "Bearer";

my $api_instance = WWW::SwaggerClient::Class1SRMServiceAPIV2Api->new();
my $source = source_example; # String | Cluster alias of the source Kafka cluster.
my $target = target_example; # String | Cluster alias of the target Kafka cluster.
my $upstreamTopic = upstreamTopic_example; # String | Source topic name. Use the name of the topic as it is present in the source cluster. Do not use the remote (replicated) topic name present in the target cluster.
my $metric = metric_example; # String | Metric name.
my $minutes = 56; # Integer | Last {x} minutes to limit the query to.
my $hours = 56; # Integer | Last {x} hours to limit the query to.
my $from = 789; # Long | Starting point of the query time range. Specify this value in epoch milli time format.
my $to = 789; # Long | End point of the query time range. Specify this value in epoch milli time format.
my $samples = 56; # Integer | Number of samples to limit the query to.

eval { 
    my $result = $api_instance->topicMetricsWithDownstreamTopicName1(source => $source, target => $target, upstreamTopic => $upstreamTopic, metric => $metric, minutes => $minutes, hours => $hours, from => $from, to => $to, samples => $samples);
    print Dumper($result);
};
if ($@) {
    warn "Exception when calling Class1SRMServiceAPIV2Api->topicMetricsWithDownstreamTopicName1: $@\n";
}

from __future__ import print_statement
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# Configure API key authorization: Authorization
swagger_client.configuration.api_key['Authorization'] = 'YOUR_API_KEY'
# Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
# swagger_client.configuration.api_key_prefix['Authorization'] = 'Bearer'

# create an instance of the API class
api_instance = swagger_client.Class1SRMServiceAPIV2Api()
source = source_example # String | Cluster alias of the source Kafka cluster.
target = target_example # String | Cluster alias of the target Kafka cluster.
upstreamTopic = upstreamTopic_example # String | Source topic name. Use the name of the topic as it is present in the source cluster. Do not use the remote (replicated) topic name present in the target cluster.
metric = metric_example # String | Metric name.
minutes = 56 # Integer | Last {x} minutes to limit the query to. (optional)
hours = 56 # Integer | Last {x} hours to limit the query to. (optional)
from = 789 # Long | Starting point of the query time range. Specify this value in epoch milli time format. (optional)
to = 789 # Long | End point of the query time range. Specify this value in epoch milli time format. (optional)
samples = 56 # Integer | Number of samples to limit the query to. (optional) (default to 1000)

try: 
    # Get metric data about the specified topic replicated from the specified source to the specified target. The replication source is derived from the {source} parameter.
    api_response = api_instance.topic_metrics_with_downstream_topic_name1(source, target, upstreamTopic, metric, minutes=minutes, hours=hours, from=from, to=to, samples=samples)
    pprint(api_response)
except ApiException as e:
    print("Exception when calling Class1SRMServiceAPIV2Api->topicMetricsWithDownstreamTopicName1: %s\n" % e)

import io.swagger.client.*;
import io.swagger.client.auth.*;
import io.swagger.client.model.*;
import io.swagger.client.api.Class2SRMServiceAPIV1Api;

import java.io.File;
import java.util.*;

public class Class2SRMServiceAPIV1ApiExample {

    public static void main(String[] args) {
        ApiClient defaultClient = Configuration.getDefaultApiClient();

        // Configure API key authorization: Authorization
        ApiKeyAuth Authorization = (ApiKeyAuth) defaultClient.getAuthentication("Authorization");
        Authorization.setApiKey("YOUR API KEY");
        // Uncomment the following line to set a prefix for the API key, e.g. "Token" (defaults to null)
        //Authorization.setApiKeyPrefix("Token");

        Class2SRMServiceAPIV1Api apiInstance = new Class2SRMServiceAPIV1Api();
        String cluster = cluster_example; // String | Cluster alias of the source Kafka cluster.
        String metric = metric_example; // String | Metric name.
        Integer minutes = 56; // Integer | Last {x} minutes to limit the query to.
        Integer hours = 56; // Integer | Last {x} hours to limit the query to.
        Long from = 789; // Long | Starting point of the query time range. Specify this value in epoch milli time format.
        Long to = 789; // Long | End point of the query time range. Specify this value in epoch milli time format.
        Integer samples = 56; // Integer | Number of samples to limit the query to.
        try {
            TimeSeriesResponseNumericMetricStats result = apiInstance.clusterMetrics(cluster, metric, minutes, hours, from, to, samples);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling Class2SRMServiceAPIV1Api#clusterMetrics");
            e.printStackTrace();
        }
    }
}

import io.swagger.client.api.Class2SRMServiceAPIV1Api;

public class Class2SRMServiceAPIV1ApiExample {

    public static void main(String[] args) {
        Class2SRMServiceAPIV1Api apiInstance = new Class2SRMServiceAPIV1Api();
        String cluster = cluster_example; // String | Cluster alias of the source Kafka cluster.
        String metric = metric_example; // String | Metric name.
        Integer minutes = 56; // Integer | Last {x} minutes to limit the query to.
        Integer hours = 56; // Integer | Last {x} hours to limit the query to.
        Long from = 789; // Long | Starting point of the query time range. Specify this value in epoch milli time format.
        Long to = 789; // Long | End point of the query time range. Specify this value in epoch milli time format.
        Integer samples = 56; // Integer | Number of samples to limit the query to.
        try {
            TimeSeriesResponseNumericMetricStats result = apiInstance.clusterMetrics(cluster, metric, minutes, hours, from, to, samples);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling Class2SRMServiceAPIV1Api#clusterMetrics");
            e.printStackTrace();
        }
    }
}

Configuration *apiConfig = [Configuration sharedConfig];
// Configure API key authorization: (authentication scheme: Authorization)
[apiConfig setApiKey:@"YOUR_API_KEY" forApiKeyIdentifier:@"Authorization"];
// Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
//[apiConfig setApiKeyPrefix:@"Bearer" forApiKeyIdentifier:@"Authorization"];
String *cluster = cluster_example; // Cluster alias of the source Kafka cluster.
String *metric = metric_example; // Metric name.
Integer *minutes = 56; // Last {x} minutes to limit the query to. (optional)
Integer *hours = 56; // Last {x} hours to limit the query to. (optional)
Long *from = 789; // Starting point of the query time range. Specify this value in epoch milli time format. (optional)
Long *to = 789; // End point of the query time range. Specify this value in epoch milli time format. (optional)
Integer *samples = 56; // Number of samples to limit the query to. (optional) (default to 1000)

Class2SRMServiceAPIV1Api *apiInstance = [[Class2SRMServiceAPIV1Api alloc] init];

// Get cluster-level metric data about the replication with the specified source cluster and the default target cluster.
[apiInstance clusterMetricsWith:cluster
    metric:metric
    minutes:minutes
    hours:hours
    from:from
    to:to
    samples:samples
              completionHandler: ^(TimeSeriesResponseNumericMetricStats output, NSError* error) {
                            if (output) {
                                NSLog(@"%@", output);
                            }
                            if (error) {
                                NSLog(@"Error: %@", error);
                            }
                        }];

var SwaggerJsClient = require('swagger-js-client');
var defaultClient = SwaggerJsClient.ApiClient.instance;

// Configure API key authorization: Authorization
var Authorization = defaultClient.authentications['Authorization'];
Authorization.apiKey = "YOUR API KEY"
// Uncomment the following line to set a prefix for the API key, e.g. "Token" (defaults to null)
//Authorization.apiKeyPrefix['Authorization'] = "Token"

var api = new SwaggerJsClient.Class2SRMServiceAPIV1Api()
var cluster = cluster_example; // {{String}} Cluster alias of the source Kafka cluster.
var metric = metric_example; // {{String}} Metric name.
var opts = { 
  'minutes': 56, // {{Integer}} Last {x} minutes to limit the query to.
  'hours': 56, // {{Integer}} Last {x} hours to limit the query to.
  'from': 789, // {{Long}} Starting point of the query time range. Specify this value in epoch milli time format.
  'to': 789, // {{Long}} End point of the query time range. Specify this value in epoch milli time format.
  'samples': 56 // {{Integer}} Number of samples to limit the query to.
};
var callback = function(error, data, response) {
  if (error) {
    console.error(error);
  } else {
    console.log('API called successfully. Returned data: ' + data);
  }
};
api.clusterMetrics(cluster, metric, opts, callback);

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class clusterMetricsExample
    {
        public void main()
        {

            // Configure API key authorization: Authorization
            Configuration.Default.ApiKey.Add("Authorization", "YOUR_API_KEY");
            // Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
            // Configuration.Default.ApiKeyPrefix.Add("Authorization", "Bearer");

            var apiInstance = new Class2SRMServiceAPIV1Api();
            var cluster = cluster_example;  // String | Cluster alias of the source Kafka cluster.
            var metric = metric_example;  // String | Metric name.
            var minutes = 56;  // Integer | Last {x} minutes to limit the query to. (optional) 
            var hours = 56;  // Integer | Last {x} hours to limit the query to. (optional) 
            var from = 789;  // Long | Starting point of the query time range. Specify this value in epoch milli time format. (optional) 
            var to = 789;  // Long | End point of the query time range. Specify this value in epoch milli time format. (optional) 
            var samples = 56;  // Integer | Number of samples to limit the query to. (optional)  (default to 1000)

            try
            {
                // Get cluster-level metric data about the replication with the specified source cluster and the default target cluster.
                TimeSeriesResponseNumericMetricStats result = apiInstance.clusterMetrics(cluster, metric, minutes, hours, from, to, samples);
                Debug.WriteLine(result);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling Class2SRMServiceAPIV1Api.clusterMetrics: " + e.Message );
            }
        }
    }
}

<?php
require_once(__DIR__ . '/vendor/autoload.php');

// Configure API key authorization: Authorization
Swagger\Client\Configuration::getDefaultConfiguration()->setApiKey('Authorization', 'YOUR_API_KEY');
// Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
// Swagger\Client\Configuration::getDefaultConfiguration()->setApiKeyPrefix('Authorization', 'Bearer');

$api_instance = new Swagger\Client\ApiClass2SRMServiceAPIV1Api();
$cluster = cluster_example; // String | Cluster alias of the source Kafka cluster.
$metric = metric_example; // String | Metric name.
$minutes = 56; // Integer | Last {x} minutes to limit the query to.
$hours = 56; // Integer | Last {x} hours to limit the query to.
$from = 789; // Long | Starting point of the query time range. Specify this value in epoch milli time format.
$to = 789; // Long | End point of the query time range. Specify this value in epoch milli time format.
$samples = 56; // Integer | Number of samples to limit the query to.

try {
    $result = $api_instance->clusterMetrics($cluster, $metric, $minutes, $hours, $from, $to, $samples);
    print_r($result);
} catch (Exception $e) {
    echo 'Exception when calling Class2SRMServiceAPIV1Api->clusterMetrics: ', $e->getMessage(), PHP_EOL;
}
?>

use Data::Dumper;
use WWW::SwaggerClient::Configuration;
use WWW::SwaggerClient::Class2SRMServiceAPIV1Api;

# Configure API key authorization: Authorization
$WWW::SwaggerClient::Configuration::api_key->{'Authorization'} = 'YOUR_API_KEY';
# uncomment below to setup prefix (e.g. Bearer) for API key, if needed
#$WWW::SwaggerClient::Configuration::api_key_prefix->{'Authorization'} = "Bearer";

my $api_instance = WWW::SwaggerClient::Class2SRMServiceAPIV1Api->new();
my $cluster = cluster_example; # String | Cluster alias of the source Kafka cluster.
my $metric = metric_example; # String | Metric name.
my $minutes = 56; # Integer | Last {x} minutes to limit the query to.
my $hours = 56; # Integer | Last {x} hours to limit the query to.
my $from = 789; # Long | Starting point of the query time range. Specify this value in epoch milli time format.
my $to = 789; # Long | End point of the query time range. Specify this value in epoch milli time format.
my $samples = 56; # Integer | Number of samples to limit the query to.

eval { 
    my $result = $api_instance->clusterMetrics(cluster => $cluster, metric => $metric, minutes => $minutes, hours => $hours, from => $from, to => $to, samples => $samples);
    print Dumper($result);
};
if ($@) {
    warn "Exception when calling Class2SRMServiceAPIV1Api->clusterMetrics: $@\n";
}

from __future__ import print_statement
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# Configure API key authorization: Authorization
swagger_client.configuration.api_key['Authorization'] = 'YOUR_API_KEY'
# Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
# swagger_client.configuration.api_key_prefix['Authorization'] = 'Bearer'

# create an instance of the API class
api_instance = swagger_client.Class2SRMServiceAPIV1Api()
cluster = cluster_example # String | Cluster alias of the source Kafka cluster.
metric = metric_example # String | Metric name.
minutes = 56 # Integer | Last {x} minutes to limit the query to. (optional)
hours = 56 # Integer | Last {x} hours to limit the query to. (optional)
from = 789 # Long | Starting point of the query time range. Specify this value in epoch milli time format. (optional)
to = 789 # Long | End point of the query time range. Specify this value in epoch milli time format. (optional)
samples = 56 # Integer | Number of samples to limit the query to. (optional) (default to 1000)

try: 
    # Get cluster-level metric data about the replication with the specified source cluster and the default target cluster.
    api_response = api_instance.cluster_metrics(cluster, metric, minutes=minutes, hours=hours, from=from, to=to, samples=samples)
    pprint(api_response)
except ApiException as e:
    print("Exception when calling Class2SRMServiceAPIV1Api->clusterMetrics: %s\n" % e)

import io.swagger.client.*;
import io.swagger.client.auth.*;
import io.swagger.client.model.*;
import io.swagger.client.api.Class2SRMServiceAPIV1Api;

import java.io.File;
import java.util.*;

public class Class2SRMServiceAPIV1ApiExample {

    public static void main(String[] args) {
        ApiClient defaultClient = Configuration.getDefaultApiClient();

        // Configure API key authorization: Authorization
        ApiKeyAuth Authorization = (ApiKeyAuth) defaultClient.getAuthentication("Authorization");
        Authorization.setApiKey("YOUR API KEY");
        // Uncomment the following line to set a prefix for the API key, e.g. "Token" (defaults to null)
        //Authorization.setApiKeyPrefix("Token");

        Class2SRMServiceAPIV1Api apiInstance = new Class2SRMServiceAPIV1Api();
        String source = source_example; // String | Cluster alias of the source Kafka cluster.
        Integer minutes = 56; // Integer | Last {x} minutes to limit the query to.
        Integer hours = 56; // Integer | Last {x} hours to limit the query to.
        Long from = 789; // Long | Starting point of the query time range. Specify this value in epoch milli time format.
        Long to = 789; // Long | End point of the query time range. Specify this value in epoch milli time format.
        try {
            map['String', TopicInfo] result = apiInstance.remoteTopics(source, minutes, hours, from, to);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling Class2SRMServiceAPIV1Api#remoteTopics");
            e.printStackTrace();
        }
    }
}

import io.swagger.client.api.Class2SRMServiceAPIV1Api;

public class Class2SRMServiceAPIV1ApiExample {

    public static void main(String[] args) {
        Class2SRMServiceAPIV1Api apiInstance = new Class2SRMServiceAPIV1Api();
        String source = source_example; // String | Cluster alias of the source Kafka cluster.
        Integer minutes = 56; // Integer | Last {x} minutes to limit the query to.
        Integer hours = 56; // Integer | Last {x} hours to limit the query to.
        Long from = 789; // Long | Starting point of the query time range. Specify this value in epoch milli time format.
        Long to = 789; // Long | End point of the query time range. Specify this value in epoch milli time format.
        try {
            map['String', TopicInfo] result = apiInstance.remoteTopics(source, minutes, hours, from, to);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling Class2SRMServiceAPIV1Api#remoteTopics");
            e.printStackTrace();
        }
    }
}

Configuration *apiConfig = [Configuration sharedConfig];
// Configure API key authorization: (authentication scheme: Authorization)
[apiConfig setApiKey:@"YOUR_API_KEY" forApiKeyIdentifier:@"Authorization"];
// Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
//[apiConfig setApiKeyPrefix:@"Bearer" forApiKeyIdentifier:@"Authorization"];
String *source = source_example; // Cluster alias of the source Kafka cluster.
Integer *minutes = 56; // Last {x} minutes to limit the query to. (optional)
Integer *hours = 56; // Last {x} hours to limit the query to. (optional)
Long *from = 789; // Starting point of the query time range. Specify this value in epoch milli time format. (optional)
Long *to = 789; // End point of the query time range. Specify this value in epoch milli time format. (optional)

Class2SRMServiceAPIV1Api *apiInstance = [[Class2SRMServiceAPIV1Api alloc] init];

// Get topic info about topics replicated from the specified source cluster to the default target cluster.
[apiInstance remoteTopicsWith:source
    minutes:minutes
    hours:hours
    from:from
    to:to
              completionHandler: ^(map['String', TopicInfo] output, NSError* error) {
                            if (output) {
                                NSLog(@"%@", output);
                            }
                            if (error) {
                                NSLog(@"Error: %@", error);
                            }
                        }];

var SwaggerJsClient = require('swagger-js-client');
var defaultClient = SwaggerJsClient.ApiClient.instance;

// Configure API key authorization: Authorization
var Authorization = defaultClient.authentications['Authorization'];
Authorization.apiKey = "YOUR API KEY"
// Uncomment the following line to set a prefix for the API key, e.g. "Token" (defaults to null)
//Authorization.apiKeyPrefix['Authorization'] = "Token"

var api = new SwaggerJsClient.Class2SRMServiceAPIV1Api()
var source = source_example; // {{String}} Cluster alias of the source Kafka cluster.
var opts = { 
  'minutes': 56, // {{Integer}} Last {x} minutes to limit the query to.
  'hours': 56, // {{Integer}} Last {x} hours to limit the query to.
  'from': 789, // {{Long}} Starting point of the query time range. Specify this value in epoch milli time format.
  'to': 789 // {{Long}} End point of the query time range. Specify this value in epoch milli time format.
};
var callback = function(error, data, response) {
  if (error) {
    console.error(error);
  } else {
    console.log('API called successfully. Returned data: ' + data);
  }
};
api.remoteTopics(source, opts, callback);

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class remoteTopicsExample
    {
        public void main()
        {

            // Configure API key authorization: Authorization
            Configuration.Default.ApiKey.Add("Authorization", "YOUR_API_KEY");
            // Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
            // Configuration.Default.ApiKeyPrefix.Add("Authorization", "Bearer");

            var apiInstance = new Class2SRMServiceAPIV1Api();
            var source = source_example;  // String | Cluster alias of the source Kafka cluster.
            var minutes = 56;  // Integer | Last {x} minutes to limit the query to. (optional) 
            var hours = 56;  // Integer | Last {x} hours to limit the query to. (optional) 
            var from = 789;  // Long | Starting point of the query time range. Specify this value in epoch milli time format. (optional) 
            var to = 789;  // Long | End point of the query time range. Specify this value in epoch milli time format. (optional) 

            try
            {
                // Get topic info about topics replicated from the specified source cluster to the default target cluster.
                map['String', TopicInfo] result = apiInstance.remoteTopics(source, minutes, hours, from, to);
                Debug.WriteLine(result);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling Class2SRMServiceAPIV1Api.remoteTopics: " + e.Message );
            }
        }
    }
}

<?php
require_once(__DIR__ . '/vendor/autoload.php');

// Configure API key authorization: Authorization
Swagger\Client\Configuration::getDefaultConfiguration()->setApiKey('Authorization', 'YOUR_API_KEY');
// Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
// Swagger\Client\Configuration::getDefaultConfiguration()->setApiKeyPrefix('Authorization', 'Bearer');

$api_instance = new Swagger\Client\ApiClass2SRMServiceAPIV1Api();
$source = source_example; // String | Cluster alias of the source Kafka cluster.
$minutes = 56; // Integer | Last {x} minutes to limit the query to.
$hours = 56; // Integer | Last {x} hours to limit the query to.
$from = 789; // Long | Starting point of the query time range. Specify this value in epoch milli time format.
$to = 789; // Long | End point of the query time range. Specify this value in epoch milli time format.

try {
    $result = $api_instance->remoteTopics($source, $minutes, $hours, $from, $to);
    print_r($result);
} catch (Exception $e) {
    echo 'Exception when calling Class2SRMServiceAPIV1Api->remoteTopics: ', $e->getMessage(), PHP_EOL;
}
?>

use Data::Dumper;
use WWW::SwaggerClient::Configuration;
use WWW::SwaggerClient::Class2SRMServiceAPIV1Api;

# Configure API key authorization: Authorization
$WWW::SwaggerClient::Configuration::api_key->{'Authorization'} = 'YOUR_API_KEY';
# uncomment below to setup prefix (e.g. Bearer) for API key, if needed
#$WWW::SwaggerClient::Configuration::api_key_prefix->{'Authorization'} = "Bearer";

my $api_instance = WWW::SwaggerClient::Class2SRMServiceAPIV1Api->new();
my $source = source_example; # String | Cluster alias of the source Kafka cluster.
my $minutes = 56; # Integer | Last {x} minutes to limit the query to.
my $hours = 56; # Integer | Last {x} hours to limit the query to.
my $from = 789; # Long | Starting point of the query time range. Specify this value in epoch milli time format.
my $to = 789; # Long | End point of the query time range. Specify this value in epoch milli time format.

eval { 
    my $result = $api_instance->remoteTopics(source => $source, minutes => $minutes, hours => $hours, from => $from, to => $to);
    print Dumper($result);
};
if ($@) {
    warn "Exception when calling Class2SRMServiceAPIV1Api->remoteTopics: $@\n";
}

from __future__ import print_statement
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# Configure API key authorization: Authorization
swagger_client.configuration.api_key['Authorization'] = 'YOUR_API_KEY'
# Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
# swagger_client.configuration.api_key_prefix['Authorization'] = 'Bearer'

# create an instance of the API class
api_instance = swagger_client.Class2SRMServiceAPIV1Api()
source = source_example # String | Cluster alias of the source Kafka cluster.
minutes = 56 # Integer | Last {x} minutes to limit the query to. (optional)
hours = 56 # Integer | Last {x} hours to limit the query to. (optional)
from = 789 # Long | Starting point of the query time range. Specify this value in epoch milli time format. (optional)
to = 789 # Long | End point of the query time range. Specify this value in epoch milli time format. (optional)

try: 
    # Get topic info about topics replicated from the specified source cluster to the default target cluster.
    api_response = api_instance.remote_topics(source, minutes=minutes, hours=hours, from=from, to=to)
    pprint(api_response)
except ApiException as e:
    print("Exception when calling Class2SRMServiceAPIV1Api->remoteTopics: %s\n" % e)

import io.swagger.client.*;
import io.swagger.client.auth.*;
import io.swagger.client.model.*;
import io.swagger.client.api.Class2SRMServiceAPIV1Api;

import java.io.File;
import java.util.*;

public class Class2SRMServiceAPIV1ApiExample {

    public static void main(String[] args) {
        ApiClient defaultClient = Configuration.getDefaultApiClient();

        // Configure API key authorization: Authorization
        ApiKeyAuth Authorization = (ApiKeyAuth) defaultClient.getAuthentication("Authorization");
        Authorization.setApiKey("YOUR API KEY");
        // Uncomment the following line to set a prefix for the API key, e.g. "Token" (defaults to null)
        //Authorization.setApiKeyPrefix("Token");

        Class2SRMServiceAPIV1Api apiInstance = new Class2SRMServiceAPIV1Api();
        array[String] source = ; // array[String] | Cluster alias of the source Kafka cluster.
        Integer minutes = 56; // Integer | Last {x} minutes to limit the query to.
        Integer hours = 56; // Integer | Last {x} hours to limit the query to.
        Long from = 789; // Long | Starting point of the query time range. Specify this value in epoch milli time format.
        Long to = 789; // Long | End point of the query time range. Specify this value in epoch milli time format.
        try {
            map['String', ReplicationInfo] result = apiInstance.replicationInfo(source, minutes, hours, from, to);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling Class2SRMServiceAPIV1Api#replicationInfo");
            e.printStackTrace();
        }
    }
}

import io.swagger.client.api.Class2SRMServiceAPIV1Api;

public class Class2SRMServiceAPIV1ApiExample {

    public static void main(String[] args) {
        Class2SRMServiceAPIV1Api apiInstance = new Class2SRMServiceAPIV1Api();
        array[String] source = ; // array[String] | Cluster alias of the source Kafka cluster.
        Integer minutes = 56; // Integer | Last {x} minutes to limit the query to.
        Integer hours = 56; // Integer | Last {x} hours to limit the query to.
        Long from = 789; // Long | Starting point of the query time range. Specify this value in epoch milli time format.
        Long to = 789; // Long | End point of the query time range. Specify this value in epoch milli time format.
        try {
            map['String', ReplicationInfo] result = apiInstance.replicationInfo(source, minutes, hours, from, to);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling Class2SRMServiceAPIV1Api#replicationInfo");
            e.printStackTrace();
        }
    }
}

Configuration *apiConfig = [Configuration sharedConfig];
// Configure API key authorization: (authentication scheme: Authorization)
[apiConfig setApiKey:@"YOUR_API_KEY" forApiKeyIdentifier:@"Authorization"];
// Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
//[apiConfig setApiKeyPrefix:@"Bearer" forApiKeyIdentifier:@"Authorization"];
array[String] *source = ; // Cluster alias of the source Kafka cluster. (optional)
Integer *minutes = 56; // Last {x} minutes to limit the query to. (optional)
Integer *hours = 56; // Last {x} hours to limit the query to. (optional)
Long *from = 789; // Starting point of the query time range. Specify this value in epoch milli time format. (optional)
Long *to = 789; // End point of the query time range. Specify this value in epoch milli time format. (optional)

Class2SRMServiceAPIV1Api *apiInstance = [[Class2SRMServiceAPIV1Api alloc] init];

// Get replication info about the replications targeting the default target cluster.
[apiInstance replicationInfoWith:source
    minutes:minutes
    hours:hours
    from:from
    to:to
              completionHandler: ^(map['String', ReplicationInfo] output, NSError* error) {
                            if (output) {
                                NSLog(@"%@", output);
                            }
                            if (error) {
                                NSLog(@"Error: %@", error);
                            }
                        }];

var SwaggerJsClient = require('swagger-js-client');
var defaultClient = SwaggerJsClient.ApiClient.instance;

// Configure API key authorization: Authorization
var Authorization = defaultClient.authentications['Authorization'];
Authorization.apiKey = "YOUR API KEY"
// Uncomment the following line to set a prefix for the API key, e.g. "Token" (defaults to null)
//Authorization.apiKeyPrefix['Authorization'] = "Token"

var api = new SwaggerJsClient.Class2SRMServiceAPIV1Api()
var opts = { 
  'source': , // {{array[String]}} Cluster alias of the source Kafka cluster.
  'minutes': 56, // {{Integer}} Last {x} minutes to limit the query to.
  'hours': 56, // {{Integer}} Last {x} hours to limit the query to.
  'from': 789, // {{Long}} Starting point of the query time range. Specify this value in epoch milli time format.
  'to': 789 // {{Long}} End point of the query time range. Specify this value in epoch milli time format.
};
var callback = function(error, data, response) {
  if (error) {
    console.error(error);
  } else {
    console.log('API called successfully. Returned data: ' + data);
  }
};
api.replicationInfo(opts, callback);

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class replicationInfoExample
    {
        public void main()
        {

            // Configure API key authorization: Authorization
            Configuration.Default.ApiKey.Add("Authorization", "YOUR_API_KEY");
            // Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
            // Configuration.Default.ApiKeyPrefix.Add("Authorization", "Bearer");

            var apiInstance = new Class2SRMServiceAPIV1Api();
            var source = new array[String](); // array[String] | Cluster alias of the source Kafka cluster. (optional) 
            var minutes = 56;  // Integer | Last {x} minutes to limit the query to. (optional) 
            var hours = 56;  // Integer | Last {x} hours to limit the query to. (optional) 
            var from = 789;  // Long | Starting point of the query time range. Specify this value in epoch milli time format. (optional) 
            var to = 789;  // Long | End point of the query time range. Specify this value in epoch milli time format. (optional) 

            try
            {
                // Get replication info about the replications targeting the default target cluster.
                map['String', ReplicationInfo] result = apiInstance.replicationInfo(source, minutes, hours, from, to);
                Debug.WriteLine(result);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling Class2SRMServiceAPIV1Api.replicationInfo: " + e.Message );
            }
        }
    }
}

<?php
require_once(__DIR__ . '/vendor/autoload.php');

// Configure API key authorization: Authorization
Swagger\Client\Configuration::getDefaultConfiguration()->setApiKey('Authorization', 'YOUR_API_KEY');
// Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
// Swagger\Client\Configuration::getDefaultConfiguration()->setApiKeyPrefix('Authorization', 'Bearer');

$api_instance = new Swagger\Client\ApiClass2SRMServiceAPIV1Api();
$source = ; // array[String] | Cluster alias of the source Kafka cluster.
$minutes = 56; // Integer | Last {x} minutes to limit the query to.
$hours = 56; // Integer | Last {x} hours to limit the query to.
$from = 789; // Long | Starting point of the query time range. Specify this value in epoch milli time format.
$to = 789; // Long | End point of the query time range. Specify this value in epoch milli time format.

try {
    $result = $api_instance->replicationInfo($source, $minutes, $hours, $from, $to);
    print_r($result);
} catch (Exception $e) {
    echo 'Exception when calling Class2SRMServiceAPIV1Api->replicationInfo: ', $e->getMessage(), PHP_EOL;
}
?>

use Data::Dumper;
use WWW::SwaggerClient::Configuration;
use WWW::SwaggerClient::Class2SRMServiceAPIV1Api;

# Configure API key authorization: Authorization
$WWW::SwaggerClient::Configuration::api_key->{'Authorization'} = 'YOUR_API_KEY';
# uncomment below to setup prefix (e.g. Bearer) for API key, if needed
#$WWW::SwaggerClient::Configuration::api_key_prefix->{'Authorization'} = "Bearer";

my $api_instance = WWW::SwaggerClient::Class2SRMServiceAPIV1Api->new();
my $source = []; # array[String] | Cluster alias of the source Kafka cluster.
my $minutes = 56; # Integer | Last {x} minutes to limit the query to.
my $hours = 56; # Integer | Last {x} hours to limit the query to.
my $from = 789; # Long | Starting point of the query time range. Specify this value in epoch milli time format.
my $to = 789; # Long | End point of the query time range. Specify this value in epoch milli time format.

eval { 
    my $result = $api_instance->replicationInfo(source => $source, minutes => $minutes, hours => $hours, from => $from, to => $to);
    print Dumper($result);
};
if ($@) {
    warn "Exception when calling Class2SRMServiceAPIV1Api->replicationInfo: $@\n";
}

from __future__ import print_statement
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# Configure API key authorization: Authorization
swagger_client.configuration.api_key['Authorization'] = 'YOUR_API_KEY'
# Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
# swagger_client.configuration.api_key_prefix['Authorization'] = 'Bearer'

# create an instance of the API class
api_instance = swagger_client.Class2SRMServiceAPIV1Api()
source =  # array[String] | Cluster alias of the source Kafka cluster. (optional)
minutes = 56 # Integer | Last {x} minutes to limit the query to. (optional)
hours = 56 # Integer | Last {x} hours to limit the query to. (optional)
from = 789 # Long | Starting point of the query time range. Specify this value in epoch milli time format. (optional)
to = 789 # Long | End point of the query time range. Specify this value in epoch milli time format. (optional)

try: 
    # Get replication info about the replications targeting the default target cluster.
    api_response = api_instance.replication_info(source=source, minutes=minutes, hours=hours, from=from, to=to)
    pprint(api_response)
except ApiException as e:
    print("Exception when calling Class2SRMServiceAPIV1Api->replicationInfo: %s\n" % e)

import io.swagger.client.*;
import io.swagger.client.auth.*;
import io.swagger.client.model.*;
import io.swagger.client.api.Class2SRMServiceAPIV1Api;

import java.io.File;
import java.util.*;

public class Class2SRMServiceAPIV1ApiExample {

    public static void main(String[] args) {
        ApiClient defaultClient = Configuration.getDefaultApiClient();

        // Configure API key authorization: Authorization
        ApiKeyAuth Authorization = (ApiKeyAuth) defaultClient.getAuthentication("Authorization");
        Authorization.setApiKey("YOUR API KEY");
        // Uncomment the following line to set a prefix for the API key, e.g. "Token" (defaults to null)
        //Authorization.setApiKeyPrefix("Token");

        Class2SRMServiceAPIV1Api apiInstance = new Class2SRMServiceAPIV1Api();
        String topic = topic_example; // String | Remote (replicated) topic name. When using the DefaultReplicationPolicy, the topic name you add here must use the following format: "{source cluster alias}{replication policy separator}{upstream topic name}".
        String metric = metric_example; // String | Metric name.
        Integer minutes = 56; // Integer | Last {x} minutes to limit the query to.
        Integer hours = 56; // Integer | Last {x} hours to limit the query to.
        Long from = 789; // Long | Starting point of the query time range. Specify this value in epoch milli time format.
        Long to = 789; // Long | Starting point of the query time range. Specify this value in epoch milli time format.
        Integer samples = 56; // Integer | Number of samples to limit the query to.
        try {
            TimeSeriesResponseNumericMetricStats result = apiInstance.topicMetrics(topic, metric, minutes, hours, from, to, samples);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling Class2SRMServiceAPIV1Api#topicMetrics");
            e.printStackTrace();
        }
    }
}

import io.swagger.client.api.Class2SRMServiceAPIV1Api;

public class Class2SRMServiceAPIV1ApiExample {

    public static void main(String[] args) {
        Class2SRMServiceAPIV1Api apiInstance = new Class2SRMServiceAPIV1Api();
        String topic = topic_example; // String | Remote (replicated) topic name. When using the DefaultReplicationPolicy, the topic name you add here must use the following format: "{source cluster alias}{replication policy separator}{upstream topic name}".
        String metric = metric_example; // String | Metric name.
        Integer minutes = 56; // Integer | Last {x} minutes to limit the query to.
        Integer hours = 56; // Integer | Last {x} hours to limit the query to.
        Long from = 789; // Long | Starting point of the query time range. Specify this value in epoch milli time format.
        Long to = 789; // Long | Starting point of the query time range. Specify this value in epoch milli time format.
        Integer samples = 56; // Integer | Number of samples to limit the query to.
        try {
            TimeSeriesResponseNumericMetricStats result = apiInstance.topicMetrics(topic, metric, minutes, hours, from, to, samples);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling Class2SRMServiceAPIV1Api#topicMetrics");
            e.printStackTrace();
        }
    }
}

Configuration *apiConfig = [Configuration sharedConfig];
// Configure API key authorization: (authentication scheme: Authorization)
[apiConfig setApiKey:@"YOUR_API_KEY" forApiKeyIdentifier:@"Authorization"];
// Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
//[apiConfig setApiKeyPrefix:@"Bearer" forApiKeyIdentifier:@"Authorization"];
String *topic = topic_example; // Remote (replicated) topic name. When using the DefaultReplicationPolicy, the topic name you add here must use the following format: "{source cluster alias}{replication policy separator}{upstream topic name}".
String *metric = metric_example; // Metric name.
Integer *minutes = 56; // Last {x} minutes to limit the query to. (optional)
Integer *hours = 56; // Last {x} hours to limit the query to. (optional)
Long *from = 789; // Starting point of the query time range. Specify this value in epoch milli time format. (optional)
Long *to = 789; // Starting point of the query time range. Specify this value in epoch milli time format. (optional)
Integer *samples = 56; // Number of samples to limit the query to. (optional) (default to 1000)

Class2SRMServiceAPIV1Api *apiInstance = [[Class2SRMServiceAPIV1Api alloc] init];

// Get metric data about the specified remote (replicated) topic.
[apiInstance topicMetricsWith:topic
    metric:metric
    minutes:minutes
    hours:hours
    from:from
    to:to
    samples:samples
              completionHandler: ^(TimeSeriesResponseNumericMetricStats output, NSError* error) {
                            if (output) {
                                NSLog(@"%@", output);
                            }
                            if (error) {
                                NSLog(@"Error: %@", error);
                            }
                        }];

var SwaggerJsClient = require('swagger-js-client');
var defaultClient = SwaggerJsClient.ApiClient.instance;

// Configure API key authorization: Authorization
var Authorization = defaultClient.authentications['Authorization'];
Authorization.apiKey = "YOUR API KEY"
// Uncomment the following line to set a prefix for the API key, e.g. "Token" (defaults to null)
//Authorization.apiKeyPrefix['Authorization'] = "Token"

var api = new SwaggerJsClient.Class2SRMServiceAPIV1Api()
var topic = topic_example; // {{String}} Remote (replicated) topic name. When using the DefaultReplicationPolicy, the topic name you add here must use the following format: "{source cluster alias}{replication policy separator}{upstream topic name}".
var metric = metric_example; // {{String}} Metric name.
var opts = { 
  'minutes': 56, // {{Integer}} Last {x} minutes to limit the query to.
  'hours': 56, // {{Integer}} Last {x} hours to limit the query to.
  'from': 789, // {{Long}} Starting point of the query time range. Specify this value in epoch milli time format.
  'to': 789, // {{Long}} Starting point of the query time range. Specify this value in epoch milli time format.
  'samples': 56 // {{Integer}} Number of samples to limit the query to.
};
var callback = function(error, data, response) {
  if (error) {
    console.error(error);
  } else {
    console.log('API called successfully. Returned data: ' + data);
  }
};
api.topicMetrics(topic, metric, opts, callback);

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class topicMetricsExample
    {
        public void main()
        {

            // Configure API key authorization: Authorization
            Configuration.Default.ApiKey.Add("Authorization", "YOUR_API_KEY");
            // Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
            // Configuration.Default.ApiKeyPrefix.Add("Authorization", "Bearer");

            var apiInstance = new Class2SRMServiceAPIV1Api();
            var topic = topic_example;  // String | Remote (replicated) topic name. When using the DefaultReplicationPolicy, the topic name you add here must use the following format: "{source cluster alias}{replication policy separator}{upstream topic name}".
            var metric = metric_example;  // String | Metric name.
            var minutes = 56;  // Integer | Last {x} minutes to limit the query to. (optional) 
            var hours = 56;  // Integer | Last {x} hours to limit the query to. (optional) 
            var from = 789;  // Long | Starting point of the query time range. Specify this value in epoch milli time format. (optional) 
            var to = 789;  // Long | Starting point of the query time range. Specify this value in epoch milli time format. (optional) 
            var samples = 56;  // Integer | Number of samples to limit the query to. (optional)  (default to 1000)

            try
            {
                // Get metric data about the specified remote (replicated) topic.
                TimeSeriesResponseNumericMetricStats result = apiInstance.topicMetrics(topic, metric, minutes, hours, from, to, samples);
                Debug.WriteLine(result);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling Class2SRMServiceAPIV1Api.topicMetrics: " + e.Message );
            }
        }
    }
}

<?php
require_once(__DIR__ . '/vendor/autoload.php');

// Configure API key authorization: Authorization
Swagger\Client\Configuration::getDefaultConfiguration()->setApiKey('Authorization', 'YOUR_API_KEY');
// Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
// Swagger\Client\Configuration::getDefaultConfiguration()->setApiKeyPrefix('Authorization', 'Bearer');

$api_instance = new Swagger\Client\ApiClass2SRMServiceAPIV1Api();
$topic = topic_example; // String | Remote (replicated) topic name. When using the DefaultReplicationPolicy, the topic name you add here must use the following format: "{source cluster alias}{replication policy separator}{upstream topic name}".
$metric = metric_example; // String | Metric name.
$minutes = 56; // Integer | Last {x} minutes to limit the query to.
$hours = 56; // Integer | Last {x} hours to limit the query to.
$from = 789; // Long | Starting point of the query time range. Specify this value in epoch milli time format.
$to = 789; // Long | Starting point of the query time range. Specify this value in epoch milli time format.
$samples = 56; // Integer | Number of samples to limit the query to.

try {
    $result = $api_instance->topicMetrics($topic, $metric, $minutes, $hours, $from, $to, $samples);
    print_r($result);
} catch (Exception $e) {
    echo 'Exception when calling Class2SRMServiceAPIV1Api->topicMetrics: ', $e->getMessage(), PHP_EOL;
}
?>

use Data::Dumper;
use WWW::SwaggerClient::Configuration;
use WWW::SwaggerClient::Class2SRMServiceAPIV1Api;

# Configure API key authorization: Authorization
$WWW::SwaggerClient::Configuration::api_key->{'Authorization'} = 'YOUR_API_KEY';
# uncomment below to setup prefix (e.g. Bearer) for API key, if needed
#$WWW::SwaggerClient::Configuration::api_key_prefix->{'Authorization'} = "Bearer";

my $api_instance = WWW::SwaggerClient::Class2SRMServiceAPIV1Api->new();
my $topic = topic_example; # String | Remote (replicated) topic name. When using the DefaultReplicationPolicy, the topic name you add here must use the following format: "{source cluster alias}{replication policy separator}{upstream topic name}".
my $metric = metric_example; # String | Metric name.
my $minutes = 56; # Integer | Last {x} minutes to limit the query to.
my $hours = 56; # Integer | Last {x} hours to limit the query to.
my $from = 789; # Long | Starting point of the query time range. Specify this value in epoch milli time format.
my $to = 789; # Long | Starting point of the query time range. Specify this value in epoch milli time format.
my $samples = 56; # Integer | Number of samples to limit the query to.

eval { 
    my $result = $api_instance->topicMetrics(topic => $topic, metric => $metric, minutes => $minutes, hours => $hours, from => $from, to => $to, samples => $samples);
    print Dumper($result);
};
if ($@) {
    warn "Exception when calling Class2SRMServiceAPIV1Api->topicMetrics: $@\n";
}

from __future__ import print_statement
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# Configure API key authorization: Authorization
swagger_client.configuration.api_key['Authorization'] = 'YOUR_API_KEY'
# Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
# swagger_client.configuration.api_key_prefix['Authorization'] = 'Bearer'

# create an instance of the API class
api_instance = swagger_client.Class2SRMServiceAPIV1Api()
topic = topic_example # String | Remote (replicated) topic name. When using the DefaultReplicationPolicy, the topic name you add here must use the following format: "{source cluster alias}{replication policy separator}{upstream topic name}".
metric = metric_example # String | Metric name.
minutes = 56 # Integer | Last {x} minutes to limit the query to. (optional)
hours = 56 # Integer | Last {x} hours to limit the query to. (optional)
from = 789 # Long | Starting point of the query time range. Specify this value in epoch milli time format. (optional)
to = 789 # Long | Starting point of the query time range. Specify this value in epoch milli time format. (optional)
samples = 56 # Integer | Number of samples to limit the query to. (optional) (default to 1000)

try: 
    # Get metric data about the specified remote (replicated) topic.
    api_response = api_instance.topic_metrics(topic, metric, minutes=minutes, hours=hours, from=from, to=to, samples=samples)
    pprint(api_response)
except ApiException as e:
    print("Exception when calling Class2SRMServiceAPIV1Api->topicMetrics: %s\n" % e)

import io.swagger.client.*;
import io.swagger.client.auth.*;
import io.swagger.client.model.*;
import io.swagger.client.api.Class3SRMServiceAPIV2InternalApi;

import java.io.File;
import java.util.*;

public class Class3SRMServiceAPIV2InternalApiExample {

    public static void main(String[] args) {
        ApiClient defaultClient = Configuration.getDefaultApiClient();

        // Configure API key authorization: Authorization
        ApiKeyAuth Authorization = (ApiKeyAuth) defaultClient.getAuthentication("Authorization");
        Authorization.setApiKey("YOUR API KEY");
        // Uncomment the following line to set a prefix for the API key, e.g. "Token" (defaults to null)
        //Authorization.setApiKeyPrefix("Token");

        Class3SRMServiceAPIV2InternalApi apiInstance = new Class3SRMServiceAPIV2InternalApi();
        String kafkaClusterId = kafkaClusterId_example; // String | 
        try {
            ClusterInfo result = apiInstance.clusterInfo1(kafkaClusterId);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling Class3SRMServiceAPIV2InternalApi#clusterInfo1");
            e.printStackTrace();
        }
    }
}

import io.swagger.client.api.Class3SRMServiceAPIV2InternalApi;

public class Class3SRMServiceAPIV2InternalApiExample {

    public static void main(String[] args) {
        Class3SRMServiceAPIV2InternalApi apiInstance = new Class3SRMServiceAPIV2InternalApi();
        String kafkaClusterId = kafkaClusterId_example; // String | 
        try {
            ClusterInfo result = apiInstance.clusterInfo1(kafkaClusterId);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling Class3SRMServiceAPIV2InternalApi#clusterInfo1");
            e.printStackTrace();
        }
    }
}

Configuration *apiConfig = [Configuration sharedConfig];
// Configure API key authorization: (authentication scheme: Authorization)
[apiConfig setApiKey:@"YOUR_API_KEY" forApiKeyIdentifier:@"Authorization"];
// Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
//[apiConfig setApiKeyPrefix:@"Bearer" forApiKeyIdentifier:@"Authorization"];
String *kafkaClusterId = kafkaClusterId_example; // 

Class3SRMServiceAPIV2InternalApi *apiInstance = [[Class3SRMServiceAPIV2InternalApi alloc] init];

[apiInstance clusterInfo1With:kafkaClusterId
              completionHandler: ^(ClusterInfo output, NSError* error) {
                            if (output) {
                                NSLog(@"%@", output);
                            }
                            if (error) {
                                NSLog(@"Error: %@", error);
                            }
                        }];

var SwaggerJsClient = require('swagger-js-client');
var defaultClient = SwaggerJsClient.ApiClient.instance;

// Configure API key authorization: Authorization
var Authorization = defaultClient.authentications['Authorization'];
Authorization.apiKey = "YOUR API KEY"
// Uncomment the following line to set a prefix for the API key, e.g. "Token" (defaults to null)
//Authorization.apiKeyPrefix['Authorization'] = "Token"

var api = new SwaggerJsClient.Class3SRMServiceAPIV2InternalApi()
var kafkaClusterId = kafkaClusterId_example; // {{String}} 

var callback = function(error, data, response) {
  if (error) {
    console.error(error);
  } else {
    console.log('API called successfully. Returned data: ' + data);
  }
};
api.clusterInfo1(kafkaClusterId, callback);

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class clusterInfo1Example
    {
        public void main()
        {

            // Configure API key authorization: Authorization
            Configuration.Default.ApiKey.Add("Authorization", "YOUR_API_KEY");
            // Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
            // Configuration.Default.ApiKeyPrefix.Add("Authorization", "Bearer");

            var apiInstance = new Class3SRMServiceAPIV2InternalApi();
            var kafkaClusterId = kafkaClusterId_example;  // String | 

            try
            {
                ClusterInfo result = apiInstance.clusterInfo1(kafkaClusterId);
                Debug.WriteLine(result);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling Class3SRMServiceAPIV2InternalApi.clusterInfo1: " + e.Message );
            }
        }
    }
}

<?php
require_once(__DIR__ . '/vendor/autoload.php');

// Configure API key authorization: Authorization
Swagger\Client\Configuration::getDefaultConfiguration()->setApiKey('Authorization', 'YOUR_API_KEY');
// Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
// Swagger\Client\Configuration::getDefaultConfiguration()->setApiKeyPrefix('Authorization', 'Bearer');

$api_instance = new Swagger\Client\ApiClass3SRMServiceAPIV2InternalApi();
$kafkaClusterId = kafkaClusterId_example; // String | 

try {
    $result = $api_instance->clusterInfo1($kafkaClusterId);
    print_r($result);
} catch (Exception $e) {
    echo 'Exception when calling Class3SRMServiceAPIV2InternalApi->clusterInfo1: ', $e->getMessage(), PHP_EOL;
}
?>

use Data::Dumper;
use WWW::SwaggerClient::Configuration;
use WWW::SwaggerClient::Class3SRMServiceAPIV2InternalApi;

# Configure API key authorization: Authorization
$WWW::SwaggerClient::Configuration::api_key->{'Authorization'} = 'YOUR_API_KEY';
# uncomment below to setup prefix (e.g. Bearer) for API key, if needed
#$WWW::SwaggerClient::Configuration::api_key_prefix->{'Authorization'} = "Bearer";

my $api_instance = WWW::SwaggerClient::Class3SRMServiceAPIV2InternalApi->new();
my $kafkaClusterId = kafkaClusterId_example; # String | 

eval { 
    my $result = $api_instance->clusterInfo1(kafkaClusterId => $kafkaClusterId);
    print Dumper($result);
};
if ($@) {
    warn "Exception when calling Class3SRMServiceAPIV2InternalApi->clusterInfo1: $@\n";
}

from __future__ import print_statement
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# Configure API key authorization: Authorization
swagger_client.configuration.api_key['Authorization'] = 'YOUR_API_KEY'
# Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
# swagger_client.configuration.api_key_prefix['Authorization'] = 'Bearer'

# create an instance of the API class
api_instance = swagger_client.Class3SRMServiceAPIV2InternalApi()
kafkaClusterId = kafkaClusterId_example # String | 

try: 
    api_response = api_instance.cluster_info1(kafkaClusterId)
    pprint(api_response)
except ApiException as e:
    print("Exception when calling Class3SRMServiceAPIV2InternalApi->clusterInfo1: %s\n" % e)

import io.swagger.client.*;
import io.swagger.client.auth.*;
import io.swagger.client.model.*;
import io.swagger.client.api.Class3SRMServiceAPIV2InternalApi;

import java.io.File;
import java.util.*;

public class Class3SRMServiceAPIV2InternalApiExample {

    public static void main(String[] args) {
        ApiClient defaultClient = Configuration.getDefaultApiClient();

        // Configure API key authorization: Authorization
        ApiKeyAuth Authorization = (ApiKeyAuth) defaultClient.getAuthentication("Authorization");
        Authorization.setApiKey("YOUR API KEY");
        // Uncomment the following line to set a prefix for the API key, e.g. "Token" (defaults to null)
        //Authorization.setApiKeyPrefix("Token");

        Class3SRMServiceAPIV2InternalApi apiInstance = new Class3SRMServiceAPIV2InternalApi();
        String source = source_example; // String | 
        String target = target_example; // String | 
        String metric = metric_example; // String | 
        Integer minutes = 56; // Integer | 
        Integer hours = 56; // Integer | 
        Long from = 789; // Long | 
        Long to = 789; // Long | 
        Integer samples = 56; // Integer | 
        try {
            TimeSeriesResponseNumericMetricStats result = apiInstance.clusterMetrics2(source, target, metric, minutes, hours, from, to, samples);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling Class3SRMServiceAPIV2InternalApi#clusterMetrics2");
            e.printStackTrace();
        }
    }
}

import io.swagger.client.api.Class3SRMServiceAPIV2InternalApi;

public class Class3SRMServiceAPIV2InternalApiExample {

    public static void main(String[] args) {
        Class3SRMServiceAPIV2InternalApi apiInstance = new Class3SRMServiceAPIV2InternalApi();
        String source = source_example; // String | 
        String target = target_example; // String | 
        String metric = metric_example; // String | 
        Integer minutes = 56; // Integer | 
        Integer hours = 56; // Integer | 
        Long from = 789; // Long | 
        Long to = 789; // Long | 
        Integer samples = 56; // Integer | 
        try {
            TimeSeriesResponseNumericMetricStats result = apiInstance.clusterMetrics2(source, target, metric, minutes, hours, from, to, samples);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling Class3SRMServiceAPIV2InternalApi#clusterMetrics2");
            e.printStackTrace();
        }
    }
}

Configuration *apiConfig = [Configuration sharedConfig];
// Configure API key authorization: (authentication scheme: Authorization)
[apiConfig setApiKey:@"YOUR_API_KEY" forApiKeyIdentifier:@"Authorization"];
// Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
//[apiConfig setApiKeyPrefix:@"Bearer" forApiKeyIdentifier:@"Authorization"];
String *source = source_example; // 
String *target = target_example; // 
String *metric = metric_example; // 
Integer *minutes = 56; //  (optional)
Integer *hours = 56; //  (optional)
Long *from = 789; //  (optional)
Long *to = 789; //  (optional)
Integer *samples = 56; //  (optional) (default to 1000)

Class3SRMServiceAPIV2InternalApi *apiInstance = [[Class3SRMServiceAPIV2InternalApi alloc] init];

[apiInstance clusterMetrics2With:source
    target:target
    metric:metric
    minutes:minutes
    hours:hours
    from:from
    to:to
    samples:samples
              completionHandler: ^(TimeSeriesResponseNumericMetricStats output, NSError* error) {
                            if (output) {
                                NSLog(@"%@", output);
                            }
                            if (error) {
                                NSLog(@"Error: %@", error);
                            }
                        }];

var SwaggerJsClient = require('swagger-js-client');
var defaultClient = SwaggerJsClient.ApiClient.instance;

// Configure API key authorization: Authorization
var Authorization = defaultClient.authentications['Authorization'];
Authorization.apiKey = "YOUR API KEY"
// Uncomment the following line to set a prefix for the API key, e.g. "Token" (defaults to null)
//Authorization.apiKeyPrefix['Authorization'] = "Token"

var api = new SwaggerJsClient.Class3SRMServiceAPIV2InternalApi()
var source = source_example; // {{String}} 
var target = target_example; // {{String}} 
var metric = metric_example; // {{String}} 
var opts = { 
  'minutes': 56, // {{Integer}} 
  'hours': 56, // {{Integer}} 
  'from': 789, // {{Long}} 
  'to': 789, // {{Long}} 
  'samples': 56 // {{Integer}} 
};
var callback = function(error, data, response) {
  if (error) {
    console.error(error);
  } else {
    console.log('API called successfully. Returned data: ' + data);
  }
};
api.clusterMetrics2(source, target, metric, opts, callback);

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class clusterMetrics2Example
    {
        public void main()
        {

            // Configure API key authorization: Authorization
            Configuration.Default.ApiKey.Add("Authorization", "YOUR_API_KEY");
            // Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
            // Configuration.Default.ApiKeyPrefix.Add("Authorization", "Bearer");

            var apiInstance = new Class3SRMServiceAPIV2InternalApi();
            var source = source_example;  // String | 
            var target = target_example;  // String | 
            var metric = metric_example;  // String | 
            var minutes = 56;  // Integer |  (optional) 
            var hours = 56;  // Integer |  (optional) 
            var from = 789;  // Long |  (optional) 
            var to = 789;  // Long |  (optional) 
            var samples = 56;  // Integer |  (optional)  (default to 1000)

            try
            {
                TimeSeriesResponseNumericMetricStats result = apiInstance.clusterMetrics2(source, target, metric, minutes, hours, from, to, samples);
                Debug.WriteLine(result);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling Class3SRMServiceAPIV2InternalApi.clusterMetrics2: " + e.Message );
            }
        }
    }
}

<?php
require_once(__DIR__ . '/vendor/autoload.php');

// Configure API key authorization: Authorization
Swagger\Client\Configuration::getDefaultConfiguration()->setApiKey('Authorization', 'YOUR_API_KEY');
// Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
// Swagger\Client\Configuration::getDefaultConfiguration()->setApiKeyPrefix('Authorization', 'Bearer');

$api_instance = new Swagger\Client\ApiClass3SRMServiceAPIV2InternalApi();
$source = source_example; // String | 
$target = target_example; // String | 
$metric = metric_example; // String | 
$minutes = 56; // Integer | 
$hours = 56; // Integer | 
$from = 789; // Long | 
$to = 789; // Long | 
$samples = 56; // Integer | 

try {
    $result = $api_instance->clusterMetrics2($source, $target, $metric, $minutes, $hours, $from, $to, $samples);
    print_r($result);
} catch (Exception $e) {
    echo 'Exception when calling Class3SRMServiceAPIV2InternalApi->clusterMetrics2: ', $e->getMessage(), PHP_EOL;
}
?>

use Data::Dumper;
use WWW::SwaggerClient::Configuration;
use WWW::SwaggerClient::Class3SRMServiceAPIV2InternalApi;

# Configure API key authorization: Authorization
$WWW::SwaggerClient::Configuration::api_key->{'Authorization'} = 'YOUR_API_KEY';
# uncomment below to setup prefix (e.g. Bearer) for API key, if needed
#$WWW::SwaggerClient::Configuration::api_key_prefix->{'Authorization'} = "Bearer";

my $api_instance = WWW::SwaggerClient::Class3SRMServiceAPIV2InternalApi->new();
my $source = source_example; # String | 
my $target = target_example; # String | 
my $metric = metric_example; # String | 
my $minutes = 56; # Integer | 
my $hours = 56; # Integer | 
my $from = 789; # Long | 
my $to = 789; # Long | 
my $samples = 56; # Integer | 

eval { 
    my $result = $api_instance->clusterMetrics2(source => $source, target => $target, metric => $metric, minutes => $minutes, hours => $hours, from => $from, to => $to, samples => $samples);
    print Dumper($result);
};
if ($@) {
    warn "Exception when calling Class3SRMServiceAPIV2InternalApi->clusterMetrics2: $@\n";
}

from __future__ import print_statement
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# Configure API key authorization: Authorization
swagger_client.configuration.api_key['Authorization'] = 'YOUR_API_KEY'
# Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
# swagger_client.configuration.api_key_prefix['Authorization'] = 'Bearer'

# create an instance of the API class
api_instance = swagger_client.Class3SRMServiceAPIV2InternalApi()
source = source_example # String | 
target = target_example # String | 
metric = metric_example # String | 
minutes = 56 # Integer |  (optional)
hours = 56 # Integer |  (optional)
from = 789 # Long |  (optional)
to = 789 # Long |  (optional)
samples = 56 # Integer |  (optional) (default to 1000)

try: 
    api_response = api_instance.cluster_metrics2(source, target, metric, minutes=minutes, hours=hours, from=from, to=to, samples=samples)
    pprint(api_response)
except ApiException as e:
    print("Exception when calling Class3SRMServiceAPIV2InternalApi->clusterMetrics2: %s\n" % e)

import io.swagger.client.*;
import io.swagger.client.auth.*;
import io.swagger.client.model.*;
import io.swagger.client.api.Class3SRMServiceAPIV2InternalApi;

import java.io.File;
import java.util.*;

public class Class3SRMServiceAPIV2InternalApiExample {

    public static void main(String[] args) {
        ApiClient defaultClient = Configuration.getDefaultApiClient();

        // Configure API key authorization: Authorization
        ApiKeyAuth Authorization = (ApiKeyAuth) defaultClient.getAuthentication("Authorization");
        Authorization.setApiKey("YOUR API KEY");
        // Uncomment the following line to set a prefix for the API key, e.g. "Token" (defaults to null)
        //Authorization.setApiKeyPrefix("Token");

        Class3SRMServiceAPIV2InternalApi apiInstance = new Class3SRMServiceAPIV2InternalApi();
        String source = source_example; // String | 
        String target = target_example; // String | 
        String metric = metric_example; // String | 
        Integer minutes = 56; // Integer | 
        Integer hours = 56; // Integer | 
        Long from = 789; // Long | 
        Long to = 789; // Long | 
        Integer samples = 56; // Integer | 
        try {
            TimeSeriesResponseNumericMetricStats result = apiInstance.clusterMetrics3(source, target, metric, minutes, hours, from, to, samples);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling Class3SRMServiceAPIV2InternalApi#clusterMetrics3");
            e.printStackTrace();
        }
    }
}

import io.swagger.client.api.Class3SRMServiceAPIV2InternalApi;

public class Class3SRMServiceAPIV2InternalApiExample {

    public static void main(String[] args) {
        Class3SRMServiceAPIV2InternalApi apiInstance = new Class3SRMServiceAPIV2InternalApi();
        String source = source_example; // String | 
        String target = target_example; // String | 
        String metric = metric_example; // String | 
        Integer minutes = 56; // Integer | 
        Integer hours = 56; // Integer | 
        Long from = 789; // Long | 
        Long to = 789; // Long | 
        Integer samples = 56; // Integer | 
        try {
            TimeSeriesResponseNumericMetricStats result = apiInstance.clusterMetrics3(source, target, metric, minutes, hours, from, to, samples);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling Class3SRMServiceAPIV2InternalApi#clusterMetrics3");
            e.printStackTrace();
        }
    }
}

Configuration *apiConfig = [Configuration sharedConfig];
// Configure API key authorization: (authentication scheme: Authorization)
[apiConfig setApiKey:@"YOUR_API_KEY" forApiKeyIdentifier:@"Authorization"];
// Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
//[apiConfig setApiKeyPrefix:@"Bearer" forApiKeyIdentifier:@"Authorization"];
String *source = source_example; // 
String *target = target_example; // 
String *metric = metric_example; // 
Integer *minutes = 56; //  (optional)
Integer *hours = 56; //  (optional)
Long *from = 789; //  (optional)
Long *to = 789; //  (optional)
Integer *samples = 56; //  (optional)

Class3SRMServiceAPIV2InternalApi *apiInstance = [[Class3SRMServiceAPIV2InternalApi alloc] init];

[apiInstance clusterMetrics3With:source
    target:target
    metric:metric
    minutes:minutes
    hours:hours
    from:from
    to:to
    samples:samples
              completionHandler: ^(TimeSeriesResponseNumericMetricStats output, NSError* error) {
                            if (output) {
                                NSLog(@"%@", output);
                            }
                            if (error) {
                                NSLog(@"Error: %@", error);
                            }
                        }];

var SwaggerJsClient = require('swagger-js-client');
var defaultClient = SwaggerJsClient.ApiClient.instance;

// Configure API key authorization: Authorization
var Authorization = defaultClient.authentications['Authorization'];
Authorization.apiKey = "YOUR API KEY"
// Uncomment the following line to set a prefix for the API key, e.g. "Token" (defaults to null)
//Authorization.apiKeyPrefix['Authorization'] = "Token"

var api = new SwaggerJsClient.Class3SRMServiceAPIV2InternalApi()
var source = source_example; // {{String}} 
var target = target_example; // {{String}} 
var metric = metric_example; // {{String}} 
var opts = { 
  'minutes': 56, // {{Integer}} 
  'hours': 56, // {{Integer}} 
  'from': 789, // {{Long}} 
  'to': 789, // {{Long}} 
  'samples': 56 // {{Integer}} 
};
var callback = function(error, data, response) {
  if (error) {
    console.error(error);
  } else {
    console.log('API called successfully. Returned data: ' + data);
  }
};
api.clusterMetrics3(source, target, metric, opts, callback);

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class clusterMetrics3Example
    {
        public void main()
        {

            // Configure API key authorization: Authorization
            Configuration.Default.ApiKey.Add("Authorization", "YOUR_API_KEY");
            // Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
            // Configuration.Default.ApiKeyPrefix.Add("Authorization", "Bearer");

            var apiInstance = new Class3SRMServiceAPIV2InternalApi();
            var source = source_example;  // String | 
            var target = target_example;  // String | 
            var metric = metric_example;  // String | 
            var minutes = 56;  // Integer |  (optional) 
            var hours = 56;  // Integer |  (optional) 
            var from = 789;  // Long |  (optional) 
            var to = 789;  // Long |  (optional) 
            var samples = 56;  // Integer |  (optional) 

            try
            {
                TimeSeriesResponseNumericMetricStats result = apiInstance.clusterMetrics3(source, target, metric, minutes, hours, from, to, samples);
                Debug.WriteLine(result);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling Class3SRMServiceAPIV2InternalApi.clusterMetrics3: " + e.Message );
            }
        }
    }
}

<?php
require_once(__DIR__ . '/vendor/autoload.php');

// Configure API key authorization: Authorization
Swagger\Client\Configuration::getDefaultConfiguration()->setApiKey('Authorization', 'YOUR_API_KEY');
// Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
// Swagger\Client\Configuration::getDefaultConfiguration()->setApiKeyPrefix('Authorization', 'Bearer');

$api_instance = new Swagger\Client\ApiClass3SRMServiceAPIV2InternalApi();
$source = source_example; // String | 
$target = target_example; // String | 
$metric = metric_example; // String | 
$minutes = 56; // Integer | 
$hours = 56; // Integer | 
$from = 789; // Long | 
$to = 789; // Long | 
$samples = 56; // Integer | 

try {
    $result = $api_instance->clusterMetrics3($source, $target, $metric, $minutes, $hours, $from, $to, $samples);
    print_r($result);
} catch (Exception $e) {
    echo 'Exception when calling Class3SRMServiceAPIV2InternalApi->clusterMetrics3: ', $e->getMessage(), PHP_EOL;
}
?>

use Data::Dumper;
use WWW::SwaggerClient::Configuration;
use WWW::SwaggerClient::Class3SRMServiceAPIV2InternalApi;

# Configure API key authorization: Authorization
$WWW::SwaggerClient::Configuration::api_key->{'Authorization'} = 'YOUR_API_KEY';
# uncomment below to setup prefix (e.g. Bearer) for API key, if needed
#$WWW::SwaggerClient::Configuration::api_key_prefix->{'Authorization'} = "Bearer";

my $api_instance = WWW::SwaggerClient::Class3SRMServiceAPIV2InternalApi->new();
my $source = source_example; # String | 
my $target = target_example; # String | 
my $metric = metric_example; # String | 
my $minutes = 56; # Integer | 
my $hours = 56; # Integer | 
my $from = 789; # Long | 
my $to = 789; # Long | 
my $samples = 56; # Integer | 

eval { 
    my $result = $api_instance->clusterMetrics3(source => $source, target => $target, metric => $metric, minutes => $minutes, hours => $hours, from => $from, to => $to, samples => $samples);
    print Dumper($result);
};
if ($@) {
    warn "Exception when calling Class3SRMServiceAPIV2InternalApi->clusterMetrics3: $@\n";
}

from __future__ import print_statement
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# Configure API key authorization: Authorization
swagger_client.configuration.api_key['Authorization'] = 'YOUR_API_KEY'
# Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
# swagger_client.configuration.api_key_prefix['Authorization'] = 'Bearer'

# create an instance of the API class
api_instance = swagger_client.Class3SRMServiceAPIV2InternalApi()
source = source_example # String | 
target = target_example # String | 
metric = metric_example # String | 
minutes = 56 # Integer |  (optional)
hours = 56 # Integer |  (optional)
from = 789 # Long |  (optional)
to = 789 # Long |  (optional)
samples = 56 # Integer |  (optional)

try: 
    api_response = api_instance.cluster_metrics3(source, target, metric, minutes=minutes, hours=hours, from=from, to=to, samples=samples)
    pprint(api_response)
except ApiException as e:
    print("Exception when calling Class3SRMServiceAPIV2InternalApi->clusterMetrics3: %s\n" % e)

import io.swagger.client.*;
import io.swagger.client.auth.*;
import io.swagger.client.model.*;
import io.swagger.client.api.Class3SRMServiceAPIV2InternalApi;

import java.io.File;
import java.util.*;

public class Class3SRMServiceAPIV2InternalApiExample {

    public static void main(String[] args) {
        ApiClient defaultClient = Configuration.getDefaultApiClient();

        // Configure API key authorization: Authorization
        ApiKeyAuth Authorization = (ApiKeyAuth) defaultClient.getAuthentication("Authorization");
        Authorization.setApiKey("YOUR API KEY");
        // Uncomment the following line to set a prefix for the API key, e.g. "Token" (defaults to null)
        //Authorization.setApiKeyPrefix("Token");

        Class3SRMServiceAPIV2InternalApi apiInstance = new Class3SRMServiceAPIV2InternalApi();
        String source = source_example; // String | 
        String target = target_example; // String | 
        String connector = connector_example; // String | 
        String metric = metric_example; // String | 
        Integer minutes = 56; // Integer | 
        Integer hours = 56; // Integer | 
        Long from = 789; // Long | 
        Long to = 789; // Long | 
        Integer samples = 56; // Integer | 
        try {
            TimeSeriesResponseConnectorStatusMetricStats result = apiInstance.connectorMetrics(source, target, connector, metric, minutes, hours, from, to, samples);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling Class3SRMServiceAPIV2InternalApi#connectorMetrics");
            e.printStackTrace();
        }
    }
}

import io.swagger.client.api.Class3SRMServiceAPIV2InternalApi;

public class Class3SRMServiceAPIV2InternalApiExample {

    public static void main(String[] args) {
        Class3SRMServiceAPIV2InternalApi apiInstance = new Class3SRMServiceAPIV2InternalApi();
        String source = source_example; // String | 
        String target = target_example; // String | 
        String connector = connector_example; // String | 
        String metric = metric_example; // String | 
        Integer minutes = 56; // Integer | 
        Integer hours = 56; // Integer | 
        Long from = 789; // Long | 
        Long to = 789; // Long | 
        Integer samples = 56; // Integer | 
        try {
            TimeSeriesResponseConnectorStatusMetricStats result = apiInstance.connectorMetrics(source, target, connector, metric, minutes, hours, from, to, samples);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling Class3SRMServiceAPIV2InternalApi#connectorMetrics");
            e.printStackTrace();
        }
    }
}

Configuration *apiConfig = [Configuration sharedConfig];
// Configure API key authorization: (authentication scheme: Authorization)
[apiConfig setApiKey:@"YOUR_API_KEY" forApiKeyIdentifier:@"Authorization"];
// Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
//[apiConfig setApiKeyPrefix:@"Bearer" forApiKeyIdentifier:@"Authorization"];
String *source = source_example; // 
String *target = target_example; // 
String *connector = connector_example; // 
String *metric = metric_example; // 
Integer *minutes = 56; //  (optional)
Integer *hours = 56; //  (optional)
Long *from = 789; //  (optional)
Long *to = 789; //  (optional)
Integer *samples = 56; //  (optional)

Class3SRMServiceAPIV2InternalApi *apiInstance = [[Class3SRMServiceAPIV2InternalApi alloc] init];

[apiInstance connectorMetricsWith:source
    target:target
    connector:connector
    metric:metric
    minutes:minutes
    hours:hours
    from:from
    to:to
    samples:samples
              completionHandler: ^(TimeSeriesResponseConnectorStatusMetricStats output, NSError* error) {
                            if (output) {
                                NSLog(@"%@", output);
                            }
                            if (error) {
                                NSLog(@"Error: %@", error);
                            }
                        }];

var SwaggerJsClient = require('swagger-js-client');
var defaultClient = SwaggerJsClient.ApiClient.instance;

// Configure API key authorization: Authorization
var Authorization = defaultClient.authentications['Authorization'];
Authorization.apiKey = "YOUR API KEY"
// Uncomment the following line to set a prefix for the API key, e.g. "Token" (defaults to null)
//Authorization.apiKeyPrefix['Authorization'] = "Token"

var api = new SwaggerJsClient.Class3SRMServiceAPIV2InternalApi()
var source = source_example; // {{String}} 
var target = target_example; // {{String}} 
var connector = connector_example; // {{String}} 
var metric = metric_example; // {{String}} 
var opts = { 
  'minutes': 56, // {{Integer}} 
  'hours': 56, // {{Integer}} 
  'from': 789, // {{Long}} 
  'to': 789, // {{Long}} 
  'samples': 56 // {{Integer}} 
};
var callback = function(error, data, response) {
  if (error) {
    console.error(error);
  } else {
    console.log('API called successfully. Returned data: ' + data);
  }
};
api.connectorMetrics(source, target, connector, metric, opts, callback);

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class connectorMetricsExample
    {
        public void main()
        {

            // Configure API key authorization: Authorization
            Configuration.Default.ApiKey.Add("Authorization", "YOUR_API_KEY");
            // Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
            // Configuration.Default.ApiKeyPrefix.Add("Authorization", "Bearer");

            var apiInstance = new Class3SRMServiceAPIV2InternalApi();
            var source = source_example;  // String | 
            var target = target_example;  // String | 
            var connector = connector_example;  // String | 
            var metric = metric_example;  // String | 
            var minutes = 56;  // Integer |  (optional) 
            var hours = 56;  // Integer |  (optional) 
            var from = 789;  // Long |  (optional) 
            var to = 789;  // Long |  (optional) 
            var samples = 56;  // Integer |  (optional) 

            try
            {
                TimeSeriesResponseConnectorStatusMetricStats result = apiInstance.connectorMetrics(source, target, connector, metric, minutes, hours, from, to, samples);
                Debug.WriteLine(result);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling Class3SRMServiceAPIV2InternalApi.connectorMetrics: " + e.Message );
            }
        }
    }
}

<?php
require_once(__DIR__ . '/vendor/autoload.php');

// Configure API key authorization: Authorization
Swagger\Client\Configuration::getDefaultConfiguration()->setApiKey('Authorization', 'YOUR_API_KEY');
// Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
// Swagger\Client\Configuration::getDefaultConfiguration()->setApiKeyPrefix('Authorization', 'Bearer');

$api_instance = new Swagger\Client\ApiClass3SRMServiceAPIV2InternalApi();
$source = source_example; // String | 
$target = target_example; // String | 
$connector = connector_example; // String | 
$metric = metric_example; // String | 
$minutes = 56; // Integer | 
$hours = 56; // Integer | 
$from = 789; // Long | 
$to = 789; // Long | 
$samples = 56; // Integer | 

try {
    $result = $api_instance->connectorMetrics($source, $target, $connector, $metric, $minutes, $hours, $from, $to, $samples);
    print_r($result);
} catch (Exception $e) {
    echo 'Exception when calling Class3SRMServiceAPIV2InternalApi->connectorMetrics: ', $e->getMessage(), PHP_EOL;
}
?>

use Data::Dumper;
use WWW::SwaggerClient::Configuration;
use WWW::SwaggerClient::Class3SRMServiceAPIV2InternalApi;

# Configure API key authorization: Authorization
$WWW::SwaggerClient::Configuration::api_key->{'Authorization'} = 'YOUR_API_KEY';
# uncomment below to setup prefix (e.g. Bearer) for API key, if needed
#$WWW::SwaggerClient::Configuration::api_key_prefix->{'Authorization'} = "Bearer";

my $api_instance = WWW::SwaggerClient::Class3SRMServiceAPIV2InternalApi->new();
my $source = source_example; # String | 
my $target = target_example; # String | 
my $connector = connector_example; # String | 
my $metric = metric_example; # String | 
my $minutes = 56; # Integer | 
my $hours = 56; # Integer | 
my $from = 789; # Long | 
my $to = 789; # Long | 
my $samples = 56; # Integer | 

eval { 
    my $result = $api_instance->connectorMetrics(source => $source, target => $target, connector => $connector, metric => $metric, minutes => $minutes, hours => $hours, from => $from, to => $to, samples => $samples);
    print Dumper($result);
};
if ($@) {
    warn "Exception when calling Class3SRMServiceAPIV2InternalApi->connectorMetrics: $@\n";
}

from __future__ import print_statement
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# Configure API key authorization: Authorization
swagger_client.configuration.api_key['Authorization'] = 'YOUR_API_KEY'
# Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
# swagger_client.configuration.api_key_prefix['Authorization'] = 'Bearer'

# create an instance of the API class
api_instance = swagger_client.Class3SRMServiceAPIV2InternalApi()
source = source_example # String | 
target = target_example # String | 
connector = connector_example # String | 
metric = metric_example # String | 
minutes = 56 # Integer |  (optional)
hours = 56 # Integer |  (optional)
from = 789 # Long |  (optional)
to = 789 # Long |  (optional)
samples = 56 # Integer |  (optional)

try: 
    api_response = api_instance.connector_metrics(source, target, connector, metric, minutes=minutes, hours=hours, from=from, to=to, samples=samples)
    pprint(api_response)
except ApiException as e:
    print("Exception when calling Class3SRMServiceAPIV2InternalApi->connectorMetrics: %s\n" % e)

import io.swagger.client.*;
import io.swagger.client.auth.*;
import io.swagger.client.model.*;
import io.swagger.client.api.Class3SRMServiceAPIV2InternalApi;

import java.io.File;
import java.util.*;

public class Class3SRMServiceAPIV2InternalApiExample {

    public static void main(String[] args) {
        
        Class3SRMServiceAPIV2InternalApi apiInstance = new Class3SRMServiceAPIV2InternalApi();
        try {
            apiInstance.healthCheck();
        } catch (ApiException e) {
            System.err.println("Exception when calling Class3SRMServiceAPIV2InternalApi#healthCheck");
            e.printStackTrace();
        }
    }
}

import io.swagger.client.api.Class3SRMServiceAPIV2InternalApi;

public class Class3SRMServiceAPIV2InternalApiExample {

    public static void main(String[] args) {
        Class3SRMServiceAPIV2InternalApi apiInstance = new Class3SRMServiceAPIV2InternalApi();
        try {
            apiInstance.healthCheck();
        } catch (ApiException e) {
            System.err.println("Exception when calling Class3SRMServiceAPIV2InternalApi#healthCheck");
            e.printStackTrace();
        }
    }
}

Class3SRMServiceAPIV2InternalApi *apiInstance = [[Class3SRMServiceAPIV2InternalApi alloc] init];

// Health check.
[apiInstance healthCheckWithCompletionHandler: 
              ^(NSError* error) {
                            if (error) {
                                NSLog(@"Error: %@", error);
                            }
                        }];

var SwaggerJsClient = require('swagger-js-client');

var api = new SwaggerJsClient.Class3SRMServiceAPIV2InternalApi()
var callback = function(error, data, response) {
  if (error) {
    console.error(error);
  } else {
    console.log('API called successfully.');
  }
};
api.healthCheck(callback);

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class healthCheckExample
    {
        public void main()
        {

            var apiInstance = new Class3SRMServiceAPIV2InternalApi();

            try
            {
                // Health check.
                apiInstance.healthCheck();
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling Class3SRMServiceAPIV2InternalApi.healthCheck: " + e.Message );
            }
        }
    }
}

<?php
require_once(__DIR__ . '/vendor/autoload.php');

$api_instance = new Swagger\Client\ApiClass3SRMServiceAPIV2InternalApi();

try {
    $api_instance->healthCheck();
} catch (Exception $e) {
    echo 'Exception when calling Class3SRMServiceAPIV2InternalApi->healthCheck: ', $e->getMessage(), PHP_EOL;
}
?>

use Data::Dumper;
use WWW::SwaggerClient::Configuration;
use WWW::SwaggerClient::Class3SRMServiceAPIV2InternalApi;

my $api_instance = WWW::SwaggerClient::Class3SRMServiceAPIV2InternalApi->new();

eval { 
    $api_instance->healthCheck();
};
if ($@) {
    warn "Exception when calling Class3SRMServiceAPIV2InternalApi->healthCheck: $@\n";
}

from __future__ import print_statement
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# create an instance of the API class
api_instance = swagger_client.Class3SRMServiceAPIV2InternalApi()

try: 
    # Health check.
    api_instance.health_check()
except ApiException as e:
    print("Exception when calling Class3SRMServiceAPIV2InternalApi->healthCheck: %s\n" % e)

import io.swagger.client.*;
import io.swagger.client.auth.*;
import io.swagger.client.model.*;
import io.swagger.client.api.Class3SRMServiceAPIV2InternalApi;

import java.io.File;
import java.util.*;

public class Class3SRMServiceAPIV2InternalApiExample {

    public static void main(String[] args) {
        ApiClient defaultClient = Configuration.getDefaultApiClient();

        // Configure API key authorization: Authorization
        ApiKeyAuth Authorization = (ApiKeyAuth) defaultClient.getAuthentication("Authorization");
        Authorization.setApiKey("YOUR API KEY");
        // Uncomment the following line to set a prefix for the API key, e.g. "Token" (defaults to null)
        //Authorization.setApiKeyPrefix("Token");

        Class3SRMServiceAPIV2InternalApi apiInstance = new Class3SRMServiceAPIV2InternalApi();
        String source = source_example; // String | 
        String target = target_example; // String | 
        Integer minutes = 56; // Integer | 
        Integer hours = 56; // Integer | 
        Long from = 789; // Long | 
        Long to = 789; // Long | 
        try {
            map['String', TopicInfo] result = apiInstance.remoteTopics2(source, target, minutes, hours, from, to);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling Class3SRMServiceAPIV2InternalApi#remoteTopics2");
            e.printStackTrace();
        }
    }
}

import io.swagger.client.api.Class3SRMServiceAPIV2InternalApi;

public class Class3SRMServiceAPIV2InternalApiExample {

    public static void main(String[] args) {
        Class3SRMServiceAPIV2InternalApi apiInstance = new Class3SRMServiceAPIV2InternalApi();
        String source = source_example; // String | 
        String target = target_example; // String | 
        Integer minutes = 56; // Integer | 
        Integer hours = 56; // Integer | 
        Long from = 789; // Long | 
        Long to = 789; // Long | 
        try {
            map['String', TopicInfo] result = apiInstance.remoteTopics2(source, target, minutes, hours, from, to);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling Class3SRMServiceAPIV2InternalApi#remoteTopics2");
            e.printStackTrace();
        }
    }
}

Configuration *apiConfig = [Configuration sharedConfig];
// Configure API key authorization: (authentication scheme: Authorization)
[apiConfig setApiKey:@"YOUR_API_KEY" forApiKeyIdentifier:@"Authorization"];
// Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
//[apiConfig setApiKeyPrefix:@"Bearer" forApiKeyIdentifier:@"Authorization"];
String *source = source_example; // 
String *target = target_example; // 
Integer *minutes = 56; //  (optional)
Integer *hours = 56; //  (optional)
Long *from = 789; //  (optional)
Long *to = 789; //  (optional)

Class3SRMServiceAPIV2InternalApi *apiInstance = [[Class3SRMServiceAPIV2InternalApi alloc] init];

[apiInstance remoteTopics2With:source
    target:target
    minutes:minutes
    hours:hours
    from:from
    to:to
              completionHandler: ^(map['String', TopicInfo] output, NSError* error) {
                            if (output) {
                                NSLog(@"%@", output);
                            }
                            if (error) {
                                NSLog(@"Error: %@", error);
                            }
                        }];

var SwaggerJsClient = require('swagger-js-client');
var defaultClient = SwaggerJsClient.ApiClient.instance;

// Configure API key authorization: Authorization
var Authorization = defaultClient.authentications['Authorization'];
Authorization.apiKey = "YOUR API KEY"
// Uncomment the following line to set a prefix for the API key, e.g. "Token" (defaults to null)
//Authorization.apiKeyPrefix['Authorization'] = "Token"

var api = new SwaggerJsClient.Class3SRMServiceAPIV2InternalApi()
var source = source_example; // {{String}} 
var target = target_example; // {{String}} 
var opts = { 
  'minutes': 56, // {{Integer}} 
  'hours': 56, // {{Integer}} 
  'from': 789, // {{Long}} 
  'to': 789 // {{Long}} 
};
var callback = function(error, data, response) {
  if (error) {
    console.error(error);
  } else {
    console.log('API called successfully. Returned data: ' + data);
  }
};
api.remoteTopics2(source, target, opts, callback);

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class remoteTopics2Example
    {
        public void main()
        {

            // Configure API key authorization: Authorization
            Configuration.Default.ApiKey.Add("Authorization", "YOUR_API_KEY");
            // Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
            // Configuration.Default.ApiKeyPrefix.Add("Authorization", "Bearer");

            var apiInstance = new Class3SRMServiceAPIV2InternalApi();
            var source = source_example;  // String | 
            var target = target_example;  // String | 
            var minutes = 56;  // Integer |  (optional) 
            var hours = 56;  // Integer |  (optional) 
            var from = 789;  // Long |  (optional) 
            var to = 789;  // Long |  (optional) 

            try
            {
                map['String', TopicInfo] result = apiInstance.remoteTopics2(source, target, minutes, hours, from, to);
                Debug.WriteLine(result);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling Class3SRMServiceAPIV2InternalApi.remoteTopics2: " + e.Message );
            }
        }
    }
}

<?php
require_once(__DIR__ . '/vendor/autoload.php');

// Configure API key authorization: Authorization
Swagger\Client\Configuration::getDefaultConfiguration()->setApiKey('Authorization', 'YOUR_API_KEY');
// Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
// Swagger\Client\Configuration::getDefaultConfiguration()->setApiKeyPrefix('Authorization', 'Bearer');

$api_instance = new Swagger\Client\ApiClass3SRMServiceAPIV2InternalApi();
$source = source_example; // String | 
$target = target_example; // String | 
$minutes = 56; // Integer | 
$hours = 56; // Integer | 
$from = 789; // Long | 
$to = 789; // Long | 

try {
    $result = $api_instance->remoteTopics2($source, $target, $minutes, $hours, $from, $to);
    print_r($result);
} catch (Exception $e) {
    echo 'Exception when calling Class3SRMServiceAPIV2InternalApi->remoteTopics2: ', $e->getMessage(), PHP_EOL;
}
?>

use Data::Dumper;
use WWW::SwaggerClient::Configuration;
use WWW::SwaggerClient::Class3SRMServiceAPIV2InternalApi;

# Configure API key authorization: Authorization
$WWW::SwaggerClient::Configuration::api_key->{'Authorization'} = 'YOUR_API_KEY';
# uncomment below to setup prefix (e.g. Bearer) for API key, if needed
#$WWW::SwaggerClient::Configuration::api_key_prefix->{'Authorization'} = "Bearer";

my $api_instance = WWW::SwaggerClient::Class3SRMServiceAPIV2InternalApi->new();
my $source = source_example; # String | 
my $target = target_example; # String | 
my $minutes = 56; # Integer | 
my $hours = 56; # Integer | 
my $from = 789; # Long | 
my $to = 789; # Long | 

eval { 
    my $result = $api_instance->remoteTopics2(source => $source, target => $target, minutes => $minutes, hours => $hours, from => $from, to => $to);
    print Dumper($result);
};
if ($@) {
    warn "Exception when calling Class3SRMServiceAPIV2InternalApi->remoteTopics2: $@\n";
}

from __future__ import print_statement
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# Configure API key authorization: Authorization
swagger_client.configuration.api_key['Authorization'] = 'YOUR_API_KEY'
# Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
# swagger_client.configuration.api_key_prefix['Authorization'] = 'Bearer'

# create an instance of the API class
api_instance = swagger_client.Class3SRMServiceAPIV2InternalApi()
source = source_example # String | 
target = target_example # String | 
minutes = 56 # Integer |  (optional)
hours = 56 # Integer |  (optional)
from = 789 # Long |  (optional)
to = 789 # Long |  (optional)

try: 
    api_response = api_instance.remote_topics2(source, target, minutes=minutes, hours=hours, from=from, to=to)
    pprint(api_response)
except ApiException as e:
    print("Exception when calling Class3SRMServiceAPIV2InternalApi->remoteTopics2: %s\n" % e)

import io.swagger.client.*;
import io.swagger.client.auth.*;
import io.swagger.client.model.*;
import io.swagger.client.api.Class3SRMServiceAPIV2InternalApi;

import java.io.File;
import java.util.*;

public class Class3SRMServiceAPIV2InternalApiExample {

    public static void main(String[] args) {
        ApiClient defaultClient = Configuration.getDefaultApiClient();

        // Configure API key authorization: Authorization
        ApiKeyAuth Authorization = (ApiKeyAuth) defaultClient.getAuthentication("Authorization");
        Authorization.setApiKey("YOUR API KEY");
        // Uncomment the following line to set a prefix for the API key, e.g. "Token" (defaults to null)
        //Authorization.setApiKeyPrefix("Token");

        Class3SRMServiceAPIV2InternalApi apiInstance = new Class3SRMServiceAPIV2InternalApi();
        array[String] sources = ; // array[String] | 
        array[String] targets = ; // array[String] | 
        Integer minutes = 56; // Integer | 
        Integer hours = 56; // Integer | 
        Long from = 789; // Long | 
        Long to = 789; // Long | 
        try {
            map['String', ReplicationInfo] result = apiInstance.replications1(sources, targets, minutes, hours, from, to);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling Class3SRMServiceAPIV2InternalApi#replications1");
            e.printStackTrace();
        }
    }
}

import io.swagger.client.api.Class3SRMServiceAPIV2InternalApi;

public class Class3SRMServiceAPIV2InternalApiExample {

    public static void main(String[] args) {
        Class3SRMServiceAPIV2InternalApi apiInstance = new Class3SRMServiceAPIV2InternalApi();
        array[String] sources = ; // array[String] | 
        array[String] targets = ; // array[String] | 
        Integer minutes = 56; // Integer | 
        Integer hours = 56; // Integer | 
        Long from = 789; // Long | 
        Long to = 789; // Long | 
        try {
            map['String', ReplicationInfo] result = apiInstance.replications1(sources, targets, minutes, hours, from, to);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling Class3SRMServiceAPIV2InternalApi#replications1");
            e.printStackTrace();
        }
    }
}

Configuration *apiConfig = [Configuration sharedConfig];
// Configure API key authorization: (authentication scheme: Authorization)
[apiConfig setApiKey:@"YOUR_API_KEY" forApiKeyIdentifier:@"Authorization"];
// Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
//[apiConfig setApiKeyPrefix:@"Bearer" forApiKeyIdentifier:@"Authorization"];
array[String] *sources = ; //  (optional)
array[String] *targets = ; //  (optional)
Integer *minutes = 56; //  (optional)
Integer *hours = 56; //  (optional)
Long *from = 789; //  (optional)
Long *to = 789; //  (optional)

Class3SRMServiceAPIV2InternalApi *apiInstance = [[Class3SRMServiceAPIV2InternalApi alloc] init];

[apiInstance replications1With:sources
    targets:targets
    minutes:minutes
    hours:hours
    from:from
    to:to
              completionHandler: ^(map['String', ReplicationInfo] output, NSError* error) {
                            if (output) {
                                NSLog(@"%@", output);
                            }
                            if (error) {
                                NSLog(@"Error: %@", error);
                            }
                        }];

var SwaggerJsClient = require('swagger-js-client');
var defaultClient = SwaggerJsClient.ApiClient.instance;

// Configure API key authorization: Authorization
var Authorization = defaultClient.authentications['Authorization'];
Authorization.apiKey = "YOUR API KEY"
// Uncomment the following line to set a prefix for the API key, e.g. "Token" (defaults to null)
//Authorization.apiKeyPrefix['Authorization'] = "Token"

var api = new SwaggerJsClient.Class3SRMServiceAPIV2InternalApi()
var opts = { 
  'sources': , // {{array[String]}} 
  'targets': , // {{array[String]}} 
  'minutes': 56, // {{Integer}} 
  'hours': 56, // {{Integer}} 
  'from': 789, // {{Long}} 
  'to': 789 // {{Long}} 
};
var callback = function(error, data, response) {
  if (error) {
    console.error(error);
  } else {
    console.log('API called successfully. Returned data: ' + data);
  }
};
api.replications1(opts, callback);

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class replications1Example
    {
        public void main()
        {

            // Configure API key authorization: Authorization
            Configuration.Default.ApiKey.Add("Authorization", "YOUR_API_KEY");
            // Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
            // Configuration.Default.ApiKeyPrefix.Add("Authorization", "Bearer");

            var apiInstance = new Class3SRMServiceAPIV2InternalApi();
            var sources = new array[String](); // array[String] |  (optional) 
            var targets = new array[String](); // array[String] |  (optional) 
            var minutes = 56;  // Integer |  (optional) 
            var hours = 56;  // Integer |  (optional) 
            var from = 789;  // Long |  (optional) 
            var to = 789;  // Long |  (optional) 

            try
            {
                map['String', ReplicationInfo] result = apiInstance.replications1(sources, targets, minutes, hours, from, to);
                Debug.WriteLine(result);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling Class3SRMServiceAPIV2InternalApi.replications1: " + e.Message );
            }
        }
    }
}

<?php
require_once(__DIR__ . '/vendor/autoload.php');

// Configure API key authorization: Authorization
Swagger\Client\Configuration::getDefaultConfiguration()->setApiKey('Authorization', 'YOUR_API_KEY');
// Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
// Swagger\Client\Configuration::getDefaultConfiguration()->setApiKeyPrefix('Authorization', 'Bearer');

$api_instance = new Swagger\Client\ApiClass3SRMServiceAPIV2InternalApi();
$sources = ; // array[String] | 
$targets = ; // array[String] | 
$minutes = 56; // Integer | 
$hours = 56; // Integer | 
$from = 789; // Long | 
$to = 789; // Long | 

try {
    $result = $api_instance->replications1($sources, $targets, $minutes, $hours, $from, $to);
    print_r($result);
} catch (Exception $e) {
    echo 'Exception when calling Class3SRMServiceAPIV2InternalApi->replications1: ', $e->getMessage(), PHP_EOL;
}
?>

use Data::Dumper;
use WWW::SwaggerClient::Configuration;
use WWW::SwaggerClient::Class3SRMServiceAPIV2InternalApi;

# Configure API key authorization: Authorization
$WWW::SwaggerClient::Configuration::api_key->{'Authorization'} = 'YOUR_API_KEY';
# uncomment below to setup prefix (e.g. Bearer) for API key, if needed
#$WWW::SwaggerClient::Configuration::api_key_prefix->{'Authorization'} = "Bearer";

my $api_instance = WWW::SwaggerClient::Class3SRMServiceAPIV2InternalApi->new();
my $sources = []; # array[String] | 
my $targets = []; # array[String] | 
my $minutes = 56; # Integer | 
my $hours = 56; # Integer | 
my $from = 789; # Long | 
my $to = 789; # Long | 

eval { 
    my $result = $api_instance->replications1(sources => $sources, targets => $targets, minutes => $minutes, hours => $hours, from => $from, to => $to);
    print Dumper($result);
};
if ($@) {
    warn "Exception when calling Class3SRMServiceAPIV2InternalApi->replications1: $@\n";
}

from __future__ import print_statement
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# Configure API key authorization: Authorization
swagger_client.configuration.api_key['Authorization'] = 'YOUR_API_KEY'
# Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
# swagger_client.configuration.api_key_prefix['Authorization'] = 'Bearer'

# create an instance of the API class
api_instance = swagger_client.Class3SRMServiceAPIV2InternalApi()
sources =  # array[String] |  (optional)
targets =  # array[String] |  (optional)
minutes = 56 # Integer |  (optional)
hours = 56 # Integer |  (optional)
from = 789 # Long |  (optional)
to = 789 # Long |  (optional)

try: 
    api_response = api_instance.replications1(sources=sources, targets=targets, minutes=minutes, hours=hours, from=from, to=to)
    pprint(api_response)
except ApiException as e:
    print("Exception when calling Class3SRMServiceAPIV2InternalApi->replications1: %s\n" % e)

import io.swagger.client.*;
import io.swagger.client.auth.*;
import io.swagger.client.model.*;
import io.swagger.client.api.Class3SRMServiceAPIV2InternalApi;

import java.io.File;
import java.util.*;

public class Class3SRMServiceAPIV2InternalApiExample {

    public static void main(String[] args) {
        ApiClient defaultClient = Configuration.getDefaultApiClient();

        // Configure API key authorization: Authorization
        ApiKeyAuth Authorization = (ApiKeyAuth) defaultClient.getAuthentication("Authorization");
        Authorization.setApiKey("YOUR API KEY");
        // Uncomment the following line to set a prefix for the API key, e.g. "Token" (defaults to null)
        //Authorization.setApiKeyPrefix("Token");

        Class3SRMServiceAPIV2InternalApi apiInstance = new Class3SRMServiceAPIV2InternalApi();
        String source = source_example; // String | 
        String target = target_example; // String | 
        String upstreamTopic = upstreamTopic_example; // String | 
        String metric = metric_example; // String | 
        Integer minutes = 56; // Integer | 
        Integer hours = 56; // Integer | 
        Long from = 789; // Long | 
        Long to = 789; // Long | 
        Integer samples = 56; // Integer | 
        try {
            TimeSeriesResponseNumericMetricStats result = apiInstance.topicMetrics1(source, target, upstreamTopic, metric, minutes, hours, from, to, samples);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling Class3SRMServiceAPIV2InternalApi#topicMetrics1");
            e.printStackTrace();
        }
    }
}

import io.swagger.client.api.Class3SRMServiceAPIV2InternalApi;

public class Class3SRMServiceAPIV2InternalApiExample {

    public static void main(String[] args) {
        Class3SRMServiceAPIV2InternalApi apiInstance = new Class3SRMServiceAPIV2InternalApi();
        String source = source_example; // String | 
        String target = target_example; // String | 
        String upstreamTopic = upstreamTopic_example; // String | 
        String metric = metric_example; // String | 
        Integer minutes = 56; // Integer | 
        Integer hours = 56; // Integer | 
        Long from = 789; // Long | 
        Long to = 789; // Long | 
        Integer samples = 56; // Integer | 
        try {
            TimeSeriesResponseNumericMetricStats result = apiInstance.topicMetrics1(source, target, upstreamTopic, metric, minutes, hours, from, to, samples);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling Class3SRMServiceAPIV2InternalApi#topicMetrics1");
            e.printStackTrace();
        }
    }
}

Configuration *apiConfig = [Configuration sharedConfig];
// Configure API key authorization: (authentication scheme: Authorization)
[apiConfig setApiKey:@"YOUR_API_KEY" forApiKeyIdentifier:@"Authorization"];
// Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
//[apiConfig setApiKeyPrefix:@"Bearer" forApiKeyIdentifier:@"Authorization"];
String *source = source_example; // 
String *target = target_example; // 
String *upstreamTopic = upstreamTopic_example; // 
String *metric = metric_example; // 
Integer *minutes = 56; //  (optional)
Integer *hours = 56; //  (optional)
Long *from = 789; //  (optional)
Long *to = 789; //  (optional)
Integer *samples = 56; //  (optional)

Class3SRMServiceAPIV2InternalApi *apiInstance = [[Class3SRMServiceAPIV2InternalApi alloc] init];

[apiInstance topicMetrics1With:source
    target:target
    upstreamTopic:upstreamTopic
    metric:metric
    minutes:minutes
    hours:hours
    from:from
    to:to
    samples:samples
              completionHandler: ^(TimeSeriesResponseNumericMetricStats output, NSError* error) {
                            if (output) {
                                NSLog(@"%@", output);
                            }
                            if (error) {
                                NSLog(@"Error: %@", error);
                            }
                        }];

var SwaggerJsClient = require('swagger-js-client');
var defaultClient = SwaggerJsClient.ApiClient.instance;

// Configure API key authorization: Authorization
var Authorization = defaultClient.authentications['Authorization'];
Authorization.apiKey = "YOUR API KEY"
// Uncomment the following line to set a prefix for the API key, e.g. "Token" (defaults to null)
//Authorization.apiKeyPrefix['Authorization'] = "Token"

var api = new SwaggerJsClient.Class3SRMServiceAPIV2InternalApi()
var source = source_example; // {{String}} 
var target = target_example; // {{String}} 
var upstreamTopic = upstreamTopic_example; // {{String}} 
var metric = metric_example; // {{String}} 
var opts = { 
  'minutes': 56, // {{Integer}} 
  'hours': 56, // {{Integer}} 
  'from': 789, // {{Long}} 
  'to': 789, // {{Long}} 
  'samples': 56 // {{Integer}} 
};
var callback = function(error, data, response) {
  if (error) {
    console.error(error);
  } else {
    console.log('API called successfully. Returned data: ' + data);
  }
};
api.topicMetrics1(source, target, upstreamTopic, metric, opts, callback);

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class topicMetrics1Example
    {
        public void main()
        {

            // Configure API key authorization: Authorization
            Configuration.Default.ApiKey.Add("Authorization", "YOUR_API_KEY");
            // Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
            // Configuration.Default.ApiKeyPrefix.Add("Authorization", "Bearer");

            var apiInstance = new Class3SRMServiceAPIV2InternalApi();
            var source = source_example;  // String | 
            var target = target_example;  // String | 
            var upstreamTopic = upstreamTopic_example;  // String | 
            var metric = metric_example;  // String | 
            var minutes = 56;  // Integer |  (optional) 
            var hours = 56;  // Integer |  (optional) 
            var from = 789;  // Long |  (optional) 
            var to = 789;  // Long |  (optional) 
            var samples = 56;  // Integer |  (optional) 

            try
            {
                TimeSeriesResponseNumericMetricStats result = apiInstance.topicMetrics1(source, target, upstreamTopic, metric, minutes, hours, from, to, samples);
                Debug.WriteLine(result);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling Class3SRMServiceAPIV2InternalApi.topicMetrics1: " + e.Message );
            }
        }
    }
}

<?php
require_once(__DIR__ . '/vendor/autoload.php');

// Configure API key authorization: Authorization
Swagger\Client\Configuration::getDefaultConfiguration()->setApiKey('Authorization', 'YOUR_API_KEY');
// Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
// Swagger\Client\Configuration::getDefaultConfiguration()->setApiKeyPrefix('Authorization', 'Bearer');

$api_instance = new Swagger\Client\ApiClass3SRMServiceAPIV2InternalApi();
$source = source_example; // String | 
$target = target_example; // String | 
$upstreamTopic = upstreamTopic_example; // String | 
$metric = metric_example; // String | 
$minutes = 56; // Integer | 
$hours = 56; // Integer | 
$from = 789; // Long | 
$to = 789; // Long | 
$samples = 56; // Integer | 

try {
    $result = $api_instance->topicMetrics1($source, $target, $upstreamTopic, $metric, $minutes, $hours, $from, $to, $samples);
    print_r($result);
} catch (Exception $e) {
    echo 'Exception when calling Class3SRMServiceAPIV2InternalApi->topicMetrics1: ', $e->getMessage(), PHP_EOL;
}
?>

use Data::Dumper;
use WWW::SwaggerClient::Configuration;
use WWW::SwaggerClient::Class3SRMServiceAPIV2InternalApi;

# Configure API key authorization: Authorization
$WWW::SwaggerClient::Configuration::api_key->{'Authorization'} = 'YOUR_API_KEY';
# uncomment below to setup prefix (e.g. Bearer) for API key, if needed
#$WWW::SwaggerClient::Configuration::api_key_prefix->{'Authorization'} = "Bearer";

my $api_instance = WWW::SwaggerClient::Class3SRMServiceAPIV2InternalApi->new();
my $source = source_example; # String | 
my $target = target_example; # String | 
my $upstreamTopic = upstreamTopic_example; # String | 
my $metric = metric_example; # String | 
my $minutes = 56; # Integer | 
my $hours = 56; # Integer | 
my $from = 789; # Long | 
my $to = 789; # Long | 
my $samples = 56; # Integer | 

eval { 
    my $result = $api_instance->topicMetrics1(source => $source, target => $target, upstreamTopic => $upstreamTopic, metric => $metric, minutes => $minutes, hours => $hours, from => $from, to => $to, samples => $samples);
    print Dumper($result);
};
if ($@) {
    warn "Exception when calling Class3SRMServiceAPIV2InternalApi->topicMetrics1: $@\n";
}

from __future__ import print_statement
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# Configure API key authorization: Authorization
swagger_client.configuration.api_key['Authorization'] = 'YOUR_API_KEY'
# Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
# swagger_client.configuration.api_key_prefix['Authorization'] = 'Bearer'

# create an instance of the API class
api_instance = swagger_client.Class3SRMServiceAPIV2InternalApi()
source = source_example # String | 
target = target_example # String | 
upstreamTopic = upstreamTopic_example # String | 
metric = metric_example # String | 
minutes = 56 # Integer |  (optional)
hours = 56 # Integer |  (optional)
from = 789 # Long |  (optional)
to = 789 # Long |  (optional)
samples = 56 # Integer |  (optional)

try: 
    api_response = api_instance.topic_metrics1(source, target, upstreamTopic, metric, minutes=minutes, hours=hours, from=from, to=to, samples=samples)
    pprint(api_response)
except ApiException as e:
    print("Exception when calling Class3SRMServiceAPIV2InternalApi->topicMetrics1: %s\n" % e)

import io.swagger.client.*;
import io.swagger.client.auth.*;
import io.swagger.client.model.*;
import io.swagger.client.api.Class3SRMServiceAPIV2InternalApi;

import java.io.File;
import java.util.*;

public class Class3SRMServiceAPIV2InternalApiExample {

    public static void main(String[] args) {
        ApiClient defaultClient = Configuration.getDefaultApiClient();

        // Configure API key authorization: Authorization
        ApiKeyAuth Authorization = (ApiKeyAuth) defaultClient.getAuthentication("Authorization");
        Authorization.setApiKey("YOUR API KEY");
        // Uncomment the following line to set a prefix for the API key, e.g. "Token" (defaults to null)
        //Authorization.setApiKeyPrefix("Token");

        Class3SRMServiceAPIV2InternalApi apiInstance = new Class3SRMServiceAPIV2InternalApi();
        String target = target_example; // String | 
        String downstreamTopic = downstreamTopic_example; // String | 
        String metric = metric_example; // String | 
        Integer minutes = 56; // Integer | 
        Integer hours = 56; // Integer | 
        Long from = 789; // Long | 
        Long to = 789; // Long | 
        Integer samples = 56; // Integer | 
        try {
            TimeSeriesResponseNumericMetricStats result = apiInstance.topicMetricsWithDownstreamTopicName2(target, downstreamTopic, metric, minutes, hours, from, to, samples);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling Class3SRMServiceAPIV2InternalApi#topicMetricsWithDownstreamTopicName2");
            e.printStackTrace();
        }
    }
}

import io.swagger.client.api.Class3SRMServiceAPIV2InternalApi;

public class Class3SRMServiceAPIV2InternalApiExample {

    public static void main(String[] args) {
        Class3SRMServiceAPIV2InternalApi apiInstance = new Class3SRMServiceAPIV2InternalApi();
        String target = target_example; // String | 
        String downstreamTopic = downstreamTopic_example; // String | 
        String metric = metric_example; // String | 
        Integer minutes = 56; // Integer | 
        Integer hours = 56; // Integer | 
        Long from = 789; // Long | 
        Long to = 789; // Long | 
        Integer samples = 56; // Integer | 
        try {
            TimeSeriesResponseNumericMetricStats result = apiInstance.topicMetricsWithDownstreamTopicName2(target, downstreamTopic, metric, minutes, hours, from, to, samples);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling Class3SRMServiceAPIV2InternalApi#topicMetricsWithDownstreamTopicName2");
            e.printStackTrace();
        }
    }
}

Configuration *apiConfig = [Configuration sharedConfig];
// Configure API key authorization: (authentication scheme: Authorization)
[apiConfig setApiKey:@"YOUR_API_KEY" forApiKeyIdentifier:@"Authorization"];
// Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
//[apiConfig setApiKeyPrefix:@"Bearer" forApiKeyIdentifier:@"Authorization"];
String *target = target_example; // 
String *downstreamTopic = downstreamTopic_example; // 
String *metric = metric_example; // 
Integer *minutes = 56; //  (optional)
Integer *hours = 56; //  (optional)
Long *from = 789; //  (optional)
Long *to = 789; //  (optional)
Integer *samples = 56; //  (optional) (default to 1000)

Class3SRMServiceAPIV2InternalApi *apiInstance = [[Class3SRMServiceAPIV2InternalApi alloc] init];

[apiInstance topicMetricsWithDownstreamTopicName2With:target
    downstreamTopic:downstreamTopic
    metric:metric
    minutes:minutes
    hours:hours
    from:from
    to:to
    samples:samples
              completionHandler: ^(TimeSeriesResponseNumericMetricStats output, NSError* error) {
                            if (output) {
                                NSLog(@"%@", output);
                            }
                            if (error) {
                                NSLog(@"Error: %@", error);
                            }
                        }];

var SwaggerJsClient = require('swagger-js-client');
var defaultClient = SwaggerJsClient.ApiClient.instance;

// Configure API key authorization: Authorization
var Authorization = defaultClient.authentications['Authorization'];
Authorization.apiKey = "YOUR API KEY"
// Uncomment the following line to set a prefix for the API key, e.g. "Token" (defaults to null)
//Authorization.apiKeyPrefix['Authorization'] = "Token"

var api = new SwaggerJsClient.Class3SRMServiceAPIV2InternalApi()
var target = target_example; // {{String}} 
var downstreamTopic = downstreamTopic_example; // {{String}} 
var metric = metric_example; // {{String}} 
var opts = { 
  'minutes': 56, // {{Integer}} 
  'hours': 56, // {{Integer}} 
  'from': 789, // {{Long}} 
  'to': 789, // {{Long}} 
  'samples': 56 // {{Integer}} 
};
var callback = function(error, data, response) {
  if (error) {
    console.error(error);
  } else {
    console.log('API called successfully. Returned data: ' + data);
  }
};
api.topicMetricsWithDownstreamTopicName2(target, downstreamTopic, metric, opts, callback);

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class topicMetricsWithDownstreamTopicName2Example
    {
        public void main()
        {

            // Configure API key authorization: Authorization
            Configuration.Default.ApiKey.Add("Authorization", "YOUR_API_KEY");
            // Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
            // Configuration.Default.ApiKeyPrefix.Add("Authorization", "Bearer");

            var apiInstance = new Class3SRMServiceAPIV2InternalApi();
            var target = target_example;  // String | 
            var downstreamTopic = downstreamTopic_example;  // String | 
            var metric = metric_example;  // String | 
            var minutes = 56;  // Integer |  (optional) 
            var hours = 56;  // Integer |  (optional) 
            var from = 789;  // Long |  (optional) 
            var to = 789;  // Long |  (optional) 
            var samples = 56;  // Integer |  (optional)  (default to 1000)

            try
            {
                TimeSeriesResponseNumericMetricStats result = apiInstance.topicMetricsWithDownstreamTopicName2(target, downstreamTopic, metric, minutes, hours, from, to, samples);
                Debug.WriteLine(result);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling Class3SRMServiceAPIV2InternalApi.topicMetricsWithDownstreamTopicName2: " + e.Message );
            }
        }
    }
}

<?php
require_once(__DIR__ . '/vendor/autoload.php');

// Configure API key authorization: Authorization
Swagger\Client\Configuration::getDefaultConfiguration()->setApiKey('Authorization', 'YOUR_API_KEY');
// Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
// Swagger\Client\Configuration::getDefaultConfiguration()->setApiKeyPrefix('Authorization', 'Bearer');

$api_instance = new Swagger\Client\ApiClass3SRMServiceAPIV2InternalApi();
$target = target_example; // String | 
$downstreamTopic = downstreamTopic_example; // String | 
$metric = metric_example; // String | 
$minutes = 56; // Integer | 
$hours = 56; // Integer | 
$from = 789; // Long | 
$to = 789; // Long | 
$samples = 56; // Integer | 

try {
    $result = $api_instance->topicMetricsWithDownstreamTopicName2($target, $downstreamTopic, $metric, $minutes, $hours, $from, $to, $samples);
    print_r($result);
} catch (Exception $e) {
    echo 'Exception when calling Class3SRMServiceAPIV2InternalApi->topicMetricsWithDownstreamTopicName2: ', $e->getMessage(), PHP_EOL;
}
?>

use Data::Dumper;
use WWW::SwaggerClient::Configuration;
use WWW::SwaggerClient::Class3SRMServiceAPIV2InternalApi;

# Configure API key authorization: Authorization
$WWW::SwaggerClient::Configuration::api_key->{'Authorization'} = 'YOUR_API_KEY';
# uncomment below to setup prefix (e.g. Bearer) for API key, if needed
#$WWW::SwaggerClient::Configuration::api_key_prefix->{'Authorization'} = "Bearer";

my $api_instance = WWW::SwaggerClient::Class3SRMServiceAPIV2InternalApi->new();
my $target = target_example; # String | 
my $downstreamTopic = downstreamTopic_example; # String | 
my $metric = metric_example; # String | 
my $minutes = 56; # Integer | 
my $hours = 56; # Integer | 
my $from = 789; # Long | 
my $to = 789; # Long | 
my $samples = 56; # Integer | 

eval { 
    my $result = $api_instance->topicMetricsWithDownstreamTopicName2(target => $target, downstreamTopic => $downstreamTopic, metric => $metric, minutes => $minutes, hours => $hours, from => $from, to => $to, samples => $samples);
    print Dumper($result);
};
if ($@) {
    warn "Exception when calling Class3SRMServiceAPIV2InternalApi->topicMetricsWithDownstreamTopicName2: $@\n";
}

from __future__ import print_statement
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# Configure API key authorization: Authorization
swagger_client.configuration.api_key['Authorization'] = 'YOUR_API_KEY'
# Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
# swagger_client.configuration.api_key_prefix['Authorization'] = 'Bearer'

# create an instance of the API class
api_instance = swagger_client.Class3SRMServiceAPIV2InternalApi()
target = target_example # String | 
downstreamTopic = downstreamTopic_example # String | 
metric = metric_example # String | 
minutes = 56 # Integer |  (optional)
hours = 56 # Integer |  (optional)
from = 789 # Long |  (optional)
to = 789 # Long |  (optional)
samples = 56 # Integer |  (optional) (default to 1000)

try: 
    api_response = api_instance.topic_metrics_with_downstream_topic_name2(target, downstreamTopic, metric, minutes=minutes, hours=hours, from=from, to=to, samples=samples)
    pprint(api_response)
except ApiException as e:
    print("Exception when calling Class3SRMServiceAPIV2InternalApi->topicMetricsWithDownstreamTopicName2: %s\n" % e)

import io.swagger.client.*;
import io.swagger.client.auth.*;
import io.swagger.client.model.*;
import io.swagger.client.api.Class3SRMServiceAPIV2InternalApi;

import java.io.File;
import java.util.*;

public class Class3SRMServiceAPIV2InternalApiExample {

    public static void main(String[] args) {
        ApiClient defaultClient = Configuration.getDefaultApiClient();

        // Configure API key authorization: Authorization
        ApiKeyAuth Authorization = (ApiKeyAuth) defaultClient.getAuthentication("Authorization");
        Authorization.setApiKey("YOUR API KEY");
        // Uncomment the following line to set a prefix for the API key, e.g. "Token" (defaults to null)
        //Authorization.setApiKeyPrefix("Token");

        Class3SRMServiceAPIV2InternalApi apiInstance = new Class3SRMServiceAPIV2InternalApi();
        String source = source_example; // String | 
        String target = target_example; // String | 
        String upstreamTopic = upstreamTopic_example; // String | 
        String metric = metric_example; // String | 
        Integer minutes = 56; // Integer | 
        Integer hours = 56; // Integer | 
        Long from = 789; // Long | 
        Long to = 789; // Long | 
        Integer samples = 56; // Integer | 
        try {
            TimeSeriesResponseNumericMetricStats result = apiInstance.topicMetricsWithDownstreamTopicName3(source, target, upstreamTopic, metric, minutes, hours, from, to, samples);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling Class3SRMServiceAPIV2InternalApi#topicMetricsWithDownstreamTopicName3");
            e.printStackTrace();
        }
    }
}

import io.swagger.client.api.Class3SRMServiceAPIV2InternalApi;

public class Class3SRMServiceAPIV2InternalApiExample {

    public static void main(String[] args) {
        Class3SRMServiceAPIV2InternalApi apiInstance = new Class3SRMServiceAPIV2InternalApi();
        String source = source_example; // String | 
        String target = target_example; // String | 
        String upstreamTopic = upstreamTopic_example; // String | 
        String metric = metric_example; // String | 
        Integer minutes = 56; // Integer | 
        Integer hours = 56; // Integer | 
        Long from = 789; // Long | 
        Long to = 789; // Long | 
        Integer samples = 56; // Integer | 
        try {
            TimeSeriesResponseNumericMetricStats result = apiInstance.topicMetricsWithDownstreamTopicName3(source, target, upstreamTopic, metric, minutes, hours, from, to, samples);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling Class3SRMServiceAPIV2InternalApi#topicMetricsWithDownstreamTopicName3");
            e.printStackTrace();
        }
    }
}

Configuration *apiConfig = [Configuration sharedConfig];
// Configure API key authorization: (authentication scheme: Authorization)
[apiConfig setApiKey:@"YOUR_API_KEY" forApiKeyIdentifier:@"Authorization"];
// Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
//[apiConfig setApiKeyPrefix:@"Bearer" forApiKeyIdentifier:@"Authorization"];
String *source = source_example; // 
String *target = target_example; // 
String *upstreamTopic = upstreamTopic_example; // 
String *metric = metric_example; // 
Integer *minutes = 56; //  (optional)
Integer *hours = 56; //  (optional)
Long *from = 789; //  (optional)
Long *to = 789; //  (optional)
Integer *samples = 56; //  (optional) (default to 1000)

Class3SRMServiceAPIV2InternalApi *apiInstance = [[Class3SRMServiceAPIV2InternalApi alloc] init];

[apiInstance topicMetricsWithDownstreamTopicName3With:source
    target:target
    upstreamTopic:upstreamTopic
    metric:metric
    minutes:minutes
    hours:hours
    from:from
    to:to
    samples:samples
              completionHandler: ^(TimeSeriesResponseNumericMetricStats output, NSError* error) {
                            if (output) {
                                NSLog(@"%@", output);
                            }
                            if (error) {
                                NSLog(@"Error: %@", error);
                            }
                        }];

var SwaggerJsClient = require('swagger-js-client');
var defaultClient = SwaggerJsClient.ApiClient.instance;

// Configure API key authorization: Authorization
var Authorization = defaultClient.authentications['Authorization'];
Authorization.apiKey = "YOUR API KEY"
// Uncomment the following line to set a prefix for the API key, e.g. "Token" (defaults to null)
//Authorization.apiKeyPrefix['Authorization'] = "Token"

var api = new SwaggerJsClient.Class3SRMServiceAPIV2InternalApi()
var source = source_example; // {{String}} 
var target = target_example; // {{String}} 
var upstreamTopic = upstreamTopic_example; // {{String}} 
var metric = metric_example; // {{String}} 
var opts = { 
  'minutes': 56, // {{Integer}} 
  'hours': 56, // {{Integer}} 
  'from': 789, // {{Long}} 
  'to': 789, // {{Long}} 
  'samples': 56 // {{Integer}} 
};
var callback = function(error, data, response) {
  if (error) {
    console.error(error);
  } else {
    console.log('API called successfully. Returned data: ' + data);
  }
};
api.topicMetricsWithDownstreamTopicName3(source, target, upstreamTopic, metric, opts, callback);

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class topicMetricsWithDownstreamTopicName3Example
    {
        public void main()
        {

            // Configure API key authorization: Authorization
            Configuration.Default.ApiKey.Add("Authorization", "YOUR_API_KEY");
            // Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
            // Configuration.Default.ApiKeyPrefix.Add("Authorization", "Bearer");

            var apiInstance = new Class3SRMServiceAPIV2InternalApi();
            var source = source_example;  // String | 
            var target = target_example;  // String | 
            var upstreamTopic = upstreamTopic_example;  // String | 
            var metric = metric_example;  // String | 
            var minutes = 56;  // Integer |  (optional) 
            var hours = 56;  // Integer |  (optional) 
            var from = 789;  // Long |  (optional) 
            var to = 789;  // Long |  (optional) 
            var samples = 56;  // Integer |  (optional)  (default to 1000)

            try
            {
                TimeSeriesResponseNumericMetricStats result = apiInstance.topicMetricsWithDownstreamTopicName3(source, target, upstreamTopic, metric, minutes, hours, from, to, samples);
                Debug.WriteLine(result);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling Class3SRMServiceAPIV2InternalApi.topicMetricsWithDownstreamTopicName3: " + e.Message );
            }
        }
    }
}

<?php
require_once(__DIR__ . '/vendor/autoload.php');

// Configure API key authorization: Authorization
Swagger\Client\Configuration::getDefaultConfiguration()->setApiKey('Authorization', 'YOUR_API_KEY');
// Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
// Swagger\Client\Configuration::getDefaultConfiguration()->setApiKeyPrefix('Authorization', 'Bearer');

$api_instance = new Swagger\Client\ApiClass3SRMServiceAPIV2InternalApi();
$source = source_example; // String | 
$target = target_example; // String | 
$upstreamTopic = upstreamTopic_example; // String | 
$metric = metric_example; // String | 
$minutes = 56; // Integer | 
$hours = 56; // Integer | 
$from = 789; // Long | 
$to = 789; // Long | 
$samples = 56; // Integer | 

try {
    $result = $api_instance->topicMetricsWithDownstreamTopicName3($source, $target, $upstreamTopic, $metric, $minutes, $hours, $from, $to, $samples);
    print_r($result);
} catch (Exception $e) {
    echo 'Exception when calling Class3SRMServiceAPIV2InternalApi->topicMetricsWithDownstreamTopicName3: ', $e->getMessage(), PHP_EOL;
}
?>

use Data::Dumper;
use WWW::SwaggerClient::Configuration;
use WWW::SwaggerClient::Class3SRMServiceAPIV2InternalApi;

# Configure API key authorization: Authorization
$WWW::SwaggerClient::Configuration::api_key->{'Authorization'} = 'YOUR_API_KEY';
# uncomment below to setup prefix (e.g. Bearer) for API key, if needed
#$WWW::SwaggerClient::Configuration::api_key_prefix->{'Authorization'} = "Bearer";

my $api_instance = WWW::SwaggerClient::Class3SRMServiceAPIV2InternalApi->new();
my $source = source_example; # String | 
my $target = target_example; # String | 
my $upstreamTopic = upstreamTopic_example; # String | 
my $metric = metric_example; # String | 
my $minutes = 56; # Integer | 
my $hours = 56; # Integer | 
my $from = 789; # Long | 
my $to = 789; # Long | 
my $samples = 56; # Integer | 

eval { 
    my $result = $api_instance->topicMetricsWithDownstreamTopicName3(source => $source, target => $target, upstreamTopic => $upstreamTopic, metric => $metric, minutes => $minutes, hours => $hours, from => $from, to => $to, samples => $samples);
    print Dumper($result);
};
if ($@) {
    warn "Exception when calling Class3SRMServiceAPIV2InternalApi->topicMetricsWithDownstreamTopicName3: $@\n";
}

from __future__ import print_statement
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# Configure API key authorization: Authorization
swagger_client.configuration.api_key['Authorization'] = 'YOUR_API_KEY'
# Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
# swagger_client.configuration.api_key_prefix['Authorization'] = 'Bearer'

# create an instance of the API class
api_instance = swagger_client.Class3SRMServiceAPIV2InternalApi()
source = source_example # String | 
target = target_example # String | 
upstreamTopic = upstreamTopic_example # String | 
metric = metric_example # String | 
minutes = 56 # Integer |  (optional)
hours = 56 # Integer |  (optional)
from = 789 # Long |  (optional)
to = 789 # Long |  (optional)
samples = 56 # Integer |  (optional) (default to 1000)

try: 
    api_response = api_instance.topic_metrics_with_downstream_topic_name3(source, target, upstreamTopic, metric, minutes=minutes, hours=hours, from=from, to=to, samples=samples)
    pprint(api_response)
except ApiException as e:
    print("Exception when calling Class3SRMServiceAPIV2InternalApi->topicMetricsWithDownstreamTopicName3: %s\n" % e)

import io.swagger.client.*;
import io.swagger.client.auth.*;
import io.swagger.client.model.*;
import io.swagger.client.api.Class4SRMServiceAPIV1InternalApi;

import java.io.File;
import java.util.*;

public class Class4SRMServiceAPIV1InternalApiExample {

    public static void main(String[] args) {
        ApiClient defaultClient = Configuration.getDefaultApiClient();

        // Configure API key authorization: Authorization
        ApiKeyAuth Authorization = (ApiKeyAuth) defaultClient.getAuthentication("Authorization");
        Authorization.setApiKey("YOUR API KEY");
        // Uncomment the following line to set a prefix for the API key, e.g. "Token" (defaults to null)
        //Authorization.setApiKeyPrefix("Token");

        Class4SRMServiceAPIV1InternalApi apiInstance = new Class4SRMServiceAPIV1InternalApi();
        String cluster = cluster_example; // String | 
        String metric = metric_example; // String | 
        Integer minutes = 56; // Integer | 
        Integer hours = 56; // Integer | 
        Long from = 789; // Long | 
        Long to = 789; // Long | 
        Integer samples = 56; // Integer | 
        try {
            TimeSeriesResponseNumericMetricStats result = apiInstance.clusterMetricsLocal(cluster, metric, minutes, hours, from, to, samples);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling Class4SRMServiceAPIV1InternalApi#clusterMetricsLocal");
            e.printStackTrace();
        }
    }
}

import io.swagger.client.api.Class4SRMServiceAPIV1InternalApi;

public class Class4SRMServiceAPIV1InternalApiExample {

    public static void main(String[] args) {
        Class4SRMServiceAPIV1InternalApi apiInstance = new Class4SRMServiceAPIV1InternalApi();
        String cluster = cluster_example; // String | 
        String metric = metric_example; // String | 
        Integer minutes = 56; // Integer | 
        Integer hours = 56; // Integer | 
        Long from = 789; // Long | 
        Long to = 789; // Long | 
        Integer samples = 56; // Integer | 
        try {
            TimeSeriesResponseNumericMetricStats result = apiInstance.clusterMetricsLocal(cluster, metric, minutes, hours, from, to, samples);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling Class4SRMServiceAPIV1InternalApi#clusterMetricsLocal");
            e.printStackTrace();
        }
    }
}

Configuration *apiConfig = [Configuration sharedConfig];
// Configure API key authorization: (authentication scheme: Authorization)
[apiConfig setApiKey:@"YOUR_API_KEY" forApiKeyIdentifier:@"Authorization"];
// Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
//[apiConfig setApiKeyPrefix:@"Bearer" forApiKeyIdentifier:@"Authorization"];
String *cluster = cluster_example; // 
String *metric = metric_example; // 
Integer *minutes = 56; //  (optional)
Integer *hours = 56; //  (optional)
Long *from = 789; //  (optional)
Long *to = 789; //  (optional)
Integer *samples = 56; //  (optional)

Class4SRMServiceAPIV1InternalApi *apiInstance = [[Class4SRMServiceAPIV1InternalApi alloc] init];

[apiInstance clusterMetricsLocalWith:cluster
    metric:metric
    minutes:minutes
    hours:hours
    from:from
    to:to
    samples:samples
              completionHandler: ^(TimeSeriesResponseNumericMetricStats output, NSError* error) {
                            if (output) {
                                NSLog(@"%@", output);
                            }
                            if (error) {
                                NSLog(@"Error: %@", error);
                            }
                        }];

var SwaggerJsClient = require('swagger-js-client');
var defaultClient = SwaggerJsClient.ApiClient.instance;

// Configure API key authorization: Authorization
var Authorization = defaultClient.authentications['Authorization'];
Authorization.apiKey = "YOUR API KEY"
// Uncomment the following line to set a prefix for the API key, e.g. "Token" (defaults to null)
//Authorization.apiKeyPrefix['Authorization'] = "Token"

var api = new SwaggerJsClient.Class4SRMServiceAPIV1InternalApi()
var cluster = cluster_example; // {{String}} 
var metric = metric_example; // {{String}} 
var opts = { 
  'minutes': 56, // {{Integer}} 
  'hours': 56, // {{Integer}} 
  'from': 789, // {{Long}} 
  'to': 789, // {{Long}} 
  'samples': 56 // {{Integer}} 
};
var callback = function(error, data, response) {
  if (error) {
    console.error(error);
  } else {
    console.log('API called successfully. Returned data: ' + data);
  }
};
api.clusterMetricsLocal(cluster, metric, opts, callback);

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class clusterMetricsLocalExample
    {
        public void main()
        {

            // Configure API key authorization: Authorization
            Configuration.Default.ApiKey.Add("Authorization", "YOUR_API_KEY");
            // Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
            // Configuration.Default.ApiKeyPrefix.Add("Authorization", "Bearer");

            var apiInstance = new Class4SRMServiceAPIV1InternalApi();
            var cluster = cluster_example;  // String | 
            var metric = metric_example;  // String | 
            var minutes = 56;  // Integer |  (optional) 
            var hours = 56;  // Integer |  (optional) 
            var from = 789;  // Long |  (optional) 
            var to = 789;  // Long |  (optional) 
            var samples = 56;  // Integer |  (optional) 

            try
            {
                TimeSeriesResponseNumericMetricStats result = apiInstance.clusterMetricsLocal(cluster, metric, minutes, hours, from, to, samples);
                Debug.WriteLine(result);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling Class4SRMServiceAPIV1InternalApi.clusterMetricsLocal: " + e.Message );
            }
        }
    }
}

<?php
require_once(__DIR__ . '/vendor/autoload.php');

// Configure API key authorization: Authorization
Swagger\Client\Configuration::getDefaultConfiguration()->setApiKey('Authorization', 'YOUR_API_KEY');
// Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
// Swagger\Client\Configuration::getDefaultConfiguration()->setApiKeyPrefix('Authorization', 'Bearer');

$api_instance = new Swagger\Client\ApiClass4SRMServiceAPIV1InternalApi();
$cluster = cluster_example; // String | 
$metric = metric_example; // String | 
$minutes = 56; // Integer | 
$hours = 56; // Integer | 
$from = 789; // Long | 
$to = 789; // Long | 
$samples = 56; // Integer | 

try {
    $result = $api_instance->clusterMetricsLocal($cluster, $metric, $minutes, $hours, $from, $to, $samples);
    print_r($result);
} catch (Exception $e) {
    echo 'Exception when calling Class4SRMServiceAPIV1InternalApi->clusterMetricsLocal: ', $e->getMessage(), PHP_EOL;
}
?>

use Data::Dumper;
use WWW::SwaggerClient::Configuration;
use WWW::SwaggerClient::Class4SRMServiceAPIV1InternalApi;

# Configure API key authorization: Authorization
$WWW::SwaggerClient::Configuration::api_key->{'Authorization'} = 'YOUR_API_KEY';
# uncomment below to setup prefix (e.g. Bearer) for API key, if needed
#$WWW::SwaggerClient::Configuration::api_key_prefix->{'Authorization'} = "Bearer";

my $api_instance = WWW::SwaggerClient::Class4SRMServiceAPIV1InternalApi->new();
my $cluster = cluster_example; # String | 
my $metric = metric_example; # String | 
my $minutes = 56; # Integer | 
my $hours = 56; # Integer | 
my $from = 789; # Long | 
my $to = 789; # Long | 
my $samples = 56; # Integer | 

eval { 
    my $result = $api_instance->clusterMetricsLocal(cluster => $cluster, metric => $metric, minutes => $minutes, hours => $hours, from => $from, to => $to, samples => $samples);
    print Dumper($result);
};
if ($@) {
    warn "Exception when calling Class4SRMServiceAPIV1InternalApi->clusterMetricsLocal: $@\n";
}

from __future__ import print_statement
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# Configure API key authorization: Authorization
swagger_client.configuration.api_key['Authorization'] = 'YOUR_API_KEY'
# Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
# swagger_client.configuration.api_key_prefix['Authorization'] = 'Bearer'

# create an instance of the API class
api_instance = swagger_client.Class4SRMServiceAPIV1InternalApi()
cluster = cluster_example # String | 
metric = metric_example # String | 
minutes = 56 # Integer |  (optional)
hours = 56 # Integer |  (optional)
from = 789 # Long |  (optional)
to = 789 # Long |  (optional)
samples = 56 # Integer |  (optional)

try: 
    api_response = api_instance.cluster_metrics_local(cluster, metric, minutes=minutes, hours=hours, from=from, to=to, samples=samples)
    pprint(api_response)
except ApiException as e:
    print("Exception when calling Class4SRMServiceAPIV1InternalApi->clusterMetricsLocal: %s\n" % e)

import io.swagger.client.*;
import io.swagger.client.auth.*;
import io.swagger.client.model.*;
import io.swagger.client.api.Class4SRMServiceAPIV1InternalApi;

import java.io.File;
import java.util.*;

public class Class4SRMServiceAPIV1InternalApiExample {

    public static void main(String[] args) {
        ApiClient defaultClient = Configuration.getDefaultApiClient();

        // Configure API key authorization: Authorization
        ApiKeyAuth Authorization = (ApiKeyAuth) defaultClient.getAuthentication("Authorization");
        Authorization.setApiKey("YOUR API KEY");
        // Uncomment the following line to set a prefix for the API key, e.g. "Token" (defaults to null)
        //Authorization.setApiKeyPrefix("Token");

        Class4SRMServiceAPIV1InternalApi apiInstance = new Class4SRMServiceAPIV1InternalApi();
        String topic = topic_example; // String | 
        String metric = metric_example; // String | 
        Integer minutes = 56; // Integer | 
        Integer hours = 56; // Integer | 
        Long from = 789; // Long | 
        Long to = 789; // Long | 
        Integer samples = 56; // Integer | 
        try {
            TimeSeriesResponseNumericMetricStats result = apiInstance.topicMetricsLocal(topic, metric, minutes, hours, from, to, samples);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling Class4SRMServiceAPIV1InternalApi#topicMetricsLocal");
            e.printStackTrace();
        }
    }
}

import io.swagger.client.api.Class4SRMServiceAPIV1InternalApi;

public class Class4SRMServiceAPIV1InternalApiExample {

    public static void main(String[] args) {
        Class4SRMServiceAPIV1InternalApi apiInstance = new Class4SRMServiceAPIV1InternalApi();
        String topic = topic_example; // String | 
        String metric = metric_example; // String | 
        Integer minutes = 56; // Integer | 
        Integer hours = 56; // Integer | 
        Long from = 789; // Long | 
        Long to = 789; // Long | 
        Integer samples = 56; // Integer | 
        try {
            TimeSeriesResponseNumericMetricStats result = apiInstance.topicMetricsLocal(topic, metric, minutes, hours, from, to, samples);
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling Class4SRMServiceAPIV1InternalApi#topicMetricsLocal");
            e.printStackTrace();
        }
    }
}

Configuration *apiConfig = [Configuration sharedConfig];
// Configure API key authorization: (authentication scheme: Authorization)
[apiConfig setApiKey:@"YOUR_API_KEY" forApiKeyIdentifier:@"Authorization"];
// Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
//[apiConfig setApiKeyPrefix:@"Bearer" forApiKeyIdentifier:@"Authorization"];
String *topic = topic_example; // 
String *metric = metric_example; // 
Integer *minutes = 56; //  (optional)
Integer *hours = 56; //  (optional)
Long *from = 789; //  (optional)
Long *to = 789; //  (optional)
Integer *samples = 56; //  (optional)

Class4SRMServiceAPIV1InternalApi *apiInstance = [[Class4SRMServiceAPIV1InternalApi alloc] init];

[apiInstance topicMetricsLocalWith:topic
    metric:metric
    minutes:minutes
    hours:hours
    from:from
    to:to
    samples:samples
              completionHandler: ^(TimeSeriesResponseNumericMetricStats output, NSError* error) {
                            if (output) {
                                NSLog(@"%@", output);
                            }
                            if (error) {
                                NSLog(@"Error: %@", error);
                            }
                        }];

var SwaggerJsClient = require('swagger-js-client');
var defaultClient = SwaggerJsClient.ApiClient.instance;

// Configure API key authorization: Authorization
var Authorization = defaultClient.authentications['Authorization'];
Authorization.apiKey = "YOUR API KEY"
// Uncomment the following line to set a prefix for the API key, e.g. "Token" (defaults to null)
//Authorization.apiKeyPrefix['Authorization'] = "Token"

var api = new SwaggerJsClient.Class4SRMServiceAPIV1InternalApi()
var topic = topic_example; // {{String}} 
var metric = metric_example; // {{String}} 
var opts = { 
  'minutes': 56, // {{Integer}} 
  'hours': 56, // {{Integer}} 
  'from': 789, // {{Long}} 
  'to': 789, // {{Long}} 
  'samples': 56 // {{Integer}} 
};
var callback = function(error, data, response) {
  if (error) {
    console.error(error);
  } else {
    console.log('API called successfully. Returned data: ' + data);
  }
};
api.topicMetricsLocal(topic, metric, opts, callback);

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class topicMetricsLocalExample
    {
        public void main()
        {

            // Configure API key authorization: Authorization
            Configuration.Default.ApiKey.Add("Authorization", "YOUR_API_KEY");
            // Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
            // Configuration.Default.ApiKeyPrefix.Add("Authorization", "Bearer");

            var apiInstance = new Class4SRMServiceAPIV1InternalApi();
            var topic = topic_example;  // String | 
            var metric = metric_example;  // String | 
            var minutes = 56;  // Integer |  (optional) 
            var hours = 56;  // Integer |  (optional) 
            var from = 789;  // Long |  (optional) 
            var to = 789;  // Long |  (optional) 
            var samples = 56;  // Integer |  (optional) 

            try
            {
                TimeSeriesResponseNumericMetricStats result = apiInstance.topicMetricsLocal(topic, metric, minutes, hours, from, to, samples);
                Debug.WriteLine(result);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling Class4SRMServiceAPIV1InternalApi.topicMetricsLocal: " + e.Message );
            }
        }
    }
}

<?php
require_once(__DIR__ . '/vendor/autoload.php');

// Configure API key authorization: Authorization
Swagger\Client\Configuration::getDefaultConfiguration()->setApiKey('Authorization', 'YOUR_API_KEY');
// Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
// Swagger\Client\Configuration::getDefaultConfiguration()->setApiKeyPrefix('Authorization', 'Bearer');

$api_instance = new Swagger\Client\ApiClass4SRMServiceAPIV1InternalApi();
$topic = topic_example; // String | 
$metric = metric_example; // String | 
$minutes = 56; // Integer | 
$hours = 56; // Integer | 
$from = 789; // Long | 
$to = 789; // Long | 
$samples = 56; // Integer | 

try {
    $result = $api_instance->topicMetricsLocal($topic, $metric, $minutes, $hours, $from, $to, $samples);
    print_r($result);
} catch (Exception $e) {
    echo 'Exception when calling Class4SRMServiceAPIV1InternalApi->topicMetricsLocal: ', $e->getMessage(), PHP_EOL;
}
?>

use Data::Dumper;
use WWW::SwaggerClient::Configuration;
use WWW::SwaggerClient::Class4SRMServiceAPIV1InternalApi;

# Configure API key authorization: Authorization
$WWW::SwaggerClient::Configuration::api_key->{'Authorization'} = 'YOUR_API_KEY';
# uncomment below to setup prefix (e.g. Bearer) for API key, if needed
#$WWW::SwaggerClient::Configuration::api_key_prefix->{'Authorization'} = "Bearer";

my $api_instance = WWW::SwaggerClient::Class4SRMServiceAPIV1InternalApi->new();
my $topic = topic_example; # String | 
my $metric = metric_example; # String | 
my $minutes = 56; # Integer | 
my $hours = 56; # Integer | 
my $from = 789; # Long | 
my $to = 789; # Long | 
my $samples = 56; # Integer | 

eval { 
    my $result = $api_instance->topicMetricsLocal(topic => $topic, metric => $metric, minutes => $minutes, hours => $hours, from => $from, to => $to, samples => $samples);
    print Dumper($result);
};
if ($@) {
    warn "Exception when calling Class4SRMServiceAPIV1InternalApi->topicMetricsLocal: $@\n";
}

from __future__ import print_statement
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# Configure API key authorization: Authorization
swagger_client.configuration.api_key['Authorization'] = 'YOUR_API_KEY'
# Uncomment below to setup prefix (e.g. Bearer) for API key, if needed
# swagger_client.configuration.api_key_prefix['Authorization'] = 'Bearer'

# create an instance of the API class
api_instance = swagger_client.Class4SRMServiceAPIV1InternalApi()
topic = topic_example # String | 
metric = metric_example # String | 
minutes = 56 # Integer |  (optional)
hours = 56 # Integer |  (optional)
from = 789 # Long |  (optional)
to = 789 # Long |  (optional)
samples = 56 # Integer |  (optional)

try: 
    api_response = api_instance.topic_metrics_local(topic, metric, minutes=minutes, hours=hours, from=from, to=to, samples=samples)
    pprint(api_response)
except ApiException as e:
    print("Exception when calling Class4SRMServiceAPIV1InternalApi->topicMetricsLocal: %s\n" % e)

import io.swagger.client.*;
import io.swagger.client.auth.*;
import io.swagger.client.model.*;
import io.swagger.client.api.DefaultApi;

import java.io.File;
import java.util.*;

public class DefaultApiExample {

    public static void main(String[] args) {
        
        DefaultApi apiInstance = new DefaultApi();
        try {
            ApiInfo result = apiInstance.apiMetadata();
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling DefaultApi#apiMetadata");
            e.printStackTrace();
        }
    }
}

import io.swagger.client.api.DefaultApi;

public class DefaultApiExample {

    public static void main(String[] args) {
        DefaultApi apiInstance = new DefaultApi();
        try {
            ApiInfo result = apiInstance.apiMetadata();
            System.out.println(result);
        } catch (ApiException e) {
            System.err.println("Exception when calling DefaultApi#apiMetadata");
            e.printStackTrace();
        }
    }
}

DefaultApi *apiInstance = [[DefaultApi alloc] init];

[apiInstance apiMetadataWithCompletionHandler: 
              ^(ApiInfo output, NSError* error) {
                            if (output) {
                                NSLog(@"%@", output);
                            }
                            if (error) {
                                NSLog(@"Error: %@", error);
                            }
                        }];

var SwaggerJsClient = require('swagger-js-client');

var api = new SwaggerJsClient.DefaultApi()
var callback = function(error, data, response) {
  if (error) {
    console.error(error);
  } else {
    console.log('API called successfully. Returned data: ' + data);
  }
};
api.apiMetadata(callback);

using System;
using System.Diagnostics;
using IO.Swagger.Api;
using IO.Swagger.Client;
using IO.Swagger.Model;

namespace Example
{
    public class apiMetadataExample
    {
        public void main()
        {

            var apiInstance = new DefaultApi();

            try
            {
                ApiInfo result = apiInstance.apiMetadata();
                Debug.WriteLine(result);
            }
            catch (Exception e)
            {
                Debug.Print("Exception when calling DefaultApi.apiMetadata: " + e.Message );
            }
        }
    }
}

<?php
require_once(__DIR__ . '/vendor/autoload.php');

$api_instance = new Swagger\Client\ApiDefaultApi();

try {
    $result = $api_instance->apiMetadata();
    print_r($result);
} catch (Exception $e) {
    echo 'Exception when calling DefaultApi->apiMetadata: ', $e->getMessage(), PHP_EOL;
}
?>

use Data::Dumper;
use WWW::SwaggerClient::Configuration;
use WWW::SwaggerClient::DefaultApi;

my $api_instance = WWW::SwaggerClient::DefaultApi->new();

eval { 
    my $result = $api_instance->apiMetadata();
    print Dumper($result);
};
if ($@) {
    warn "Exception when calling DefaultApi->apiMetadata: $@\n";
}

from __future__ import print_statement
import time
import swagger_client
from swagger_client.rest import ApiException
from pprint import pprint

# create an instance of the API class
api_instance = swagger_client.DefaultApi()

try: 
    api_response = api_instance.api_metadata()
    pprint(api_response)
except ApiException as e:
    print("Exception when calling DefaultApi->apiMetadata: %s\n" % e)