ccloud-go-sdk

A Confluent Cloud GOLang SDK for the Telemetry API

How To

Install/Get

go get github.com/nerdynick/ccloud-go-sdk

Create Telemetry Client

import "github.com/nerdynick/ccloud-go-sdk/telemetry"

func main(){
    telemetryClient := telemetry.New(MyAPIKey, MyAPISecret)
}

The TelemetryClient also has the following additional attributes that you can adjust to configure how the TelemetryClient interacts with the API

PageLimit  int
DataSet    Dataset
BaseURL    string
MaxWorkers int

Get All Available Resources

import "github.com/nerdynick/ccloud-go-sdk/telemetry"

func main(){
    telemetryClient := telemetry.New(MyAPIKey, MyAPISecret)
    resourceTypes, err := telemetryClient.GetAvailableResources()
}

Get All Available Metrics for a Kafka Cluster

import (
    "github.com/nerdynick/ccloud-go-sdk/telemetry"
    "github.com/nerdynick/ccloud-go-sdk/telemetry/labels"
)

func main(){
    telemetryClient := telemetry.New(MyAPIKey, MyAPISecret)
    metrics, err := telemetryClient.GetAvailableMetricsForResource(labels.ResourceKafka, "MyClusterID")
}

Get All Available Metrics

Do Note: This func is deprecated post Telemetry API V1. You will want to use the GetAvailableMetricsForResource instead.

import "github.com/nerdynick/ccloud-go-sdk/telemetry"

func main(){
    telemetryClient := telemetry.New(MyAPIKey, MyAPISecret)
    metrics, err := telemetryClient.GetAvailableMetrics()
}

Documentation

Full Docs | Telemetry Docs |