All URIs are relative to https://psrc-00000.region.provider.confluent.cloud
Method | HTTP request | Description |
---|---|---|
DeleteSubjectConfig | Delete /config/{subject} | Delete subject compatibility level |
DeleteTopLevelConfig | Delete /config | Delete global compatibility level |
GetClusterConfig | Get /clusterconfig | Get cluster config |
GetSubjectLevelConfig | Get /config/{subject} | Get subject compatibility level |
GetTopLevelConfig | Get /config | Get global compatibility level |
UpdateSubjectLevelConfig | Put /config/{subject} | Update subject compatibility level |
UpdateTopLevelConfig | Put /config | Update global compatibility level |
string DeleteSubjectConfig(ctx, subject).Execute()
Delete subject compatibility level
package main
import (
"context"
"fmt"
"os"
openapiclient "./openapi"
)
func main() {
subject := "subject_example" // string | Name of the subject
configuration := openapiclient.NewConfiguration()
api_client := openapiclient.NewAPIClient(configuration)
resp, r, err := api_client.ConfigV1Api.DeleteSubjectConfig(context.Background(), subject).Execute()
if err != nil {
fmt.Fprintf(os.Stderr, "Error when calling `ConfigV1Api.DeleteSubjectConfig``: %v\n", err)
fmt.Fprintf(os.Stderr, "Full HTTP response: %v\n", r)
}
// response from `DeleteSubjectConfig`: string
fmt.Fprintf(os.Stdout, "Response from `ConfigV1Api.DeleteSubjectConfig`: %v\n", resp)
}
Name | Type | Description | Notes |
---|---|---|---|
ctx | context.Context | context for authentication, logging, cancellation, deadlines, tracing, etc. | |
subject | string | Name of the subject |
Other parameters are passed through a pointer to a apiDeleteSubjectConfigRequest struct via the builder pattern
Name | Type | Description | Notes |
---|
string
external-access-token, resource-api-key
- Content-Type: Not defined
- Accept: application/vnd.schemaregistry.v1+json, application/vnd.schemaregistry+json; qs=0.9, application/json; qs=0.5, application/json
[Back to top] [Back to API list] [Back to Model list] [Back to README]
string DeleteTopLevelConfig(ctx).Execute()
Delete global compatibility level
package main
import (
"context"
"fmt"
"os"
openapiclient "./openapi"
)
func main() {
configuration := openapiclient.NewConfiguration()
api_client := openapiclient.NewAPIClient(configuration)
resp, r, err := api_client.ConfigV1Api.DeleteTopLevelConfig(context.Background()).Execute()
if err != nil {
fmt.Fprintf(os.Stderr, "Error when calling `ConfigV1Api.DeleteTopLevelConfig``: %v\n", err)
fmt.Fprintf(os.Stderr, "Full HTTP response: %v\n", r)
}
// response from `DeleteTopLevelConfig`: string
fmt.Fprintf(os.Stdout, "Response from `ConfigV1Api.DeleteTopLevelConfig`: %v\n", resp)
}
This endpoint does not need any parameter.
Other parameters are passed through a pointer to a apiDeleteTopLevelConfigRequest struct via the builder pattern
string
external-access-token, resource-api-key
- Content-Type: Not defined
- Accept: application/vnd.schemaregistry.v1+json, application/vnd.schemaregistry+json; qs=0.9, application/json; qs=0.5, application/json
[Back to top] [Back to API list] [Back to Model list] [Back to README]
ClusterConfig GetClusterConfig(ctx).Execute()
Get cluster config
package main
import (
"context"
"fmt"
"os"
openapiclient "./openapi"
)
func main() {
configuration := openapiclient.NewConfiguration()
api_client := openapiclient.NewAPIClient(configuration)
resp, r, err := api_client.ConfigV1Api.GetClusterConfig(context.Background()).Execute()
if err != nil {
fmt.Fprintf(os.Stderr, "Error when calling `ConfigV1Api.GetClusterConfig``: %v\n", err)
fmt.Fprintf(os.Stderr, "Full HTTP response: %v\n", r)
}
// response from `GetClusterConfig`: ClusterConfig
fmt.Fprintf(os.Stdout, "Response from `ConfigV1Api.GetClusterConfig`: %v\n", resp)
}
This endpoint does not need any parameter.
Other parameters are passed through a pointer to a apiGetClusterConfigRequest struct via the builder pattern
external-access-token, resource-api-key
- Content-Type: Not defined
- Accept: application/vnd.schemaregistry.v1+json, application/vnd.schemaregistry+json; qs=0.9, application/json; qs=0.5, application/json
[Back to top] [Back to API list] [Back to Model list] [Back to README]
Config GetSubjectLevelConfig(ctx, subject).DefaultToGlobal(defaultToGlobal).Execute()
Get subject compatibility level
package main
import (
"context"
"fmt"
"os"
openapiclient "./openapi"
)
func main() {
subject := "subject_example" // string | Name of the subject
defaultToGlobal := true // bool | Whether to return the global compatibility level if subject compatibility level not found (optional)
configuration := openapiclient.NewConfiguration()
api_client := openapiclient.NewAPIClient(configuration)
resp, r, err := api_client.ConfigV1Api.GetSubjectLevelConfig(context.Background(), subject).DefaultToGlobal(defaultToGlobal).Execute()
if err != nil {
fmt.Fprintf(os.Stderr, "Error when calling `ConfigV1Api.GetSubjectLevelConfig``: %v\n", err)
fmt.Fprintf(os.Stderr, "Full HTTP response: %v\n", r)
}
// response from `GetSubjectLevelConfig`: Config
fmt.Fprintf(os.Stdout, "Response from `ConfigV1Api.GetSubjectLevelConfig`: %v\n", resp)
}
Name | Type | Description | Notes |
---|---|---|---|
ctx | context.Context | context for authentication, logging, cancellation, deadlines, tracing, etc. | |
subject | string | Name of the subject |
Other parameters are passed through a pointer to a apiGetSubjectLevelConfigRequest struct via the builder pattern
Name | Type | Description | Notes |
---|
defaultToGlobal | bool | Whether to return the global compatibility level if subject compatibility level not found |
external-access-token, resource-api-key
- Content-Type: Not defined
- Accept: application/vnd.schemaregistry.v1+json, application/vnd.schemaregistry+json; qs=0.9, application/json; qs=0.5, application/json
[Back to top] [Back to API list] [Back to Model list] [Back to README]
Config GetTopLevelConfig(ctx).Execute()
Get global compatibility level
package main
import (
"context"
"fmt"
"os"
openapiclient "./openapi"
)
func main() {
configuration := openapiclient.NewConfiguration()
api_client := openapiclient.NewAPIClient(configuration)
resp, r, err := api_client.ConfigV1Api.GetTopLevelConfig(context.Background()).Execute()
if err != nil {
fmt.Fprintf(os.Stderr, "Error when calling `ConfigV1Api.GetTopLevelConfig``: %v\n", err)
fmt.Fprintf(os.Stderr, "Full HTTP response: %v\n", r)
}
// response from `GetTopLevelConfig`: Config
fmt.Fprintf(os.Stdout, "Response from `ConfigV1Api.GetTopLevelConfig`: %v\n", resp)
}
This endpoint does not need any parameter.
Other parameters are passed through a pointer to a apiGetTopLevelConfigRequest struct via the builder pattern
external-access-token, resource-api-key
- Content-Type: Not defined
- Accept: application/vnd.schemaregistry.v1+json, application/vnd.schemaregistry+json; qs=0.9, application/json; qs=0.5, application/json
[Back to top] [Back to API list] [Back to Model list] [Back to README]
ConfigUpdateRequest UpdateSubjectLevelConfig(ctx, subject).ConfigUpdateRequest(configUpdateRequest).Execute()
Update subject compatibility level
package main
import (
"context"
"fmt"
"os"
openapiclient "./openapi"
)
func main() {
subject := "subject_example" // string | Name of the subject
configUpdateRequest := *openapiclient.NewConfigUpdateRequest() // ConfigUpdateRequest | Config Update Request
configuration := openapiclient.NewConfiguration()
api_client := openapiclient.NewAPIClient(configuration)
resp, r, err := api_client.ConfigV1Api.UpdateSubjectLevelConfig(context.Background(), subject).ConfigUpdateRequest(configUpdateRequest).Execute()
if err != nil {
fmt.Fprintf(os.Stderr, "Error when calling `ConfigV1Api.UpdateSubjectLevelConfig``: %v\n", err)
fmt.Fprintf(os.Stderr, "Full HTTP response: %v\n", r)
}
// response from `UpdateSubjectLevelConfig`: ConfigUpdateRequest
fmt.Fprintf(os.Stdout, "Response from `ConfigV1Api.UpdateSubjectLevelConfig`: %v\n", resp)
}
Name | Type | Description | Notes |
---|---|---|---|
ctx | context.Context | context for authentication, logging, cancellation, deadlines, tracing, etc. | |
subject | string | Name of the subject |
Other parameters are passed through a pointer to a apiUpdateSubjectLevelConfigRequest struct via the builder pattern
Name | Type | Description | Notes |
---|
configUpdateRequest | ConfigUpdateRequest | Config Update Request |
external-access-token, resource-api-key
- Content-Type: application/vnd.schemaregistry.v1+json, application/vnd.schemaregistry+json, application/json, application/octet-stream
- Accept: application/vnd.schemaregistry.v1+json, application/vnd.schemaregistry+json; qs=0.9, application/json; qs=0.5, application/json
[Back to top] [Back to API list] [Back to Model list] [Back to README]
ConfigUpdateRequest UpdateTopLevelConfig(ctx).ConfigUpdateRequest(configUpdateRequest).Execute()
Update global compatibility level
package main
import (
"context"
"fmt"
"os"
openapiclient "./openapi"
)
func main() {
configUpdateRequest := *openapiclient.NewConfigUpdateRequest() // ConfigUpdateRequest | Config Update Request
configuration := openapiclient.NewConfiguration()
api_client := openapiclient.NewAPIClient(configuration)
resp, r, err := api_client.ConfigV1Api.UpdateTopLevelConfig(context.Background()).ConfigUpdateRequest(configUpdateRequest).Execute()
if err != nil {
fmt.Fprintf(os.Stderr, "Error when calling `ConfigV1Api.UpdateTopLevelConfig``: %v\n", err)
fmt.Fprintf(os.Stderr, "Full HTTP response: %v\n", r)
}
// response from `UpdateTopLevelConfig`: ConfigUpdateRequest
fmt.Fprintf(os.Stdout, "Response from `ConfigV1Api.UpdateTopLevelConfig`: %v\n", resp)
}
Other parameters are passed through a pointer to a apiUpdateTopLevelConfigRequest struct via the builder pattern
Name | Type | Description | Notes |
---|---|---|---|
configUpdateRequest | ConfigUpdateRequest | Config Update Request |
external-access-token, resource-api-key
- Content-Type: application/vnd.schemaregistry.v1+json, application/vnd.schemaregistry+json, application/json, application/octet-stream
- Accept: application/vnd.schemaregistry.v1+json, application/vnd.schemaregistry+json; qs=0.9, application/json; qs=0.5, application/json
[Back to top] [Back to API list] [Back to Model list] [Back to README]