Skip to content

ionos-cloud/sdk-go-kafka

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

8 Commits
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 

Repository files navigation

Gitter

Go API client for ionoscloud

An managed Apache Kafka cluster is designed to be highly fault-tolerant and scalable, allowing large volumes of data to be ingested, stored, and processed in real-time. By distributing data across multiple brokers, Kafka achieves high throughput and low latency, making it suitable for applications requiring real-time data processing and analytics.

Overview

This API client was generated by the OpenAPI Generator project. By using the OpenAPI-spec from a remote server, you can easily generate an API client.

Installation

Install the following dependencies:

go get github.com/stretchr/testify/assert
go get golang.org/x/oauth2
go get golang.org/x/net/context
go get github.com/antihax/optional

Put the package under your project folder and add the following in import:

import "./ionoscloud"

Authentication

All available server URLs are:

By default, https://kafka.de-fra.ionos.com is used, however this can be overriden at authentication, either by setting the IONOS_API_URL environment variable or by specifying the hostUrl parameter when initializing the sdk client.

The username and password or the authentication token can be manually specified when initializing the sdk client:

client := ionoscloud.NewAPIClient(ionoscloud.NewConfiguration(username, password, token, hostUrl))

Environment variables can also be used. The sdk uses the following variables:

  • IONOS_TOKEN - login via token. This is the recommended way to authenticate.
  • IONOS_USERNAME - to specify the username used to login
  • IONOS_PASSWORD - to specify the password
  • IONOS_API_URL - to specify the API server URL

In this case, the client configuration needs to be initialized using NewConfigurationFromEnv().

client := ionoscloud.NewAPIClient(ionoscloud.NewConfigurationFromEnv())

Documentation for API Endpoints

All URIs are relative to https://kafka.de-fra.ionos.com

API Endpoints table
Class Method HTTP request Description
ClustersApi ClustersDelete Delete /clusters/{clusterId} Delete Cluster
ClustersApi ClustersFindById Get /clusters/{clusterId} Retrieve Cluster
ClustersApi ClustersGet Get /clusters Retrieve all Clusters
ClustersApi ClustersPost Post /clusters Create Cluster
TopicsApi ClustersTopicsDelete Delete /clusters/{clusterId}/topics/{topicId} Delete Topic
TopicsApi ClustersTopicsFindById Get /clusters/{clusterId}/topics/{topicId} Retrieve Topic
TopicsApi ClustersTopicsGet Get /clusters/{clusterId}/topics Retrieve all Topics
TopicsApi ClustersTopicsPost Post /clusters/{clusterId}/topics Create Topic
UsersApi ClustersUsersAccessGet Get /clusters/{clusterId}/users/{userId}/access Retrieve Kafka User with credentials.
UsersApi ClustersUsersGet Get /clusters/{clusterId}/users Retrieve all Users

Documentation For Models

All URIs are relative to https://kafka.de-fra.ionos.com

API models list

[Back to API list] [Back to Model list]