Documentation ¶
Index ¶
- Variables
- func CacheExpires(r *http.Response) time.Time
- type ACLV3Api
- type ACLV3ApiService
- func (a *ACLV3ApiService) CreateKafkaAcls(ctx _context.Context, clusterId string, localVarOptionals *CreateKafkaAclsOpts) (*_nethttp.Response, error)
- func (a *ACLV3ApiService) DeleteKafkaAcls(ctx _context.Context, clusterId string, localVarOptionals *DeleteKafkaAclsOpts) (InlineResponse200, *_nethttp.Response, error)
- func (a *ACLV3ApiService) GetKafkaAcls(ctx _context.Context, clusterId string, localVarOptionals *GetKafkaAclsOpts) (AclDataList, *_nethttp.Response, error)
- type APIClient
- type APIKey
- type APIResponse
- type AbstractConfigData
- type AbstractConfigDataAllOf
- type AclData
- type AclDataAllOf
- type AclDataList
- type AclResourceType
- type AlterBrokerReplicaExclusionData
- type AlterBrokerReplicaExclusionDataAllOf
- type AlterBrokerReplicaExclusionDataList
- type AlterBrokerReplicaExclusionDataListAllOf
- type AlterConfigBatchRequestData
- type AlterConfigBatchRequestDataData
- type AlterMirrorStatusResponseData
- type AlterMirrorStatusResponseDataAllOf
- type AlterMirrorStatusResponseDataList
- type AlterMirrorStatusResponseDataListAllOf
- type AlterMirrorsRequestData
- type AnyUnevenLoadData
- type AnyUnevenLoadDataAllOf
- type BalancerStatusData
- type BalancerStatusDataAllOf
- type BalancerStatusV3Api
- type BalancerStatusV3ApiService
- func (a *BalancerStatusV3ApiService) ClustersClusterIdBalancerAnyUnevenLoadGet(ctx _context.Context, clusterId string) (AnyUnevenLoadData, *_nethttp.Response, error)
- func (a *BalancerStatusV3ApiService) ClustersClusterIdBalancerGet(ctx _context.Context, clusterId string) (BalancerStatusData, *_nethttp.Response, error)
- type BasicAuth
- type BrokerApi
- type BrokerApiService
- type BrokerConfigData
- type BrokerConfigDataAllOf
- type BrokerConfigDataList
- type BrokerConfigDataListAllOf
- type BrokerData
- type BrokerDataAllOf
- type BrokerDataList
- type BrokerDataListAllOf
- type BrokerRemovalData
- type BrokerRemovalDataAllOf
- type BrokerRemovalDataList
- type BrokerRemovalDataListAllOf
- type BrokerReplicaExclusionApi
- type BrokerReplicaExclusionApiService
- func (a *BrokerReplicaExclusionApiService) ClustersClusterIdBrokerReplicaExclusionsBrokerIdGet(ctx _context.Context, clusterId string, brokerId int32) (BrokerReplicaExclusionData, *_nethttp.Response, error)
- func (a *BrokerReplicaExclusionApiService) ClustersClusterIdBrokerReplicaExclusionsGet(ctx _context.Context, clusterId string) (BrokerReplicaExclusionDataList, *_nethttp.Response, error)
- func (a *BrokerReplicaExclusionApiService) ClustersClusterIdBrokerReplicaExclusionscreatePost(ctx _context.Context, clusterId string, ...) (AlterBrokerReplicaExclusionDataList, *_nethttp.Response, error)
- func (a *BrokerReplicaExclusionApiService) ClustersClusterIdBrokerReplicaExclusionsdeletePost(ctx _context.Context, clusterId string, ...) (AlterBrokerReplicaExclusionDataList, *_nethttp.Response, error)
- type BrokerReplicaExclusionBatchRequestData
- type BrokerReplicaExclusionData
- type BrokerReplicaExclusionDataAllOf
- type BrokerReplicaExclusionDataList
- type BrokerReplicaExclusionDataListAllOf
- type BrokerReplicaExclusionRequestData
- type BrokerTaskApi
- type BrokerTaskApiService
- func (a *BrokerTaskApiService) ClustersClusterIdBrokersBrokerIdTasksGet(ctx _context.Context, clusterId string, brokerId int32) (BrokerTaskDataList, *_nethttp.Response, error)
- func (a *BrokerTaskApiService) ClustersClusterIdBrokersBrokerIdTasksTaskTypeGet(ctx _context.Context, clusterId string, brokerId int32, ...) (BrokerTaskData, *_nethttp.Response, error)
- func (a *BrokerTaskApiService) ClustersClusterIdBrokersTasksGet(ctx _context.Context, clusterId string) (BrokerTaskDataList, *_nethttp.Response, error)
- func (a *BrokerTaskApiService) ClustersClusterIdBrokersTasksTaskTypeGet(ctx _context.Context, clusterId string, taskType BrokerTaskType) (BrokerTaskDataList, *_nethttp.Response, error)
- type BrokerTaskData
- type BrokerTaskDataAllOf
- type BrokerTaskDataList
- type BrokerTaskDataListAllOf
- type BrokerTaskType
- type BrokerV3Api
- type BrokerV3ApiService
- func (a *BrokerV3ApiService) ClustersClusterIdBrokersBrokerIdDelete(ctx _context.Context, clusterId string, brokerId int32, ...) (BrokerRemovalData, *_nethttp.Response, error)
- func (a *BrokerV3ApiService) ClustersClusterIdBrokersBrokerIdGet(ctx _context.Context, clusterId string, brokerId int32) (BrokerData, *_nethttp.Response, error)
- func (a *BrokerV3ApiService) ClustersClusterIdBrokersBrokerIdPartitionReplicasGet(ctx _context.Context, clusterId string, brokerId int32) (ReplicaDataList, *_nethttp.Response, error)
- func (a *BrokerV3ApiService) ClustersClusterIdBrokersGet(ctx _context.Context, clusterId string) (BrokerDataList, *_nethttp.Response, error)
- type ClusterConfigData
- type ClusterConfigDataAllOf
- type ClusterConfigDataList
- type ClusterConfigDataListAllOf
- type ClusterData
- type ClusterDataAllOf
- type ClusterDataList
- type ClusterDataListAllOf
- type ClusterLinkingV3Api
- type ClusterLinkingV3ApiService
- func (a *ClusterLinkingV3ApiService) CreateKafkaLink(ctx _context.Context, clusterId string, linkName string, ...) (*_nethttp.Response, error)
- func (a *ClusterLinkingV3ApiService) CreateKafkaMirrorTopic(ctx _context.Context, clusterId string, linkName string, ...) (*_nethttp.Response, error)
- func (a *ClusterLinkingV3ApiService) DeleteKafkaLink(ctx _context.Context, clusterId string, linkName string, ...) (*_nethttp.Response, error)
- func (a *ClusterLinkingV3ApiService) DeleteKafkaLinkConfig(ctx _context.Context, clusterId string, linkName string, configName string) (*_nethttp.Response, error)
- func (a *ClusterLinkingV3ApiService) GetKafkaLink(ctx _context.Context, clusterId string, linkName string, ...) (ListLinksResponseData, *_nethttp.Response, error)
- func (a *ClusterLinkingV3ApiService) GetKafkaLinkConfigs(ctx _context.Context, clusterId string, linkName string, configName string) (ListLinkConfigsResponseData, *_nethttp.Response, error)
- func (a *ClusterLinkingV3ApiService) ListKafkaLinkConfigs(ctx _context.Context, clusterId string, linkName string) (ListLinkConfigsResponseDataList, *_nethttp.Response, error)
- func (a *ClusterLinkingV3ApiService) ListKafkaLinks(ctx _context.Context, clusterId string) (ListLinksResponseDataList, *_nethttp.Response, error)
- func (a *ClusterLinkingV3ApiService) ListKafkaMirrorTopics(ctx _context.Context, clusterId string, ...) (ListMirrorTopicsResponseDataList, *_nethttp.Response, error)
- func (a *ClusterLinkingV3ApiService) ListKafkaMirrorTopicsUnderLink(ctx _context.Context, clusterId string, linkName string, ...) (ListMirrorTopicsResponseDataList, *_nethttp.Response, error)
- func (a *ClusterLinkingV3ApiService) ReadKafkaMirrorTopic(ctx _context.Context, clusterId string, linkName string, ...) (ListMirrorTopicsResponseData, *_nethttp.Response, error)
- func (a *ClusterLinkingV3ApiService) UpdateKafkaLinkConfig(ctx _context.Context, clusterId string, linkName string, configName string, ...) (*_nethttp.Response, error)
- func (a *ClusterLinkingV3ApiService) UpdateKafkaLinkConfigBatch(ctx _context.Context, clusterId string, linkName string, ...) (*_nethttp.Response, error)
- func (a *ClusterLinkingV3ApiService) UpdateKafkaMirrorTopicsFailover(ctx _context.Context, clusterId string, linkName string, ...) (AlterMirrorStatusResponseDataList, *_nethttp.Response, error)
- func (a *ClusterLinkingV3ApiService) UpdateKafkaMirrorTopicsPause(ctx _context.Context, clusterId string, linkName string, ...) (AlterMirrorStatusResponseDataList, *_nethttp.Response, error)
- func (a *ClusterLinkingV3ApiService) UpdateKafkaMirrorTopicsPromote(ctx _context.Context, clusterId string, linkName string, ...) (AlterMirrorStatusResponseDataList, *_nethttp.Response, error)
- func (a *ClusterLinkingV3ApiService) UpdateKafkaMirrorTopicsResume(ctx _context.Context, clusterId string, linkName string, ...) (AlterMirrorStatusResponseDataList, *_nethttp.Response, error)
- func (a *ClusterLinkingV3ApiService) UpdateKafkaMirrorTopicsReverseAndPauseMirror(ctx _context.Context, clusterId string, linkName string, ...) (AlterMirrorStatusResponseDataList, *_nethttp.Response, error)
- func (a *ClusterLinkingV3ApiService) UpdateKafkaMirrorTopicsReverseAndStarMirror(ctx _context.Context, clusterId string, linkName string, ...) (AlterMirrorStatusResponseDataList, *_nethttp.Response, error)
- type ClusterV3Api
- type ClusterV3ApiService
- type ClustersClusterIdBrokerReplicaExclusionscreatePostOpts
- type ClustersClusterIdBrokerReplicaExclusionsdeletePostOpts
- type ClustersClusterIdBrokersBrokerIdConfigsNamePutOpts
- type ClustersClusterIdBrokersBrokerIdConfigsalterPostOpts
- type ClustersClusterIdBrokersBrokerIdDeleteOpts
- type ClustersClusterIdBrokersdeletePostOpts
- type ClustersClusterIdTopicsTopicNameRecordsPostOpts
- type ConfigData
- type ConfigSynonymData
- type ConfigsV3Api
- type ConfigsV3ApiService
- func (a *ConfigsV3ApiService) ClustersClusterIdBrokersBrokerIdConfigsGet(ctx _context.Context, clusterId string, brokerId int32) (BrokerConfigDataList, *_nethttp.Response, error)
- func (a *ConfigsV3ApiService) ClustersClusterIdBrokersBrokerIdConfigsNameDelete(ctx _context.Context, clusterId string, brokerId int32, name string) (*_nethttp.Response, error)
- func (a *ConfigsV3ApiService) ClustersClusterIdBrokersBrokerIdConfigsNameGet(ctx _context.Context, clusterId string, brokerId int32, name string) (BrokerConfigData, *_nethttp.Response, error)
- func (a *ConfigsV3ApiService) ClustersClusterIdBrokersBrokerIdConfigsNamePut(ctx _context.Context, clusterId string, brokerId int32, name string, ...) (*_nethttp.Response, error)
- func (a *ConfigsV3ApiService) ClustersClusterIdBrokersBrokerIdConfigsalterPost(ctx _context.Context, clusterId string, brokerId int32, ...) (*_nethttp.Response, error)
- func (a *ConfigsV3ApiService) ClustersClusterIdBrokersConfigsGet(ctx _context.Context, clusterId string) (BrokerConfigDataList, *_nethttp.Response, error)
- func (a *ConfigsV3ApiService) DeleteKafkaClusterConfig(ctx _context.Context, clusterId string, name string) (*_nethttp.Response, error)
- func (a *ConfigsV3ApiService) DeleteKafkaTopicConfig(ctx _context.Context, clusterId string, topicName string, name string) (*_nethttp.Response, error)
- func (a *ConfigsV3ApiService) GetKafkaClusterConfig(ctx _context.Context, clusterId string, name string) (ClusterConfigData, *_nethttp.Response, error)
- func (a *ConfigsV3ApiService) GetKafkaTopicConfig(ctx _context.Context, clusterId string, topicName string, name string) (TopicConfigData, *_nethttp.Response, error)
- func (a *ConfigsV3ApiService) ListKafkaAllTopicConfigs(ctx _context.Context, clusterId string) (TopicConfigDataList, *_nethttp.Response, error)
- func (a *ConfigsV3ApiService) ListKafkaClusterConfigs(ctx _context.Context, clusterId string) (ClusterConfigDataList, *_nethttp.Response, error)
- func (a *ConfigsV3ApiService) ListKafkaDefaultTopicConfigs(ctx _context.Context, clusterId string, topicName string) (TopicConfigDataList, *_nethttp.Response, error)
- func (a *ConfigsV3ApiService) ListKafkaTopicConfigs(ctx _context.Context, clusterId string, topicName string) (TopicConfigDataList, *_nethttp.Response, error)
- func (a *ConfigsV3ApiService) UpdateKafkaClusterConfig(ctx _context.Context, clusterId string, name string, ...) (*_nethttp.Response, error)
- func (a *ConfigsV3ApiService) UpdateKafkaClusterConfigs(ctx _context.Context, clusterId string, ...) (*_nethttp.Response, error)
- func (a *ConfigsV3ApiService) UpdateKafkaTopicConfig(ctx _context.Context, clusterId string, topicName string, name string, ...) (*_nethttp.Response, error)
- func (a *ConfigsV3ApiService) UpdateKafkaTopicConfigBatch(ctx _context.Context, clusterId string, topicName string, ...) (*_nethttp.Response, error)
- type Configuration
- type ConsumerAssignmentData
- type ConsumerAssignmentDataAllOf
- type ConsumerAssignmentDataList
- type ConsumerAssignmentDataListAllOf
- type ConsumerData
- type ConsumerDataAllOf
- type ConsumerDataList
- type ConsumerDataListAllOf
- type ConsumerGroupData
- type ConsumerGroupDataAllOf
- type ConsumerGroupDataList
- type ConsumerGroupDataListAllOf
- type ConsumerGroupLagSummaryData
- type ConsumerGroupLagSummaryDataAllOf
- type ConsumerGroupV3Api
- type ConsumerGroupV3ApiService
- func (a *ConsumerGroupV3ApiService) GetKafkaConsumer(ctx _context.Context, clusterId string, consumerGroupId string, ...) (ConsumerData, *_nethttp.Response, error)
- func (a *ConsumerGroupV3ApiService) GetKafkaConsumerAssignment(ctx _context.Context, clusterId string, consumerGroupId string, ...) (ConsumerAssignmentData, *_nethttp.Response, error)
- func (a *ConsumerGroupV3ApiService) GetKafkaConsumerGroup(ctx _context.Context, clusterId string, consumerGroupId string) (ConsumerGroupData, *_nethttp.Response, error)
- func (a *ConsumerGroupV3ApiService) GetKafkaConsumerGroupLagSummary(ctx _context.Context, clusterId string, consumerGroupId string) (ConsumerGroupLagSummaryData, *_nethttp.Response, error)
- func (a *ConsumerGroupV3ApiService) ListKafkaConsumerAssignment(ctx _context.Context, clusterId string, consumerGroupId string, ...) (ConsumerAssignmentDataList, *_nethttp.Response, error)
- func (a *ConsumerGroupV3ApiService) ListKafkaConsumerGroups(ctx _context.Context, clusterId string) (ConsumerGroupDataList, *_nethttp.Response, error)
- func (a *ConsumerGroupV3ApiService) ListKafkaConsumerLags(ctx _context.Context, clusterId string, consumerGroupId string) (ConsumerLagDataList, *_nethttp.Response, error)
- func (a *ConsumerGroupV3ApiService) ListKafkaConsumers(ctx _context.Context, clusterId string, consumerGroupId string) (ConsumerDataList, *_nethttp.Response, error)
- type ConsumerLagData
- type ConsumerLagDataAllOf
- type ConsumerLagDataList
- type ConsumerLagDataListAllOf
- type CreateAclRequestData
- type CreateKafkaAclsOpts
- type CreateKafkaLinkOpts
- type CreateKafkaMirrorTopicOpts
- type CreateKafkaTopicOpts
- type CreateLinkRequestData
- type CreateMirrorTopicRequestData
- type CreateTopicRequestData
- type CreateTopicRequestDataConfigs
- type CreateTopicRequestDataReplicasAssignments
- type DeleteKafkaAclsOpts
- type DeleteKafkaLinkOpts
- type Error
- type GenericOpenAPIError
- type GetKafkaAclsOpts
- type GetKafkaLinkOpts
- type InlineResponse200
- type LinkTask
- type LinkTaskError
- type ListKafkaMirrorTopicsOpts
- type ListKafkaMirrorTopicsUnderLinkOpts
- type ListLinkConfigsResponseData
- type ListLinkConfigsResponseDataAllOf
- type ListLinkConfigsResponseDataList
- type ListLinkConfigsResponseDataListAllOf
- type ListLinksResponseData
- type ListLinksResponseDataAllOf
- type ListLinksResponseDataList
- type ListLinksResponseDataListAllOf
- type ListMirrorTopicsResponseData
- type ListMirrorTopicsResponseDataAllOf
- type ListMirrorTopicsResponseDataList
- type ListMirrorTopicsResponseDataListAllOf
- type MirrorLag
- type MirrorTopicStatus
- type PartitionApi
- type PartitionApiService
- func (a *PartitionApiService) ClustersClusterIdTopicsPartitionsReassignmentGet(ctx _context.Context, clusterId string) (ReassignmentDataList, *_nethttp.Response, error)
- func (a *PartitionApiService) ClustersClusterIdTopicsTopicNamePartitionsPartitionIdReassignmentGet(ctx _context.Context, clusterId string, topicName string, partitionId int32) (ReassignmentData, *_nethttp.Response, error)
- func (a *PartitionApiService) ClustersClusterIdTopicsTopicNamePartitionsReassignmentGet(ctx _context.Context, clusterId string, topicName string) (ReassignmentDataList, *_nethttp.Response, error)
- type PartitionData
- type PartitionDataAllOf
- type PartitionDataList
- type PartitionDataListAllOf
- type PartitionV3Api
- type PartitionV3ApiService
- func (a *PartitionV3ApiService) GetKafkaConsumerLag(ctx _context.Context, clusterId string, consumerGroupId string, ...) (ConsumerLagData, *_nethttp.Response, error)
- func (a *PartitionV3ApiService) GetKafkaPartition(ctx _context.Context, clusterId string, topicName string, partitionId int32) (PartitionData, *_nethttp.Response, error)
- func (a *PartitionV3ApiService) ListKafkaPartitions(ctx _context.Context, clusterId string, topicName string) (PartitionDataList, *_nethttp.Response, error)
- type ProduceRequest
- type ProduceRequestData
- type ProduceRequestHeader
- type ProduceResponse
- type ProduceResponseData
- type ReadKafkaMirrorTopicOpts
- type ReassignmentData
- type ReassignmentDataAllOf
- type ReassignmentDataList
- type ReassignmentDataListAllOf
- type RecordsV3Api
- type RecordsV3ApiService
- type Relationship
- type RemoveBrokerTaskApi
- type RemoveBrokerTaskApiService
- func (a *RemoveBrokerTaskApiService) ClustersClusterIdRemoveBrokerTasksBrokerIdGet(ctx _context.Context, clusterId string, brokerId int32) (RemoveBrokerTaskData, *_nethttp.Response, error)
- func (a *RemoveBrokerTaskApiService) ClustersClusterIdRemoveBrokerTasksGet(ctx _context.Context, clusterId string) (RemoveBrokerTaskDataList, *_nethttp.Response, error)
- type RemoveBrokerTaskData
- type RemoveBrokerTaskDataAllOf
- type RemoveBrokerTaskDataList
- type RemoveBrokerTaskDataListAllOf
- type RemoveBrokersRequestData
- type ReplicaApi
- type ReplicaApiService
- func (a *ReplicaApiService) ClustersClusterIdTopicsTopicNamePartitionsPartitionIdReplicasBrokerIdGet(ctx _context.Context, clusterId string, topicName string, partitionId int32, ...) (ReplicaData, *_nethttp.Response, error)
- func (a *ReplicaApiService) ClustersClusterIdTopicsTopicNamePartitionsPartitionIdReplicasGet(ctx _context.Context, clusterId string, topicName string, partitionId int32) (ReplicaDataList, *_nethttp.Response, error)
- type ReplicaData
- type ReplicaDataAllOf
- type ReplicaDataList
- type ReplicaDataListAllOf
- type ReplicaStatusApi
- type ReplicaStatusApiService
- func (a *ReplicaStatusApiService) ClustersClusterIdTopicsPartitionsReplicaStatusGet(ctx _context.Context, clusterId string) (ReplicaStatusDataList, *_nethttp.Response, error)
- func (a *ReplicaStatusApiService) ClustersClusterIdTopicsTopicNamePartitionsPartitionIdReplicaStatusGet(ctx _context.Context, clusterId string, topicName string, partitionId int32) (ReplicaStatusDataList, *_nethttp.Response, error)
- func (a *ReplicaStatusApiService) ClustersClusterIdTopicsTopicNamePartitionsReplicaStatusGet(ctx _context.Context, clusterId string, topicName string) (ReplicaStatusDataList, *_nethttp.Response, error)
- type ReplicaStatusData
- type ReplicaStatusDataAllOf
- type ReplicaStatusDataList
- type ReplicaStatusDataListAllOf
- type ReplicaV3Api
- type ReplicaV3ApiService
- type Resource
- type ResourceCollection
- type ResourceCollectionMetadata
- type ResourceMetadata
- type ServerConfiguration
- type ServerVariable
- type TopicConfigData
- type TopicConfigDataAllOf
- type TopicConfigDataList
- type TopicConfigDataListAllOf
- type TopicData
- type TopicDataAllOf
- type TopicDataList
- type TopicDataListAllOf
- type TopicList
- type TopicV3Api
- type TopicV3ApiService
- func (a *TopicV3ApiService) CreateKafkaTopic(ctx _context.Context, clusterId string, ...) (TopicData, *_nethttp.Response, error)
- func (a *TopicV3ApiService) DeleteKafkaTopic(ctx _context.Context, clusterId string, topicName string) (*_nethttp.Response, error)
- func (a *TopicV3ApiService) GetKafkaTopic(ctx _context.Context, clusterId string, topicName string) (TopicData, *_nethttp.Response, error)
- func (a *TopicV3ApiService) ListKafkaTopics(ctx _context.Context, clusterId string) (TopicDataList, *_nethttp.Response, error)
- type UnregisterBrokerData
- type UnregisterV3Api
- type UnregisterV3ApiService
- type UpdateConfigRequestData
- type UpdateKafkaClusterConfigOpts
- type UpdateKafkaClusterConfigsOpts
- type UpdateKafkaLinkConfigBatchOpts
- type UpdateKafkaLinkConfigOpts
- type UpdateKafkaMirrorTopicsFailoverOpts
- type UpdateKafkaMirrorTopicsPauseOpts
- type UpdateKafkaMirrorTopicsPromoteOpts
- type UpdateKafkaMirrorTopicsResumeOpts
- type UpdateKafkaMirrorTopicsReverseAndPauseMirrorOpts
- type UpdateKafkaMirrorTopicsReverseAndStarMirrorOpts
- type UpdateKafkaTopicConfigBatchOpts
- type UpdateKafkaTopicConfigOpts
- type UpdateLinkConfigRequestData
Constants ¶
This section is empty.
Variables ¶
var ( // ContextOAuth2 takes an oauth2.TokenSource as authentication for the request. ContextOAuth2 = contextKey("token") // ContextBasicAuth takes BasicAuth as authentication for the request. ContextBasicAuth = contextKey("basic") // ContextAccessToken takes a string oauth2 access token as authentication for the request. ContextAccessToken = contextKey("accesstoken") // ContextAPIKey takes an APIKey as authentication for the request ContextAPIKey = contextKey("apikey") )
Functions ¶
Types ¶
type ACLV3Api ¶ added in v0.3.8
type ACLV3Api interface { /* * CreateKafkaAcls Create ACLs * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Creates an ACL. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param optional nil or *CreateKafkaAclsOpts - Optional Parameters: * @param "CreateAclRequestData" (optional.Interface of CreateAclRequestData) - The ACL creation request. */ CreateKafkaAcls(ctx _context.Context, clusterId string, localVarOptionals *CreateKafkaAclsOpts) (*_nethttp.Response, error) /* * DeleteKafkaAcls Delete ACLs * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Deletes the list of ACLs that matches the search criteria. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param optional nil or *DeleteKafkaAclsOpts - Optional Parameters: * @param "ResourceType" (optional.Interface of AclResourceType) - The ACL resource type. * @param "ResourceName" (optional.String) - The ACL resource name. * @param "PatternType" (optional.String) - The ACL pattern type. * @param "Principal" (optional.String) - The ACL principal. * @param "Host" (optional.String) - The ACL host. * @param "Operation" (optional.String) - The ACL operation. * @param "Permission" (optional.String) - The ACL permission. * @return InlineResponse200 */ DeleteKafkaAcls(ctx _context.Context, clusterId string, localVarOptionals *DeleteKafkaAclsOpts) (InlineResponse200, *_nethttp.Response, error) /* * GetKafkaAcls Search ACLs * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Returns a list of ACLs that match the search criteria. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param optional nil or *GetKafkaAclsOpts - Optional Parameters: * @param "ResourceType" (optional.Interface of AclResourceType) - The ACL resource type. * @param "ResourceName" (optional.String) - The ACL resource name. * @param "PatternType" (optional.String) - The ACL pattern type. * @param "Principal" (optional.String) - The ACL principal. * @param "Host" (optional.String) - The ACL host. * @param "Operation" (optional.String) - The ACL operation. * @param "Permission" (optional.String) - The ACL permission. * @return AclDataList */ GetKafkaAcls(ctx _context.Context, clusterId string, localVarOptionals *GetKafkaAclsOpts) (AclDataList, *_nethttp.Response, error) }
type ACLV3ApiService ¶ added in v0.3.8
type ACLV3ApiService service
ACLV3ApiService ACLV3Api service
func (*ACLV3ApiService) CreateKafkaAcls ¶ added in v0.3.8
func (a *ACLV3ApiService) CreateKafkaAcls(ctx _context.Context, clusterId string, localVarOptionals *CreateKafkaAclsOpts) (*_nethttp.Response, error)
* CreateKafkaAcls Create ACLs * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Creates an ACL. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param optional nil or *CreateKafkaAclsOpts - Optional Parameters: * @param "CreateAclRequestData" (optional.Interface of CreateAclRequestData) - The ACL creation request.
func (*ACLV3ApiService) DeleteKafkaAcls ¶ added in v0.3.8
func (a *ACLV3ApiService) DeleteKafkaAcls(ctx _context.Context, clusterId string, localVarOptionals *DeleteKafkaAclsOpts) (InlineResponse200, *_nethttp.Response, error)
* DeleteKafkaAcls Delete ACLs * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Deletes the list of ACLs that matches the search criteria. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param optional nil or *DeleteKafkaAclsOpts - Optional Parameters: * @param "ResourceType" (optional.Interface of AclResourceType) - The ACL resource type. * @param "ResourceName" (optional.String) - The ACL resource name. * @param "PatternType" (optional.String) - The ACL pattern type. * @param "Principal" (optional.String) - The ACL principal. * @param "Host" (optional.String) - The ACL host. * @param "Operation" (optional.String) - The ACL operation. * @param "Permission" (optional.String) - The ACL permission. * @return InlineResponse200
func (*ACLV3ApiService) GetKafkaAcls ¶ added in v0.3.8
func (a *ACLV3ApiService) GetKafkaAcls(ctx _context.Context, clusterId string, localVarOptionals *GetKafkaAclsOpts) (AclDataList, *_nethttp.Response, error)
* GetKafkaAcls Search ACLs * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Returns a list of ACLs that match the search criteria. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param optional nil or *GetKafkaAclsOpts - Optional Parameters: * @param "ResourceType" (optional.Interface of AclResourceType) - The ACL resource type. * @param "ResourceName" (optional.String) - The ACL resource name. * @param "PatternType" (optional.String) - The ACL pattern type. * @param "Principal" (optional.String) - The ACL principal. * @param "Host" (optional.String) - The ACL host. * @param "Operation" (optional.String) - The ACL operation. * @param "Permission" (optional.String) - The ACL permission. * @return AclDataList
type APIClient ¶
type APIClient struct { ACLV3Api ACLV3Api BalancerStatusV3Api BalancerStatusV3Api BrokerApi BrokerApi BrokerReplicaExclusionApi BrokerReplicaExclusionApi BrokerTaskApi BrokerTaskApi BrokerV3Api BrokerV3Api ClusterLinkingV3Api ClusterLinkingV3Api ClusterV3Api ClusterV3Api ConfigsV3Api ConfigsV3Api ConsumerGroupV3Api ConsumerGroupV3Api PartitionApi PartitionApi PartitionV3Api PartitionV3Api RecordsV3Api RecordsV3Api RemoveBrokerTaskApi RemoveBrokerTaskApi ReplicaApi ReplicaApi ReplicaStatusApi ReplicaStatusApi ReplicaV3Api ReplicaV3Api TopicV3Api TopicV3Api UnregisterV3Api UnregisterV3Api // contains filtered or unexported fields }
APIClient manages communication with the REST Admin API API v3.0.0 In most cases there should be only one, shared, APIClient.
func NewAPIClient ¶
func NewAPIClient(cfg *Configuration) *APIClient
NewAPIClient creates a new API client. Requires a userAgent string describing your application. optionally a custom http.Client to allow for advanced features such as caching.
func (*APIClient) ChangeBasePath ¶
ChangeBasePath changes base path to allow switching to mocks
func (*APIClient) GetConfig ¶
func (c *APIClient) GetConfig() *Configuration
Allow modification of underlying config for alternate implementations and testing Caution: modifying the configuration while live can cause data races and potentially unwanted behavior
type APIKey ¶
APIKey provides API key based authentication to a request passed via context using ContextAPIKey
type APIResponse ¶
type APIResponse struct { *http.Response `json:"-"` Message string `json:"message,omitempty"` // Operation is the name of the OpenAPI operation. Operation string `json:"operation,omitempty"` // RequestURL is the request URL. This value is always available, even if the // embedded *http.Response is nil. RequestURL string `json:"url,omitempty"` // Method is the HTTP method used for the request. This value is always // available, even if the embedded *http.Response is nil. Method string `json:"method,omitempty"` // Payload holds the contents of the response body (which may be nil or empty). // This is provided here as the raw response.Body() reader will have already // been drained. Payload []byte `json:"-"` }
APIResponse stores the API response returned by the server.
func NewAPIResponse ¶
func NewAPIResponse(r *http.Response) *APIResponse
NewAPIResponse returns a new APIResonse object.
func NewAPIResponseWithError ¶
func NewAPIResponseWithError(errorMessage string) *APIResponse
NewAPIResponseWithError returns a new APIResponse object with the provided error message.
type AbstractConfigData ¶
type AbstractConfigData struct { Kind string `json:"kind"` Metadata ResourceMetadata `json:"metadata"` ClusterId string `json:"cluster_id"` Name string `json:"name"` Value *string `json:"value,omitempty"` IsDefault bool `json:"is_default"` IsReadOnly bool `json:"is_read_only"` IsSensitive bool `json:"is_sensitive"` Source string `json:"source"` Synonyms []ConfigSynonymData `json:"synonyms"` }
AbstractConfigData struct for AbstractConfigData
type AbstractConfigDataAllOf ¶
type AbstractConfigDataAllOf struct { ClusterId string `json:"cluster_id"` Name string `json:"name"` Value *string `json:"value,omitempty"` IsDefault bool `json:"is_default"` IsReadOnly bool `json:"is_read_only"` IsSensitive bool `json:"is_sensitive"` Source string `json:"source"` Synonyms []ConfigSynonymData `json:"synonyms"` }
AbstractConfigDataAllOf struct for AbstractConfigDataAllOf
type AclData ¶
type AclData struct { Kind string `json:"kind"` Metadata ResourceMetadata `json:"metadata"` ClusterId string `json:"cluster_id"` ResourceType AclResourceType `json:"resource_type"` ResourceName string `json:"resource_name"` PatternType string `json:"pattern_type"` Principal string `json:"principal"` Host string `json:"host"` Operation string `json:"operation"` Permission string `json:"permission"` }
AclData struct for AclData
type AclDataAllOf ¶
type AclDataAllOf struct { ClusterId string `json:"cluster_id"` ResourceType AclResourceType `json:"resource_type"` ResourceName string `json:"resource_name"` PatternType string `json:"pattern_type"` Principal string `json:"principal"` Host string `json:"host"` Operation string `json:"operation"` Permission string `json:"permission"` }
AclDataAllOf struct for AclDataAllOf
type AclDataList ¶
type AclDataList struct { Kind string `json:"kind"` Metadata ResourceCollectionMetadata `json:"metadata"` Data []AclData `json:"data"` }
AclDataList struct for AclDataList
type AclResourceType ¶
type AclResourceType string
AclResourceType the model 'AclResourceType'
const ( ACLRESOURCETYPE_UNKNOWN AclResourceType = "UNKNOWN" ACLRESOURCETYPE_ANY AclResourceType = "ANY" ACLRESOURCETYPE_TOPIC AclResourceType = "TOPIC" ACLRESOURCETYPE_GROUP AclResourceType = "GROUP" ACLRESOURCETYPE_CLUSTER AclResourceType = "CLUSTER" ACLRESOURCETYPE_TRANSACTIONAL_ID AclResourceType = "TRANSACTIONAL_ID" ACLRESOURCETYPE_DELEGATION_TOKEN AclResourceType = "DELEGATION_TOKEN" )
List of AclResourceType
type AlterBrokerReplicaExclusionData ¶ added in v0.3.8
type AlterBrokerReplicaExclusionData struct { Kind string `json:"kind"` Metadata ResourceMetadata `json:"metadata"` ClusterId string `json:"cluster_id"` BrokerId int32 `json:"broker_id"` Exclusion string `json:"exclusion"` Reason string `json:"reason"` ErrorCode *int32 `json:"error_code,omitempty"` ErrorMessage *string `json:"error_message,omitempty"` Broker Relationship `json:"broker"` }
AlterBrokerReplicaExclusionData struct for AlterBrokerReplicaExclusionData
type AlterBrokerReplicaExclusionDataAllOf ¶ added in v0.3.8
type AlterBrokerReplicaExclusionDataAllOf struct { ClusterId string `json:"cluster_id"` BrokerId int32 `json:"broker_id"` Exclusion string `json:"exclusion"` Reason string `json:"reason"` ErrorCode *int32 `json:"error_code,omitempty"` ErrorMessage *string `json:"error_message,omitempty"` Broker Relationship `json:"broker"` }
AlterBrokerReplicaExclusionDataAllOf struct for AlterBrokerReplicaExclusionDataAllOf
type AlterBrokerReplicaExclusionDataList ¶ added in v0.3.8
type AlterBrokerReplicaExclusionDataList struct { Kind string `json:"kind"` Metadata ResourceCollectionMetadata `json:"metadata"` Data []AlterBrokerReplicaExclusionData `json:"data"` }
AlterBrokerReplicaExclusionDataList struct for AlterBrokerReplicaExclusionDataList
type AlterBrokerReplicaExclusionDataListAllOf ¶ added in v0.3.8
type AlterBrokerReplicaExclusionDataListAllOf struct {
Data []AlterBrokerReplicaExclusionData `json:"data"`
}
AlterBrokerReplicaExclusionDataListAllOf struct for AlterBrokerReplicaExclusionDataListAllOf
type AlterConfigBatchRequestData ¶
type AlterConfigBatchRequestData struct {
Data []AlterConfigBatchRequestDataData `json:"data"`
}
AlterConfigBatchRequestData struct for AlterConfigBatchRequestData
type AlterConfigBatchRequestDataData ¶
type AlterConfigBatchRequestDataData struct { Name string `json:"name"` Value *string `json:"value,omitempty"` Operation *string `json:"operation,omitempty"` }
AlterConfigBatchRequestDataData struct for AlterConfigBatchRequestDataData
type AlterMirrorStatusResponseData ¶
type AlterMirrorStatusResponseData struct { Kind string `json:"kind"` Metadata ResourceMetadata `json:"metadata"` MirrorTopicName string `json:"mirror_topic_name"` ErrorMessage *string `json:"error_message"` ErrorCode *int32 `json:"error_code"` MirrorLags []MirrorLag `json:"mirror_lags"` }
AlterMirrorStatusResponseData struct for AlterMirrorStatusResponseData
type AlterMirrorStatusResponseDataAllOf ¶
type AlterMirrorStatusResponseDataAllOf struct { MirrorTopicName string `json:"mirror_topic_name"` ErrorMessage *string `json:"error_message"` ErrorCode *int32 `json:"error_code"` MirrorLags []MirrorLag `json:"mirror_lags"` }
AlterMirrorStatusResponseDataAllOf struct for AlterMirrorStatusResponseDataAllOf
type AlterMirrorStatusResponseDataList ¶
type AlterMirrorStatusResponseDataList struct { Kind string `json:"kind"` Metadata ResourceCollectionMetadata `json:"metadata"` Data []AlterMirrorStatusResponseData `json:"data"` }
AlterMirrorStatusResponseDataList struct for AlterMirrorStatusResponseDataList
type AlterMirrorStatusResponseDataListAllOf ¶
type AlterMirrorStatusResponseDataListAllOf struct {
Data []AlterMirrorStatusResponseData `json:"data"`
}
AlterMirrorStatusResponseDataListAllOf struct for AlterMirrorStatusResponseDataListAllOf
type AlterMirrorsRequestData ¶
type AlterMirrorsRequestData struct { // The mirror topics specified as a list of topic names. MirrorTopicNames []string `json:"mirror_topic_names,omitempty"` // The mirror topics specified as a pattern. MirrorTopicNamePattern string `json:"mirror_topic_name_pattern,omitempty"` }
AlterMirrorsRequestData struct for AlterMirrorsRequestData
type AnyUnevenLoadData ¶
type AnyUnevenLoadData struct { Kind string `json:"kind"` Metadata ResourceMetadata `json:"metadata"` ClusterId string `json:"cluster_id"` Status string `json:"status"` PreviousStatus string `json:"previous_status"` // The date and time at which this task was created. StatusUpdatedAt time.Time `json:"status_updated_at"` // The date and time at which this task was created. PreviousStatusUpdatedAt time.Time `json:"previous_status_updated_at"` ErrorCode *int32 `json:"error_code,omitempty"` ErrorMessage *string `json:"error_message,omitempty"` BrokerTasks Relationship `json:"broker_tasks"` }
AnyUnevenLoadData struct for AnyUnevenLoadData
type AnyUnevenLoadDataAllOf ¶
type AnyUnevenLoadDataAllOf struct { ClusterId string `json:"cluster_id"` Status string `json:"status"` PreviousStatus string `json:"previous_status"` // The date and time at which this task was created. StatusUpdatedAt time.Time `json:"status_updated_at"` // The date and time at which this task was created. PreviousStatusUpdatedAt time.Time `json:"previous_status_updated_at"` ErrorCode *int32 `json:"error_code,omitempty"` ErrorMessage *string `json:"error_message,omitempty"` BrokerTasks Relationship `json:"broker_tasks"` }
AnyUnevenLoadDataAllOf struct for AnyUnevenLoadDataAllOf
type BalancerStatusData ¶
type BalancerStatusData struct { Kind string `json:"kind"` Metadata ResourceMetadata `json:"metadata"` ClusterId string `json:"cluster_id"` Status string `json:"status"` ErrorCode *int32 `json:"error_code,omitempty"` ErrorMessage *string `json:"error_message,omitempty"` AnyUnevenLoad Relationship `json:"any_uneven_load"` BrokerTasks Relationship `json:"broker_tasks"` }
BalancerStatusData struct for BalancerStatusData
type BalancerStatusDataAllOf ¶
type BalancerStatusDataAllOf struct { ClusterId string `json:"cluster_id"` Status string `json:"status"` ErrorCode *int32 `json:"error_code,omitempty"` ErrorMessage *string `json:"error_message,omitempty"` AnyUnevenLoad Relationship `json:"any_uneven_load"` BrokerTasks Relationship `json:"broker_tasks"` }
BalancerStatusDataAllOf struct for BalancerStatusDataAllOf
type BalancerStatusV3Api ¶ added in v0.3.8
type BalancerStatusV3Api interface { /* * ClustersClusterIdBalancerAnyUnevenLoadGet Get AnyUnevenLoad status * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Returns status of the AnyUnevenLoad for the cluster specified by ``cluster_id``. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @return AnyUnevenLoadData */ ClustersClusterIdBalancerAnyUnevenLoadGet(ctx _context.Context, clusterId string) (AnyUnevenLoadData, *_nethttp.Response, error) /* * ClustersClusterIdBalancerGet Get status of the balancer * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) 'Returns status about the balancer component for the cluster specified with ``cluster_id``.' * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @return BalancerStatusData */ ClustersClusterIdBalancerGet(ctx _context.Context, clusterId string) (BalancerStatusData, *_nethttp.Response, error) }
type BalancerStatusV3ApiService ¶ added in v0.3.8
type BalancerStatusV3ApiService service
BalancerStatusV3ApiService BalancerStatusV3Api service
func (*BalancerStatusV3ApiService) ClustersClusterIdBalancerAnyUnevenLoadGet ¶ added in v0.3.8
func (a *BalancerStatusV3ApiService) ClustersClusterIdBalancerAnyUnevenLoadGet(ctx _context.Context, clusterId string) (AnyUnevenLoadData, *_nethttp.Response, error)
* ClustersClusterIdBalancerAnyUnevenLoadGet Get AnyUnevenLoad status * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Returns status of the AnyUnevenLoad for the cluster specified by ``cluster_id``. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @return AnyUnevenLoadData
func (*BalancerStatusV3ApiService) ClustersClusterIdBalancerGet ¶ added in v0.3.8
func (a *BalancerStatusV3ApiService) ClustersClusterIdBalancerGet(ctx _context.Context, clusterId string) (BalancerStatusData, *_nethttp.Response, error)
* ClustersClusterIdBalancerGet Get status of the balancer * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) 'Returns status about the balancer component for the cluster specified with ``cluster_id``.' * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @return BalancerStatusData
type BasicAuth ¶
type BasicAuth struct { UserName string `json:"userName,omitempty"` Password string `json:"password,omitempty"` }
BasicAuth provides basic http authentication to a request passed via context using ContextBasicAuth
type BrokerApi ¶
type BrokerApi interface { /* * ClustersClusterIdBrokersdeletePost Delete several brokers * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param optional nil or *ClustersClusterIdBrokersdeletePostOpts - Optional Parameters: * @param "ShouldShutdown" (optional.Bool) - To shutdown the broker or not, Default: true * @param "RemoveBrokersRequestData" (optional.Interface of RemoveBrokersRequestData) - Broker ids to remove * @return BrokerRemovalDataList */ ClustersClusterIdBrokersdeletePost(ctx _context.Context, clusterId string, localVarOptionals *ClustersClusterIdBrokersdeletePostOpts) (BrokerRemovalDataList, *_nethttp.Response, error) }
type BrokerApiService ¶
type BrokerApiService service
BrokerApiService BrokerApi service
func (*BrokerApiService) ClustersClusterIdBrokersdeletePost ¶
func (a *BrokerApiService) ClustersClusterIdBrokersdeletePost(ctx _context.Context, clusterId string, localVarOptionals *ClustersClusterIdBrokersdeletePostOpts) (BrokerRemovalDataList, *_nethttp.Response, error)
* ClustersClusterIdBrokersdeletePost Delete several brokers * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param optional nil or *ClustersClusterIdBrokersdeletePostOpts - Optional Parameters: * @param "ShouldShutdown" (optional.Bool) - To shutdown the broker or not, Default: true * @param "RemoveBrokersRequestData" (optional.Interface of RemoveBrokersRequestData) - Broker ids to remove * @return BrokerRemovalDataList
type BrokerConfigData ¶
type BrokerConfigData struct { Kind string `json:"kind"` Metadata ResourceMetadata `json:"metadata"` ClusterId string `json:"cluster_id"` Name string `json:"name"` Value *string `json:"value,omitempty"` IsDefault bool `json:"is_default"` IsReadOnly bool `json:"is_read_only"` IsSensitive bool `json:"is_sensitive"` Source string `json:"source"` Synonyms []ConfigSynonymData `json:"synonyms"` BrokerId int32 `json:"broker_id"` }
BrokerConfigData struct for BrokerConfigData
type BrokerConfigDataAllOf ¶
type BrokerConfigDataAllOf struct {
BrokerId int32 `json:"broker_id"`
}
BrokerConfigDataAllOf struct for BrokerConfigDataAllOf
type BrokerConfigDataList ¶
type BrokerConfigDataList struct { Kind string `json:"kind"` Metadata ResourceCollectionMetadata `json:"metadata"` Data []BrokerConfigData `json:"data"` }
BrokerConfigDataList struct for BrokerConfigDataList
type BrokerConfigDataListAllOf ¶
type BrokerConfigDataListAllOf struct {
Data []BrokerConfigData `json:"data"`
}
BrokerConfigDataListAllOf struct for BrokerConfigDataListAllOf
type BrokerData ¶
type BrokerData struct { Kind string `json:"kind"` Metadata ResourceMetadata `json:"metadata"` ClusterId string `json:"cluster_id"` BrokerId int32 `json:"broker_id"` Host *string `json:"host,omitempty"` Port *int32 `json:"port,omitempty"` Rack *string `json:"rack,omitempty"` Configs Relationship `json:"configs"` PartitionReplicas Relationship `json:"partition_replicas"` }
BrokerData struct for BrokerData
type BrokerDataAllOf ¶
type BrokerDataAllOf struct { ClusterId string `json:"cluster_id"` BrokerId int32 `json:"broker_id"` Host *string `json:"host,omitempty"` Port *int32 `json:"port,omitempty"` Rack *string `json:"rack,omitempty"` Configs Relationship `json:"configs"` PartitionReplicas Relationship `json:"partition_replicas"` }
BrokerDataAllOf struct for BrokerDataAllOf
type BrokerDataList ¶
type BrokerDataList struct { Kind string `json:"kind"` Metadata ResourceCollectionMetadata `json:"metadata"` Data []BrokerData `json:"data"` }
BrokerDataList struct for BrokerDataList
type BrokerDataListAllOf ¶
type BrokerDataListAllOf struct {
Data []BrokerData `json:"data"`
}
BrokerDataListAllOf struct for BrokerDataListAllOf
type BrokerRemovalData ¶
type BrokerRemovalData struct { Kind string `json:"kind"` Metadata ResourceMetadata `json:"metadata"` ClusterId string `json:"cluster_id"` BrokerId int32 `json:"broker_id"` BrokerTask Relationship `json:"broker_task"` Broker Relationship `json:"broker"` }
BrokerRemovalData struct for BrokerRemovalData
type BrokerRemovalDataAllOf ¶
type BrokerRemovalDataAllOf struct { ClusterId string `json:"cluster_id"` BrokerId int32 `json:"broker_id"` BrokerTask Relationship `json:"broker_task"` Broker Relationship `json:"broker"` }
BrokerRemovalDataAllOf struct for BrokerRemovalDataAllOf
type BrokerRemovalDataList ¶
type BrokerRemovalDataList struct { Kind string `json:"kind"` Metadata ResourceCollectionMetadata `json:"metadata"` Data []BrokerRemovalData `json:"data"` }
BrokerRemovalDataList struct for BrokerRemovalDataList
type BrokerRemovalDataListAllOf ¶
type BrokerRemovalDataListAllOf struct {
Data []BrokerRemovalData `json:"data"`
}
BrokerRemovalDataListAllOf struct for BrokerRemovalDataListAllOf
type BrokerReplicaExclusionApi ¶ added in v0.3.8
type BrokerReplicaExclusionApi interface { /* * ClustersClusterIdBrokerReplicaExclusionsBrokerIdGet Get a Broker Replica Exclusions. * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Returns a Broker Replica Exclusions in the cluster specified with ``cluster_id`` and broker specified with ``broker_id``. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param brokerId The Kafka broker ID. * @return BrokerReplicaExclusionData */ ClustersClusterIdBrokerReplicaExclusionsBrokerIdGet(ctx _context.Context, clusterId string, brokerId int32) (BrokerReplicaExclusionData, *_nethttp.Response, error) /* * ClustersClusterIdBrokerReplicaExclusionsGet Get all Broker Replica Exclusions. * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Returns all Broker Replica Exclusions in the cluster specified with ``cluster_id``. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @return BrokerReplicaExclusionDataList */ ClustersClusterIdBrokerReplicaExclusionsGet(ctx _context.Context, clusterId string) (BrokerReplicaExclusionDataList, *_nethttp.Response, error) /* * ClustersClusterIdBrokerReplicaExclusionscreatePost Create Broker Replica Exclusions * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Create Broker Replica Exclusions for brokers in the cluster specified with ``cluster_id``. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param optional nil or *ClustersClusterIdBrokerReplicaExclusionscreatePostOpts - Optional Parameters: * @param "BrokerReplicaExclusionBatchRequestData" (optional.Interface of BrokerReplicaExclusionBatchRequestData) - Alter Broker Replica Exclusions. * @return AlterBrokerReplicaExclusionDataList */ ClustersClusterIdBrokerReplicaExclusionscreatePost(ctx _context.Context, clusterId string, localVarOptionals *ClustersClusterIdBrokerReplicaExclusionscreatePostOpts) (AlterBrokerReplicaExclusionDataList, *_nethttp.Response, error) /* * ClustersClusterIdBrokerReplicaExclusionsdeletePost Delete Broker Replica Exclusions * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Delete Broker Replica Exclusions for brokers in the cluster specified with ``cluster_id``. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param optional nil or *ClustersClusterIdBrokerReplicaExclusionsdeletePostOpts - Optional Parameters: * @param "BrokerReplicaExclusionBatchRequestData" (optional.Interface of BrokerReplicaExclusionBatchRequestData) - Alter Broker Replica Exclusions. * @return AlterBrokerReplicaExclusionDataList */ ClustersClusterIdBrokerReplicaExclusionsdeletePost(ctx _context.Context, clusterId string, localVarOptionals *ClustersClusterIdBrokerReplicaExclusionsdeletePostOpts) (AlterBrokerReplicaExclusionDataList, *_nethttp.Response, error) }
type BrokerReplicaExclusionApiService ¶ added in v0.3.8
type BrokerReplicaExclusionApiService service
BrokerReplicaExclusionApiService BrokerReplicaExclusionApi service
func (*BrokerReplicaExclusionApiService) ClustersClusterIdBrokerReplicaExclusionsBrokerIdGet ¶ added in v0.3.8
func (a *BrokerReplicaExclusionApiService) ClustersClusterIdBrokerReplicaExclusionsBrokerIdGet(ctx _context.Context, clusterId string, brokerId int32) (BrokerReplicaExclusionData, *_nethttp.Response, error)
* ClustersClusterIdBrokerReplicaExclusionsBrokerIdGet Get a Broker Replica Exclusions. * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Returns a Broker Replica Exclusions in the cluster specified with ``cluster_id`` and broker specified with ``broker_id``. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param brokerId The Kafka broker ID. * @return BrokerReplicaExclusionData
func (*BrokerReplicaExclusionApiService) ClustersClusterIdBrokerReplicaExclusionsGet ¶ added in v0.3.8
func (a *BrokerReplicaExclusionApiService) ClustersClusterIdBrokerReplicaExclusionsGet(ctx _context.Context, clusterId string) (BrokerReplicaExclusionDataList, *_nethttp.Response, error)
* ClustersClusterIdBrokerReplicaExclusionsGet Get all Broker Replica Exclusions. * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Returns all Broker Replica Exclusions in the cluster specified with ``cluster_id``. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @return BrokerReplicaExclusionDataList
func (*BrokerReplicaExclusionApiService) ClustersClusterIdBrokerReplicaExclusionscreatePost ¶ added in v0.3.8
func (a *BrokerReplicaExclusionApiService) ClustersClusterIdBrokerReplicaExclusionscreatePost(ctx _context.Context, clusterId string, localVarOptionals *ClustersClusterIdBrokerReplicaExclusionscreatePostOpts) (AlterBrokerReplicaExclusionDataList, *_nethttp.Response, error)
* ClustersClusterIdBrokerReplicaExclusionscreatePost Create Broker Replica Exclusions * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Create Broker Replica Exclusions for brokers in the cluster specified with ``cluster_id``. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param optional nil or *ClustersClusterIdBrokerReplicaExclusionscreatePostOpts - Optional Parameters: * @param "BrokerReplicaExclusionBatchRequestData" (optional.Interface of BrokerReplicaExclusionBatchRequestData) - Alter Broker Replica Exclusions. * @return AlterBrokerReplicaExclusionDataList
func (*BrokerReplicaExclusionApiService) ClustersClusterIdBrokerReplicaExclusionsdeletePost ¶ added in v0.3.8
func (a *BrokerReplicaExclusionApiService) ClustersClusterIdBrokerReplicaExclusionsdeletePost(ctx _context.Context, clusterId string, localVarOptionals *ClustersClusterIdBrokerReplicaExclusionsdeletePostOpts) (AlterBrokerReplicaExclusionDataList, *_nethttp.Response, error)
* ClustersClusterIdBrokerReplicaExclusionsdeletePost Delete Broker Replica Exclusions * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Delete Broker Replica Exclusions for brokers in the cluster specified with ``cluster_id``. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param optional nil or *ClustersClusterIdBrokerReplicaExclusionsdeletePostOpts - Optional Parameters: * @param "BrokerReplicaExclusionBatchRequestData" (optional.Interface of BrokerReplicaExclusionBatchRequestData) - Alter Broker Replica Exclusions. * @return AlterBrokerReplicaExclusionDataList
type BrokerReplicaExclusionBatchRequestData ¶ added in v0.3.8
type BrokerReplicaExclusionBatchRequestData struct {
Data []BrokerReplicaExclusionRequestData `json:"data"`
}
BrokerReplicaExclusionBatchRequestData struct for BrokerReplicaExclusionBatchRequestData
type BrokerReplicaExclusionData ¶ added in v0.3.8
type BrokerReplicaExclusionData struct { Kind string `json:"kind"` Metadata ResourceMetadata `json:"metadata"` ClusterId string `json:"cluster_id"` BrokerId int32 `json:"broker_id"` Reason string `json:"reason"` Broker Relationship `json:"broker"` }
BrokerReplicaExclusionData struct for BrokerReplicaExclusionData
type BrokerReplicaExclusionDataAllOf ¶ added in v0.3.8
type BrokerReplicaExclusionDataAllOf struct { ClusterId string `json:"cluster_id"` BrokerId int32 `json:"broker_id"` Reason string `json:"reason"` Broker Relationship `json:"broker"` }
BrokerReplicaExclusionDataAllOf struct for BrokerReplicaExclusionDataAllOf
type BrokerReplicaExclusionDataList ¶ added in v0.3.8
type BrokerReplicaExclusionDataList struct { Kind string `json:"kind"` Metadata ResourceCollectionMetadata `json:"metadata"` Data []BrokerReplicaExclusionData `json:"data"` }
BrokerReplicaExclusionDataList struct for BrokerReplicaExclusionDataList
type BrokerReplicaExclusionDataListAllOf ¶ added in v0.3.8
type BrokerReplicaExclusionDataListAllOf struct {
Data []BrokerReplicaExclusionData `json:"data"`
}
BrokerReplicaExclusionDataListAllOf struct for BrokerReplicaExclusionDataListAllOf
type BrokerReplicaExclusionRequestData ¶ added in v0.3.8
type BrokerReplicaExclusionRequestData struct { BrokerId int32 `json:"broker_id"` Reason string `json:"reason"` }
BrokerReplicaExclusionRequestData struct for BrokerReplicaExclusionRequestData
type BrokerTaskApi ¶
type BrokerTaskApi interface { /* * ClustersClusterIdBrokersBrokerIdTasksGet List Broker Tasks of a specific Broker * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Returns a list of all broker tasks for broker specified with ``broker_id`` in the cluster specified with ``cluster_id``. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param brokerId The Kafka broker ID. * @return BrokerTaskDataList */ ClustersClusterIdBrokersBrokerIdTasksGet(ctx _context.Context, clusterId string, brokerId int32) (BrokerTaskDataList, *_nethttp.Response, error) /* * ClustersClusterIdBrokersBrokerIdTasksTaskTypeGet Get single Broker Task. * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Returns a single Broker Task specified with ``task_type`` for broker specified with ``broker_id`` in the cluster specified with ``cluster_id``. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param brokerId The Kafka broker ID. * @param taskType The Kafka broker task type. * @return BrokerTaskData */ ClustersClusterIdBrokersBrokerIdTasksTaskTypeGet(ctx _context.Context, clusterId string, brokerId int32, taskType BrokerTaskType) (BrokerTaskData, *_nethttp.Response, error) /* * ClustersClusterIdBrokersTasksGet List Broker Tasks * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Returns a list of all tasks for all brokers in the cluster specified with ``cluster_id``. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @return BrokerTaskDataList */ ClustersClusterIdBrokersTasksGet(ctx _context.Context, clusterId string) (BrokerTaskDataList, *_nethttp.Response, error) /* * ClustersClusterIdBrokersTasksTaskTypeGet List Broker Tasks of a specific TaskType * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Returns a list of all broker tasks of specified ``task_type`` in the cluster specified with ``cluster_id``. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param taskType The Kafka broker task type. * @return BrokerTaskDataList */ ClustersClusterIdBrokersTasksTaskTypeGet(ctx _context.Context, clusterId string, taskType BrokerTaskType) (BrokerTaskDataList, *_nethttp.Response, error) }
type BrokerTaskApiService ¶
type BrokerTaskApiService service
BrokerTaskApiService BrokerTaskApi service
func (*BrokerTaskApiService) ClustersClusterIdBrokersBrokerIdTasksGet ¶
func (a *BrokerTaskApiService) ClustersClusterIdBrokersBrokerIdTasksGet(ctx _context.Context, clusterId string, brokerId int32) (BrokerTaskDataList, *_nethttp.Response, error)
* ClustersClusterIdBrokersBrokerIdTasksGet List Broker Tasks of a specific Broker * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Returns a list of all broker tasks for broker specified with ``broker_id`` in the cluster specified with ``cluster_id``. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param brokerId The Kafka broker ID. * @return BrokerTaskDataList
func (*BrokerTaskApiService) ClustersClusterIdBrokersBrokerIdTasksTaskTypeGet ¶
func (a *BrokerTaskApiService) ClustersClusterIdBrokersBrokerIdTasksTaskTypeGet(ctx _context.Context, clusterId string, brokerId int32, taskType BrokerTaskType) (BrokerTaskData, *_nethttp.Response, error)
* ClustersClusterIdBrokersBrokerIdTasksTaskTypeGet Get single Broker Task. * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Returns a single Broker Task specified with ``task_type`` for broker specified with ``broker_id`` in the cluster specified with ``cluster_id``. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param brokerId The Kafka broker ID. * @param taskType The Kafka broker task type. * @return BrokerTaskData
func (*BrokerTaskApiService) ClustersClusterIdBrokersTasksGet ¶
func (a *BrokerTaskApiService) ClustersClusterIdBrokersTasksGet(ctx _context.Context, clusterId string) (BrokerTaskDataList, *_nethttp.Response, error)
* ClustersClusterIdBrokersTasksGet List Broker Tasks * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Returns a list of all tasks for all brokers in the cluster specified with ``cluster_id``. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @return BrokerTaskDataList
func (*BrokerTaskApiService) ClustersClusterIdBrokersTasksTaskTypeGet ¶
func (a *BrokerTaskApiService) ClustersClusterIdBrokersTasksTaskTypeGet(ctx _context.Context, clusterId string, taskType BrokerTaskType) (BrokerTaskDataList, *_nethttp.Response, error)
* ClustersClusterIdBrokersTasksTaskTypeGet List Broker Tasks of a specific TaskType * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Returns a list of all broker tasks of specified ``task_type`` in the cluster specified with ``cluster_id``. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param taskType The Kafka broker task type. * @return BrokerTaskDataList
type BrokerTaskData ¶
type BrokerTaskData struct { Kind string `json:"kind"` Metadata ResourceMetadata `json:"metadata"` ClusterId string `json:"cluster_id"` BrokerId int32 `json:"broker_id"` TaskType BrokerTaskType `json:"task_type"` TaskStatus string `json:"task_status"` ShutdownScheduled *bool `json:"shutdown_scheduled,omitempty"` SubTaskStatuses map[string]string `json:"sub_task_statuses"` // The date and time at which this task was created. CreatedAt time.Time `json:"created_at"` // The date and time at which this task was last updated. UpdatedAt time.Time `json:"updated_at"` ErrorCode *int32 `json:"error_code,omitempty"` ErrorMessage *string `json:"error_message,omitempty"` Broker Relationship `json:"broker"` }
BrokerTaskData struct for BrokerTaskData
type BrokerTaskDataAllOf ¶
type BrokerTaskDataAllOf struct { ClusterId string `json:"cluster_id"` BrokerId int32 `json:"broker_id"` TaskType BrokerTaskType `json:"task_type"` TaskStatus string `json:"task_status"` ShutdownScheduled *bool `json:"shutdown_scheduled,omitempty"` SubTaskStatuses map[string]string `json:"sub_task_statuses"` // The date and time at which this task was created. CreatedAt time.Time `json:"created_at"` // The date and time at which this task was last updated. UpdatedAt time.Time `json:"updated_at"` ErrorCode *int32 `json:"error_code,omitempty"` ErrorMessage *string `json:"error_message,omitempty"` Broker Relationship `json:"broker"` }
BrokerTaskDataAllOf struct for BrokerTaskDataAllOf
type BrokerTaskDataList ¶
type BrokerTaskDataList struct { Kind string `json:"kind"` Metadata ResourceCollectionMetadata `json:"metadata"` Data []BrokerTaskData `json:"data"` }
BrokerTaskDataList struct for BrokerTaskDataList
type BrokerTaskDataListAllOf ¶
type BrokerTaskDataListAllOf struct {
Data []BrokerTaskData `json:"data"`
}
BrokerTaskDataListAllOf struct for BrokerTaskDataListAllOf
type BrokerTaskType ¶
type BrokerTaskType string
BrokerTaskType the model 'BrokerTaskType'
const ( BROKERTASKTYPE_ADD_BROKER BrokerTaskType = "add-broker" BROKERTASKTYPE_REMOVE_BROKER BrokerTaskType = "remove-broker" )
List of BrokerTaskType
type BrokerV3Api ¶ added in v0.3.8
type BrokerV3Api interface { /* * ClustersClusterIdBrokersBrokerIdDelete Delete Broker * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Deletes the broker that is specified by ``broker_id``. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param brokerId The Kafka broker ID. * @param optional nil or *ClustersClusterIdBrokersBrokerIdDeleteOpts - Optional Parameters: * @param "ShouldShutdown" (optional.Bool) - To shutdown the broker or not, Default: true * @return BrokerRemovalData */ ClustersClusterIdBrokersBrokerIdDelete(ctx _context.Context, clusterId string, brokerId int32, localVarOptionals *ClustersClusterIdBrokersBrokerIdDeleteOpts) (BrokerRemovalData, *_nethttp.Response, error) /* * ClustersClusterIdBrokersBrokerIdGet Get Broker * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Returns the broker specified by ``broker_id``. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param brokerId The Kafka broker ID. * @return BrokerData */ ClustersClusterIdBrokersBrokerIdGet(ctx _context.Context, clusterId string, brokerId int32) (BrokerData, *_nethttp.Response, error) /* * ClustersClusterIdBrokersBrokerIdPartitionReplicasGet Search Replicas by Broker * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Returns the list of replicas assigned to the specified broker. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param brokerId The Kafka broker ID. * @return ReplicaDataList */ ClustersClusterIdBrokersBrokerIdPartitionReplicasGet(ctx _context.Context, clusterId string, brokerId int32) (ReplicaDataList, *_nethttp.Response, error) /* * ClustersClusterIdBrokersGet List Brokers * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Return a list of brokers that belong to the specified Kafka cluster. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @return BrokerDataList */ ClustersClusterIdBrokersGet(ctx _context.Context, clusterId string) (BrokerDataList, *_nethttp.Response, error) }
type BrokerV3ApiService ¶ added in v0.3.8
type BrokerV3ApiService service
BrokerV3ApiService BrokerV3Api service
func (*BrokerV3ApiService) ClustersClusterIdBrokersBrokerIdDelete ¶ added in v0.3.8
func (a *BrokerV3ApiService) ClustersClusterIdBrokersBrokerIdDelete(ctx _context.Context, clusterId string, brokerId int32, localVarOptionals *ClustersClusterIdBrokersBrokerIdDeleteOpts) (BrokerRemovalData, *_nethttp.Response, error)
* ClustersClusterIdBrokersBrokerIdDelete Delete Broker * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Deletes the broker that is specified by ``broker_id``. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param brokerId The Kafka broker ID. * @param optional nil or *ClustersClusterIdBrokersBrokerIdDeleteOpts - Optional Parameters: * @param "ShouldShutdown" (optional.Bool) - To shutdown the broker or not, Default: true * @return BrokerRemovalData
func (*BrokerV3ApiService) ClustersClusterIdBrokersBrokerIdGet ¶ added in v0.3.8
func (a *BrokerV3ApiService) ClustersClusterIdBrokersBrokerIdGet(ctx _context.Context, clusterId string, brokerId int32) (BrokerData, *_nethttp.Response, error)
* ClustersClusterIdBrokersBrokerIdGet Get Broker * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Returns the broker specified by ``broker_id``. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param brokerId The Kafka broker ID. * @return BrokerData
func (*BrokerV3ApiService) ClustersClusterIdBrokersBrokerIdPartitionReplicasGet ¶ added in v0.3.8
func (a *BrokerV3ApiService) ClustersClusterIdBrokersBrokerIdPartitionReplicasGet(ctx _context.Context, clusterId string, brokerId int32) (ReplicaDataList, *_nethttp.Response, error)
* ClustersClusterIdBrokersBrokerIdPartitionReplicasGet Search Replicas by Broker * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Returns the list of replicas assigned to the specified broker. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param brokerId The Kafka broker ID. * @return ReplicaDataList
func (*BrokerV3ApiService) ClustersClusterIdBrokersGet ¶ added in v0.3.8
func (a *BrokerV3ApiService) ClustersClusterIdBrokersGet(ctx _context.Context, clusterId string) (BrokerDataList, *_nethttp.Response, error)
* ClustersClusterIdBrokersGet List Brokers * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Return a list of brokers that belong to the specified Kafka cluster. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @return BrokerDataList
type ClusterConfigData ¶
type ClusterConfigData struct { Kind string `json:"kind"` Metadata ResourceMetadata `json:"metadata"` ClusterId string `json:"cluster_id"` Name string `json:"name"` Value *string `json:"value,omitempty"` IsDefault bool `json:"is_default"` IsReadOnly bool `json:"is_read_only"` IsSensitive bool `json:"is_sensitive"` Source string `json:"source"` Synonyms []ConfigSynonymData `json:"synonyms"` ConfigType string `json:"config_type"` }
ClusterConfigData struct for ClusterConfigData
type ClusterConfigDataAllOf ¶
type ClusterConfigDataAllOf struct {
ConfigType string `json:"config_type"`
}
ClusterConfigDataAllOf struct for ClusterConfigDataAllOf
type ClusterConfigDataList ¶
type ClusterConfigDataList struct { Kind string `json:"kind"` Metadata ResourceCollectionMetadata `json:"metadata"` Data []ClusterConfigData `json:"data"` }
ClusterConfigDataList struct for ClusterConfigDataList
type ClusterConfigDataListAllOf ¶
type ClusterConfigDataListAllOf struct {
Data []ClusterConfigData `json:"data"`
}
ClusterConfigDataListAllOf struct for ClusterConfigDataListAllOf
type ClusterData ¶
type ClusterData struct { Kind string `json:"kind"` Metadata ResourceMetadata `json:"metadata"` ClusterId string `json:"cluster_id"` Controller Relationship `json:"controller,omitempty"` Acls Relationship `json:"acls"` Brokers Relationship `json:"brokers"` BrokerConfigs Relationship `json:"broker_configs"` ConsumerGroups Relationship `json:"consumer_groups"` Topics Relationship `json:"topics"` PartitionReassignments Relationship `json:"partition_reassignments"` }
ClusterData struct for ClusterData
type ClusterDataAllOf ¶
type ClusterDataAllOf struct { ClusterId string `json:"cluster_id"` Controller Relationship `json:"controller,omitempty"` Acls Relationship `json:"acls"` Brokers Relationship `json:"brokers"` BrokerConfigs Relationship `json:"broker_configs"` ConsumerGroups Relationship `json:"consumer_groups"` Topics Relationship `json:"topics"` PartitionReassignments Relationship `json:"partition_reassignments"` }
ClusterDataAllOf struct for ClusterDataAllOf
type ClusterDataList ¶
type ClusterDataList struct { Kind string `json:"kind"` Metadata ResourceCollectionMetadata `json:"metadata"` Data []ClusterData `json:"data"` }
ClusterDataList struct for ClusterDataList
type ClusterDataListAllOf ¶
type ClusterDataListAllOf struct {
Data []ClusterData `json:"data"`
}
ClusterDataListAllOf struct for ClusterDataListAllOf
type ClusterLinkingV3Api ¶ added in v0.3.8
type ClusterLinkingV3Api interface { /* * CreateKafkaLink Create a cluster link * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Cluster link creation requires source cluster security configurations in the configs JSON section of the data request payload. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param linkName The link name * @param optional nil or *CreateKafkaLinkOpts - Optional Parameters: * @param "ValidateOnly" (optional.Bool) - To validate the action can be performed successfully or not. Default: false * @param "ValidateLink" (optional.Bool) - To synchronously validate that the source cluster ID is expected and the dest cluster has the permission to read topics in the source cluster. Default: true * @param "CreateLinkRequestData" (optional.Interface of CreateLinkRequestData) - Create a cluster link */ CreateKafkaLink(ctx _context.Context, clusterId string, linkName string, localVarOptionals *CreateKafkaLinkOpts) (*_nethttp.Response, error) /* * CreateKafkaMirrorTopic Create a mirror topic * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Create a topic in the destination cluster mirroring a topic in the source cluster * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param linkName The link name * @param optional nil or *CreateKafkaMirrorTopicOpts - Optional Parameters: * @param "CreateMirrorTopicRequestData" (optional.Interface of CreateMirrorTopicRequestData) - Name and configs of the topics mirroring from and mirroring to */ CreateKafkaMirrorTopic(ctx _context.Context, clusterId string, linkName string, localVarOptionals *CreateKafkaMirrorTopicOpts) (*_nethttp.Response, error) /* * DeleteKafkaLink Delete the cluster link * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param linkName The link name * @param optional nil or *DeleteKafkaLinkOpts - Optional Parameters: * @param "Force" (optional.Bool) - Force the action. Default: false * @param "ValidateOnly" (optional.Bool) - To validate the action can be performed successfully or not. Default: false */ DeleteKafkaLink(ctx _context.Context, clusterId string, linkName string, localVarOptionals *DeleteKafkaLinkOpts) (*_nethttp.Response, error) /* * DeleteKafkaLinkConfig Reset the given config to default value * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param linkName The link name * @param configName The link config name */ DeleteKafkaLinkConfig(ctx _context.Context, clusterId string, linkName string, configName string) (*_nethttp.Response, error) /* * GetKafkaLink Describe the cluster link * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) ``link_id`` in ``ListLinksResponseData`` is deprecated and may be removed in a future release. Use the new ``cluster_link_id`` instead. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param linkName The link name * @param optional nil or *GetKafkaLinkOpts - Optional Parameters: * @param "IncludeTasks" (optional.Bool) - Whether to include cluster linking tasks in the response. Default: false * @return ListLinksResponseData */ GetKafkaLink(ctx _context.Context, clusterId string, linkName string, localVarOptionals *GetKafkaLinkOpts) (ListLinksResponseData, *_nethttp.Response, error) /* * GetKafkaLinkConfigs Describe the config under the cluster link * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param linkName The link name * @param configName The link config name * @return ListLinkConfigsResponseData */ GetKafkaLinkConfigs(ctx _context.Context, clusterId string, linkName string, configName string) (ListLinkConfigsResponseData, *_nethttp.Response, error) /* * ListKafkaLinkConfigs List all configs of the cluster link * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param linkName The link name * @return ListLinkConfigsResponseDataList */ ListKafkaLinkConfigs(ctx _context.Context, clusterId string, linkName string) (ListLinkConfigsResponseDataList, *_nethttp.Response, error) /* * ListKafkaLinks List all cluster links in the dest cluster * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) ``link_id`` in ``ListLinksResponseData`` is deprecated and may be removed in a future release. Use the new ``cluster_link_id`` instead. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @return ListLinksResponseDataList */ ListKafkaLinks(ctx _context.Context, clusterId string) (ListLinksResponseDataList, *_nethttp.Response, error) /* * ListKafkaMirrorTopics List mirror topics * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) List all mirror topics in the cluster * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param optional nil or *ListKafkaMirrorTopicsOpts - Optional Parameters: * @param "MirrorStatus" (optional.Interface of MirrorTopicStatus) - The status of the mirror topic. If not specified, all mirror topics will be returned. * @return ListMirrorTopicsResponseDataList */ ListKafkaMirrorTopics(ctx _context.Context, clusterId string, localVarOptionals *ListKafkaMirrorTopicsOpts) (ListMirrorTopicsResponseDataList, *_nethttp.Response, error) /* * ListKafkaMirrorTopicsUnderLink List mirror topics * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) List all mirror topics under the link * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param linkName The link name * @param optional nil or *ListKafkaMirrorTopicsUnderLinkOpts - Optional Parameters: * @param "MirrorStatus" (optional.Interface of MirrorTopicStatus) - The status of the mirror topic. If not specified, all mirror topics will be returned. * @return ListMirrorTopicsResponseDataList */ ListKafkaMirrorTopicsUnderLink(ctx _context.Context, clusterId string, linkName string, localVarOptionals *ListKafkaMirrorTopicsUnderLinkOpts) (ListMirrorTopicsResponseDataList, *_nethttp.Response, error) /* * ReadKafkaMirrorTopic Describe the mirror topic * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param linkName The link name * @param mirrorTopicName Cluster Linking mirror topic name * @param optional nil or *ReadKafkaMirrorTopicOpts - Optional Parameters: * @param "IncludeStateTransitionErrors" (optional.Bool) - Whether to include mirror state transition errors in the response. Default: false * @return ListMirrorTopicsResponseData */ ReadKafkaMirrorTopic(ctx _context.Context, clusterId string, linkName string, mirrorTopicName string, localVarOptionals *ReadKafkaMirrorTopicOpts) (ListMirrorTopicsResponseData, *_nethttp.Response, error) /* * UpdateKafkaLinkConfig Alter the config under the cluster link * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param linkName The link name * @param configName The link config name * @param optional nil or *UpdateKafkaLinkConfigOpts - Optional Parameters: * @param "UpdateLinkConfigRequestData" (optional.Interface of UpdateLinkConfigRequestData) - Link config value to update */ UpdateKafkaLinkConfig(ctx _context.Context, clusterId string, linkName string, configName string, localVarOptionals *UpdateKafkaLinkConfigOpts) (*_nethttp.Response, error) /* * UpdateKafkaLinkConfigBatch Batch Alter Cluster Link Configs * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Batch Alter Cluster Link Configs * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param linkName The link name * @param optional nil or *UpdateKafkaLinkConfigBatchOpts - Optional Parameters: * @param "ValidateOnly" (optional.Bool) - To validate the action can be performed successfully or not. Default: false * @param "AlterConfigBatchRequestData" (optional.Interface of AlterConfigBatchRequestData) - */ UpdateKafkaLinkConfigBatch(ctx _context.Context, clusterId string, linkName string, localVarOptionals *UpdateKafkaLinkConfigBatchOpts) (*_nethttp.Response, error) /* * UpdateKafkaMirrorTopicsFailover Failover the mirror topics * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param linkName The link name * @param optional nil or *UpdateKafkaMirrorTopicsFailoverOpts - Optional Parameters: * @param "ValidateOnly" (optional.Bool) - To validate the action can be performed successfully or not. Default: false * @param "AlterMirrorsRequestData" (optional.Interface of AlterMirrorsRequestData) - Mirror topics to be altered. * @return AlterMirrorStatusResponseDataList */ UpdateKafkaMirrorTopicsFailover(ctx _context.Context, clusterId string, linkName string, localVarOptionals *UpdateKafkaMirrorTopicsFailoverOpts) (AlterMirrorStatusResponseDataList, *_nethttp.Response, error) /* * UpdateKafkaMirrorTopicsPause Pause the mirror topics * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param linkName The link name * @param optional nil or *UpdateKafkaMirrorTopicsPauseOpts - Optional Parameters: * @param "ValidateOnly" (optional.Bool) - To validate the action can be performed successfully or not. Default: false * @param "AlterMirrorsRequestData" (optional.Interface of AlterMirrorsRequestData) - Mirror topics to be altered. * @return AlterMirrorStatusResponseDataList */ UpdateKafkaMirrorTopicsPause(ctx _context.Context, clusterId string, linkName string, localVarOptionals *UpdateKafkaMirrorTopicsPauseOpts) (AlterMirrorStatusResponseDataList, *_nethttp.Response, error) /* * UpdateKafkaMirrorTopicsPromote Promote the mirror topics * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param linkName The link name * @param optional nil or *UpdateKafkaMirrorTopicsPromoteOpts - Optional Parameters: * @param "ValidateOnly" (optional.Bool) - To validate the action can be performed successfully or not. Default: false * @param "AlterMirrorsRequestData" (optional.Interface of AlterMirrorsRequestData) - Mirror topics to be altered. * @return AlterMirrorStatusResponseDataList */ UpdateKafkaMirrorTopicsPromote(ctx _context.Context, clusterId string, linkName string, localVarOptionals *UpdateKafkaMirrorTopicsPromoteOpts) (AlterMirrorStatusResponseDataList, *_nethttp.Response, error) /* * UpdateKafkaMirrorTopicsResume Resume the mirror topics * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param linkName The link name * @param optional nil or *UpdateKafkaMirrorTopicsResumeOpts - Optional Parameters: * @param "ValidateOnly" (optional.Bool) - To validate the action can be performed successfully or not. Default: false * @param "AlterMirrorsRequestData" (optional.Interface of AlterMirrorsRequestData) - Mirror topics to be altered. * @return AlterMirrorStatusResponseDataList */ UpdateKafkaMirrorTopicsResume(ctx _context.Context, clusterId string, linkName string, localVarOptionals *UpdateKafkaMirrorTopicsResumeOpts) (AlterMirrorStatusResponseDataList, *_nethttp.Response, error) /* * UpdateKafkaMirrorTopicsReverseAndPauseMirror Reverse local mirror topic and pause the remote mirror topic * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param linkName The link name * @param optional nil or *UpdateKafkaMirrorTopicsReverseAndPauseMirrorOpts - Optional Parameters: * @param "ValidateOnly" (optional.Bool) - To validate the action can be performed successfully or not. Default: false * @param "AlterMirrorsRequestData" (optional.Interface of AlterMirrorsRequestData) - Mirror topics to be altered. * @return AlterMirrorStatusResponseDataList */ UpdateKafkaMirrorTopicsReverseAndPauseMirror(ctx _context.Context, clusterId string, linkName string, localVarOptionals *UpdateKafkaMirrorTopicsReverseAndPauseMirrorOpts) (AlterMirrorStatusResponseDataList, *_nethttp.Response, error) /* * UpdateKafkaMirrorTopicsReverseAndStarMirror Reverse local mirror topic and start the remote mirror topic * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param linkName The link name * @param optional nil or *UpdateKafkaMirrorTopicsReverseAndStarMirrorOpts - Optional Parameters: * @param "ValidateOnly" (optional.Bool) - To validate the action can be performed successfully or not. Default: false * @param "AlterMirrorsRequestData" (optional.Interface of AlterMirrorsRequestData) - Mirror topics to be altered. * @return AlterMirrorStatusResponseDataList */ UpdateKafkaMirrorTopicsReverseAndStarMirror(ctx _context.Context, clusterId string, linkName string, localVarOptionals *UpdateKafkaMirrorTopicsReverseAndStarMirrorOpts) (AlterMirrorStatusResponseDataList, *_nethttp.Response, error) }
type ClusterLinkingV3ApiService ¶ added in v0.3.8
type ClusterLinkingV3ApiService service
ClusterLinkingV3ApiService ClusterLinkingV3Api service
func (*ClusterLinkingV3ApiService) CreateKafkaLink ¶ added in v0.3.8
func (a *ClusterLinkingV3ApiService) CreateKafkaLink(ctx _context.Context, clusterId string, linkName string, localVarOptionals *CreateKafkaLinkOpts) (*_nethttp.Response, error)
* CreateKafkaLink Create a cluster link * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Cluster link creation requires source cluster security configurations in the configs JSON section of the data request payload. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param linkName The link name * @param optional nil or *CreateKafkaLinkOpts - Optional Parameters: * @param "ValidateOnly" (optional.Bool) - To validate the action can be performed successfully or not. Default: false * @param "ValidateLink" (optional.Bool) - To synchronously validate that the source cluster ID is expected and the dest cluster has the permission to read topics in the source cluster. Default: true * @param "CreateLinkRequestData" (optional.Interface of CreateLinkRequestData) - Create a cluster link
func (*ClusterLinkingV3ApiService) CreateKafkaMirrorTopic ¶ added in v0.3.8
func (a *ClusterLinkingV3ApiService) CreateKafkaMirrorTopic(ctx _context.Context, clusterId string, linkName string, localVarOptionals *CreateKafkaMirrorTopicOpts) (*_nethttp.Response, error)
* CreateKafkaMirrorTopic Create a mirror topic * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Create a topic in the destination cluster mirroring a topic in the source cluster * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param linkName The link name * @param optional nil or *CreateKafkaMirrorTopicOpts - Optional Parameters: * @param "CreateMirrorTopicRequestData" (optional.Interface of CreateMirrorTopicRequestData) - Name and configs of the topics mirroring from and mirroring to
func (*ClusterLinkingV3ApiService) DeleteKafkaLink ¶ added in v0.3.8
func (a *ClusterLinkingV3ApiService) DeleteKafkaLink(ctx _context.Context, clusterId string, linkName string, localVarOptionals *DeleteKafkaLinkOpts) (*_nethttp.Response, error)
* DeleteKafkaLink Delete the cluster link * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param linkName The link name * @param optional nil or *DeleteKafkaLinkOpts - Optional Parameters: * @param "Force" (optional.Bool) - Force the action. Default: false * @param "ValidateOnly" (optional.Bool) - To validate the action can be performed successfully or not. Default: false
func (*ClusterLinkingV3ApiService) DeleteKafkaLinkConfig ¶ added in v0.3.8
func (a *ClusterLinkingV3ApiService) DeleteKafkaLinkConfig(ctx _context.Context, clusterId string, linkName string, configName string) (*_nethttp.Response, error)
* DeleteKafkaLinkConfig Reset the given config to default value * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param linkName The link name * @param configName The link config name
func (*ClusterLinkingV3ApiService) GetKafkaLink ¶ added in v0.3.8
func (a *ClusterLinkingV3ApiService) GetKafkaLink(ctx _context.Context, clusterId string, linkName string, localVarOptionals *GetKafkaLinkOpts) (ListLinksResponseData, *_nethttp.Response, error)
* GetKafkaLink Describe the cluster link * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) ``link_id`` in ``ListLinksResponseData`` is deprecated and may be removed in a future release. Use the new ``cluster_link_id`` instead. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param linkName The link name * @param optional nil or *GetKafkaLinkOpts - Optional Parameters: * @param "IncludeTasks" (optional.Bool) - Whether to include cluster linking tasks in the response. Default: false * @return ListLinksResponseData
func (*ClusterLinkingV3ApiService) GetKafkaLinkConfigs ¶ added in v0.3.8
func (a *ClusterLinkingV3ApiService) GetKafkaLinkConfigs(ctx _context.Context, clusterId string, linkName string, configName string) (ListLinkConfigsResponseData, *_nethttp.Response, error)
* GetKafkaLinkConfigs Describe the config under the cluster link * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param linkName The link name * @param configName The link config name * @return ListLinkConfigsResponseData
func (*ClusterLinkingV3ApiService) ListKafkaLinkConfigs ¶ added in v0.3.8
func (a *ClusterLinkingV3ApiService) ListKafkaLinkConfigs(ctx _context.Context, clusterId string, linkName string) (ListLinkConfigsResponseDataList, *_nethttp.Response, error)
* ListKafkaLinkConfigs List all configs of the cluster link * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param linkName The link name * @return ListLinkConfigsResponseDataList
func (*ClusterLinkingV3ApiService) ListKafkaLinks ¶ added in v0.3.8
func (a *ClusterLinkingV3ApiService) ListKafkaLinks(ctx _context.Context, clusterId string) (ListLinksResponseDataList, *_nethttp.Response, error)
* ListKafkaLinks List all cluster links in the dest cluster * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) ``link_id`` in ``ListLinksResponseData`` is deprecated and may be removed in a future release. Use the new ``cluster_link_id`` instead. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @return ListLinksResponseDataList
func (*ClusterLinkingV3ApiService) ListKafkaMirrorTopics ¶ added in v0.3.8
func (a *ClusterLinkingV3ApiService) ListKafkaMirrorTopics(ctx _context.Context, clusterId string, localVarOptionals *ListKafkaMirrorTopicsOpts) (ListMirrorTopicsResponseDataList, *_nethttp.Response, error)
* ListKafkaMirrorTopics List mirror topics * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) List all mirror topics in the cluster * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param optional nil or *ListKafkaMirrorTopicsOpts - Optional Parameters: * @param "MirrorStatus" (optional.Interface of MirrorTopicStatus) - The status of the mirror topic. If not specified, all mirror topics will be returned. * @return ListMirrorTopicsResponseDataList
func (*ClusterLinkingV3ApiService) ListKafkaMirrorTopicsUnderLink ¶ added in v0.3.8
func (a *ClusterLinkingV3ApiService) ListKafkaMirrorTopicsUnderLink(ctx _context.Context, clusterId string, linkName string, localVarOptionals *ListKafkaMirrorTopicsUnderLinkOpts) (ListMirrorTopicsResponseDataList, *_nethttp.Response, error)
* ListKafkaMirrorTopicsUnderLink List mirror topics * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) List all mirror topics under the link * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param linkName The link name * @param optional nil or *ListKafkaMirrorTopicsUnderLinkOpts - Optional Parameters: * @param "MirrorStatus" (optional.Interface of MirrorTopicStatus) - The status of the mirror topic. If not specified, all mirror topics will be returned. * @return ListMirrorTopicsResponseDataList
func (*ClusterLinkingV3ApiService) ReadKafkaMirrorTopic ¶ added in v0.3.8
func (a *ClusterLinkingV3ApiService) ReadKafkaMirrorTopic(ctx _context.Context, clusterId string, linkName string, mirrorTopicName string, localVarOptionals *ReadKafkaMirrorTopicOpts) (ListMirrorTopicsResponseData, *_nethttp.Response, error)
* ReadKafkaMirrorTopic Describe the mirror topic * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param linkName The link name * @param mirrorTopicName Cluster Linking mirror topic name * @param optional nil or *ReadKafkaMirrorTopicOpts - Optional Parameters: * @param "IncludeStateTransitionErrors" (optional.Bool) - Whether to include mirror state transition errors in the response. Default: false * @return ListMirrorTopicsResponseData
func (*ClusterLinkingV3ApiService) UpdateKafkaLinkConfig ¶ added in v0.3.8
func (a *ClusterLinkingV3ApiService) UpdateKafkaLinkConfig(ctx _context.Context, clusterId string, linkName string, configName string, localVarOptionals *UpdateKafkaLinkConfigOpts) (*_nethttp.Response, error)
* UpdateKafkaLinkConfig Alter the config under the cluster link * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param linkName The link name * @param configName The link config name * @param optional nil or *UpdateKafkaLinkConfigOpts - Optional Parameters: * @param "UpdateLinkConfigRequestData" (optional.Interface of UpdateLinkConfigRequestData) - Link config value to update
func (*ClusterLinkingV3ApiService) UpdateKafkaLinkConfigBatch ¶ added in v0.3.8
func (a *ClusterLinkingV3ApiService) UpdateKafkaLinkConfigBatch(ctx _context.Context, clusterId string, linkName string, localVarOptionals *UpdateKafkaLinkConfigBatchOpts) (*_nethttp.Response, error)
* UpdateKafkaLinkConfigBatch Batch Alter Cluster Link Configs * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Batch Alter Cluster Link Configs * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param linkName The link name * @param optional nil or *UpdateKafkaLinkConfigBatchOpts - Optional Parameters: * @param "ValidateOnly" (optional.Bool) - To validate the action can be performed successfully or not. Default: false * @param "AlterConfigBatchRequestData" (optional.Interface of AlterConfigBatchRequestData) -
func (*ClusterLinkingV3ApiService) UpdateKafkaMirrorTopicsFailover ¶ added in v0.3.8
func (a *ClusterLinkingV3ApiService) UpdateKafkaMirrorTopicsFailover(ctx _context.Context, clusterId string, linkName string, localVarOptionals *UpdateKafkaMirrorTopicsFailoverOpts) (AlterMirrorStatusResponseDataList, *_nethttp.Response, error)
* UpdateKafkaMirrorTopicsFailover Failover the mirror topics * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param linkName The link name * @param optional nil or *UpdateKafkaMirrorTopicsFailoverOpts - Optional Parameters: * @param "ValidateOnly" (optional.Bool) - To validate the action can be performed successfully or not. Default: false * @param "AlterMirrorsRequestData" (optional.Interface of AlterMirrorsRequestData) - Mirror topics to be altered. * @return AlterMirrorStatusResponseDataList
func (*ClusterLinkingV3ApiService) UpdateKafkaMirrorTopicsPause ¶ added in v0.3.8
func (a *ClusterLinkingV3ApiService) UpdateKafkaMirrorTopicsPause(ctx _context.Context, clusterId string, linkName string, localVarOptionals *UpdateKafkaMirrorTopicsPauseOpts) (AlterMirrorStatusResponseDataList, *_nethttp.Response, error)
* UpdateKafkaMirrorTopicsPause Pause the mirror topics * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param linkName The link name * @param optional nil or *UpdateKafkaMirrorTopicsPauseOpts - Optional Parameters: * @param "ValidateOnly" (optional.Bool) - To validate the action can be performed successfully or not. Default: false * @param "AlterMirrorsRequestData" (optional.Interface of AlterMirrorsRequestData) - Mirror topics to be altered. * @return AlterMirrorStatusResponseDataList
func (*ClusterLinkingV3ApiService) UpdateKafkaMirrorTopicsPromote ¶ added in v0.3.8
func (a *ClusterLinkingV3ApiService) UpdateKafkaMirrorTopicsPromote(ctx _context.Context, clusterId string, linkName string, localVarOptionals *UpdateKafkaMirrorTopicsPromoteOpts) (AlterMirrorStatusResponseDataList, *_nethttp.Response, error)
* UpdateKafkaMirrorTopicsPromote Promote the mirror topics * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param linkName The link name * @param optional nil or *UpdateKafkaMirrorTopicsPromoteOpts - Optional Parameters: * @param "ValidateOnly" (optional.Bool) - To validate the action can be performed successfully or not. Default: false * @param "AlterMirrorsRequestData" (optional.Interface of AlterMirrorsRequestData) - Mirror topics to be altered. * @return AlterMirrorStatusResponseDataList
func (*ClusterLinkingV3ApiService) UpdateKafkaMirrorTopicsResume ¶ added in v0.3.8
func (a *ClusterLinkingV3ApiService) UpdateKafkaMirrorTopicsResume(ctx _context.Context, clusterId string, linkName string, localVarOptionals *UpdateKafkaMirrorTopicsResumeOpts) (AlterMirrorStatusResponseDataList, *_nethttp.Response, error)
* UpdateKafkaMirrorTopicsResume Resume the mirror topics * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param linkName The link name * @param optional nil or *UpdateKafkaMirrorTopicsResumeOpts - Optional Parameters: * @param "ValidateOnly" (optional.Bool) - To validate the action can be performed successfully or not. Default: false * @param "AlterMirrorsRequestData" (optional.Interface of AlterMirrorsRequestData) - Mirror topics to be altered. * @return AlterMirrorStatusResponseDataList
func (*ClusterLinkingV3ApiService) UpdateKafkaMirrorTopicsReverseAndPauseMirror ¶ added in v0.3.18
func (a *ClusterLinkingV3ApiService) UpdateKafkaMirrorTopicsReverseAndPauseMirror(ctx _context.Context, clusterId string, linkName string, localVarOptionals *UpdateKafkaMirrorTopicsReverseAndPauseMirrorOpts) (AlterMirrorStatusResponseDataList, *_nethttp.Response, error)
* UpdateKafkaMirrorTopicsReverseAndPauseMirror Reverse local mirror topic and pause the remote mirror topic * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param linkName The link name * @param optional nil or *UpdateKafkaMirrorTopicsReverseAndPauseMirrorOpts - Optional Parameters: * @param "ValidateOnly" (optional.Bool) - To validate the action can be performed successfully or not. Default: false * @param "AlterMirrorsRequestData" (optional.Interface of AlterMirrorsRequestData) - Mirror topics to be altered. * @return AlterMirrorStatusResponseDataList
func (*ClusterLinkingV3ApiService) UpdateKafkaMirrorTopicsReverseAndStarMirror ¶ added in v0.3.18
func (a *ClusterLinkingV3ApiService) UpdateKafkaMirrorTopicsReverseAndStarMirror(ctx _context.Context, clusterId string, linkName string, localVarOptionals *UpdateKafkaMirrorTopicsReverseAndStarMirrorOpts) (AlterMirrorStatusResponseDataList, *_nethttp.Response, error)
* UpdateKafkaMirrorTopicsReverseAndStarMirror Reverse local mirror topic and start the remote mirror topic * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param linkName The link name * @param optional nil or *UpdateKafkaMirrorTopicsReverseAndStarMirrorOpts - Optional Parameters: * @param "ValidateOnly" (optional.Bool) - To validate the action can be performed successfully or not. Default: false * @param "AlterMirrorsRequestData" (optional.Interface of AlterMirrorsRequestData) - Mirror topics to be altered. * @return AlterMirrorStatusResponseDataList
type ClusterV3Api ¶ added in v0.3.8
type ClusterV3Api interface { /* * ClustersGet List Clusters * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) 'Returns a list of known Kafka clusters. Currently both Kafka and Kafka REST Proxy are only aware of the Kafka cluster pointed at by the ``bootstrap.servers`` configuration. Therefore only one Kafka cluster will be returned in the response.' * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @return ClusterDataList */ ClustersGet(ctx _context.Context) (ClusterDataList, *_nethttp.Response, error) /* * GetKafkaCluster Get Cluster * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Returns the Kafka cluster with the specified ``cluster_id``. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @return ClusterData */ GetKafkaCluster(ctx _context.Context, clusterId string) (ClusterData, *_nethttp.Response, error) }
type ClusterV3ApiService ¶ added in v0.3.8
type ClusterV3ApiService service
ClusterV3ApiService ClusterV3Api service
func (*ClusterV3ApiService) ClustersGet ¶ added in v0.3.8
func (a *ClusterV3ApiService) ClustersGet(ctx _context.Context) (ClusterDataList, *_nethttp.Response, error)
* ClustersGet List Clusters * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) 'Returns a list of known Kafka clusters. Currently both Kafka and Kafka REST Proxy are only aware of the Kafka cluster pointed at by the ``bootstrap.servers`` configuration. Therefore only one Kafka cluster will be returned in the response.' * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @return ClusterDataList
func (*ClusterV3ApiService) GetKafkaCluster ¶ added in v0.3.8
func (a *ClusterV3ApiService) GetKafkaCluster(ctx _context.Context, clusterId string) (ClusterData, *_nethttp.Response, error)
* GetKafkaCluster Get Cluster * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Returns the Kafka cluster with the specified ``cluster_id``. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @return ClusterData
type ClustersClusterIdBrokerReplicaExclusionscreatePostOpts ¶ added in v0.3.8
type ClustersClusterIdBrokerReplicaExclusionscreatePostOpts struct {
BrokerReplicaExclusionBatchRequestData optional.Interface
}
ClustersClusterIdBrokerReplicaExclusionscreatePostOpts Optional parameters for the method 'ClustersClusterIdBrokerReplicaExclusionscreatePost'
type ClustersClusterIdBrokerReplicaExclusionsdeletePostOpts ¶ added in v0.3.8
type ClustersClusterIdBrokerReplicaExclusionsdeletePostOpts struct {
BrokerReplicaExclusionBatchRequestData optional.Interface
}
ClustersClusterIdBrokerReplicaExclusionsdeletePostOpts Optional parameters for the method 'ClustersClusterIdBrokerReplicaExclusionsdeletePost'
type ClustersClusterIdBrokersBrokerIdConfigsNamePutOpts ¶
type ClustersClusterIdBrokersBrokerIdConfigsNamePutOpts struct {
UpdateConfigRequestData optional.Interface
}
ClustersClusterIdBrokersBrokerIdConfigsNamePutOpts Optional parameters for the method 'ClustersClusterIdBrokersBrokerIdConfigsNamePut'
type ClustersClusterIdBrokersBrokerIdConfigsalterPostOpts ¶
type ClustersClusterIdBrokersBrokerIdConfigsalterPostOpts struct {
AlterConfigBatchRequestData optional.Interface
}
ClustersClusterIdBrokersBrokerIdConfigsalterPostOpts Optional parameters for the method 'ClustersClusterIdBrokersBrokerIdConfigsalterPost'
type ClustersClusterIdBrokersBrokerIdDeleteOpts ¶
ClustersClusterIdBrokersBrokerIdDeleteOpts Optional parameters for the method 'ClustersClusterIdBrokersBrokerIdDelete'
type ClustersClusterIdBrokersdeletePostOpts ¶
type ClustersClusterIdBrokersdeletePostOpts struct { ShouldShutdown optional.Bool RemoveBrokersRequestData optional.Interface }
ClustersClusterIdBrokersdeletePostOpts Optional parameters for the method 'ClustersClusterIdBrokersdeletePost'
type ClustersClusterIdTopicsTopicNameRecordsPostOpts ¶ added in v0.3.8
ClustersClusterIdTopicsTopicNameRecordsPostOpts Optional parameters for the method 'ClustersClusterIdTopicsTopicNameRecordsPost'
type ConfigData ¶
ConfigData struct for ConfigData
type ConfigSynonymData ¶
type ConfigSynonymData struct { Name string `json:"name"` Value *string `json:"value,omitempty"` Source string `json:"source"` }
ConfigSynonymData struct for ConfigSynonymData
type ConfigsV3Api ¶ added in v0.3.8
type ConfigsV3Api interface { /* * ClustersClusterIdBrokersBrokerIdConfigsGet List Broker Configs * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Return the list of configuration parameters that belong to the specified Kafka broker. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param brokerId The Kafka broker ID. * @return BrokerConfigDataList */ ClustersClusterIdBrokersBrokerIdConfigsGet(ctx _context.Context, clusterId string, brokerId int32) (BrokerConfigDataList, *_nethttp.Response, error) /* * ClustersClusterIdBrokersBrokerIdConfigsNameDelete Reset Broker Config * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Resets the configuration parameter specified by ``name`` to its default value. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param brokerId The Kafka broker ID. * @param name The configuration parameter name. */ ClustersClusterIdBrokersBrokerIdConfigsNameDelete(ctx _context.Context, clusterId string, brokerId int32, name string) (*_nethttp.Response, error) /* * ClustersClusterIdBrokersBrokerIdConfigsNameGet Get Broker Config * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Return the configuration parameter specified by ``name``. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param brokerId The Kafka broker ID. * @param name The configuration parameter name. * @return BrokerConfigData */ ClustersClusterIdBrokersBrokerIdConfigsNameGet(ctx _context.Context, clusterId string, brokerId int32, name string) (BrokerConfigData, *_nethttp.Response, error) /* * ClustersClusterIdBrokersBrokerIdConfigsNamePut Update Broker Config * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Updates the configuration parameter specified by ``name``. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param brokerId The Kafka broker ID. * @param name The configuration parameter name. * @param optional nil or *ClustersClusterIdBrokersBrokerIdConfigsNamePutOpts - Optional Parameters: * @param "UpdateConfigRequestData" (optional.Interface of UpdateConfigRequestData) - The broker configuration parameter update request. */ ClustersClusterIdBrokersBrokerIdConfigsNamePut(ctx _context.Context, clusterId string, brokerId int32, name string, localVarOptionals *ClustersClusterIdBrokersBrokerIdConfigsNamePutOpts) (*_nethttp.Response, error) /* * ClustersClusterIdBrokersBrokerIdConfigsalterPost Batch Alter Broker Configs * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Updates or deletes a set of broker configuration parameters. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param brokerId The Kafka broker ID. * @param optional nil or *ClustersClusterIdBrokersBrokerIdConfigsalterPostOpts - Optional Parameters: * @param "AlterConfigBatchRequestData" (optional.Interface of AlterConfigBatchRequestData) - The alter broker configuration parameter batch request. */ ClustersClusterIdBrokersBrokerIdConfigsalterPost(ctx _context.Context, clusterId string, brokerId int32, localVarOptionals *ClustersClusterIdBrokersBrokerIdConfigsalterPostOpts) (*_nethttp.Response, error) /* * ClustersClusterIdBrokersConfigsGet List All Broker Configs * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Return the list of configuration parameters for all the brokers in the given Kafka cluster. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @return BrokerConfigDataList */ ClustersClusterIdBrokersConfigsGet(ctx _context.Context, clusterId string) (BrokerConfigDataList, *_nethttp.Response, error) /* * DeleteKafkaClusterConfig Reset Cluster Config * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Resets the configuration parameter specified by ``name`` to its default value. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param name The configuration parameter name. */ DeleteKafkaClusterConfig(ctx _context.Context, clusterId string, name string) (*_nethttp.Response, error) /* * DeleteKafkaTopicConfig Reset Topic Config * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Resets the config with given `name` to its default value. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param topicName The topic name. * @param name The configuration parameter name. */ DeleteKafkaTopicConfig(ctx _context.Context, clusterId string, topicName string, name string) (*_nethttp.Response, error) /* * GetKafkaClusterConfig Get Cluster Config * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Returns the configuration parameter specified by ``name``. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param name The configuration parameter name. * @return ClusterConfigData */ GetKafkaClusterConfig(ctx _context.Context, clusterId string, name string) (ClusterConfigData, *_nethttp.Response, error) /* * GetKafkaTopicConfig Get Topic Config * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Return the config with the given `name`. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param topicName The topic name. * @param name The configuration parameter name. * @return TopicConfigData */ GetKafkaTopicConfig(ctx _context.Context, clusterId string, topicName string, name string) (TopicConfigData, *_nethttp.Response, error) /* * ListKafkaAllTopicConfigs Get All Topic Configs * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Returns all topic configurations for topics hosted by the specified cluster. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @return TopicConfigDataList */ ListKafkaAllTopicConfigs(ctx _context.Context, clusterId string) (TopicConfigDataList, *_nethttp.Response, error) /* * ListKafkaClusterConfigs List Cluster Configs * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Returns a list of configuration parameters for the specified Kafka cluster. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @return ClusterConfigDataList */ ListKafkaClusterConfigs(ctx _context.Context, clusterId string) (ClusterConfigDataList, *_nethttp.Response, error) /* * ListKafkaDefaultTopicConfigs List Default Topic Configs * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param topicName The topic name. * @return TopicConfigDataList */ ListKafkaDefaultTopicConfigs(ctx _context.Context, clusterId string, topicName string) (TopicConfigDataList, *_nethttp.Response, error) /* * ListKafkaTopicConfigs List Topic Configs * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Return the list of configs that belong to the specified topic. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param topicName The topic name. * @return TopicConfigDataList */ ListKafkaTopicConfigs(ctx _context.Context, clusterId string, topicName string) (TopicConfigDataList, *_nethttp.Response, error) /* * UpdateKafkaClusterConfig Update Cluster Config * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Updates the configuration parameter specified by ``name``. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param name The configuration parameter name. * @param optional nil or *UpdateKafkaClusterConfigOpts - Optional Parameters: * @param "UpdateConfigRequestData" (optional.Interface of UpdateConfigRequestData) - The cluster configuration parameter update request. */ UpdateKafkaClusterConfig(ctx _context.Context, clusterId string, name string, localVarOptionals *UpdateKafkaClusterConfigOpts) (*_nethttp.Response, error) /* * UpdateKafkaClusterConfigs Batch Alter Cluster Configs * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Updates or deletes a set of Kafka cluster configuration parameters. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param optional nil or *UpdateKafkaClusterConfigsOpts - Optional Parameters: * @param "AlterConfigBatchRequestData" (optional.Interface of AlterConfigBatchRequestData) - The alter cluster configuration parameter batch request. */ UpdateKafkaClusterConfigs(ctx _context.Context, clusterId string, localVarOptionals *UpdateKafkaClusterConfigsOpts) (*_nethttp.Response, error) /* * UpdateKafkaTopicConfig Update Topic Config * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Updates the config with given `name`. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param topicName The topic name. * @param name The configuration parameter name. * @param optional nil or *UpdateKafkaTopicConfigOpts - Optional Parameters: * @param "UpdateConfigRequestData" (optional.Interface of UpdateConfigRequestData) - The topic configuration parameter update request. */ UpdateKafkaTopicConfig(ctx _context.Context, clusterId string, topicName string, name string, localVarOptionals *UpdateKafkaTopicConfigOpts) (*_nethttp.Response, error) /* * UpdateKafkaTopicConfigBatch Batch Alter Topic Configs * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Updates or deletes a set of topic configs. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param topicName The topic name. * @param optional nil or *UpdateKafkaTopicConfigBatchOpts - Optional Parameters: * @param "AlterConfigBatchRequestData" (optional.Interface of AlterConfigBatchRequestData) - The alter topic configuration parameter batch request. */ UpdateKafkaTopicConfigBatch(ctx _context.Context, clusterId string, topicName string, localVarOptionals *UpdateKafkaTopicConfigBatchOpts) (*_nethttp.Response, error) }
type ConfigsV3ApiService ¶ added in v0.3.8
type ConfigsV3ApiService service
ConfigsV3ApiService ConfigsV3Api service
func (*ConfigsV3ApiService) ClustersClusterIdBrokersBrokerIdConfigsGet ¶ added in v0.3.8
func (a *ConfigsV3ApiService) ClustersClusterIdBrokersBrokerIdConfigsGet(ctx _context.Context, clusterId string, brokerId int32) (BrokerConfigDataList, *_nethttp.Response, error)
* ClustersClusterIdBrokersBrokerIdConfigsGet List Broker Configs * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Return the list of configuration parameters that belong to the specified Kafka broker. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param brokerId The Kafka broker ID. * @return BrokerConfigDataList
func (*ConfigsV3ApiService) ClustersClusterIdBrokersBrokerIdConfigsNameDelete ¶ added in v0.3.8
func (a *ConfigsV3ApiService) ClustersClusterIdBrokersBrokerIdConfigsNameDelete(ctx _context.Context, clusterId string, brokerId int32, name string) (*_nethttp.Response, error)
* ClustersClusterIdBrokersBrokerIdConfigsNameDelete Reset Broker Config * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Resets the configuration parameter specified by ``name`` to its default value. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param brokerId The Kafka broker ID. * @param name The configuration parameter name.
func (*ConfigsV3ApiService) ClustersClusterIdBrokersBrokerIdConfigsNameGet ¶ added in v0.3.8
func (a *ConfigsV3ApiService) ClustersClusterIdBrokersBrokerIdConfigsNameGet(ctx _context.Context, clusterId string, brokerId int32, name string) (BrokerConfigData, *_nethttp.Response, error)
* ClustersClusterIdBrokersBrokerIdConfigsNameGet Get Broker Config * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Return the configuration parameter specified by ``name``. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param brokerId The Kafka broker ID. * @param name The configuration parameter name. * @return BrokerConfigData
func (*ConfigsV3ApiService) ClustersClusterIdBrokersBrokerIdConfigsNamePut ¶ added in v0.3.8
func (a *ConfigsV3ApiService) ClustersClusterIdBrokersBrokerIdConfigsNamePut(ctx _context.Context, clusterId string, brokerId int32, name string, localVarOptionals *ClustersClusterIdBrokersBrokerIdConfigsNamePutOpts) (*_nethttp.Response, error)
* ClustersClusterIdBrokersBrokerIdConfigsNamePut Update Broker Config * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Updates the configuration parameter specified by ``name``. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param brokerId The Kafka broker ID. * @param name The configuration parameter name. * @param optional nil or *ClustersClusterIdBrokersBrokerIdConfigsNamePutOpts - Optional Parameters: * @param "UpdateConfigRequestData" (optional.Interface of UpdateConfigRequestData) - The broker configuration parameter update request.
func (*ConfigsV3ApiService) ClustersClusterIdBrokersBrokerIdConfigsalterPost ¶ added in v0.3.8
func (a *ConfigsV3ApiService) ClustersClusterIdBrokersBrokerIdConfigsalterPost(ctx _context.Context, clusterId string, brokerId int32, localVarOptionals *ClustersClusterIdBrokersBrokerIdConfigsalterPostOpts) (*_nethttp.Response, error)
* ClustersClusterIdBrokersBrokerIdConfigsalterPost Batch Alter Broker Configs * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Updates or deletes a set of broker configuration parameters. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param brokerId The Kafka broker ID. * @param optional nil or *ClustersClusterIdBrokersBrokerIdConfigsalterPostOpts - Optional Parameters: * @param "AlterConfigBatchRequestData" (optional.Interface of AlterConfigBatchRequestData) - The alter broker configuration parameter batch request.
func (*ConfigsV3ApiService) ClustersClusterIdBrokersConfigsGet ¶ added in v0.3.8
func (a *ConfigsV3ApiService) ClustersClusterIdBrokersConfigsGet(ctx _context.Context, clusterId string) (BrokerConfigDataList, *_nethttp.Response, error)
* ClustersClusterIdBrokersConfigsGet List All Broker Configs * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Return the list of configuration parameters for all the brokers in the given Kafka cluster. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @return BrokerConfigDataList
func (*ConfigsV3ApiService) DeleteKafkaClusterConfig ¶ added in v0.3.8
func (a *ConfigsV3ApiService) DeleteKafkaClusterConfig(ctx _context.Context, clusterId string, name string) (*_nethttp.Response, error)
* DeleteKafkaClusterConfig Reset Cluster Config * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Resets the configuration parameter specified by ``name`` to its default value. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param name The configuration parameter name.
func (*ConfigsV3ApiService) DeleteKafkaTopicConfig ¶ added in v0.3.8
func (a *ConfigsV3ApiService) DeleteKafkaTopicConfig(ctx _context.Context, clusterId string, topicName string, name string) (*_nethttp.Response, error)
* DeleteKafkaTopicConfig Reset Topic Config * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Resets the config with given `name` to its default value. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param topicName The topic name. * @param name The configuration parameter name.
func (*ConfigsV3ApiService) GetKafkaClusterConfig ¶ added in v0.3.8
func (a *ConfigsV3ApiService) GetKafkaClusterConfig(ctx _context.Context, clusterId string, name string) (ClusterConfigData, *_nethttp.Response, error)
* GetKafkaClusterConfig Get Cluster Config * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Returns the configuration parameter specified by ``name``. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param name The configuration parameter name. * @return ClusterConfigData
func (*ConfigsV3ApiService) GetKafkaTopicConfig ¶ added in v0.3.8
func (a *ConfigsV3ApiService) GetKafkaTopicConfig(ctx _context.Context, clusterId string, topicName string, name string) (TopicConfigData, *_nethttp.Response, error)
* GetKafkaTopicConfig Get Topic Config * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Return the config with the given `name`. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param topicName The topic name. * @param name The configuration parameter name. * @return TopicConfigData
func (*ConfigsV3ApiService) ListKafkaAllTopicConfigs ¶ added in v0.3.8
func (a *ConfigsV3ApiService) ListKafkaAllTopicConfigs(ctx _context.Context, clusterId string) (TopicConfigDataList, *_nethttp.Response, error)
* ListKafkaAllTopicConfigs Get All Topic Configs * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Returns all topic configurations for topics hosted by the specified cluster. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @return TopicConfigDataList
func (*ConfigsV3ApiService) ListKafkaClusterConfigs ¶ added in v0.3.8
func (a *ConfigsV3ApiService) ListKafkaClusterConfigs(ctx _context.Context, clusterId string) (ClusterConfigDataList, *_nethttp.Response, error)
* ListKafkaClusterConfigs List Cluster Configs * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Returns a list of configuration parameters for the specified Kafka cluster. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @return ClusterConfigDataList
func (*ConfigsV3ApiService) ListKafkaDefaultTopicConfigs ¶ added in v0.3.8
func (a *ConfigsV3ApiService) ListKafkaDefaultTopicConfigs(ctx _context.Context, clusterId string, topicName string) (TopicConfigDataList, *_nethttp.Response, error)
* ListKafkaDefaultTopicConfigs List Default Topic Configs * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param topicName The topic name. * @return TopicConfigDataList
func (*ConfigsV3ApiService) ListKafkaTopicConfigs ¶ added in v0.3.8
func (a *ConfigsV3ApiService) ListKafkaTopicConfigs(ctx _context.Context, clusterId string, topicName string) (TopicConfigDataList, *_nethttp.Response, error)
* ListKafkaTopicConfigs List Topic Configs * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Return the list of configs that belong to the specified topic. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param topicName The topic name. * @return TopicConfigDataList
func (*ConfigsV3ApiService) UpdateKafkaClusterConfig ¶ added in v0.3.8
func (a *ConfigsV3ApiService) UpdateKafkaClusterConfig(ctx _context.Context, clusterId string, name string, localVarOptionals *UpdateKafkaClusterConfigOpts) (*_nethttp.Response, error)
* UpdateKafkaClusterConfig Update Cluster Config * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Updates the configuration parameter specified by ``name``. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param name The configuration parameter name. * @param optional nil or *UpdateKafkaClusterConfigOpts - Optional Parameters: * @param "UpdateConfigRequestData" (optional.Interface of UpdateConfigRequestData) - The cluster configuration parameter update request.
func (*ConfigsV3ApiService) UpdateKafkaClusterConfigs ¶ added in v0.3.8
func (a *ConfigsV3ApiService) UpdateKafkaClusterConfigs(ctx _context.Context, clusterId string, localVarOptionals *UpdateKafkaClusterConfigsOpts) (*_nethttp.Response, error)
* UpdateKafkaClusterConfigs Batch Alter Cluster Configs * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Updates or deletes a set of Kafka cluster configuration parameters. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param optional nil or *UpdateKafkaClusterConfigsOpts - Optional Parameters: * @param "AlterConfigBatchRequestData" (optional.Interface of AlterConfigBatchRequestData) - The alter cluster configuration parameter batch request.
func (*ConfigsV3ApiService) UpdateKafkaTopicConfig ¶ added in v0.3.8
func (a *ConfigsV3ApiService) UpdateKafkaTopicConfig(ctx _context.Context, clusterId string, topicName string, name string, localVarOptionals *UpdateKafkaTopicConfigOpts) (*_nethttp.Response, error)
* UpdateKafkaTopicConfig Update Topic Config * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Updates the config with given `name`. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param topicName The topic name. * @param name The configuration parameter name. * @param optional nil or *UpdateKafkaTopicConfigOpts - Optional Parameters: * @param "UpdateConfigRequestData" (optional.Interface of UpdateConfigRequestData) - The topic configuration parameter update request.
func (*ConfigsV3ApiService) UpdateKafkaTopicConfigBatch ¶ added in v0.3.8
func (a *ConfigsV3ApiService) UpdateKafkaTopicConfigBatch(ctx _context.Context, clusterId string, topicName string, localVarOptionals *UpdateKafkaTopicConfigBatchOpts) (*_nethttp.Response, error)
* UpdateKafkaTopicConfigBatch Batch Alter Topic Configs * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Updates or deletes a set of topic configs. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param topicName The topic name. * @param optional nil or *UpdateKafkaTopicConfigBatchOpts - Optional Parameters: * @param "AlterConfigBatchRequestData" (optional.Interface of AlterConfigBatchRequestData) - The alter topic configuration parameter batch request.
type Configuration ¶
type Configuration struct { BasePath string `json:"basePath,omitempty"` Host string `json:"host,omitempty"` Scheme string `json:"scheme,omitempty"` DefaultHeader map[string]string `json:"defaultHeader,omitempty"` UserAgent string `json:"userAgent,omitempty"` Debug bool `json:"debug,omitempty"` Servers []ServerConfiguration HTTPClient *http.Client }
Configuration stores the configuration of the API client
func NewConfiguration ¶
func NewConfiguration() *Configuration
NewConfiguration returns a new Configuration object
func (*Configuration) AddDefaultHeader ¶
func (c *Configuration) AddDefaultHeader(key string, value string)
AddDefaultHeader adds a new HTTP header to the default header in the request
type ConsumerAssignmentData ¶
type ConsumerAssignmentData struct { Kind string `json:"kind"` Metadata ResourceMetadata `json:"metadata"` ClusterId string `json:"cluster_id"` ConsumerGroupId string `json:"consumer_group_id"` ConsumerId string `json:"consumer_id"` TopicName string `json:"topic_name"` PartitionId int32 `json:"partition_id"` Partition Relationship `json:"partition"` Lag Relationship `json:"lag"` }
ConsumerAssignmentData struct for ConsumerAssignmentData
type ConsumerAssignmentDataAllOf ¶
type ConsumerAssignmentDataAllOf struct { ClusterId string `json:"cluster_id"` ConsumerGroupId string `json:"consumer_group_id"` ConsumerId string `json:"consumer_id"` TopicName string `json:"topic_name"` PartitionId int32 `json:"partition_id"` Partition Relationship `json:"partition"` Lag Relationship `json:"lag"` }
ConsumerAssignmentDataAllOf struct for ConsumerAssignmentDataAllOf
type ConsumerAssignmentDataList ¶
type ConsumerAssignmentDataList struct { Kind string `json:"kind"` Metadata ResourceCollectionMetadata `json:"metadata"` Data []ConsumerAssignmentData `json:"data"` }
ConsumerAssignmentDataList struct for ConsumerAssignmentDataList
type ConsumerAssignmentDataListAllOf ¶
type ConsumerAssignmentDataListAllOf struct {
Data []ConsumerAssignmentData `json:"data"`
}
ConsumerAssignmentDataListAllOf struct for ConsumerAssignmentDataListAllOf
type ConsumerData ¶
type ConsumerData struct { Kind string `json:"kind"` Metadata ResourceMetadata `json:"metadata"` ClusterId string `json:"cluster_id"` ConsumerGroupId string `json:"consumer_group_id"` ConsumerId string `json:"consumer_id"` InstanceId *string `json:"instance_id,omitempty"` ClientId string `json:"client_id"` Assignments Relationship `json:"assignments"` }
ConsumerData struct for ConsumerData
type ConsumerDataAllOf ¶
type ConsumerDataAllOf struct { ClusterId string `json:"cluster_id"` ConsumerGroupId string `json:"consumer_group_id"` ConsumerId string `json:"consumer_id"` InstanceId *string `json:"instance_id,omitempty"` ClientId string `json:"client_id"` Assignments Relationship `json:"assignments"` }
ConsumerDataAllOf struct for ConsumerDataAllOf
type ConsumerDataList ¶
type ConsumerDataList struct { Kind string `json:"kind"` Metadata ResourceCollectionMetadata `json:"metadata"` Data []ConsumerData `json:"data"` }
ConsumerDataList struct for ConsumerDataList
type ConsumerDataListAllOf ¶
type ConsumerDataListAllOf struct {
Data []ConsumerData `json:"data"`
}
ConsumerDataListAllOf struct for ConsumerDataListAllOf
type ConsumerGroupData ¶
type ConsumerGroupData struct { Kind string `json:"kind"` Metadata ResourceMetadata `json:"metadata"` ClusterId string `json:"cluster_id"` ConsumerGroupId string `json:"consumer_group_id"` IsSimple bool `json:"is_simple"` PartitionAssignor string `json:"partition_assignor"` State string `json:"state"` Coordinator Relationship `json:"coordinator"` Consumer Relationship `json:"consumer,omitempty"` LagSummary Relationship `json:"lag_summary"` }
ConsumerGroupData struct for ConsumerGroupData
type ConsumerGroupDataAllOf ¶
type ConsumerGroupDataAllOf struct { ClusterId string `json:"cluster_id"` ConsumerGroupId string `json:"consumer_group_id"` IsSimple bool `json:"is_simple"` PartitionAssignor string `json:"partition_assignor"` State string `json:"state"` Coordinator Relationship `json:"coordinator"` Consumer Relationship `json:"consumer,omitempty"` LagSummary Relationship `json:"lag_summary"` }
ConsumerGroupDataAllOf struct for ConsumerGroupDataAllOf
type ConsumerGroupDataList ¶
type ConsumerGroupDataList struct { Kind string `json:"kind"` Metadata ResourceCollectionMetadata `json:"metadata"` Data []ConsumerGroupData `json:"data"` }
ConsumerGroupDataList struct for ConsumerGroupDataList
type ConsumerGroupDataListAllOf ¶
type ConsumerGroupDataListAllOf struct {
Data []ConsumerGroupData `json:"data"`
}
ConsumerGroupDataListAllOf struct for ConsumerGroupDataListAllOf
type ConsumerGroupLagSummaryData ¶
type ConsumerGroupLagSummaryData struct { Kind string `json:"kind"` Metadata ResourceMetadata `json:"metadata"` ClusterId string `json:"cluster_id"` ConsumerGroupId string `json:"consumer_group_id"` MaxLagConsumerId string `json:"max_lag_consumer_id"` MaxLagInstanceId *string `json:"max_lag_instance_id,omitempty"` MaxLagClientId string `json:"max_lag_client_id"` MaxLagTopicName string `json:"max_lag_topic_name"` MaxLagPartitionId int32 `json:"max_lag_partition_id"` MaxLag int64 `json:"max_lag"` TotalLag int64 `json:"total_lag"` MaxLagConsumer Relationship `json:"max_lag_consumer"` MaxLagPartition Relationship `json:"max_lag_partition"` }
ConsumerGroupLagSummaryData struct for ConsumerGroupLagSummaryData
type ConsumerGroupLagSummaryDataAllOf ¶
type ConsumerGroupLagSummaryDataAllOf struct { ClusterId string `json:"cluster_id"` ConsumerGroupId string `json:"consumer_group_id"` MaxLagConsumerId string `json:"max_lag_consumer_id"` MaxLagInstanceId *string `json:"max_lag_instance_id,omitempty"` MaxLagClientId string `json:"max_lag_client_id"` MaxLagTopicName string `json:"max_lag_topic_name"` MaxLagPartitionId int32 `json:"max_lag_partition_id"` MaxLag int64 `json:"max_lag"` TotalLag int64 `json:"total_lag"` MaxLagConsumer Relationship `json:"max_lag_consumer"` MaxLagPartition Relationship `json:"max_lag_partition"` }
ConsumerGroupLagSummaryDataAllOf struct for ConsumerGroupLagSummaryDataAllOf
type ConsumerGroupV3Api ¶ added in v0.3.8
type ConsumerGroupV3Api interface { /* * GetKafkaConsumer Get Consumer * * [![Early Access](https://img.shields.io/badge/Lifecycle%20Stage-Early%20Access-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) [![Request Access To Cluster Admin for Kafka (v3)](https://img.shields.io/badge/-Request%20Access%20To%20Cluster%20Admin%20For%20Kafka%20v3-%23bc8540)](mailto:ccloud-rest-api+consumer-lag-earlyaccess@confluent.io?subject=Request%20to%20join%20v3%20API%20Early%20Access&body=I%E2%80%99d%20like%20to%20join%20the%20Confluent%20Cluster%20Admin%20For%20Kafka%20v3%20Early%20Access%20to%20provide%20early%20feedback%20on%20consumer%20lag%20apis%21%20My%20Cloud%20Organization%20ID%20is%20%3Cretrieve%20from%20https%3A//confluent.cloud/settings/billing/payment%3E.) Returns the consumer specified by the ``consumer_id``. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param consumerGroupId The consumer group ID. * @param consumerId The consumer ID. * @return ConsumerData */ GetKafkaConsumer(ctx _context.Context, clusterId string, consumerGroupId string, consumerId string) (ConsumerData, *_nethttp.Response, error) /* * GetKafkaConsumerAssignment Get Consumer Assignment * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Returns information about the assignment for the specified consumer to the specified partition. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param consumerGroupId The consumer group ID. * @param consumerId The consumer ID. * @param topicName The topic name. * @param partitionId The partition ID. * @return ConsumerAssignmentData */ GetKafkaConsumerAssignment(ctx _context.Context, clusterId string, consumerGroupId string, consumerId string, topicName string, partitionId int32) (ConsumerAssignmentData, *_nethttp.Response, error) /* * GetKafkaConsumerGroup Get Consumer Group * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Returns the consumer group specified by the ``consumer_group_id``. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param consumerGroupId The consumer group ID. * @return ConsumerGroupData */ GetKafkaConsumerGroup(ctx _context.Context, clusterId string, consumerGroupId string) (ConsumerGroupData, *_nethttp.Response, error) /* * GetKafkaConsumerGroupLagSummary Get Consumer Group Lag Summary. * * [![Early Access](https://img.shields.io/badge/Lifecycle%20Stage-Early%20Access-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) [![Request Access To Cluster Admin for Kafka (v3)](https://img.shields.io/badge/-Request%20Access%20To%20Cluster%20Admin%20For%20Kafka%20v3-%23bc8540)](mailto:ccloud-rest-api+consumer-lag-earlyaccess@confluent.io?subject=Request%20to%20join%20v3%20API%20Early%20Access&body=I%E2%80%99d%20like%20to%20join%20the%20Confluent%20Cluster%20Admin%20For%20Kafka%20v3%20Early%20Access%20to%20provide%20early%20feedback%20on%20consumer%20lag%20apis%21%20My%20Cloud%20Organization%20ID%20is%20%3Cretrieve%20from%20https%3A//confluent.cloud/settings/billing/payment%3E.) Returns the max and total lag of the consumers belonging to the specified consumer group. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param consumerGroupId The consumer group ID. * @return ConsumerGroupLagSummaryData */ GetKafkaConsumerGroupLagSummary(ctx _context.Context, clusterId string, consumerGroupId string) (ConsumerGroupLagSummaryData, *_nethttp.Response, error) /* * ListKafkaConsumerAssignment List Consumer Assignments * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Returns a list of partition assignments for the specified consumer. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param consumerGroupId The consumer group ID. * @param consumerId The consumer ID. * @return ConsumerAssignmentDataList */ ListKafkaConsumerAssignment(ctx _context.Context, clusterId string, consumerGroupId string, consumerId string) (ConsumerAssignmentDataList, *_nethttp.Response, error) /* * ListKafkaConsumerGroups List Consumer Groups * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Returns the list of consumer groups that belong to the specified Kafka cluster. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @return ConsumerGroupDataList */ ListKafkaConsumerGroups(ctx _context.Context, clusterId string) (ConsumerGroupDataList, *_nethttp.Response, error) /* * ListKafkaConsumerLags List Consumer Lags * * [![Early Access](https://img.shields.io/badge/Lifecycle%20Stage-Early%20Access-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) [![Request Access To Cluster Admin for Kafka (v3)](https://img.shields.io/badge/-Request%20Access%20To%20Cluster%20Admin%20For%20Kafka%20v3-%23bc8540)](mailto:ccloud-rest-api+consumer-lag-earlyaccess@confluent.io?subject=Request%20to%20join%20v3%20API%20Early%20Access&body=I%E2%80%99d%20like%20to%20join%20the%20Confluent%20Cluster%20Admin%20For%20Kafka%20v3%20Early%20Access%20to%20provide%20early%20feedback%20on%20consumer%20lag%20apis%21%20My%20Cloud%20Organization%20ID%20is%20%3Cretrieve%20from%20https%3A//confluent.cloud/settings/billing/payment%3E.) Returns a list of consumer lags of the consumers belonging to the specified consumer group. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param consumerGroupId The consumer group ID. * @return ConsumerLagDataList */ ListKafkaConsumerLags(ctx _context.Context, clusterId string, consumerGroupId string) (ConsumerLagDataList, *_nethttp.Response, error) /* * ListKafkaConsumers List Consumers * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Returns a list of consumers that belong to the specified consumer group. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param consumerGroupId The consumer group ID. * @return ConsumerDataList */ ListKafkaConsumers(ctx _context.Context, clusterId string, consumerGroupId string) (ConsumerDataList, *_nethttp.Response, error) }
type ConsumerGroupV3ApiService ¶ added in v0.3.8
type ConsumerGroupV3ApiService service
ConsumerGroupV3ApiService ConsumerGroupV3Api service
func (*ConsumerGroupV3ApiService) GetKafkaConsumer ¶ added in v0.3.8
func (a *ConsumerGroupV3ApiService) GetKafkaConsumer(ctx _context.Context, clusterId string, consumerGroupId string, consumerId string) (ConsumerData, *_nethttp.Response, error)
* GetKafkaConsumer Get Consumer * * [![Early Access](https://img.shields.io/badge/Lifecycle%20Stage-Early%20Access-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) [![Request Access To Cluster Admin for Kafka (v3)](https://img.shields.io/badge/-Request%20Access%20To%20Cluster%20Admin%20For%20Kafka%20v3-%23bc8540)](mailto:ccloud-rest-api+consumer-lag-earlyaccess@confluent.io?subject=Request%20to%20join%20v3%20API%20Early%20Access&body=I%E2%80%99d%20like%20to%20join%20the%20Confluent%20Cluster%20Admin%20For%20Kafka%20v3%20Early%20Access%20to%20provide%20early%20feedback%20on%20consumer%20lag%20apis%21%20My%20Cloud%20Organization%20ID%20is%20%3Cretrieve%20from%20https%3A//confluent.cloud/settings/billing/payment%3E.) Returns the consumer specified by the ``consumer_id``. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param consumerGroupId The consumer group ID. * @param consumerId The consumer ID. * @return ConsumerData
func (*ConsumerGroupV3ApiService) GetKafkaConsumerAssignment ¶ added in v0.3.8
func (a *ConsumerGroupV3ApiService) GetKafkaConsumerAssignment(ctx _context.Context, clusterId string, consumerGroupId string, consumerId string, topicName string, partitionId int32) (ConsumerAssignmentData, *_nethttp.Response, error)
* GetKafkaConsumerAssignment Get Consumer Assignment * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Returns information about the assignment for the specified consumer to the specified partition. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param consumerGroupId The consumer group ID. * @param consumerId The consumer ID. * @param topicName The topic name. * @param partitionId The partition ID. * @return ConsumerAssignmentData
func (*ConsumerGroupV3ApiService) GetKafkaConsumerGroup ¶ added in v0.3.8
func (a *ConsumerGroupV3ApiService) GetKafkaConsumerGroup(ctx _context.Context, clusterId string, consumerGroupId string) (ConsumerGroupData, *_nethttp.Response, error)
* GetKafkaConsumerGroup Get Consumer Group * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Returns the consumer group specified by the ``consumer_group_id``. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param consumerGroupId The consumer group ID. * @return ConsumerGroupData
func (*ConsumerGroupV3ApiService) GetKafkaConsumerGroupLagSummary ¶ added in v0.3.8
func (a *ConsumerGroupV3ApiService) GetKafkaConsumerGroupLagSummary(ctx _context.Context, clusterId string, consumerGroupId string) (ConsumerGroupLagSummaryData, *_nethttp.Response, error)
* GetKafkaConsumerGroupLagSummary Get Consumer Group Lag Summary. * * [![Early Access](https://img.shields.io/badge/Lifecycle%20Stage-Early%20Access-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) [![Request Access To Cluster Admin for Kafka (v3)](https://img.shields.io/badge/-Request%20Access%20To%20Cluster%20Admin%20For%20Kafka%20v3-%23bc8540)](mailto:ccloud-rest-api+consumer-lag-earlyaccess@confluent.io?subject=Request%20to%20join%20v3%20API%20Early%20Access&body=I%E2%80%99d%20like%20to%20join%20the%20Confluent%20Cluster%20Admin%20For%20Kafka%20v3%20Early%20Access%20to%20provide%20early%20feedback%20on%20consumer%20lag%20apis%21%20My%20Cloud%20Organization%20ID%20is%20%3Cretrieve%20from%20https%3A//confluent.cloud/settings/billing/payment%3E.) Returns the max and total lag of the consumers belonging to the specified consumer group. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param consumerGroupId The consumer group ID. * @return ConsumerGroupLagSummaryData
func (*ConsumerGroupV3ApiService) ListKafkaConsumerAssignment ¶ added in v0.3.8
func (a *ConsumerGroupV3ApiService) ListKafkaConsumerAssignment(ctx _context.Context, clusterId string, consumerGroupId string, consumerId string) (ConsumerAssignmentDataList, *_nethttp.Response, error)
* ListKafkaConsumerAssignment List Consumer Assignments * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Returns a list of partition assignments for the specified consumer. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param consumerGroupId The consumer group ID. * @param consumerId The consumer ID. * @return ConsumerAssignmentDataList
func (*ConsumerGroupV3ApiService) ListKafkaConsumerGroups ¶ added in v0.3.8
func (a *ConsumerGroupV3ApiService) ListKafkaConsumerGroups(ctx _context.Context, clusterId string) (ConsumerGroupDataList, *_nethttp.Response, error)
* ListKafkaConsumerGroups List Consumer Groups * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Returns the list of consumer groups that belong to the specified Kafka cluster. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @return ConsumerGroupDataList
func (*ConsumerGroupV3ApiService) ListKafkaConsumerLags ¶ added in v0.3.8
func (a *ConsumerGroupV3ApiService) ListKafkaConsumerLags(ctx _context.Context, clusterId string, consumerGroupId string) (ConsumerLagDataList, *_nethttp.Response, error)
* ListKafkaConsumerLags List Consumer Lags * * [![Early Access](https://img.shields.io/badge/Lifecycle%20Stage-Early%20Access-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) [![Request Access To Cluster Admin for Kafka (v3)](https://img.shields.io/badge/-Request%20Access%20To%20Cluster%20Admin%20For%20Kafka%20v3-%23bc8540)](mailto:ccloud-rest-api+consumer-lag-earlyaccess@confluent.io?subject=Request%20to%20join%20v3%20API%20Early%20Access&body=I%E2%80%99d%20like%20to%20join%20the%20Confluent%20Cluster%20Admin%20For%20Kafka%20v3%20Early%20Access%20to%20provide%20early%20feedback%20on%20consumer%20lag%20apis%21%20My%20Cloud%20Organization%20ID%20is%20%3Cretrieve%20from%20https%3A//confluent.cloud/settings/billing/payment%3E.) Returns a list of consumer lags of the consumers belonging to the specified consumer group. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param consumerGroupId The consumer group ID. * @return ConsumerLagDataList
func (*ConsumerGroupV3ApiService) ListKafkaConsumers ¶ added in v0.3.8
func (a *ConsumerGroupV3ApiService) ListKafkaConsumers(ctx _context.Context, clusterId string, consumerGroupId string) (ConsumerDataList, *_nethttp.Response, error)
* ListKafkaConsumers List Consumers * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Returns a list of consumers that belong to the specified consumer group. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param consumerGroupId The consumer group ID. * @return ConsumerDataList
type ConsumerLagData ¶
type ConsumerLagData struct { Kind string `json:"kind"` Metadata ResourceMetadata `json:"metadata"` ClusterId string `json:"cluster_id"` ConsumerGroupId string `json:"consumer_group_id"` TopicName string `json:"topic_name"` PartitionId int32 `json:"partition_id"` CurrentOffset int64 `json:"current_offset"` LogEndOffset int64 `json:"log_end_offset"` Lag int64 `json:"lag"` ConsumerId string `json:"consumer_id"` InstanceId *string `json:"instance_id,omitempty"` ClientId string `json:"client_id"` }
ConsumerLagData struct for ConsumerLagData
type ConsumerLagDataAllOf ¶
type ConsumerLagDataAllOf struct { ClusterId string `json:"cluster_id"` ConsumerGroupId string `json:"consumer_group_id"` TopicName string `json:"topic_name"` PartitionId int32 `json:"partition_id"` CurrentOffset int64 `json:"current_offset"` LogEndOffset int64 `json:"log_end_offset"` Lag int64 `json:"lag"` ConsumerId string `json:"consumer_id"` InstanceId *string `json:"instance_id,omitempty"` ClientId string `json:"client_id"` }
ConsumerLagDataAllOf struct for ConsumerLagDataAllOf
type ConsumerLagDataList ¶
type ConsumerLagDataList struct { Kind string `json:"kind"` Metadata ResourceCollectionMetadata `json:"metadata"` Data []ConsumerLagData `json:"data"` }
ConsumerLagDataList struct for ConsumerLagDataList
type ConsumerLagDataListAllOf ¶
type ConsumerLagDataListAllOf struct {
Data []ConsumerLagData `json:"data"`
}
ConsumerLagDataListAllOf struct for ConsumerLagDataListAllOf
type CreateAclRequestData ¶
type CreateAclRequestData struct { ResourceType AclResourceType `json:"resource_type"` ResourceName string `json:"resource_name"` PatternType string `json:"pattern_type"` Principal string `json:"principal"` Host string `json:"host"` Operation string `json:"operation"` Permission string `json:"permission"` }
CreateAclRequestData struct for CreateAclRequestData
type CreateKafkaAclsOpts ¶ added in v0.3.8
CreateKafkaAclsOpts Optional parameters for the method 'CreateKafkaAcls'
type CreateKafkaLinkOpts ¶ added in v0.3.8
type CreateKafkaLinkOpts struct { ValidateOnly optional.Bool ValidateLink optional.Bool CreateLinkRequestData optional.Interface }
CreateKafkaLinkOpts Optional parameters for the method 'CreateKafkaLink'
type CreateKafkaMirrorTopicOpts ¶ added in v0.3.8
CreateKafkaMirrorTopicOpts Optional parameters for the method 'CreateKafkaMirrorTopic'
type CreateKafkaTopicOpts ¶ added in v0.3.8
CreateKafkaTopicOpts Optional parameters for the method 'CreateKafkaTopic'
type CreateLinkRequestData ¶
type CreateLinkRequestData struct { SourceClusterId string `json:"source_cluster_id,omitempty"` DestinationClusterId string `json:"destination_cluster_id,omitempty"` RemoteClusterId string `json:"remote_cluster_id,omitempty"` ClusterLinkId string `json:"cluster_link_id,omitempty"` Configs []ConfigData `json:"configs,omitempty"` }
CreateLinkRequestData struct for CreateLinkRequestData
type CreateMirrorTopicRequestData ¶
type CreateMirrorTopicRequestData struct { SourceTopicName string `json:"source_topic_name"` MirrorTopicName string `json:"mirror_topic_name,omitempty"` ReplicationFactor int32 `json:"replication_factor,omitempty"` Configs []ConfigData `json:"configs,omitempty"` }
CreateMirrorTopicRequestData struct for CreateMirrorTopicRequestData
type CreateTopicRequestData ¶
type CreateTopicRequestData struct { TopicName string `json:"topic_name"` PartitionsCount int32 `json:"partitions_count,omitempty"` ReplicationFactor int32 `json:"replication_factor,omitempty"` ReplicasAssignments []CreateTopicRequestDataReplicasAssignments `json:"replicas_assignments,omitempty"` Configs []CreateTopicRequestDataConfigs `json:"configs,omitempty"` }
CreateTopicRequestData struct for CreateTopicRequestData
type CreateTopicRequestDataConfigs ¶
type CreateTopicRequestDataConfigs struct { Name string `json:"name"` Value *string `json:"value,omitempty"` }
CreateTopicRequestDataConfigs struct for CreateTopicRequestDataConfigs
type CreateTopicRequestDataReplicasAssignments ¶
type CreateTopicRequestDataReplicasAssignments struct { PartitionId int32 `json:"partition_id"` BrokerIds []int32 `json:"broker_ids"` }
CreateTopicRequestDataReplicasAssignments struct for CreateTopicRequestDataReplicasAssignments
type DeleteKafkaAclsOpts ¶ added in v0.3.8
type DeleteKafkaAclsOpts struct { ResourceType optional.Interface ResourceName optional.String PatternType optional.String Principal optional.String Host optional.String Operation optional.String Permission optional.String }
DeleteKafkaAclsOpts Optional parameters for the method 'DeleteKafkaAcls'
type DeleteKafkaLinkOpts ¶ added in v0.3.14
DeleteKafkaLinkOpts Optional parameters for the method 'DeleteKafkaLink'
type GenericOpenAPIError ¶
type GenericOpenAPIError struct {
// contains filtered or unexported fields
}
GenericOpenAPIError Provides access to the body, error and model on returned errors.
func (GenericOpenAPIError) Body ¶
func (e GenericOpenAPIError) Body() []byte
Body returns the raw bytes of the response
func (GenericOpenAPIError) Error ¶
func (e GenericOpenAPIError) Error() string
Error returns non-empty string if there was an error.
func (GenericOpenAPIError) Model ¶
func (e GenericOpenAPIError) Model() interface{}
Model returns the unpacked model of the error
type GetKafkaAclsOpts ¶ added in v0.3.8
type GetKafkaAclsOpts struct { ResourceType optional.Interface ResourceName optional.String PatternType optional.String Principal optional.String Host optional.String Operation optional.String Permission optional.String }
GetKafkaAclsOpts Optional parameters for the method 'GetKafkaAcls'
type GetKafkaLinkOpts ¶ added in v0.3.18
GetKafkaLinkOpts Optional parameters for the method 'GetKafkaLink'
type InlineResponse200 ¶
type InlineResponse200 struct {
Data []AclData `json:"data"`
}
InlineResponse200 struct for InlineResponse200
type LinkTask ¶ added in v0.3.18
type LinkTask struct { TaskName string `json:"task_name"` State string `json:"state"` Errors []LinkTaskError `json:"errors"` }
LinkTask struct for LinkTask
type LinkTaskError ¶ added in v0.3.18
type LinkTaskError struct { ErrorCode string `json:"error_code"` ErrorMessage string `json:"error_message"` }
LinkTaskError struct for LinkTaskError
type ListKafkaMirrorTopicsOpts ¶ added in v0.3.8
ListKafkaMirrorTopicsOpts Optional parameters for the method 'ListKafkaMirrorTopics'
type ListKafkaMirrorTopicsUnderLinkOpts ¶ added in v0.3.8
ListKafkaMirrorTopicsUnderLinkOpts Optional parameters for the method 'ListKafkaMirrorTopicsUnderLink'
type ListLinkConfigsResponseData ¶
type ListLinkConfigsResponseData struct { Kind string `json:"kind"` Metadata ResourceMetadata `json:"metadata"` ClusterId string `json:"cluster_id"` Name string `json:"name"` Value string `json:"value"` ReadOnly bool `json:"read_only"` Sensitive bool `json:"sensitive"` Source string `json:"source"` Synonyms []string `json:"synonyms"` LinkName string `json:"link_name"` }
ListLinkConfigsResponseData struct for ListLinkConfigsResponseData
type ListLinkConfigsResponseDataAllOf ¶
type ListLinkConfigsResponseDataAllOf struct { ClusterId string `json:"cluster_id"` Name string `json:"name"` Value string `json:"value"` ReadOnly bool `json:"read_only"` Sensitive bool `json:"sensitive"` Source string `json:"source"` Synonyms []string `json:"synonyms"` LinkName string `json:"link_name"` }
ListLinkConfigsResponseDataAllOf struct for ListLinkConfigsResponseDataAllOf
type ListLinkConfigsResponseDataList ¶
type ListLinkConfigsResponseDataList struct { Kind string `json:"kind"` Metadata ResourceCollectionMetadata `json:"metadata"` Data []ListLinkConfigsResponseData `json:"data"` }
ListLinkConfigsResponseDataList struct for ListLinkConfigsResponseDataList
type ListLinkConfigsResponseDataListAllOf ¶
type ListLinkConfigsResponseDataListAllOf struct {
Data []ListLinkConfigsResponseData `json:"data"`
}
ListLinkConfigsResponseDataListAllOf struct for ListLinkConfigsResponseDataListAllOf
type ListLinksResponseData ¶
type ListLinksResponseData struct { Kind string `json:"kind"` Metadata ResourceMetadata `json:"metadata"` SourceClusterId *string `json:"source_cluster_id,omitempty"` DestinationClusterId *string `json:"destination_cluster_id,omitempty"` RemoteClusterId *string `json:"remote_cluster_id,omitempty"` LinkName string `json:"link_name"` LinkId string `json:"link_id,omitempty"` ClusterLinkId string `json:"cluster_link_id"` TopicNames []string `json:"topic_names"` LinkError string `json:"link_error,omitempty"` LinkErrorMessage *string `json:"link_error_message,omitempty"` LinkState string `json:"link_state,omitempty"` Tasks *[]LinkTask `json:"tasks,omitempty"` }
ListLinksResponseData struct for ListLinksResponseData
type ListLinksResponseDataAllOf ¶
type ListLinksResponseDataAllOf struct { SourceClusterId *string `json:"source_cluster_id,omitempty"` DestinationClusterId *string `json:"destination_cluster_id,omitempty"` RemoteClusterId *string `json:"remote_cluster_id,omitempty"` LinkName string `json:"link_name"` LinkId string `json:"link_id,omitempty"` ClusterLinkId string `json:"cluster_link_id"` TopicNames []string `json:"topic_names"` LinkError string `json:"link_error,omitempty"` LinkErrorMessage *string `json:"link_error_message,omitempty"` LinkState string `json:"link_state,omitempty"` Tasks *[]LinkTask `json:"tasks,omitempty"` }
ListLinksResponseDataAllOf struct for ListLinksResponseDataAllOf
type ListLinksResponseDataList ¶
type ListLinksResponseDataList struct { Kind string `json:"kind"` Metadata ResourceCollectionMetadata `json:"metadata"` Data []ListLinksResponseData `json:"data"` }
ListLinksResponseDataList struct for ListLinksResponseDataList
type ListLinksResponseDataListAllOf ¶
type ListLinksResponseDataListAllOf struct {
Data []ListLinksResponseData `json:"data"`
}
ListLinksResponseDataListAllOf struct for ListLinksResponseDataListAllOf
type ListMirrorTopicsResponseData ¶
type ListMirrorTopicsResponseData struct { Kind string `json:"kind"` Metadata ResourceMetadata `json:"metadata"` LinkName string `json:"link_name"` MirrorTopicName string `json:"mirror_topic_name"` SourceTopicName string `json:"source_topic_name"` NumPartitions int32 `json:"num_partitions"` MirrorLags []MirrorLag `json:"mirror_lags"` MirrorStatus MirrorTopicStatus `json:"mirror_status"` MirrorTopicError string `json:"mirror_topic_error"` StateTimeMs int64 `json:"state_time_ms"` MirrorStateTransitionErrors []LinkTaskError `json:"mirror_state_transition_errors,omitempty"` }
ListMirrorTopicsResponseData struct for ListMirrorTopicsResponseData
type ListMirrorTopicsResponseDataAllOf ¶
type ListMirrorTopicsResponseDataAllOf struct { LinkName string `json:"link_name"` MirrorTopicName string `json:"mirror_topic_name"` SourceTopicName string `json:"source_topic_name"` NumPartitions int32 `json:"num_partitions"` MirrorLags []MirrorLag `json:"mirror_lags"` MirrorStatus MirrorTopicStatus `json:"mirror_status"` MirrorTopicError string `json:"mirror_topic_error"` StateTimeMs int64 `json:"state_time_ms"` MirrorStateTransitionErrors []LinkTaskError `json:"mirror_state_transition_errors,omitempty"` }
ListMirrorTopicsResponseDataAllOf struct for ListMirrorTopicsResponseDataAllOf
type ListMirrorTopicsResponseDataList ¶
type ListMirrorTopicsResponseDataList struct { Kind string `json:"kind"` Metadata ResourceCollectionMetadata `json:"metadata"` Data []ListMirrorTopicsResponseData `json:"data"` }
ListMirrorTopicsResponseDataList struct for ListMirrorTopicsResponseDataList
type ListMirrorTopicsResponseDataListAllOf ¶
type ListMirrorTopicsResponseDataListAllOf struct {
Data []ListMirrorTopicsResponseData `json:"data"`
}
ListMirrorTopicsResponseDataListAllOf struct for ListMirrorTopicsResponseDataListAllOf
type MirrorLag ¶
type MirrorLag struct { Partition int32 `json:"partition"` Lag int64 `json:"lag"` LastSourceFetchOffset int64 `json:"last_source_fetch_offset"` }
MirrorLag struct for MirrorLag
type MirrorTopicStatus ¶
type MirrorTopicStatus string
MirrorTopicStatus the model 'MirrorTopicStatus'
const ( MIRRORTOPICSTATUS_ACTIVE MirrorTopicStatus = "ACTIVE" MIRRORTOPICSTATUS_FAILED MirrorTopicStatus = "FAILED" MIRRORTOPICSTATUS_LINK_FAILED MirrorTopicStatus = "LINK_FAILED" MIRRORTOPICSTATUS_LINK_PAUSED MirrorTopicStatus = "LINK_PAUSED" MIRRORTOPICSTATUS_PAUSED MirrorTopicStatus = "PAUSED" MIRRORTOPICSTATUS_PENDING_STOPPED MirrorTopicStatus = "PENDING_STOPPED" MIRRORTOPICSTATUS_SOURCE_UNAVAILABLE MirrorTopicStatus = "SOURCE_UNAVAILABLE" MIRRORTOPICSTATUS_STOPPED MirrorTopicStatus = "STOPPED" MIRRORTOPICSTATUS_UNKNOWN MirrorTopicStatus = "UNKNOWN" MIRRORTOPICSTATUS_PENDING_SYNCHRONIZE MirrorTopicStatus = "PENDING_SYNCHRONIZE" MIRRORTOPICSTATUS_PENDING_MIRROR MirrorTopicStatus = "PENDING_MIRROR" )
List of MirrorTopicStatus
type PartitionApi ¶
type PartitionApi interface { /* * ClustersClusterIdTopicsPartitionsReassignmentGet List All Replica Reassignments * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Returns the list of all ongoing replica reassignments in the given Kafka cluster. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @return ReassignmentDataList */ ClustersClusterIdTopicsPartitionsReassignmentGet(ctx _context.Context, clusterId string) (ReassignmentDataList, *_nethttp.Response, error) /* * ClustersClusterIdTopicsTopicNamePartitionsPartitionIdReassignmentGet Get Replica Reassignments * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Returns the list of ongoing replica reassignments for the given partition. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param topicName The topic name. * @param partitionId The partition ID. * @return ReassignmentData */ ClustersClusterIdTopicsTopicNamePartitionsPartitionIdReassignmentGet(ctx _context.Context, clusterId string, topicName string, partitionId int32) (ReassignmentData, *_nethttp.Response, error) /* * ClustersClusterIdTopicsTopicNamePartitionsReassignmentGet Search Replica Reassignments By Topic * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Returns the list of ongoing replica reassignments for the given topic. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param topicName The topic name. * @return ReassignmentDataList */ ClustersClusterIdTopicsTopicNamePartitionsReassignmentGet(ctx _context.Context, clusterId string, topicName string) (ReassignmentDataList, *_nethttp.Response, error) }
type PartitionApiService ¶
type PartitionApiService service
PartitionApiService PartitionApi service
func (*PartitionApiService) ClustersClusterIdTopicsPartitionsReassignmentGet ¶
func (a *PartitionApiService) ClustersClusterIdTopicsPartitionsReassignmentGet(ctx _context.Context, clusterId string) (ReassignmentDataList, *_nethttp.Response, error)
* ClustersClusterIdTopicsPartitionsReassignmentGet List All Replica Reassignments * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Returns the list of all ongoing replica reassignments in the given Kafka cluster. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @return ReassignmentDataList
func (*PartitionApiService) ClustersClusterIdTopicsTopicNamePartitionsPartitionIdReassignmentGet ¶
func (a *PartitionApiService) ClustersClusterIdTopicsTopicNamePartitionsPartitionIdReassignmentGet(ctx _context.Context, clusterId string, topicName string, partitionId int32) (ReassignmentData, *_nethttp.Response, error)
* ClustersClusterIdTopicsTopicNamePartitionsPartitionIdReassignmentGet Get Replica Reassignments * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Returns the list of ongoing replica reassignments for the given partition. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param topicName The topic name. * @param partitionId The partition ID. * @return ReassignmentData
func (*PartitionApiService) ClustersClusterIdTopicsTopicNamePartitionsReassignmentGet ¶
func (a *PartitionApiService) ClustersClusterIdTopicsTopicNamePartitionsReassignmentGet(ctx _context.Context, clusterId string, topicName string) (ReassignmentDataList, *_nethttp.Response, error)
* ClustersClusterIdTopicsTopicNamePartitionsReassignmentGet Search Replica Reassignments By Topic * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Returns the list of ongoing replica reassignments for the given topic. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param topicName The topic name. * @return ReassignmentDataList
type PartitionData ¶
type PartitionData struct { Kind string `json:"kind"` Metadata ResourceMetadata `json:"metadata"` ClusterId string `json:"cluster_id"` TopicName string `json:"topic_name"` PartitionId int32 `json:"partition_id"` Leader Relationship `json:"leader,omitempty"` Replicas Relationship `json:"replicas"` Reassignment Relationship `json:"reassignment"` }
PartitionData struct for PartitionData
type PartitionDataAllOf ¶
type PartitionDataAllOf struct { ClusterId string `json:"cluster_id"` TopicName string `json:"topic_name"` PartitionId int32 `json:"partition_id"` Leader Relationship `json:"leader,omitempty"` Replicas Relationship `json:"replicas"` Reassignment Relationship `json:"reassignment"` }
PartitionDataAllOf struct for PartitionDataAllOf
type PartitionDataList ¶
type PartitionDataList struct { Kind string `json:"kind"` Metadata ResourceCollectionMetadata `json:"metadata"` Data []PartitionData `json:"data"` }
PartitionDataList struct for PartitionDataList
type PartitionDataListAllOf ¶
type PartitionDataListAllOf struct {
Data []PartitionData `json:"data"`
}
PartitionDataListAllOf struct for PartitionDataListAllOf
type PartitionV3Api ¶ added in v0.3.8
type PartitionV3Api interface { /* * GetKafkaConsumerLag Get Consumer Lag * * [![Early Access](https://img.shields.io/badge/Lifecycle%20Stage-Early%20Access-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) [![Request Access To Cluster Admin for Kafka (v3)](https://img.shields.io/badge/-Request%20Access%20To%20Cluster%20Admin%20For%20Kafka%20v3-%23bc8540)](mailto:ccloud-rest-api+consumer-lag-earlyaccess@confluent.io?subject=Request%20to%20join%20v3%20API%20Early%20Access&body=I%E2%80%99d%20like%20to%20join%20the%20Confluent%20Cluster%20Admin%20For%20Kafka%20v3%20Early%20Access%20to%20provide%20early%20feedback%20on%20consumer%20lag%20apis%21%20My%20Cloud%20Organization%20ID%20is%20%3Cretrieve%20from%20https%3A//confluent.cloud/settings/billing/payment%3E.) Returns the consumer lag on a partition with the given `partition_id`. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param consumerGroupId The consumer group ID. * @param topicName The topic name. * @param partitionId The partition ID. * @return ConsumerLagData */ GetKafkaConsumerLag(ctx _context.Context, clusterId string, consumerGroupId string, topicName string, partitionId int32) (ConsumerLagData, *_nethttp.Response, error) /* * GetKafkaPartition Get Partition * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Returns the partition with the given `partition_id`. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param topicName The topic name. * @param partitionId The partition ID. * @return PartitionData */ GetKafkaPartition(ctx _context.Context, clusterId string, topicName string, partitionId int32) (PartitionData, *_nethttp.Response, error) /* * ListKafkaPartitions List Partitions * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Returns the list of partitions that belong to the specified topic. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param topicName The topic name. * @return PartitionDataList */ ListKafkaPartitions(ctx _context.Context, clusterId string, topicName string) (PartitionDataList, *_nethttp.Response, error) }
type PartitionV3ApiService ¶ added in v0.3.8
type PartitionV3ApiService service
PartitionV3ApiService PartitionV3Api service
func (*PartitionV3ApiService) GetKafkaConsumerLag ¶ added in v0.3.8
func (a *PartitionV3ApiService) GetKafkaConsumerLag(ctx _context.Context, clusterId string, consumerGroupId string, topicName string, partitionId int32) (ConsumerLagData, *_nethttp.Response, error)
* GetKafkaConsumerLag Get Consumer Lag * * [![Early Access](https://img.shields.io/badge/Lifecycle%20Stage-Early%20Access-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) [![Request Access To Cluster Admin for Kafka (v3)](https://img.shields.io/badge/-Request%20Access%20To%20Cluster%20Admin%20For%20Kafka%20v3-%23bc8540)](mailto:ccloud-rest-api+consumer-lag-earlyaccess@confluent.io?subject=Request%20to%20join%20v3%20API%20Early%20Access&body=I%E2%80%99d%20like%20to%20join%20the%20Confluent%20Cluster%20Admin%20For%20Kafka%20v3%20Early%20Access%20to%20provide%20early%20feedback%20on%20consumer%20lag%20apis%21%20My%20Cloud%20Organization%20ID%20is%20%3Cretrieve%20from%20https%3A//confluent.cloud/settings/billing/payment%3E.) Returns the consumer lag on a partition with the given `partition_id`. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param consumerGroupId The consumer group ID. * @param topicName The topic name. * @param partitionId The partition ID. * @return ConsumerLagData
func (*PartitionV3ApiService) GetKafkaPartition ¶ added in v0.3.8
func (a *PartitionV3ApiService) GetKafkaPartition(ctx _context.Context, clusterId string, topicName string, partitionId int32) (PartitionData, *_nethttp.Response, error)
* GetKafkaPartition Get Partition * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Returns the partition with the given `partition_id`. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param topicName The topic name. * @param partitionId The partition ID. * @return PartitionData
func (*PartitionV3ApiService) ListKafkaPartitions ¶ added in v0.3.8
func (a *PartitionV3ApiService) ListKafkaPartitions(ctx _context.Context, clusterId string, topicName string) (PartitionDataList, *_nethttp.Response, error)
* ListKafkaPartitions List Partitions * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Returns the list of partitions that belong to the specified topic. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param topicName The topic name. * @return PartitionDataList
type ProduceRequest ¶ added in v0.3.8
type ProduceRequest struct { PartitionId *int32 `json:"partition_id,omitempty"` Headers []ProduceRequestHeader `json:"headers,omitempty"` Key *ProduceRequestData `json:"key,omitempty"` Value *ProduceRequestData `json:"value,omitempty"` Timestamp *time.Time `json:"timestamp,omitempty"` }
ProduceRequest struct for ProduceRequest
type ProduceRequestData ¶ added in v0.3.8
type ProduceRequestData struct { Type string `json:"type,omitempty"` Subject *string `json:"subject,omitempty"` SubjectNameStrategy *string `json:"subject_name_strategy,omitempty"` SchemaId *int32 `json:"schema_id,omitempty"` SchemaVersion *int32 `json:"schema_version,omitempty"` Schema *string `json:"schema,omitempty"` Data *interface{} `json:"data,omitempty"` }
ProduceRequestData struct for ProduceRequestData
type ProduceRequestHeader ¶ added in v0.3.8
type ProduceRequestHeader struct { Name string `json:"name"` Value *string `json:"value,omitempty"` }
ProduceRequestHeader struct for ProduceRequestHeader
type ProduceResponse ¶ added in v0.3.8
type ProduceResponse struct { ClusterId string `json:"cluster_id"` TopicName string `json:"topic_name"` PartitionId int32 `json:"partition_id"` Offset int32 `json:"offset"` Timestamp *time.Time `json:"timestamp,omitempty"` Key *ProduceResponseData `json:"key,omitempty"` Value *ProduceResponseData `json:"value,omitempty"` }
ProduceResponse struct for ProduceResponse
type ProduceResponseData ¶ added in v0.3.8
type ProduceResponseData struct { Size int64 `json:"size"` Type *string `json:"type,omitempty"` Subject *string `json:"subject,omitempty"` SchemaId *int32 `json:"schema_id,omitempty"` SchemaVersion *int32 `json:"schema_version,omitempty"` }
ProduceResponseData struct for ProduceResponseData
type ReadKafkaMirrorTopicOpts ¶ added in v0.3.18
ReadKafkaMirrorTopicOpts Optional parameters for the method 'ReadKafkaMirrorTopic'
type ReassignmentData ¶
type ReassignmentData struct { Kind string `json:"kind"` Metadata ResourceMetadata `json:"metadata"` ClusterId string `json:"cluster_id"` TopicName string `json:"topic_name"` PartitionId int32 `json:"partition_id"` AddingReplicas []int32 `json:"adding_replicas"` RemovingReplicas []int32 `json:"removing_replicas"` Replicas Relationship `json:"replicas"` }
ReassignmentData struct for ReassignmentData
type ReassignmentDataAllOf ¶
type ReassignmentDataAllOf struct { ClusterId string `json:"cluster_id"` TopicName string `json:"topic_name"` PartitionId int32 `json:"partition_id"` AddingReplicas []int32 `json:"adding_replicas"` RemovingReplicas []int32 `json:"removing_replicas"` Replicas Relationship `json:"replicas"` }
ReassignmentDataAllOf struct for ReassignmentDataAllOf
type ReassignmentDataList ¶
type ReassignmentDataList struct { Kind string `json:"kind"` Metadata ResourceCollectionMetadata `json:"metadata"` Data []ReassignmentData `json:"data"` }
ReassignmentDataList struct for ReassignmentDataList
type ReassignmentDataListAllOf ¶
type ReassignmentDataListAllOf struct {
Data []ReassignmentData `json:"data"`
}
ReassignmentDataListAllOf struct for ReassignmentDataListAllOf
type RecordsV3Api ¶ added in v0.3.15
type RecordsV3Api interface { /* * ClustersClusterIdTopicsTopicNameRecordsPost Produce records to the given topic. * * [![Early Access](https://img.shields.io/badge/Lifecycle%20Stage-Early%20Access-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Produce records to the given topic, returning delivery reports for each record produced. This API can be used in streaming mode by setting \"Transfer-Encoding: chunked\" header. For as long as the connection is kept open, the server will keep accepting records. For each record sent to the server, the server will asynchronously send back a delivery report, in the same order. Records are streamed to and from the server as Concatenated JSON. Errors are reported per record. The HTTP status code will be HTTP 200 OK as long as the connection is successfully established. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param topicName The topic name. * @param optional nil or *ClustersClusterIdTopicsTopicNameRecordsPostOpts - Optional Parameters: * @param "ProduceRequest" (optional.Interface of ProduceRequest) - A single record to be produced to Kafka. To produce multiple records on the same connection, simply concatenate all the records, e.g.: {\"partition_id\":1}{\"partition_id\":2}. Delivery reports will be concatenated on the same order as the records are sent. See examples for the options available. * @return ProduceResponse */ ClustersClusterIdTopicsTopicNameRecordsPost(ctx _context.Context, clusterId string, topicName string, localVarOptionals *ClustersClusterIdTopicsTopicNameRecordsPostOpts) (ProduceResponse, *_nethttp.Response, error) }
type RecordsV3ApiService ¶ added in v0.3.15
type RecordsV3ApiService service
RecordsV3ApiService RecordsV3Api service
func (*RecordsV3ApiService) ClustersClusterIdTopicsTopicNameRecordsPost ¶ added in v0.3.15
func (a *RecordsV3ApiService) ClustersClusterIdTopicsTopicNameRecordsPost(ctx _context.Context, clusterId string, topicName string, localVarOptionals *ClustersClusterIdTopicsTopicNameRecordsPostOpts) (ProduceResponse, *_nethttp.Response, error)
* ClustersClusterIdTopicsTopicNameRecordsPost Produce records to the given topic. * * [![Early Access](https://img.shields.io/badge/Lifecycle%20Stage-Early%20Access-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Produce records to the given topic, returning delivery reports for each record produced. This API can be used in streaming mode by setting \"Transfer-Encoding: chunked\" header. For as long as the connection is kept open, the server will keep accepting records. For each record sent to the server, the server will asynchronously send back a delivery report, in the same order. Records are streamed to and from the server as Concatenated JSON. Errors are reported per record. The HTTP status code will be HTTP 200 OK as long as the connection is successfully established. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param topicName The topic name. * @param optional nil or *ClustersClusterIdTopicsTopicNameRecordsPostOpts - Optional Parameters: * @param "ProduceRequest" (optional.Interface of ProduceRequest) - A single record to be produced to Kafka. To produce multiple records on the same connection, simply concatenate all the records, e.g.: {\"partition_id\":1}{\"partition_id\":2}. Delivery reports will be concatenated on the same order as the records are sent. See examples for the options available. * @return ProduceResponse
type Relationship ¶
type Relationship struct {
Related string `json:"related"`
}
Relationship struct for Relationship
type RemoveBrokerTaskApi ¶
type RemoveBrokerTaskApi interface { /* * ClustersClusterIdRemoveBrokerTasksBrokerIdGet Get Remove Broker Task * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Return the remove broker task for the specified ``broker_id``. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param brokerId The Kafka broker ID. * @return RemoveBrokerTaskData */ ClustersClusterIdRemoveBrokerTasksBrokerIdGet(ctx _context.Context, clusterId string, brokerId int32) (RemoveBrokerTaskData, *_nethttp.Response, error) /* * ClustersClusterIdRemoveBrokerTasksGet List Remove Broker Tasks * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Returns a list of remove-broker-tasks for the specified Kafka cluster. ``/remove-broker-tasks`` is deprecated and may be removed in a future release. Use the new ``/tasks`` API instead. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @return RemoveBrokerTaskDataList */ ClustersClusterIdRemoveBrokerTasksGet(ctx _context.Context, clusterId string) (RemoveBrokerTaskDataList, *_nethttp.Response, error) }
type RemoveBrokerTaskApiService ¶
type RemoveBrokerTaskApiService service
RemoveBrokerTaskApiService RemoveBrokerTaskApi service
func (*RemoveBrokerTaskApiService) ClustersClusterIdRemoveBrokerTasksBrokerIdGet ¶
func (a *RemoveBrokerTaskApiService) ClustersClusterIdRemoveBrokerTasksBrokerIdGet(ctx _context.Context, clusterId string, brokerId int32) (RemoveBrokerTaskData, *_nethttp.Response, error)
* ClustersClusterIdRemoveBrokerTasksBrokerIdGet Get Remove Broker Task * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Return the remove broker task for the specified ``broker_id``. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param brokerId The Kafka broker ID. * @return RemoveBrokerTaskData
func (*RemoveBrokerTaskApiService) ClustersClusterIdRemoveBrokerTasksGet ¶
func (a *RemoveBrokerTaskApiService) ClustersClusterIdRemoveBrokerTasksGet(ctx _context.Context, clusterId string) (RemoveBrokerTaskDataList, *_nethttp.Response, error)
* ClustersClusterIdRemoveBrokerTasksGet List Remove Broker Tasks * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Returns a list of remove-broker-tasks for the specified Kafka cluster. ``/remove-broker-tasks`` is deprecated and may be removed in a future release. Use the new ``/tasks`` API instead. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @return RemoveBrokerTaskDataList
type RemoveBrokerTaskData ¶
type RemoveBrokerTaskData struct { Kind string `json:"kind"` Metadata ResourceMetadata `json:"metadata"` ClusterId string `json:"cluster_id"` BrokerId int32 `json:"broker_id"` ShutdownScheduled bool `json:"shutdown_scheduled"` BrokerReplicaExclusionStatus string `json:"broker_replica_exclusion_status"` PartitionReassignmentStatus string `json:"partition_reassignment_status"` BrokerShutdownStatus string `json:"broker_shutdown_status"` ErrorCode *int32 `json:"error_code,omitempty"` ErrorMessage *string `json:"error_message,omitempty"` Broker Relationship `json:"broker"` }
RemoveBrokerTaskData struct for RemoveBrokerTaskData
type RemoveBrokerTaskDataAllOf ¶
type RemoveBrokerTaskDataAllOf struct { ClusterId string `json:"cluster_id"` BrokerId int32 `json:"broker_id"` ShutdownScheduled bool `json:"shutdown_scheduled"` BrokerReplicaExclusionStatus string `json:"broker_replica_exclusion_status"` PartitionReassignmentStatus string `json:"partition_reassignment_status"` BrokerShutdownStatus string `json:"broker_shutdown_status"` ErrorCode *int32 `json:"error_code,omitempty"` ErrorMessage *string `json:"error_message,omitempty"` Broker Relationship `json:"broker"` }
RemoveBrokerTaskDataAllOf struct for RemoveBrokerTaskDataAllOf
type RemoveBrokerTaskDataList ¶
type RemoveBrokerTaskDataList struct { Kind string `json:"kind"` Metadata ResourceCollectionMetadata `json:"metadata"` Data []RemoveBrokerTaskData `json:"data"` }
RemoveBrokerTaskDataList struct for RemoveBrokerTaskDataList
type RemoveBrokerTaskDataListAllOf ¶
type RemoveBrokerTaskDataListAllOf struct {
Data []RemoveBrokerTaskData `json:"data"`
}
RemoveBrokerTaskDataListAllOf struct for RemoveBrokerTaskDataListAllOf
type RemoveBrokersRequestData ¶
type RemoveBrokersRequestData struct {
BrokerIds []int32 `json:"broker_ids"`
}
RemoveBrokersRequestData struct for RemoveBrokersRequestData
type ReplicaApi ¶
type ReplicaApi interface { /* * ClustersClusterIdTopicsTopicNamePartitionsPartitionIdReplicasBrokerIdGet Get Replica * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Returns the replica for the specified partition assigned to the specified broker. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param topicName The topic name. * @param partitionId The partition ID. * @param brokerId The Kafka broker ID. * @return ReplicaData */ ClustersClusterIdTopicsTopicNamePartitionsPartitionIdReplicasBrokerIdGet(ctx _context.Context, clusterId string, topicName string, partitionId int32, brokerId int32) (ReplicaData, *_nethttp.Response, error) /* * ClustersClusterIdTopicsTopicNamePartitionsPartitionIdReplicasGet List Replicas * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Returns the list of replicas for the specified partition. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param topicName The topic name. * @param partitionId The partition ID. * @return ReplicaDataList */ ClustersClusterIdTopicsTopicNamePartitionsPartitionIdReplicasGet(ctx _context.Context, clusterId string, topicName string, partitionId int32) (ReplicaDataList, *_nethttp.Response, error) }
type ReplicaApiService ¶
type ReplicaApiService service
ReplicaApiService ReplicaApi service
func (*ReplicaApiService) ClustersClusterIdTopicsTopicNamePartitionsPartitionIdReplicasBrokerIdGet ¶
func (a *ReplicaApiService) ClustersClusterIdTopicsTopicNamePartitionsPartitionIdReplicasBrokerIdGet(ctx _context.Context, clusterId string, topicName string, partitionId int32, brokerId int32) (ReplicaData, *_nethttp.Response, error)
* ClustersClusterIdTopicsTopicNamePartitionsPartitionIdReplicasBrokerIdGet Get Replica * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Returns the replica for the specified partition assigned to the specified broker. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param topicName The topic name. * @param partitionId The partition ID. * @param brokerId The Kafka broker ID. * @return ReplicaData
func (*ReplicaApiService) ClustersClusterIdTopicsTopicNamePartitionsPartitionIdReplicasGet ¶
func (a *ReplicaApiService) ClustersClusterIdTopicsTopicNamePartitionsPartitionIdReplicasGet(ctx _context.Context, clusterId string, topicName string, partitionId int32) (ReplicaDataList, *_nethttp.Response, error)
* ClustersClusterIdTopicsTopicNamePartitionsPartitionIdReplicasGet List Replicas * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Returns the list of replicas for the specified partition. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param topicName The topic name. * @param partitionId The partition ID. * @return ReplicaDataList
type ReplicaData ¶
type ReplicaData struct { Kind string `json:"kind"` Metadata ResourceMetadata `json:"metadata"` ClusterId string `json:"cluster_id"` TopicName string `json:"topic_name"` PartitionId int32 `json:"partition_id"` BrokerId int32 `json:"broker_id"` IsLeader bool `json:"is_leader"` IsInSync bool `json:"is_in_sync"` Broker Relationship `json:"broker"` }
ReplicaData struct for ReplicaData
type ReplicaDataAllOf ¶
type ReplicaDataAllOf struct { ClusterId string `json:"cluster_id"` TopicName string `json:"topic_name"` PartitionId int32 `json:"partition_id"` BrokerId int32 `json:"broker_id"` IsLeader bool `json:"is_leader"` IsInSync bool `json:"is_in_sync"` Broker Relationship `json:"broker"` }
ReplicaDataAllOf struct for ReplicaDataAllOf
type ReplicaDataList ¶
type ReplicaDataList struct { Kind string `json:"kind"` Metadata ResourceCollectionMetadata `json:"metadata"` Data []ReplicaData `json:"data"` }
ReplicaDataList struct for ReplicaDataList
type ReplicaDataListAllOf ¶
type ReplicaDataListAllOf struct {
Data []ReplicaData `json:"data"`
}
ReplicaDataListAllOf struct for ReplicaDataListAllOf
type ReplicaStatusApi ¶
type ReplicaStatusApi interface { /* * ClustersClusterIdTopicsPartitionsReplicaStatusGet List All Replica Statuses from a cluster. * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Return the all the replica statuses for the specified ``cluster_id``. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @return ReplicaStatusDataList */ ClustersClusterIdTopicsPartitionsReplicaStatusGet(ctx _context.Context, clusterId string) (ReplicaStatusDataList, *_nethttp.Response, error) /* * ClustersClusterIdTopicsTopicNamePartitionsPartitionIdReplicaStatusGet List Partition Replica Statuses. * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Return the all the replica statuses for the specified ``topic_name`` and ``partition_id``. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param topicName The topic name. * @param partitionId The partition ID. * @return ReplicaStatusDataList */ ClustersClusterIdTopicsTopicNamePartitionsPartitionIdReplicaStatusGet(ctx _context.Context, clusterId string, topicName string, partitionId int32) (ReplicaStatusDataList, *_nethttp.Response, error) /* * ClustersClusterIdTopicsTopicNamePartitionsReplicaStatusGet List All Partition Replica Statuses. * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Return the all the replica statuses for the specified ``topic_name``. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param topicName The topic name. * @return ReplicaStatusDataList */ ClustersClusterIdTopicsTopicNamePartitionsReplicaStatusGet(ctx _context.Context, clusterId string, topicName string) (ReplicaStatusDataList, *_nethttp.Response, error) }
type ReplicaStatusApiService ¶
type ReplicaStatusApiService service
ReplicaStatusApiService ReplicaStatusApi service
func (*ReplicaStatusApiService) ClustersClusterIdTopicsPartitionsReplicaStatusGet ¶ added in v0.3.8
func (a *ReplicaStatusApiService) ClustersClusterIdTopicsPartitionsReplicaStatusGet(ctx _context.Context, clusterId string) (ReplicaStatusDataList, *_nethttp.Response, error)
* ClustersClusterIdTopicsPartitionsReplicaStatusGet List All Replica Statuses from a cluster. * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Return the all the replica statuses for the specified ``cluster_id``. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @return ReplicaStatusDataList
func (*ReplicaStatusApiService) ClustersClusterIdTopicsTopicNamePartitionsPartitionIdReplicaStatusGet ¶
func (a *ReplicaStatusApiService) ClustersClusterIdTopicsTopicNamePartitionsPartitionIdReplicaStatusGet(ctx _context.Context, clusterId string, topicName string, partitionId int32) (ReplicaStatusDataList, *_nethttp.Response, error)
* ClustersClusterIdTopicsTopicNamePartitionsPartitionIdReplicaStatusGet List Partition Replica Statuses. * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Return the all the replica statuses for the specified ``topic_name`` and ``partition_id``. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param topicName The topic name. * @param partitionId The partition ID. * @return ReplicaStatusDataList
func (*ReplicaStatusApiService) ClustersClusterIdTopicsTopicNamePartitionsReplicaStatusGet ¶
func (a *ReplicaStatusApiService) ClustersClusterIdTopicsTopicNamePartitionsReplicaStatusGet(ctx _context.Context, clusterId string, topicName string) (ReplicaStatusDataList, *_nethttp.Response, error)
* ClustersClusterIdTopicsTopicNamePartitionsReplicaStatusGet List All Partition Replica Statuses. * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Return the all the replica statuses for the specified ``topic_name``. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param topicName The topic name. * @return ReplicaStatusDataList
type ReplicaStatusData ¶
type ReplicaStatusData struct { Kind string `json:"kind"` Metadata ResourceMetadata `json:"metadata"` ClusterId string `json:"cluster_id"` TopicName string `json:"topic_name"` BrokerId int32 `json:"broker_id"` PartitionId int32 `json:"partition_id"` IsLeader bool `json:"is_leader"` IsObserver bool `json:"is_observer"` IsIsrEligible bool `json:"is_isr_eligible"` IsInIsr bool `json:"is_in_isr"` IsCaughtUp bool `json:"is_caught_up"` LogStartOffset int64 `json:"log_start_offset"` LogEndOffset int64 `json:"log_end_offset"` LastCaughtUpTimeMs int64 `json:"last_caught_up_time_ms"` LastFetchTimeMs int64 `json:"last_fetch_time_ms"` LinkName string `json:"link_name,omitempty"` }
ReplicaStatusData struct for ReplicaStatusData
type ReplicaStatusDataAllOf ¶
type ReplicaStatusDataAllOf struct { ClusterId string `json:"cluster_id"` TopicName string `json:"topic_name"` BrokerId int32 `json:"broker_id"` PartitionId int32 `json:"partition_id"` IsLeader bool `json:"is_leader"` IsObserver bool `json:"is_observer"` IsIsrEligible bool `json:"is_isr_eligible"` IsInIsr bool `json:"is_in_isr"` IsCaughtUp bool `json:"is_caught_up"` LogStartOffset int64 `json:"log_start_offset"` LogEndOffset int64 `json:"log_end_offset"` LastCaughtUpTimeMs int64 `json:"last_caught_up_time_ms"` LastFetchTimeMs int64 `json:"last_fetch_time_ms"` LinkName string `json:"link_name,omitempty"` }
ReplicaStatusDataAllOf struct for ReplicaStatusDataAllOf
type ReplicaStatusDataList ¶
type ReplicaStatusDataList struct { Kind string `json:"kind"` Metadata ResourceCollectionMetadata `json:"metadata"` Data []ReplicaStatusData `json:"data"` }
ReplicaStatusDataList struct for ReplicaStatusDataList
type ReplicaStatusDataListAllOf ¶
type ReplicaStatusDataListAllOf struct {
Data []ReplicaStatusData `json:"data"`
}
ReplicaStatusDataListAllOf struct for ReplicaStatusDataListAllOf
type ReplicaV3Api ¶ added in v0.3.8
type ReplicaV3Api interface { /* * ClustersClusterIdBrokersBrokerIdPartitionReplicasGet Search Replicas by Broker * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Returns the list of replicas assigned to the specified broker. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param brokerId The Kafka broker ID. * @return ReplicaDataList */ ClustersClusterIdBrokersBrokerIdPartitionReplicasGet(ctx _context.Context, clusterId string, brokerId int32) (ReplicaDataList, *_nethttp.Response, error) }
type ReplicaV3ApiService ¶ added in v0.3.8
type ReplicaV3ApiService service
ReplicaV3ApiService ReplicaV3Api service
func (*ReplicaV3ApiService) ClustersClusterIdBrokersBrokerIdPartitionReplicasGet ¶ added in v0.3.8
func (a *ReplicaV3ApiService) ClustersClusterIdBrokersBrokerIdPartitionReplicasGet(ctx _context.Context, clusterId string, brokerId int32) (ReplicaDataList, *_nethttp.Response, error)
* ClustersClusterIdBrokersBrokerIdPartitionReplicasGet Search Replicas by Broker * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Returns the list of replicas assigned to the specified broker. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param brokerId The Kafka broker ID. * @return ReplicaDataList
type Resource ¶
type Resource struct { Kind string `json:"kind"` Metadata ResourceMetadata `json:"metadata"` }
Resource struct for Resource
type ResourceCollection ¶
type ResourceCollection struct { Kind string `json:"kind"` Metadata ResourceCollectionMetadata `json:"metadata"` }
ResourceCollection struct for ResourceCollection
type ResourceCollectionMetadata ¶
type ResourceCollectionMetadata struct { Self string `json:"self"` Next *string `json:"next,omitempty"` }
ResourceCollectionMetadata struct for ResourceCollectionMetadata
type ResourceMetadata ¶
type ResourceMetadata struct { Self string `json:"self"` ResourceName *string `json:"resource_name,omitempty"` }
ResourceMetadata struct for ResourceMetadata
type ServerConfiguration ¶
type ServerConfiguration struct { Url string Description string Variables map[string]ServerVariable }
ServerConfiguration stores the information about a server
type ServerVariable ¶
ServerVariable stores the information about a server variable
type TopicConfigData ¶
type TopicConfigData struct { Kind string `json:"kind"` Metadata ResourceMetadata `json:"metadata"` ClusterId string `json:"cluster_id"` Name string `json:"name"` Value *string `json:"value,omitempty"` IsDefault bool `json:"is_default"` IsReadOnly bool `json:"is_read_only"` IsSensitive bool `json:"is_sensitive"` Source string `json:"source"` Synonyms []ConfigSynonymData `json:"synonyms"` TopicName string `json:"topic_name"` }
TopicConfigData struct for TopicConfigData
type TopicConfigDataAllOf ¶
type TopicConfigDataAllOf struct {
TopicName string `json:"topic_name"`
}
TopicConfigDataAllOf struct for TopicConfigDataAllOf
type TopicConfigDataList ¶
type TopicConfigDataList struct { Kind string `json:"kind"` Metadata ResourceCollectionMetadata `json:"metadata"` Data []TopicConfigData `json:"data"` }
TopicConfigDataList struct for TopicConfigDataList
type TopicConfigDataListAllOf ¶
type TopicConfigDataListAllOf struct {
Data []TopicConfigData `json:"data"`
}
TopicConfigDataListAllOf struct for TopicConfigDataListAllOf
type TopicData ¶
type TopicData struct { Kind string `json:"kind"` Metadata ResourceMetadata `json:"metadata"` ClusterId string `json:"cluster_id"` TopicName string `json:"topic_name"` IsInternal bool `json:"is_internal"` ReplicationFactor int32 `json:"replication_factor"` PartitionsCount int32 `json:"partitions_count"` Partitions Relationship `json:"partitions"` Configs Relationship `json:"configs"` PartitionReassignments Relationship `json:"partition_reassignments"` }
TopicData struct for TopicData
type TopicDataAllOf ¶
type TopicDataAllOf struct { ClusterId string `json:"cluster_id"` TopicName string `json:"topic_name"` IsInternal bool `json:"is_internal"` ReplicationFactor int32 `json:"replication_factor"` PartitionsCount int32 `json:"partitions_count"` Partitions Relationship `json:"partitions"` Configs Relationship `json:"configs"` PartitionReassignments Relationship `json:"partition_reassignments"` }
TopicDataAllOf struct for TopicDataAllOf
type TopicDataList ¶
type TopicDataList struct { Kind string `json:"kind"` Metadata ResourceCollectionMetadata `json:"metadata"` Data []TopicData `json:"data"` }
TopicDataList struct for TopicDataList
type TopicDataListAllOf ¶
type TopicDataListAllOf struct {
Data []TopicData `json:"data"`
}
TopicDataListAllOf struct for TopicDataListAllOf
type TopicList ¶
type TopicList struct {
Topics []string `json:"topics"`
}
TopicList struct for TopicList
type TopicV3Api ¶ added in v0.3.8
type TopicV3Api interface { /* * CreateKafkaTopic Create Topic * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Creates a topic. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param optional nil or *CreateKafkaTopicOpts - Optional Parameters: * @param "CreateTopicRequestData" (optional.Interface of CreateTopicRequestData) - The topic creation request. * @return TopicData */ CreateKafkaTopic(ctx _context.Context, clusterId string, localVarOptionals *CreateKafkaTopicOpts) (TopicData, *_nethttp.Response, error) /* * DeleteKafkaTopic Delete Topic * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Deletes the topic with the given `topic_name`. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param topicName The topic name. */ DeleteKafkaTopic(ctx _context.Context, clusterId string, topicName string) (*_nethttp.Response, error) /* * GetKafkaTopic Get Topic * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Returns the topic with the given `topic_name`. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param topicName The topic name. * @return TopicData */ GetKafkaTopic(ctx _context.Context, clusterId string, topicName string) (TopicData, *_nethttp.Response, error) /* * ListKafkaTopics List Topics * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Returns the list of topics that belong to the specified Kafka cluster. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @return TopicDataList */ ListKafkaTopics(ctx _context.Context, clusterId string) (TopicDataList, *_nethttp.Response, error) }
type TopicV3ApiService ¶ added in v0.3.8
type TopicV3ApiService service
TopicV3ApiService TopicV3Api service
func (*TopicV3ApiService) CreateKafkaTopic ¶ added in v0.3.8
func (a *TopicV3ApiService) CreateKafkaTopic(ctx _context.Context, clusterId string, localVarOptionals *CreateKafkaTopicOpts) (TopicData, *_nethttp.Response, error)
* CreateKafkaTopic Create Topic * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Creates a topic. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param optional nil or *CreateKafkaTopicOpts - Optional Parameters: * @param "CreateTopicRequestData" (optional.Interface of CreateTopicRequestData) - The topic creation request. * @return TopicData
func (*TopicV3ApiService) DeleteKafkaTopic ¶ added in v0.3.8
func (a *TopicV3ApiService) DeleteKafkaTopic(ctx _context.Context, clusterId string, topicName string) (*_nethttp.Response, error)
* DeleteKafkaTopic Delete Topic * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Deletes the topic with the given `topic_name`. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param topicName The topic name.
func (*TopicV3ApiService) GetKafkaTopic ¶ added in v0.3.8
func (a *TopicV3ApiService) GetKafkaTopic(ctx _context.Context, clusterId string, topicName string) (TopicData, *_nethttp.Response, error)
* GetKafkaTopic Get Topic * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Returns the topic with the given `topic_name`. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param topicName The topic name. * @return TopicData
func (*TopicV3ApiService) ListKafkaTopics ¶ added in v0.3.8
func (a *TopicV3ApiService) ListKafkaTopics(ctx _context.Context, clusterId string) (TopicDataList, *_nethttp.Response, error)
* ListKafkaTopics List Topics * * [![Generally Available](https://img.shields.io/badge/Lifecycle%20Stage-Generally%20Available-%2345c6e8)](#section/Versioning/API-Lifecycle-Policy) Returns the list of topics that belong to the specified Kafka cluster. * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @return TopicDataList
type UnregisterBrokerData ¶ added in v0.3.15
type UnregisterBrokerData struct { ClusterId string `json:"cluster_id"` BrokerId int32 `json:"broker_id"` }
UnregisterBrokerData struct for UnregisterBrokerData
type UnregisterV3Api ¶ added in v0.3.15
type UnregisterV3Api interface { /* * ClustersClusterIdBrokersBrokerIdunregisterPost Unregister a Broker * * Unregisters a broker from the cluster. This API is only supported for Kafka clusters running in KRaft mode. If run against a cluster running with ZooKeeper, a 400 response with an unsupported version error code will be returned (see BadRequestErrorResponse for more detail). * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param brokerId The Kafka broker ID. * @return UnregisterBrokerData */ ClustersClusterIdBrokersBrokerIdunregisterPost(ctx _context.Context, clusterId string, brokerId int32) (UnregisterBrokerData, *_nethttp.Response, error) }
type UnregisterV3ApiService ¶ added in v0.3.15
type UnregisterV3ApiService service
UnregisterV3ApiService UnregisterV3Api service
func (*UnregisterV3ApiService) ClustersClusterIdBrokersBrokerIdunregisterPost ¶ added in v0.3.15
func (a *UnregisterV3ApiService) ClustersClusterIdBrokersBrokerIdunregisterPost(ctx _context.Context, clusterId string, brokerId int32) (UnregisterBrokerData, *_nethttp.Response, error)
* ClustersClusterIdBrokersBrokerIdunregisterPost Unregister a Broker * * Unregisters a broker from the cluster. This API is only supported for Kafka clusters running in KRaft mode. If run against a cluster running with ZooKeeper, a 400 response with an unsupported version error code will be returned (see BadRequestErrorResponse for more detail). * * @param ctx _context.Context - for authentication, logging, cancellation, deadlines, tracing, etc. Passed from http.Request or context.Background(). * @param clusterId The Kafka cluster ID. * @param brokerId The Kafka broker ID. * @return UnregisterBrokerData
type UpdateConfigRequestData ¶
type UpdateConfigRequestData struct {
Value *string `json:"value,omitempty"`
}
UpdateConfigRequestData struct for UpdateConfigRequestData
type UpdateKafkaClusterConfigOpts ¶ added in v0.3.8
UpdateKafkaClusterConfigOpts Optional parameters for the method 'UpdateKafkaClusterConfig'
type UpdateKafkaClusterConfigsOpts ¶ added in v0.3.8
UpdateKafkaClusterConfigsOpts Optional parameters for the method 'UpdateKafkaClusterConfigs'
type UpdateKafkaLinkConfigBatchOpts ¶ added in v0.3.8
type UpdateKafkaLinkConfigBatchOpts struct { ValidateOnly optional.Bool AlterConfigBatchRequestData optional.Interface }
UpdateKafkaLinkConfigBatchOpts Optional parameters for the method 'UpdateKafkaLinkConfigBatch'
type UpdateKafkaLinkConfigOpts ¶ added in v0.3.8
UpdateKafkaLinkConfigOpts Optional parameters for the method 'UpdateKafkaLinkConfig'
type UpdateKafkaMirrorTopicsFailoverOpts ¶ added in v0.3.8
type UpdateKafkaMirrorTopicsFailoverOpts struct { ValidateOnly optional.Bool AlterMirrorsRequestData optional.Interface }
UpdateKafkaMirrorTopicsFailoverOpts Optional parameters for the method 'UpdateKafkaMirrorTopicsFailover'
type UpdateKafkaMirrorTopicsPauseOpts ¶ added in v0.3.8
type UpdateKafkaMirrorTopicsPauseOpts struct { ValidateOnly optional.Bool AlterMirrorsRequestData optional.Interface }
UpdateKafkaMirrorTopicsPauseOpts Optional parameters for the method 'UpdateKafkaMirrorTopicsPause'
type UpdateKafkaMirrorTopicsPromoteOpts ¶ added in v0.3.8
type UpdateKafkaMirrorTopicsPromoteOpts struct { ValidateOnly optional.Bool AlterMirrorsRequestData optional.Interface }
UpdateKafkaMirrorTopicsPromoteOpts Optional parameters for the method 'UpdateKafkaMirrorTopicsPromote'
type UpdateKafkaMirrorTopicsResumeOpts ¶ added in v0.3.8
type UpdateKafkaMirrorTopicsResumeOpts struct { ValidateOnly optional.Bool AlterMirrorsRequestData optional.Interface }
UpdateKafkaMirrorTopicsResumeOpts Optional parameters for the method 'UpdateKafkaMirrorTopicsResume'
type UpdateKafkaMirrorTopicsReverseAndPauseMirrorOpts ¶ added in v0.3.18
type UpdateKafkaMirrorTopicsReverseAndPauseMirrorOpts struct { ValidateOnly optional.Bool AlterMirrorsRequestData optional.Interface }
UpdateKafkaMirrorTopicsReverseAndPauseMirrorOpts Optional parameters for the method 'UpdateKafkaMirrorTopicsReverseAndPauseMirror'
type UpdateKafkaMirrorTopicsReverseAndStarMirrorOpts ¶ added in v0.3.18
type UpdateKafkaMirrorTopicsReverseAndStarMirrorOpts struct { ValidateOnly optional.Bool AlterMirrorsRequestData optional.Interface }
UpdateKafkaMirrorTopicsReverseAndStarMirrorOpts Optional parameters for the method 'UpdateKafkaMirrorTopicsReverseAndStarMirror'
type UpdateKafkaTopicConfigBatchOpts ¶ added in v0.3.8
UpdateKafkaTopicConfigBatchOpts Optional parameters for the method 'UpdateKafkaTopicConfigBatch'
type UpdateKafkaTopicConfigOpts ¶ added in v0.3.8
UpdateKafkaTopicConfigOpts Optional parameters for the method 'UpdateKafkaTopicConfig'
type UpdateLinkConfigRequestData ¶
type UpdateLinkConfigRequestData struct {
Value string `json:"value"`
}
UpdateLinkConfigRequestData struct for UpdateLinkConfigRequestData
Source Files ¶
- api_aclv3.go
- api_balancer_status_v3.go
- api_broker.go
- api_broker_replica_exclusion.go
- api_broker_task.go
- api_broker_v3.go
- api_cluster_linking_v3.go
- api_cluster_v3.go
- api_configs_v3.go
- api_consumer_group_v3.go
- api_partition.go
- api_partition_v3.go
- api_records_v3.go
- api_remove_broker_task.go
- api_replica.go
- api_replica_status.go
- api_replica_v3.go
- api_topic_v3.go
- api_unregister_v3.go
- client.go
- configuration.go
- model_abstract_config_data.go
- model_abstract_config_data_all_of.go
- model_acl_data.go
- model_acl_data_all_of.go
- model_acl_data_list.go
- model_acl_resource_type.go
- model_alter_broker_replica_exclusion_data.go
- model_alter_broker_replica_exclusion_data_all_of.go
- model_alter_broker_replica_exclusion_data_list.go
- model_alter_broker_replica_exclusion_data_list_all_of.go
- model_alter_config_batch_request_data.go
- model_alter_config_batch_request_data_data.go
- model_alter_mirror_status_response_data.go
- model_alter_mirror_status_response_data_all_of.go
- model_alter_mirror_status_response_data_list.go
- model_alter_mirror_status_response_data_list_all_of.go
- model_alter_mirrors_request_data.go
- model_any_uneven_load_data.go
- model_any_uneven_load_data_all_of.go
- model_balancer_status_data.go
- model_balancer_status_data_all_of.go
- model_broker_config_data.go
- model_broker_config_data_all_of.go
- model_broker_config_data_list.go
- model_broker_config_data_list_all_of.go
- model_broker_data.go
- model_broker_data_all_of.go
- model_broker_data_list.go
- model_broker_data_list_all_of.go
- model_broker_removal_data.go
- model_broker_removal_data_all_of.go
- model_broker_removal_data_list.go
- model_broker_removal_data_list_all_of.go
- model_broker_replica_exclusion_batch_request_data.go
- model_broker_replica_exclusion_data.go
- model_broker_replica_exclusion_data_all_of.go
- model_broker_replica_exclusion_data_list.go
- model_broker_replica_exclusion_data_list_all_of.go
- model_broker_replica_exclusion_request_data.go
- model_broker_task_data.go
- model_broker_task_data_all_of.go
- model_broker_task_data_list.go
- model_broker_task_data_list_all_of.go
- model_broker_task_type.go
- model_cluster_config_data.go
- model_cluster_config_data_all_of.go
- model_cluster_config_data_list.go
- model_cluster_config_data_list_all_of.go
- model_cluster_data.go
- model_cluster_data_all_of.go
- model_cluster_data_list.go
- model_cluster_data_list_all_of.go
- model_config_data.go
- model_config_synonym_data.go
- model_consumer_assignment_data.go
- model_consumer_assignment_data_all_of.go
- model_consumer_assignment_data_list.go
- model_consumer_assignment_data_list_all_of.go
- model_consumer_data.go
- model_consumer_data_all_of.go
- model_consumer_data_list.go
- model_consumer_data_list_all_of.go
- model_consumer_group_data.go
- model_consumer_group_data_all_of.go
- model_consumer_group_data_list.go
- model_consumer_group_data_list_all_of.go
- model_consumer_group_lag_summary_data.go
- model_consumer_group_lag_summary_data_all_of.go
- model_consumer_lag_data.go
- model_consumer_lag_data_all_of.go
- model_consumer_lag_data_list.go
- model_consumer_lag_data_list_all_of.go
- model_create_acl_request_data.go
- model_create_link_request_data.go
- model_create_mirror_topic_request_data.go
- model_create_topic_request_data.go
- model_create_topic_request_data_configs.go
- model_create_topic_request_data_replicas_assignments.go
- model_error.go
- model_inline_response_200.go
- model_link_task.go
- model_link_task_error.go
- model_list_link_configs_response_data.go
- model_list_link_configs_response_data_all_of.go
- model_list_link_configs_response_data_list.go
- model_list_link_configs_response_data_list_all_of.go
- model_list_links_response_data.go
- model_list_links_response_data_all_of.go
- model_list_links_response_data_list.go
- model_list_links_response_data_list_all_of.go
- model_list_mirror_topics_response_data.go
- model_list_mirror_topics_response_data_all_of.go
- model_list_mirror_topics_response_data_list.go
- model_list_mirror_topics_response_data_list_all_of.go
- model_mirror_lag.go
- model_mirror_topic_status.go
- model_partition_data.go
- model_partition_data_all_of.go
- model_partition_data_list.go
- model_partition_data_list_all_of.go
- model_produce_request.go
- model_produce_request_data.go
- model_produce_request_header.go
- model_produce_response.go
- model_produce_response_data.go
- model_reassignment_data.go
- model_reassignment_data_all_of.go
- model_reassignment_data_list.go
- model_reassignment_data_list_all_of.go
- model_relationship.go
- model_remove_broker_task_data.go
- model_remove_broker_task_data_all_of.go
- model_remove_broker_task_data_list.go
- model_remove_broker_task_data_list_all_of.go
- model_remove_brokers_request_data.go
- model_replica_data.go
- model_replica_data_all_of.go
- model_replica_data_list.go
- model_replica_data_list_all_of.go
- model_replica_status_data.go
- model_replica_status_data_all_of.go
- model_replica_status_data_list.go
- model_replica_status_data_list_all_of.go
- model_resource.go
- model_resource_collection.go
- model_resource_collection_metadata.go
- model_resource_metadata.go
- model_topic_config_data.go
- model_topic_config_data_all_of.go
- model_topic_config_data_list.go
- model_topic_config_data_list_all_of.go
- model_topic_data.go
- model_topic_data_all_of.go
- model_topic_data_list.go
- model_topic_data_list_all_of.go
- model_topic_list.go
- model_unregister_broker_data.go
- model_update_config_request_data.go
- model_update_link_config_request_data.go
- response.go