kafkarestv3

package module

Go to main page

Versions in this module

v0

v0.3.18

Jan 18, 2024

Changes in this version

type AlterMirrorsRequestData

+ MirrorTopicNamePattern string

type ClusterLinkingV3Api

+ UpdateKafkaMirrorTopicsReverseAndPauseMirror func(ctx _context.Context, clusterId string, linkName string, ...) (AlterMirrorStatusResponseDataList, *_nethttp.Response, error)

+ UpdateKafkaMirrorTopicsReverseAndStarMirror func(ctx _context.Context, clusterId string, linkName string, ...) (AlterMirrorStatusResponseDataList, *_nethttp.Response, error)

type ClusterLinkingV3ApiService

+ 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 CreateLinkRequestData

+ ClusterLinkId string

+ RemoteClusterId string

+ type GetKafkaLinkOpts struct

+ IncludeTasks optional.Bool

+ type LinkTask struct

+ Errors []LinkTaskError

+ State string

+ TaskName string

+ type LinkTaskError struct

+ ErrorCode string

+ ErrorMessage string

type ListLinksResponseData

+ LinkError string

+ LinkErrorMessage *string

+ LinkState string

+ RemoteClusterId *string

+ Tasks *[]LinkTask

type ListLinksResponseDataAllOf

+ LinkError string

+ LinkErrorMessage *string

+ LinkState string

+ RemoteClusterId *string

+ Tasks *[]LinkTask

type ListMirrorTopicsResponseData

+ MirrorStateTransitionErrors []LinkTaskError

+ MirrorTopicError string

type ListMirrorTopicsResponseDataAllOf

+ MirrorStateTransitionErrors []LinkTaskError

+ MirrorTopicError string

type MirrorTopicStatus

+ const MIRRORTOPICSTATUS_LINK_FAILED

+ const MIRRORTOPICSTATUS_LINK_PAUSED

+ const MIRRORTOPICSTATUS_SOURCE_UNAVAILABLE

+ const MIRRORTOPICSTATUS_UNKNOWN

+ type ReadKafkaMirrorTopicOpts struct

+ IncludeStateTransitionErrors optional.Bool

+ type UpdateKafkaMirrorTopicsReverseAndPauseMirrorOpts struct

+ AlterMirrorsRequestData optional.Interface

+ ValidateOnly optional.Bool

+ type UpdateKafkaMirrorTopicsReverseAndStarMirrorOpts struct

+ AlterMirrorsRequestData optional.Interface

+ ValidateOnly optional.Bool

v0.3.17

Oct 11, 2023

Changes in this version

type ClusterLinkingV3Api

+ UpdateKafkaMirrorTopicsPromoteLocalAndPauseRemoteMirror func(ctx _context.Context, clusterId string, linkName string, ...) (AlterMirrorStatusResponseDataList, *_nethttp.Response, error)

+ UpdateKafkaMirrorTopicsPromoteLocalAndStartRemoteMirror func(ctx _context.Context, clusterId string, linkName string, ...) (AlterMirrorStatusResponseDataList, *_nethttp.Response, error)

type ClusterLinkingV3ApiService

+ func (a *ClusterLinkingV3ApiService) UpdateKafkaMirrorTopicsPromoteLocalAndPauseRemoteMirror(ctx _context.Context, clusterId string, linkName string, ...) (AlterMirrorStatusResponseDataList, *_nethttp.Response, error)

+ func (a *ClusterLinkingV3ApiService) UpdateKafkaMirrorTopicsPromoteLocalAndStartRemoteMirror(ctx _context.Context, clusterId string, linkName string, ...) (AlterMirrorStatusResponseDataList, *_nethttp.Response, error)

type MirrorTopicStatus

+ const MIRRORTOPICSTATUS_PENDING_MIRROR

+ const MIRRORTOPICSTATUS_PENDING_SYNCHRONIZE

+ type UpdateKafkaMirrorTopicsPromoteLocalAndPauseRemoteMirrorOpts struct

+ AlterMirrorsRequestData optional.Interface

+ ValidateOnly optional.Bool

+ type UpdateKafkaMirrorTopicsPromoteLocalAndStartRemoteMirrorOpts struct

+ AlterMirrorsRequestData optional.Interface

+ ValidateOnly optional.Bool

v0.3.16

Jul 25, 2023

v0.3.15

Jul 13, 2022

Changes in this version

type APIClient

+ RecordsV3Api RecordsV3Api

+ UnregisterV3Api UnregisterV3Api

type ProduceRequestData

+ Schema *string

+ type RecordsV3Api interface

+ ClustersClusterIdTopicsTopicNameRecordsPost func(ctx _context.Context, clusterId string, topicName string, ...) (ProduceResponse, *_nethttp.Response, error)

+ type RecordsV3ApiService service

+ func (a *RecordsV3ApiService) ClustersClusterIdTopicsTopicNameRecordsPost(ctx _context.Context, clusterId string, topicName string, ...) (ProduceResponse, *_nethttp.Response, error)

+ type UnregisterBrokerData struct

+ BrokerId int32

+ ClusterId string

+ type UnregisterV3Api interface

+ ClustersClusterIdBrokersBrokerIdunregisterPost func(ctx _context.Context, clusterId string, brokerId int32) (UnregisterBrokerData, *_nethttp.Response, error)

+ type UnregisterV3ApiService service

+ func (a *UnregisterV3ApiService) ClustersClusterIdBrokersBrokerIdunregisterPost(ctx _context.Context, clusterId string, brokerId int32) (UnregisterBrokerData, *_nethttp.Response, error)

v0.3.14

Apr 1, 2022

Changes in this version

+ func PtrBool(v bool) *bool

+ func PtrFloat32(v float32) *float32

+ func PtrFloat64(v float64) *float64

+ func PtrInt(v int) *int

+ func PtrInt32(v int32) *int32

+ func PtrInt64(v int64) *int64

+ func PtrString(v string) *string

+ func PtrTime(v time.Time) *time.Time

type CreateKafkaLinkOpts

+ ValidateLink optional.Bool

+ ValidateOnly optional.Bool

type CreateLinkRequestData

+ DestinationClusterId string

+ type DeleteKafkaLinkOpts struct

+ Force optional.Bool

+ ValidateOnly optional.Bool

type ListLinksResponseData

+ ClusterLinkId string

+ DestinationClusterId *string

type ListLinksResponseDataAllOf

+ ClusterLinkId string

+ DestinationClusterId *string

+ type NullableBool struct

+ func NewNullableBool(val *bool) *NullableBool

+ func (v *NullableBool) Set(val *bool)

+ func (v *NullableBool) UnmarshalJSON(src []byte) error

+ func (v *NullableBool) Unset()

+ func (v NullableBool) Get() *bool

+ func (v NullableBool) IsSet() bool

+ func (v NullableBool) MarshalJSON() ([]byte, error)

+ type NullableFloat32 struct

+ func NewNullableFloat32(val *float32) *NullableFloat32

+ func (v *NullableFloat32) Set(val *float32)

+ func (v *NullableFloat32) UnmarshalJSON(src []byte) error

+ func (v *NullableFloat32) Unset()

+ func (v NullableFloat32) Get() *float32

+ func (v NullableFloat32) IsSet() bool

+ func (v NullableFloat32) MarshalJSON() ([]byte, error)

+ type NullableFloat64 struct

+ func NewNullableFloat64(val *float64) *NullableFloat64

+ func (v *NullableFloat64) Set(val *float64)

+ func (v *NullableFloat64) UnmarshalJSON(src []byte) error

+ func (v *NullableFloat64) Unset()

+ func (v NullableFloat64) Get() *float64

+ func (v NullableFloat64) IsSet() bool

+ func (v NullableFloat64) MarshalJSON() ([]byte, error)

+ type NullableInt struct

+ func NewNullableInt(val *int) *NullableInt

+ func (v *NullableInt) Set(val *int)

+ func (v *NullableInt) UnmarshalJSON(src []byte) error

+ func (v *NullableInt) Unset()

+ func (v NullableInt) Get() *int

+ func (v NullableInt) IsSet() bool

+ func (v NullableInt) MarshalJSON() ([]byte, error)

+ type NullableInt32 struct

+ func NewNullableInt32(val *int32) *NullableInt32

+ func (v *NullableInt32) Set(val *int32)

+ func (v *NullableInt32) UnmarshalJSON(src []byte) error

+ func (v *NullableInt32) Unset()

+ func (v NullableInt32) Get() *int32

+ func (v NullableInt32) IsSet() bool

+ func (v NullableInt32) MarshalJSON() ([]byte, error)

+ type NullableInt64 struct

+ func NewNullableInt64(val *int64) *NullableInt64

+ func (v *NullableInt64) Set(val *int64)

+ func (v *NullableInt64) UnmarshalJSON(src []byte) error

+ func (v *NullableInt64) Unset()

+ func (v NullableInt64) Get() *int64

+ func (v NullableInt64) IsSet() bool

+ func (v NullableInt64) MarshalJSON() ([]byte, error)

+ type NullableString struct

+ func NewNullableString(val *string) *NullableString

+ func (v *NullableString) Set(val *string)

+ func (v *NullableString) UnmarshalJSON(src []byte) error

+ func (v *NullableString) Unset()

+ func (v NullableString) Get() *string

+ func (v NullableString) IsSet() bool

+ func (v NullableString) MarshalJSON() ([]byte, error)

+ type NullableTime struct

+ func NewNullableTime(val *time.Time) *NullableTime

+ func (v *NullableTime) Set(val *time.Time)

+ func (v *NullableTime) UnmarshalJSON(src []byte) error

+ func (v *NullableTime) Unset()

+ func (v NullableTime) Get() *time.Time

+ func (v NullableTime) IsSet() bool

+ func (v NullableTime) MarshalJSON() ([]byte, error)

type UpdateKafkaLinkConfigBatchOpts

+ ValidateOnly optional.Bool

v0.3.13

Jan 25, 2022

Changes in this version

type CreateMirrorTopicRequestData

+ MirrorTopicName string

v0.3.12

Oct 26, 2021

v0.3.11

Oct 26, 2021

v0.3.10

Oct 25, 2021

v0.3.9

Oct 25, 2021

v0.3.8

Oct 25, 2021

Changes in this version

+ type ACLV3Api interface

+ CreateKafkaAcls func(ctx _context.Context, clusterId string, localVarOptionals *CreateKafkaAclsOpts) (*_nethttp.Response, error)

+ DeleteKafkaAcls func(ctx _context.Context, clusterId string, localVarOptionals *DeleteKafkaAclsOpts) (InlineResponse200, *_nethttp.Response, error)

+ GetKafkaAcls func(ctx _context.Context, clusterId string, localVarOptionals *GetKafkaAclsOpts) (AclDataList, *_nethttp.Response, error)

+ type ACLV3ApiService service

+ 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

+ ACLV3Api ACLV3Api

+ BalancerStatusV3Api BalancerStatusV3Api

+ BrokerReplicaExclusionApi BrokerReplicaExclusionApi

+ BrokerV3Api BrokerV3Api

+ ClusterLinkingV3Api ClusterLinkingV3Api

+ ClusterV3Api ClusterV3Api

+ ConfigsV3Api ConfigsV3Api

+ ConsumerGroupV3Api ConsumerGroupV3Api

+ PartitionV3Api PartitionV3Api

+ RecordsApi RecordsApi

+ RemoveBrokerTaskApi RemoveBrokerTaskApi

+ ReplicaV3Api ReplicaV3Api

+ TopicV3Api TopicV3Api

+ type AlterBrokerReplicaExclusionData struct

+ Broker Relationship

+ BrokerId int32

+ ClusterId string

+ ErrorCode *int32

+ ErrorMessage *string

+ Exclusion ExclusionOp

+ Kind string

+ Metadata ResourceMetadata

+ Reason string

+ type AlterBrokerReplicaExclusionDataAllOf struct

+ Broker Relationship

+ BrokerId int32

+ ClusterId string

+ ErrorCode *int32

+ ErrorMessage *string

+ Exclusion ExclusionOp

+ Reason string

+ type AlterBrokerReplicaExclusionDataList struct

+ Data []AlterBrokerReplicaExclusionData

+ Kind string

+ Metadata ResourceCollectionMetadata

+ type AlterBrokerReplicaExclusionDataListAllOf struct

+ Data []AlterBrokerReplicaExclusionData

type AnyUnevenLoadStatus

+ const ANYUNEVENLOADSTATUS_UNKNOWN

type BalancerStatus

+ const BALANCERSTATUS_UNKNOWN

+ type BalancerStatusV3Api interface

+ ClustersClusterIdBalancerAnyUnevenLoadGet func(ctx _context.Context, clusterId string) (AnyUnevenLoadData, *_nethttp.Response, error)

+ ClustersClusterIdBalancerGet func(ctx _context.Context, clusterId string) (BalancerStatusData, *_nethttp.Response, error)

+ type BalancerStatusV3ApiService service

+ 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 BrokerReplicaExclusionApi interface

+ ClustersClusterIdBrokerReplicaExclusionsBrokerIdGet func(ctx _context.Context, clusterId string, brokerId int32) (BrokerReplicaExclusionData, *_nethttp.Response, error)

+ ClustersClusterIdBrokerReplicaExclusionsGet func(ctx _context.Context, clusterId string) (BrokerReplicaExclusionDataList, *_nethttp.Response, error)

+ ClustersClusterIdBrokerReplicaExclusionscreatePost func(ctx _context.Context, clusterId string, ...) (AlterBrokerReplicaExclusionDataList, *_nethttp.Response, error)

+ ClustersClusterIdBrokerReplicaExclusionsdeletePost func(ctx _context.Context, clusterId string, ...) (AlterBrokerReplicaExclusionDataList, *_nethttp.Response, error)

+ type BrokerReplicaExclusionApiService service

+ 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 struct

+ Data []BrokerReplicaExclusionRequestData

+ type BrokerReplicaExclusionData struct

+ Broker Relationship

+ BrokerId int32

+ ClusterId string

+ Kind string

+ Metadata ResourceMetadata

+ Reason string

+ type BrokerReplicaExclusionDataAllOf struct

+ Broker Relationship

+ BrokerId int32

+ ClusterId string

+ Reason string

+ type BrokerReplicaExclusionDataList struct

+ Data []BrokerReplicaExclusionData

+ Kind string

+ Metadata ResourceCollectionMetadata

+ type BrokerReplicaExclusionDataListAllOf struct

+ Data []BrokerReplicaExclusionData

+ type BrokerReplicaExclusionRequestData struct

+ BrokerId int32

+ Reason string

+ type BrokerReplicaExclusionStatus string

+ const BROKERREPLICAEXCLUSIONSTATUS_CANCELED

+ const BROKERREPLICAEXCLUSIONSTATUS_COMPLETED

+ const BROKERREPLICAEXCLUSIONSTATUS_ERROR

+ const BROKERREPLICAEXCLUSIONSTATUS_EXCLUDED

+ const BROKERREPLICAEXCLUSIONSTATUS_IN_PROGRESS

+ const BROKERREPLICAEXCLUSIONSTATUS_PENDING

+ const BROKERREPLICAEXCLUSIONSTATUS_REMOVING

+ const BROKERREPLICAEXCLUSIONSTATUS_UNKNOWN

type BrokerShutdownStatus

+ const BROKERSHUTDOWNSTATUS_IN_PROGRESS

+ const BROKERSHUTDOWNSTATUS_UNKNOWN

type BrokerTaskStatus

+ const BROKERTASKSTATUS_UNKNOWN

+ type BrokerV3Api interface

+ ClustersClusterIdBrokersBrokerIdDelete func(ctx _context.Context, clusterId string, brokerId int32, ...) (BrokerRemovalData, *_nethttp.Response, error)

+ ClustersClusterIdBrokersBrokerIdGet func(ctx _context.Context, clusterId string, brokerId int32) (BrokerData, *_nethttp.Response, error)

+ ClustersClusterIdBrokersBrokerIdPartitionReplicasGet func(ctx _context.Context, clusterId string, brokerId int32) (ReplicaDataList, *_nethttp.Response, error)

+ ClustersClusterIdBrokersGet func(ctx _context.Context, clusterId string) (BrokerDataList, *_nethttp.Response, error)

+ type BrokerV3ApiService service

+ 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 ClusterLinkingV3Api interface

+ CreateKafkaLink func(ctx _context.Context, clusterId string, linkName string, ...) (*_nethttp.Response, error)

+ CreateKafkaMirrorTopic func(ctx _context.Context, clusterId string, linkName string, ...) (*_nethttp.Response, error)

+ DeleteKafkaLink func(ctx _context.Context, clusterId string, linkName string) (*_nethttp.Response, error)

+ DeleteKafkaLinkConfig func(ctx _context.Context, clusterId string, linkName string, configName string) (*_nethttp.Response, error)

+ GetKafkaLink func(ctx _context.Context, clusterId string, linkName string) (ListLinksResponseData, *_nethttp.Response, error)

+ GetKafkaLinkConfigs func(ctx _context.Context, clusterId string, linkName string, configName string) (ListLinkConfigsResponseData, *_nethttp.Response, error)

+ ListKafkaLinkConfigs func(ctx _context.Context, clusterId string, linkName string) (ListLinkConfigsResponseDataList, *_nethttp.Response, error)

+ ListKafkaLinks func(ctx _context.Context, clusterId string) (ListLinksResponseDataList, *_nethttp.Response, error)

+ ListKafkaMirrorTopics func(ctx _context.Context, clusterId string, ...) (ListMirrorTopicsResponseDataList, *_nethttp.Response, error)

+ ListKafkaMirrorTopicsUnderLink func(ctx _context.Context, clusterId string, linkName string, ...) (ListMirrorTopicsResponseDataList, *_nethttp.Response, error)

+ ReadKafkaMirrorTopic func(ctx _context.Context, clusterId string, linkName string, ...) (ListMirrorTopicsResponseData, *_nethttp.Response, error)

+ UpdateKafkaLinkConfig func(ctx _context.Context, clusterId string, linkName string, configName string, ...) (*_nethttp.Response, error)

+ UpdateKafkaLinkConfigBatch func(ctx _context.Context, clusterId string, linkName string, ...) (*_nethttp.Response, error)

+ UpdateKafkaMirrorTopicsFailover func(ctx _context.Context, clusterId string, linkName string, ...) (AlterMirrorStatusResponseDataList, *_nethttp.Response, error)

+ UpdateKafkaMirrorTopicsPause func(ctx _context.Context, clusterId string, linkName string, ...) (AlterMirrorStatusResponseDataList, *_nethttp.Response, error)

+ UpdateKafkaMirrorTopicsPromote func(ctx _context.Context, clusterId string, linkName string, ...) (AlterMirrorStatusResponseDataList, *_nethttp.Response, error)

+ UpdateKafkaMirrorTopicsResume func(ctx _context.Context, clusterId string, linkName string, ...) (AlterMirrorStatusResponseDataList, *_nethttp.Response, error)

+ type ClusterLinkingV3ApiService service

+ 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)

+ type ClusterV3Api interface

+ ClustersGet func(ctx _context.Context) (ClusterDataList, *_nethttp.Response, error)

+ GetKafkaCluster func(ctx _context.Context, clusterId string) (ClusterData, *_nethttp.Response, error)

+ type ClusterV3ApiService service

+ func (a *ClusterV3ApiService) ClustersGet(ctx _context.Context) (ClusterDataList, *_nethttp.Response, error)

+ func (a *ClusterV3ApiService) GetKafkaCluster(ctx _context.Context, clusterId string) (ClusterData, *_nethttp.Response, error)

+ type ClustersClusterIdBrokerReplicaExclusionscreatePostOpts struct

+ BrokerReplicaExclusionBatchRequestData optional.Interface

+ type ClustersClusterIdBrokerReplicaExclusionsdeletePostOpts struct

+ BrokerReplicaExclusionBatchRequestData optional.Interface

+ type ClustersClusterIdTopicsTopicNameRecordsPostOpts struct

+ ProduceRequest optional.Interface

+ type ConfigsV3Api interface

+ ClustersClusterIdBrokersBrokerIdConfigsGet func(ctx _context.Context, clusterId string, brokerId int32) (BrokerConfigDataList, *_nethttp.Response, error)

+ ClustersClusterIdBrokersBrokerIdConfigsNameDelete func(ctx _context.Context, clusterId string, brokerId int32, name string) (*_nethttp.Response, error)

+ ClustersClusterIdBrokersBrokerIdConfigsNameGet func(ctx _context.Context, clusterId string, brokerId int32, name string) (BrokerConfigData, *_nethttp.Response, error)

+ ClustersClusterIdBrokersBrokerIdConfigsNamePut func(ctx _context.Context, clusterId string, brokerId int32, name string, ...) (*_nethttp.Response, error)

+ ClustersClusterIdBrokersBrokerIdConfigsalterPost func(ctx _context.Context, clusterId string, brokerId int32, ...) (*_nethttp.Response, error)

+ ClustersClusterIdBrokersConfigsGet func(ctx _context.Context, clusterId string) (BrokerConfigDataList, *_nethttp.Response, error)

+ DeleteKafkaClusterConfig func(ctx _context.Context, clusterId string, name string) (*_nethttp.Response, error)

+ DeleteKafkaTopicConfig func(ctx _context.Context, clusterId string, topicName string, name string) (*_nethttp.Response, error)

+ GetKafkaClusterConfig func(ctx _context.Context, clusterId string, name string) (ClusterConfigData, *_nethttp.Response, error)

+ GetKafkaTopicConfig func(ctx _context.Context, clusterId string, topicName string, name string) (TopicConfigData, *_nethttp.Response, error)

+ ListKafkaAllTopicConfigs func(ctx _context.Context, clusterId string) (TopicConfigDataList, *_nethttp.Response, error)

+ ListKafkaClusterConfigs func(ctx _context.Context, clusterId string) (ClusterConfigDataList, *_nethttp.Response, error)

+ ListKafkaDefaultTopicConfigs func(ctx _context.Context, clusterId string, topicName string) (TopicConfigDataList, *_nethttp.Response, error)

+ ListKafkaTopicConfigs func(ctx _context.Context, clusterId string, topicName string) (TopicConfigDataList, *_nethttp.Response, error)

+ UpdateKafkaClusterConfig func(ctx _context.Context, clusterId string, name string, ...) (*_nethttp.Response, error)

+ UpdateKafkaClusterConfigs func(ctx _context.Context, clusterId string, ...) (*_nethttp.Response, error)

+ UpdateKafkaTopicConfig func(ctx _context.Context, clusterId string, topicName string, name string, ...) (*_nethttp.Response, error)

+ UpdateKafkaTopicConfigBatch func(ctx _context.Context, clusterId string, topicName string, ...) (*_nethttp.Response, error)

+ type ConfigsV3ApiService service

+ 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 ConsumerGroupV3Api interface

+ GetKafkaConsumer func(ctx _context.Context, clusterId string, consumerGroupId string, ...) (ConsumerData, *_nethttp.Response, error)

+ GetKafkaConsumerAssignment func(ctx _context.Context, clusterId string, consumerGroupId string, ...) (ConsumerAssignmentData, *_nethttp.Response, error)

+ GetKafkaConsumerGroup func(ctx _context.Context, clusterId string, consumerGroupId string) (ConsumerGroupData, *_nethttp.Response, error)

+ GetKafkaConsumerGroupLagSummary func(ctx _context.Context, clusterId string, consumerGroupId string) (ConsumerGroupLagSummaryData, *_nethttp.Response, error)

+ ListKafkaConsumerAssignment func(ctx _context.Context, clusterId string, consumerGroupId string, ...) (ConsumerAssignmentDataList, *_nethttp.Response, error)

+ ListKafkaConsumerGroups func(ctx _context.Context, clusterId string) (ConsumerGroupDataList, *_nethttp.Response, error)

+ ListKafkaConsumerLags func(ctx _context.Context, clusterId string, consumerGroupId string) (ConsumerLagDataList, *_nethttp.Response, error)

+ ListKafkaConsumers func(ctx _context.Context, clusterId string, consumerGroupId string) (ConsumerDataList, *_nethttp.Response, error)

+ type ConsumerGroupV3ApiService service

+ 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 CreateKafkaAclsOpts struct

+ CreateAclRequestData optional.Interface

+ type CreateKafkaLinkOpts struct

+ CreateLinkRequestData optional.Interface

+ type CreateKafkaMirrorTopicOpts struct

+ CreateMirrorTopicRequestData optional.Interface

+ type CreateKafkaTopicOpts struct

+ CreateTopicRequestData optional.Interface

+ type DeleteKafkaAclsOpts struct

+ Host optional.String

+ Operation optional.Interface

+ PatternType optional.Interface

+ Permission optional.Interface

+ Principal optional.String

+ ResourceName optional.String

+ ResourceType optional.Interface

+ type ExclusionOp string

+ const EXCLUSIONOP_DELETE

+ const EXCLUSIONOP_SET

+ const EXCLUSIONOP_UNKNOWN

+ type GetKafkaAclsOpts struct

+ Host optional.String

+ Operation optional.Interface

+ PatternType optional.Interface

+ Permission optional.Interface

+ Principal optional.String

+ ResourceName optional.String

+ ResourceType optional.Interface

+ type ListKafkaMirrorTopicsOpts struct

+ MirrorStatus optional.Interface

+ type ListKafkaMirrorTopicsUnderLinkOpts struct

+ MirrorStatus optional.Interface

type ListLinksResponseData

+ TopicsNames []string

type ListLinksResponseDataAllOf

+ TopicsNames []string

type ListMirrorTopicsResponseData

+ MirrorTopicStatus MirrorTopicStatus

type ListMirrorTopicsResponseDataAllOf

+ MirrorTopicStatus MirrorTopicStatus

+ type MirrorLags struct

type PartitionReassignmentStatus

+ const PARTITIONREASSIGNMENTSTATUS_UNKNOWN

+ type PartitionV3Api interface

+ GetKafkaConsumerLag func(ctx _context.Context, clusterId string, consumerGroupId string, ...) (ConsumerLagData, *_nethttp.Response, error)

+ GetKafkaPartition func(ctx _context.Context, clusterId string, topicName string, partitionId int32) (PartitionData, *_nethttp.Response, error)

+ ListKafkaPartitions func(ctx _context.Context, clusterId string, topicName string) (PartitionDataList, *_nethttp.Response, error)

+ type PartitionV3ApiService service

+ 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 struct

+ Headers []ProduceRequestHeader

+ Key *ProduceRequestData

+ PartitionId *int32

+ Timestamp *time.Time

+ Value *ProduceRequestData

+ type ProduceRequestData struct

+ Data *interface{}

+ RawSchema *string

+ SchemaId *int32

+ SchemaVersion *int32

+ Subject *string

+ SubjectNameStrategy *string

+ Type string

+ type ProduceRequestHeader struct

+ Name string

+ Value *string

+ type ProduceResponse struct

+ ClusterId string

+ Key *ProduceResponseData

+ Offset int32

+ PartitionId int32

+ Timestamp *time.Time

+ TopicName string

+ Value *ProduceResponseData

+ type ProduceResponseData struct

+ SchemaId *int32

+ SchemaVersion *int32

+ Size int32

+ Subject *string

+ Type *string

+ type RecordsApi interface

+ ClustersClusterIdTopicsTopicNameRecordsPost func(ctx _context.Context, clusterId string, topicName string, ...) (ProduceResponse, *_nethttp.Response, error)

+ type RecordsApiService service

+ func (a *RecordsApiService) ClustersClusterIdTopicsTopicNameRecordsPost(ctx _context.Context, clusterId string, topicName string, ...) (ProduceResponse, *_nethttp.Response, error)

type RemoveBrokerTaskData

+ BrokerReplicaExclusionStatus BrokerReplicaExclusionStatus

+ ShutdownScheduled bool

type RemoveBrokerTaskDataAllOf

+ BrokerReplicaExclusionStatus BrokerReplicaExclusionStatus

+ ShutdownScheduled bool

type ReplicaStatusApi

+ ClustersClusterIdTopicsPartitionsReplicaStatusGet func(ctx _context.Context, clusterId string) (ReplicaStatusDataList, *_nethttp.Response, error)

type ReplicaStatusApiService

+ func (a *ReplicaStatusApiService) ClustersClusterIdTopicsPartitionsReplicaStatusGet(ctx _context.Context, clusterId string) (ReplicaStatusDataList, *_nethttp.Response, error)

+ type ReplicaV3Api interface

+ ClustersClusterIdBrokersBrokerIdPartitionReplicasGet func(ctx _context.Context, clusterId string, brokerId int32) (ReplicaDataList, *_nethttp.Response, error)

+ type ReplicaV3ApiService service

+ func (a *ReplicaV3ApiService) ClustersClusterIdBrokersBrokerIdPartitionReplicasGet(ctx _context.Context, clusterId string, brokerId int32) (ReplicaDataList, *_nethttp.Response, error)

type TopicData

+ PartitionsCount int32

type TopicDataAllOf

+ PartitionsCount int32

+ type TopicV3Api interface

+ CreateKafkaTopic func(ctx _context.Context, clusterId string, ...) (TopicData, *_nethttp.Response, error)

+ DeleteKafkaTopic func(ctx _context.Context, clusterId string, topicName string) (*_nethttp.Response, error)

+ GetKafkaTopic func(ctx _context.Context, clusterId string, topicName string) (TopicData, *_nethttp.Response, error)

+ ListKafkaTopics func(ctx _context.Context, clusterId string) (TopicDataList, *_nethttp.Response, error)

+ type TopicV3ApiService service

+ 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 UpdateKafkaClusterConfigOpts struct

+ UpdateConfigRequestData optional.Interface

+ type UpdateKafkaClusterConfigsOpts struct

+ AlterConfigBatchRequestData optional.Interface

+ type UpdateKafkaLinkConfigBatchOpts struct

+ AlterConfigBatchRequestData optional.Interface

+ type UpdateKafkaLinkConfigOpts struct

+ UpdateLinkConfigRequestData optional.Interface

+ type UpdateKafkaMirrorTopicsFailoverOpts struct

+ AlterMirrorsRequestData optional.Interface

+ ValidateOnly optional.Bool

+ type UpdateKafkaMirrorTopicsPauseOpts struct

+ AlterMirrorsRequestData optional.Interface

+ ValidateOnly optional.Bool

+ type UpdateKafkaMirrorTopicsPromoteOpts struct

+ AlterMirrorsRequestData optional.Interface

+ ValidateOnly optional.Bool

+ type UpdateKafkaMirrorTopicsResumeOpts struct

+ AlterMirrorsRequestData optional.Interface

+ ValidateOnly optional.Bool

+ type UpdateKafkaTopicConfigBatchOpts struct

+ AlterConfigBatchRequestData optional.Interface

+ type UpdateKafkaTopicConfigOpts struct

+ UpdateConfigRequestData optional.Interface

v0.3.7

Sep 22, 2021

v0.3.6

Sep 22, 2021

Changes in this version

+ var ContextAPIKey = contextKey("apikey")

+ var ContextAccessToken = contextKey("accesstoken")

+ var ContextBasicAuth = contextKey("basic")

+ var ContextOAuth2 = contextKey("token")

+ func CacheExpires(r *http.Response) time.Time

+ type ACLApi interface

+ ClustersClusterIdAclsDelete func(ctx _context.Context, clusterId string, ...) (InlineResponse200, *_nethttp.Response, error)

+ ClustersClusterIdAclsGet func(ctx _context.Context, clusterId string, ...) (AclDataList, *_nethttp.Response, error)

+ ClustersClusterIdAclsPost func(ctx _context.Context, clusterId string, ...) (*_nethttp.Response, error)

+ type ACLApiService service

+ func (a *ACLApiService) ClustersClusterIdAclsDelete(ctx _context.Context, clusterId string, ...) (InlineResponse200, *_nethttp.Response, error)

+ func (a *ACLApiService) ClustersClusterIdAclsGet(ctx _context.Context, clusterId string, ...) (AclDataList, *_nethttp.Response, error)

+ func (a *ACLApiService) ClustersClusterIdAclsPost(ctx _context.Context, clusterId string, ...) (*_nethttp.Response, error)

+ type APIClient struct

+ ACLApi ACLApi

+ BrokerApi BrokerApi

+ BrokerTaskApi BrokerTaskApi

+ ClusterApi ClusterApi

+ ClusterLinkingApi ClusterLinkingApi

+ ConfigsApi ConfigsApi

+ ConsumerGroupApi ConsumerGroupApi

+ PartitionApi PartitionApi

+ ReplicaApi ReplicaApi

+ ReplicaStatusApi ReplicaStatusApi

+ TopicApi TopicApi

+ func NewAPIClient(cfg *Configuration) *APIClient

+ func (c *APIClient) ChangeBasePath(path string)

+ func (c *APIClient) GetConfig() *Configuration

+ type APIKey struct

+ Key string

+ Prefix string

+ type APIResponse struct

+ Message string

+ Method string

+ Operation string

+ Payload []byte

+ RequestURL string

+ func NewAPIResponse(r *http.Response) *APIResponse

+ func NewAPIResponseWithError(errorMessage string) *APIResponse

+ type AbstractConfigData struct

+ ClusterId string

+ IsDefault bool

+ IsReadOnly bool

+ IsSensitive bool

+ Kind string

+ Metadata ResourceMetadata

+ Name string

+ Source ConfigSource

+ Synonyms []ConfigSynonymData

+ Value *string

+ type AbstractConfigDataAllOf struct

+ ClusterId string

+ IsDefault bool

+ IsReadOnly bool

+ IsSensitive bool

+ Name string

+ Source ConfigSource

+ Synonyms []ConfigSynonymData

+ Value *string

+ type AclData struct

+ ClusterId string

+ Host string

+ Kind string

+ Metadata ResourceMetadata

+ Operation AclOperation

+ PatternType AclPatternType

+ Permission AclPermission

+ Principal string

+ ResourceName string

+ ResourceType AclResourceType

+ type AclDataAllOf struct

+ ClusterId string

+ Host string

+ Operation AclOperation

+ PatternType AclPatternType

+ Permission AclPermission

+ Principal string

+ ResourceName string

+ ResourceType AclResourceType

+ type AclDataList struct

+ Data []AclData

+ Kind string

+ Metadata ResourceCollectionMetadata

+ type AclOperation string

+ const ACLOPERATION_ALL

+ const ACLOPERATION_ALTER

+ const ACLOPERATION_ALTER_CONFIGS

+ const ACLOPERATION_ANY

+ const ACLOPERATION_CLUSTER_ACTION

+ const ACLOPERATION_CREATE

+ const ACLOPERATION_DELETE

+ const ACLOPERATION_DESCRIBE

+ const ACLOPERATION_DESCRIBE_CONFIGS

+ const ACLOPERATION_IDEMPOTENT_WRITE

+ const ACLOPERATION_READ

+ const ACLOPERATION_UNKNOWN

+ const ACLOPERATION_WRITE

+ type AclPatternType string

+ const ACLPATTERNTYPE_ANY

+ const ACLPATTERNTYPE_LITERAL

+ const ACLPATTERNTYPE_MATCH

+ const ACLPATTERNTYPE_PREFIXED

+ const ACLPATTERNTYPE_UNKNOWN

+ type AclPermission string

+ const ACLPERMISSION_ALLOW

+ const ACLPERMISSION_ANY

+ const ACLPERMISSION_DENY

+ const ACLPERMISSION_UNKNOWN

+ type AclResourceType string

+ const ACLRESOURCETYPE_ANY

+ const ACLRESOURCETYPE_CLUSTER

+ const ACLRESOURCETYPE_DELEGATION_TOKEN

+ const ACLRESOURCETYPE_GROUP

+ const ACLRESOURCETYPE_TOPIC

+ const ACLRESOURCETYPE_TRANSACTIONAL_ID

+ const ACLRESOURCETYPE_UNKNOWN

+ type AlterConfigBatchRequestData struct

+ Data []AlterConfigBatchRequestDataData

+ type AlterConfigBatchRequestDataData struct

+ Name string

+ Operation *string

+ Value *string

+ type AlterMirrorStatusResponseData struct

+ ErrorCode *int32

+ ErrorMessage *string

+ Kind string

+ Metadata ResourceMetadata

+ MirrorLags []MirrorLag

+ MirrorTopicName string

+ type AlterMirrorStatusResponseDataAllOf struct

+ ErrorCode *int32

+ ErrorMessage *string

+ MirrorLags []MirrorLag

+ MirrorTopicName string

+ type AlterMirrorStatusResponseDataList struct

+ Data []AlterMirrorStatusResponseData

+ Kind string

+ Metadata ResourceCollectionMetadata

+ type AlterMirrorStatusResponseDataListAllOf struct

+ Data []AlterMirrorStatusResponseData

+ type AlterMirrorsRequestData struct

+ MirrorTopicNames []string

+ type AnyUnevenLoadData struct

+ BrokerTasks Relationship

+ ClusterId string

+ ErrorCode *int32

+ ErrorMessage *string

+ Kind string

+ Metadata ResourceMetadata

+ PreviousStatus AnyUnevenLoadStatus

+ PreviousStatusUpdatedAt time.Time

+ Status AnyUnevenLoadStatus

+ StatusUpdatedAt time.Time

+ type AnyUnevenLoadDataAllOf struct

+ BrokerTasks Relationship

+ ClusterId string

+ ErrorCode *int32

+ ErrorMessage *string

+ PreviousStatus AnyUnevenLoadStatus

+ PreviousStatusUpdatedAt time.Time

+ Status AnyUnevenLoadStatus

+ StatusUpdatedAt time.Time

+ type AnyUnevenLoadStatus string

+ const ANYUNEVENLOADSTATUS_ABORTED

+ const ANYUNEVENLOADSTATUS_BALANCED

+ const ANYUNEVENLOADSTATUS_BALANCING

+ const ANYUNEVENLOADSTATUS_BALANCING_FAILED

+ const ANYUNEVENLOADSTATUS_DISABLED

+ const ANYUNEVENLOADSTATUS_STARTING

+ type BalancerStatus string

+ const BALANCERSTATUS_BOOTSTRAPPING

+ const BALANCERSTATUS_DISABLED

+ const BALANCERSTATUS_ENABLED

+ const BALANCERSTATUS_ERROR

+ const BALANCERSTATUS_FAILOVER

+ const BALANCERSTATUS_LOAD_FAILURE

+ const BALANCERSTATUS_STARTING

+ type BalancerStatusApi interface

+ ClustersClusterIdBalancerAnyUnevenLoadGet func(ctx _context.Context, clusterId string) (AnyUnevenLoadData, *_nethttp.Response, error)

+ ClustersClusterIdBalancerGet func(ctx _context.Context, clusterId string) (BalancerStatusData, *_nethttp.Response, error)

+ type BalancerStatusApiService service

+ func (a *BalancerStatusApiService) ClustersClusterIdBalancerAnyUnevenLoadGet(ctx _context.Context, clusterId string) (AnyUnevenLoadData, *_nethttp.Response, error)

+ func (a *BalancerStatusApiService) ClustersClusterIdBalancerGet(ctx _context.Context, clusterId string) (BalancerStatusData, *_nethttp.Response, error)

+ type BalancerStatusData struct

+ AnyUnevenLoad Relationship

+ BrokerTasks Relationship

+ ClusterId string

+ ErrorCode *int32

+ ErrorMessage *string

+ Kind string

+ Metadata ResourceMetadata

+ Status BalancerStatus

+ type BalancerStatusDataAllOf struct

+ AnyUnevenLoad Relationship

+ BrokerTasks Relationship

+ ClusterId string

+ ErrorCode *int32

+ ErrorMessage *string

+ Status BalancerStatus

+ type BasicAuth struct

+ Password string

+ UserName string

+ type BrokerApi interface

+ ClustersClusterIdBrokersBrokerIdDelete func(ctx _context.Context, clusterId string, brokerId int32, ...) (BrokerRemovalData, *_nethttp.Response, error)

+ ClustersClusterIdBrokersBrokerIdGet func(ctx _context.Context, clusterId string, brokerId int32) (BrokerData, *_nethttp.Response, error)

+ ClustersClusterIdBrokersBrokerIdPartitionReplicasGet func(ctx _context.Context, clusterId string, brokerId int32) (ReplicaDataList, *_nethttp.Response, error)

+ ClustersClusterIdBrokersGet func(ctx _context.Context, clusterId string) (BrokerDataList, *_nethttp.Response, error)

+ ClustersClusterIdBrokersdeletePost func(ctx _context.Context, clusterId string, ...) (BrokerRemovalDataList, *_nethttp.Response, error)

+ type BrokerApiService service

+ func (a *BrokerApiService) ClustersClusterIdBrokersBrokerIdDelete(ctx _context.Context, clusterId string, brokerId int32, ...) (BrokerRemovalData, *_nethttp.Response, error)

+ func (a *BrokerApiService) ClustersClusterIdBrokersBrokerIdGet(ctx _context.Context, clusterId string, brokerId int32) (BrokerData, *_nethttp.Response, error)

+ func (a *BrokerApiService) ClustersClusterIdBrokersBrokerIdPartitionReplicasGet(ctx _context.Context, clusterId string, brokerId int32) (ReplicaDataList, *_nethttp.Response, error)

+ func (a *BrokerApiService) ClustersClusterIdBrokersGet(ctx _context.Context, clusterId string) (BrokerDataList, *_nethttp.Response, error)

+ func (a *BrokerApiService) ClustersClusterIdBrokersdeletePost(ctx _context.Context, clusterId string, ...) (BrokerRemovalDataList, *_nethttp.Response, error)

+ type BrokerConfigData struct

+ BrokerId int32

+ ClusterId string

+ IsDefault bool

+ IsReadOnly bool

+ IsSensitive bool

+ Kind string

+ Metadata ResourceMetadata

+ Name string

+ Source ConfigSource

+ Synonyms []ConfigSynonymData

+ Value *string

+ type BrokerConfigDataAllOf struct

+ BrokerId int32

+ type BrokerConfigDataList struct

+ Data []BrokerConfigData

+ Kind string

+ Metadata ResourceCollectionMetadata

+ type BrokerConfigDataListAllOf struct

+ Data []BrokerConfigData

+ type BrokerData struct

+ BrokerId int32

+ ClusterId string

+ Configs Relationship

+ Host *string

+ Kind string

+ Metadata ResourceMetadata

+ PartitionReplicas Relationship

+ Port *int32

+ Rack *string

+ type BrokerDataAllOf struct

+ BrokerId int32

+ ClusterId string

+ Configs Relationship

+ Host *string

+ PartitionReplicas Relationship

+ Port *int32

+ Rack *string

+ type BrokerDataList struct

+ Data []BrokerData

+ Kind string

+ Metadata ResourceCollectionMetadata

+ type BrokerDataListAllOf struct

+ Data []BrokerData

+ type BrokerRemovalData struct

+ Broker Relationship

+ BrokerId int32

+ BrokerTask Relationship

+ ClusterId string

+ Kind string

+ Metadata ResourceMetadata

+ type BrokerRemovalDataAllOf struct

+ Broker Relationship

+ BrokerId int32

+ BrokerTask Relationship

+ ClusterId string

+ type BrokerRemovalDataList struct

+ Data []BrokerRemovalData

+ Kind string

+ Metadata ResourceCollectionMetadata

+ type BrokerRemovalDataListAllOf struct

+ Data []BrokerRemovalData

+ type BrokerShutdownStatus string

+ const BROKERSHUTDOWNSTATUS_CANCELED

+ const BROKERSHUTDOWNSTATUS_COMPLETED

+ const BROKERSHUTDOWNSTATUS_ERROR

+ const BROKERSHUTDOWNSTATUS_PENDING

+ type BrokerTaskApi interface

+ ClustersClusterIdBrokersBrokerIdTasksGet func(ctx _context.Context, clusterId string, brokerId int32) (BrokerTaskDataList, *_nethttp.Response, error)

+ ClustersClusterIdBrokersBrokerIdTasksTaskTypeGet func(ctx _context.Context, clusterId string, brokerId int32, ...) (BrokerTaskData, *_nethttp.Response, error)

+ ClustersClusterIdBrokersTasksGet func(ctx _context.Context, clusterId string) (BrokerTaskDataList, *_nethttp.Response, error)

+ ClustersClusterIdBrokersTasksTaskTypeGet func(ctx _context.Context, clusterId string, taskType BrokerTaskType) (BrokerTaskDataList, *_nethttp.Response, error)

+ type BrokerTaskApiService service

+ 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 struct

+ Broker Relationship

+ BrokerId int32

+ ClusterId string

+ CreatedAt time.Time

+ ErrorCode *int32

+ ErrorMessage *string

+ Kind string

+ Metadata ResourceMetadata

+ ShutdownScheduled *bool

+ SubTaskStatuses map[string]string

+ TaskStatus string

+ TaskType BrokerTaskType

+ UpdatedAt time.Time

+ type BrokerTaskDataAllOf struct

+ Broker Relationship

+ BrokerId int32

+ ClusterId string

+ CreatedAt time.Time

+ ErrorCode *int32

+ ErrorMessage *string

+ ShutdownScheduled *bool

+ SubTaskStatuses map[string]string

+ TaskStatus string

+ TaskType BrokerTaskType

+ UpdatedAt time.Time

+ type BrokerTaskDataList struct

+ Data []BrokerTaskData

+ Kind string

+ Metadata ResourceCollectionMetadata

+ type BrokerTaskDataListAllOf struct

+ Data []BrokerTaskData

+ type BrokerTaskStatus string

+ const BROKERTASKSTATUS_FAILED

+ const BROKERTASKSTATUS_IN_PROGRESS

+ const BROKERTASKSTATUS_SUCCESS

+ type BrokerTaskType string

+ const BROKERTASKTYPE_ADD_BROKER

+ const BROKERTASKTYPE_REMOVE_BROKER

+ type ClusterApi interface

+ ClustersClusterIdGet func(ctx _context.Context, clusterId string) (ClusterData, *_nethttp.Response, error)

+ ClustersGet func(ctx _context.Context) (ClusterDataList, *_nethttp.Response, error)

+ type ClusterApiService service

+ func (a *ClusterApiService) ClustersClusterIdGet(ctx _context.Context, clusterId string) (ClusterData, *_nethttp.Response, error)

+ func (a *ClusterApiService) ClustersGet(ctx _context.Context) (ClusterDataList, *_nethttp.Response, error)

+ type ClusterConfigData struct

+ ClusterId string

+ ConfigType ClusterConfigType

+ IsDefault bool

+ IsReadOnly bool

+ IsSensitive bool

+ Kind string

+ Metadata ResourceMetadata

+ Name string

+ Source ConfigSource

+ Synonyms []ConfigSynonymData

+ Value *string

+ type ClusterConfigDataAllOf struct

+ ConfigType ClusterConfigType

+ type ClusterConfigDataList struct

+ Data []ClusterConfigData

+ Kind string

+ Metadata ResourceCollectionMetadata

+ type ClusterConfigDataListAllOf struct

+ Data []ClusterConfigData

+ type ClusterConfigType string

+ const CLUSTERCONFIGTYPE_BROKER

+ type ClusterData struct

+ Acls Relationship

+ BrokerConfigs Relationship

+ Brokers Relationship

+ ClusterId string

+ ConsumerGroups Relationship

+ Controller Relationship

+ Kind string

+ Metadata ResourceMetadata

+ PartitionReassignments Relationship

+ Topics Relationship

+ type ClusterDataAllOf struct

+ Acls Relationship

+ BrokerConfigs Relationship

+ Brokers Relationship

+ ClusterId string

+ ConsumerGroups Relationship

+ Controller Relationship

+ PartitionReassignments Relationship

+ Topics Relationship

+ type ClusterDataList struct

+ Data []ClusterData

+ Kind string

+ Metadata ResourceCollectionMetadata

+ type ClusterDataListAllOf struct

+ Data []ClusterData

+ type ClusterLinkingApi interface

+ ClustersClusterIdLinksGet func(ctx _context.Context, clusterId string) (ListLinksResponseDataList, *_nethttp.Response, error)

+ ClustersClusterIdLinksLinkNameConfigsConfigNameDelete func(ctx _context.Context, clusterId string, linkName string, configName string) (*_nethttp.Response, error)

+ ClustersClusterIdLinksLinkNameConfigsConfigNameGet func(ctx _context.Context, clusterId string, linkName string, configName string) (ListLinkConfigsResponseData, *_nethttp.Response, error)

+ ClustersClusterIdLinksLinkNameConfigsConfigNamePut func(ctx _context.Context, clusterId string, linkName string, configName string, ...) (*_nethttp.Response, error)

+ ClustersClusterIdLinksLinkNameConfigsGet func(ctx _context.Context, clusterId string, linkName string) (ListLinkConfigsResponseDataList, *_nethttp.Response, error)

+ ClustersClusterIdLinksLinkNameConfigsalterPut func(ctx _context.Context, clusterId string, linkName string, ...) (*_nethttp.Response, error)

+ ClustersClusterIdLinksLinkNameDelete func(ctx _context.Context, clusterId string, linkName string) (*_nethttp.Response, error)

+ ClustersClusterIdLinksLinkNameGet func(ctx _context.Context, clusterId string, linkName string) (ListLinksResponseData, *_nethttp.Response, error)

+ ClustersClusterIdLinksLinkNameMirrorsGet func(ctx _context.Context, clusterId string, linkName string, ...) (ListMirrorTopicsResponseDataList, *_nethttp.Response, error)

+ ClustersClusterIdLinksLinkNameMirrorsMirrorTopicNameGet func(ctx _context.Context, clusterId string, linkName string, ...) (ListMirrorTopicsResponseData, *_nethttp.Response, error)

+ ClustersClusterIdLinksLinkNameMirrorsPost func(ctx _context.Context, clusterId string, linkName string, ...) (*_nethttp.Response, error)

+ ClustersClusterIdLinksLinkNameMirrorsfailoverPost func(ctx _context.Context, clusterId string, linkName string, ...) (AlterMirrorStatusResponseDataList, *_nethttp.Response, error)

+ ClustersClusterIdLinksLinkNameMirrorspausePost func(ctx _context.Context, clusterId string, linkName string, ...) (AlterMirrorStatusResponseDataList, *_nethttp.Response, error)

+ ClustersClusterIdLinksLinkNameMirrorspromotePost func(ctx _context.Context, clusterId string, linkName string, ...) (AlterMirrorStatusResponseDataList, *_nethttp.Response, error)

+ ClustersClusterIdLinksLinkNameMirrorsresumePost func(ctx _context.Context, clusterId string, linkName string, ...) (AlterMirrorStatusResponseDataList, *_nethttp.Response, error)

+ ClustersClusterIdLinksMirrorsGet func(ctx _context.Context, clusterId string, ...) (ListMirrorTopicsResponseDataList, *_nethttp.Response, error)

+ ClustersClusterIdLinksPost func(ctx _context.Context, clusterId string, linkName string, ...) (*_nethttp.Response, error)

+ type ClusterLinkingApiService service

+ func (a *ClusterLinkingApiService) ClustersClusterIdLinksGet(ctx _context.Context, clusterId string) (ListLinksResponseDataList, *_nethttp.Response, error)

+ func (a *ClusterLinkingApiService) ClustersClusterIdLinksLinkNameConfigsConfigNameDelete(ctx _context.Context, clusterId string, linkName string, configName string) (*_nethttp.Response, error)

+ func (a *ClusterLinkingApiService) ClustersClusterIdLinksLinkNameConfigsConfigNameGet(ctx _context.Context, clusterId string, linkName string, configName string) (ListLinkConfigsResponseData, *_nethttp.Response, error)

+ func (a *ClusterLinkingApiService) ClustersClusterIdLinksLinkNameConfigsConfigNamePut(ctx _context.Context, clusterId string, linkName string, configName string, ...) (*_nethttp.Response, error)

+ func (a *ClusterLinkingApiService) ClustersClusterIdLinksLinkNameConfigsGet(ctx _context.Context, clusterId string, linkName string) (ListLinkConfigsResponseDataList, *_nethttp.Response, error)

+ func (a *ClusterLinkingApiService) ClustersClusterIdLinksLinkNameConfigsalterPut(ctx _context.Context, clusterId string, linkName string, ...) (*_nethttp.Response, error)

+ func (a *ClusterLinkingApiService) ClustersClusterIdLinksLinkNameDelete(ctx _context.Context, clusterId string, linkName string) (*_nethttp.Response, error)

+ func (a *ClusterLinkingApiService) ClustersClusterIdLinksLinkNameGet(ctx _context.Context, clusterId string, linkName string) (ListLinksResponseData, *_nethttp.Response, error)

+ func (a *ClusterLinkingApiService) ClustersClusterIdLinksLinkNameMirrorsGet(ctx _context.Context, clusterId string, linkName string, ...) (ListMirrorTopicsResponseDataList, *_nethttp.Response, error)

+ func (a *ClusterLinkingApiService) ClustersClusterIdLinksLinkNameMirrorsMirrorTopicNameGet(ctx _context.Context, clusterId string, linkName string, ...) (ListMirrorTopicsResponseData, *_nethttp.Response, error)

+ func (a *ClusterLinkingApiService) ClustersClusterIdLinksLinkNameMirrorsPost(ctx _context.Context, clusterId string, linkName string, ...) (*_nethttp.Response, error)

+ func (a *ClusterLinkingApiService) ClustersClusterIdLinksLinkNameMirrorsfailoverPost(ctx _context.Context, clusterId string, linkName string, ...) (AlterMirrorStatusResponseDataList, *_nethttp.Response, error)

+ func (a *ClusterLinkingApiService) ClustersClusterIdLinksLinkNameMirrorspausePost(ctx _context.Context, clusterId string, linkName string, ...) (AlterMirrorStatusResponseDataList, *_nethttp.Response, error)

+ func (a *ClusterLinkingApiService) ClustersClusterIdLinksLinkNameMirrorspromotePost(ctx _context.Context, clusterId string, linkName string, ...) (AlterMirrorStatusResponseDataList, *_nethttp.Response, error)

+ func (a *ClusterLinkingApiService) ClustersClusterIdLinksLinkNameMirrorsresumePost(ctx _context.Context, clusterId string, linkName string, ...) (AlterMirrorStatusResponseDataList, *_nethttp.Response, error)

+ func (a *ClusterLinkingApiService) ClustersClusterIdLinksMirrorsGet(ctx _context.Context, clusterId string, ...) (ListMirrorTopicsResponseDataList, *_nethttp.Response, error)

+ func (a *ClusterLinkingApiService) ClustersClusterIdLinksPost(ctx _context.Context, clusterId string, linkName string, ...) (*_nethttp.Response, error)

+ type ClustersClusterIdAclsDeleteOpts struct

+ Host optional.String

+ Operation optional.Interface

+ PatternType optional.Interface

+ Permission optional.Interface

+ Principal optional.String

+ ResourceName optional.String

+ ResourceType optional.Interface

+ type ClustersClusterIdAclsGetOpts struct

+ Host optional.String

+ Operation optional.Interface

+ PatternType optional.Interface

+ Permission optional.Interface

+ Principal optional.String

+ ResourceName optional.String

+ ResourceType optional.Interface

+ type ClustersClusterIdAclsPostOpts struct

+ CreateAclRequestData optional.Interface

+ type ClustersClusterIdBrokerConfigsNamePutOpts struct

+ UpdateConfigRequestData optional.Interface

+ type ClustersClusterIdBrokerConfigsalterPostOpts struct

+ AlterConfigBatchRequestData optional.Interface

+ type ClustersClusterIdBrokersBrokerIdConfigsNamePutOpts struct

+ UpdateConfigRequestData optional.Interface

+ type ClustersClusterIdBrokersBrokerIdConfigsalterPostOpts struct

+ AlterConfigBatchRequestData optional.Interface

+ type ClustersClusterIdBrokersBrokerIdDeleteOpts struct

+ ShouldShutdown optional.Bool

+ type ClustersClusterIdBrokersdeletePostOpts struct

+ RemoveBrokersRequestData optional.Interface

+ ShouldShutdown optional.Bool

+ type ClustersClusterIdLinksLinkNameConfigsConfigNamePutOpts struct

+ UpdateLinkConfigRequestData optional.Interface

+ type ClustersClusterIdLinksLinkNameConfigsalterPutOpts struct

+ AlterConfigBatchRequestData optional.Interface

+ type ClustersClusterIdLinksLinkNameMirrorsGetOpts struct

+ MirrorStatus optional.Interface

+ type ClustersClusterIdLinksLinkNameMirrorsPostOpts struct

+ CreateMirrorTopicRequestData optional.Interface

+ type ClustersClusterIdLinksLinkNameMirrorsfailoverPostOpts struct

+ AlterMirrorsRequestData optional.Interface

+ ValidateOnly optional.Bool

+ type ClustersClusterIdLinksLinkNameMirrorspausePostOpts struct

+ AlterMirrorsRequestData optional.Interface

+ ValidateOnly optional.Bool

+ type ClustersClusterIdLinksLinkNameMirrorspromotePostOpts struct

+ AlterMirrorsRequestData optional.Interface

+ ValidateOnly optional.Bool

+ type ClustersClusterIdLinksLinkNameMirrorsresumePostOpts struct

+ AlterMirrorsRequestData optional.Interface

+ ValidateOnly optional.Bool

+ type ClustersClusterIdLinksMirrorsGetOpts struct

+ MirrorStatus optional.Interface

+ type ClustersClusterIdLinksPostOpts struct

+ CreateLinkRequestData optional.Interface

+ ValidateLink optional.Bool

+ ValidateOnly optional.Bool

+ type ClustersClusterIdTopicsPostOpts struct

+ CreateTopicRequestData optional.Interface

+ type ClustersClusterIdTopicsTopicNameConfigsNamePutOpts struct

+ UpdateConfigRequestData optional.Interface

+ type ClustersClusterIdTopicsTopicNameConfigsalterPostOpts struct

+ AlterConfigBatchRequestData optional.Interface

+ type ConfigData struct

+ Name string

+ Value *string

+ type ConfigSource string

+ const CONFIGSOURCE_DEFAULT_CONFIG

+ const CONFIGSOURCE_DYNAMIC_BROKER_CONFIG

+ const CONFIGSOURCE_DYNAMIC_BROKER_LOGGER_CONFIG

+ const CONFIGSOURCE_DYNAMIC_CLUSTER_LINK_CONFIG

+ const CONFIGSOURCE_DYNAMIC_DEFAULT_BROKER_CONFIG

+ const CONFIGSOURCE_DYNAMIC_TOPIC_CONFIG

+ const CONFIGSOURCE_STATIC_BROKER_CONFIG

+ const CONFIGSOURCE_UNKNOWN

+ type ConfigSynonymData struct

+ Name string

+ Source ConfigSource

+ Value *string

+ type ConfigsApi interface

+ ClustersClusterIdBrokerConfigsGet func(ctx _context.Context, clusterId string) (ClusterConfigDataList, *_nethttp.Response, error)

+ ClustersClusterIdBrokerConfigsNameDelete func(ctx _context.Context, clusterId string, name string) (*_nethttp.Response, error)

+ ClustersClusterIdBrokerConfigsNameGet func(ctx _context.Context, clusterId string, name string) (ClusterConfigData, *_nethttp.Response, error)

+ ClustersClusterIdBrokerConfigsNamePut func(ctx _context.Context, clusterId string, name string, ...) (*_nethttp.Response, error)

+ ClustersClusterIdBrokerConfigsalterPost func(ctx _context.Context, clusterId string, ...) (*_nethttp.Response, error)

+ ClustersClusterIdBrokersBrokerIdConfigsGet func(ctx _context.Context, clusterId string, brokerId int32) (BrokerConfigDataList, *_nethttp.Response, error)

+ ClustersClusterIdBrokersBrokerIdConfigsNameDelete func(ctx _context.Context, clusterId string, brokerId int32, name string) (*_nethttp.Response, error)

+ ClustersClusterIdBrokersBrokerIdConfigsNameGet func(ctx _context.Context, clusterId string, brokerId int32, name string) (BrokerConfigData, *_nethttp.Response, error)

+ ClustersClusterIdBrokersBrokerIdConfigsNamePut func(ctx _context.Context, clusterId string, brokerId int32, name string, ...) (*_nethttp.Response, error)

+ ClustersClusterIdBrokersBrokerIdConfigsalterPost func(ctx _context.Context, clusterId string, brokerId int32, ...) (*_nethttp.Response, error)

+ ClustersClusterIdTopicsTopicNameConfigsGet func(ctx _context.Context, clusterId string, topicName string) (TopicConfigDataList, *_nethttp.Response, error)

+ ClustersClusterIdTopicsTopicNameConfigsNameDelete func(ctx _context.Context, clusterId string, topicName string, name string) (*_nethttp.Response, error)

+ ClustersClusterIdTopicsTopicNameConfigsNameGet func(ctx _context.Context, clusterId string, topicName string, name string) (TopicConfigData, *_nethttp.Response, error)

+ ClustersClusterIdTopicsTopicNameConfigsNamePut func(ctx _context.Context, clusterId string, topicName string, name string, ...) (*_nethttp.Response, error)

+ ClustersClusterIdTopicsTopicNameConfigsalterPost func(ctx _context.Context, clusterId string, topicName string, ...) (*_nethttp.Response, error)

+ type ConfigsApiService service

+ func (a *ConfigsApiService) ClustersClusterIdBrokerConfigsGet(ctx _context.Context, clusterId string) (ClusterConfigDataList, *_nethttp.Response, error)

+ func (a *ConfigsApiService) ClustersClusterIdBrokerConfigsNameDelete(ctx _context.Context, clusterId string, name string) (*_nethttp.Response, error)

+ func (a *ConfigsApiService) ClustersClusterIdBrokerConfigsNameGet(ctx _context.Context, clusterId string, name string) (ClusterConfigData, *_nethttp.Response, error)

+ func (a *ConfigsApiService) ClustersClusterIdBrokerConfigsNamePut(ctx _context.Context, clusterId string, name string, ...) (*_nethttp.Response, error)

+ func (a *ConfigsApiService) ClustersClusterIdBrokerConfigsalterPost(ctx _context.Context, clusterId string, ...) (*_nethttp.Response, error)

+ func (a *ConfigsApiService) ClustersClusterIdBrokersBrokerIdConfigsGet(ctx _context.Context, clusterId string, brokerId int32) (BrokerConfigDataList, *_nethttp.Response, error)

+ func (a *ConfigsApiService) ClustersClusterIdBrokersBrokerIdConfigsNameDelete(ctx _context.Context, clusterId string, brokerId int32, name string) (*_nethttp.Response, error)

+ func (a *ConfigsApiService) ClustersClusterIdBrokersBrokerIdConfigsNameGet(ctx _context.Context, clusterId string, brokerId int32, name string) (BrokerConfigData, *_nethttp.Response, error)

+ func (a *ConfigsApiService) ClustersClusterIdBrokersBrokerIdConfigsNamePut(ctx _context.Context, clusterId string, brokerId int32, name string, ...) (*_nethttp.Response, error)

+ func (a *ConfigsApiService) ClustersClusterIdBrokersBrokerIdConfigsalterPost(ctx _context.Context, clusterId string, brokerId int32, ...) (*_nethttp.Response, error)

+ func (a *ConfigsApiService) ClustersClusterIdTopicsTopicNameConfigsGet(ctx _context.Context, clusterId string, topicName string) (TopicConfigDataList, *_nethttp.Response, error)

+ func (a *ConfigsApiService) ClustersClusterIdTopicsTopicNameConfigsNameDelete(ctx _context.Context, clusterId string, topicName string, name string) (*_nethttp.Response, error)

+ func (a *ConfigsApiService) ClustersClusterIdTopicsTopicNameConfigsNameGet(ctx _context.Context, clusterId string, topicName string, name string) (TopicConfigData, *_nethttp.Response, error)

+ func (a *ConfigsApiService) ClustersClusterIdTopicsTopicNameConfigsNamePut(ctx _context.Context, clusterId string, topicName string, name string, ...) (*_nethttp.Response, error)

+ func (a *ConfigsApiService) ClustersClusterIdTopicsTopicNameConfigsalterPost(ctx _context.Context, clusterId string, topicName string, ...) (*_nethttp.Response, error)

+ type Configuration struct

+ BasePath string

+ Debug bool

+ DefaultHeader map[string]string

+ HTTPClient *http.Client

+ Host string

+ Scheme string

+ Servers []ServerConfiguration

+ UserAgent string

+ func NewConfiguration() *Configuration

+ func (c *Configuration) AddDefaultHeader(key string, value string)

+ func (c *Configuration) ServerUrl(index int, variables map[string]string) (string, error)

+ type ConsumerAssignmentData struct

+ ClusterId string

+ ConsumerGroupId string

+ ConsumerId string

+ Kind string

+ Lag Relationship

+ Metadata ResourceMetadata

+ Partition Relationship

+ PartitionId int32

+ TopicName string

+ type ConsumerAssignmentDataAllOf struct

+ ClusterId string

+ ConsumerGroupId string

+ ConsumerId string

+ Lag Relationship

+ Partition Relationship

+ PartitionId int32

+ TopicName string

+ type ConsumerAssignmentDataList struct

+ Data []ConsumerAssignmentData

+ Kind string

+ Metadata ResourceCollectionMetadata

+ type ConsumerAssignmentDataListAllOf struct

+ Data []ConsumerAssignmentData

+ type ConsumerData struct

+ Assignments Relationship

+ ClientId string

+ ClusterId string

+ ConsumerGroupId string

+ ConsumerId string

+ InstanceId *string

+ Kind string

+ Metadata ResourceMetadata

+ type ConsumerDataAllOf struct

+ Assignments Relationship

+ ClientId string

+ ClusterId string

+ ConsumerGroupId string

+ ConsumerId string

+ InstanceId *string

+ type ConsumerDataList struct

+ Data []ConsumerData

+ Kind string

+ Metadata ResourceCollectionMetadata

+ type ConsumerDataListAllOf struct

+ Data []ConsumerData

+ type ConsumerGroupApi interface

+ ... func(ctx _context.Context, clusterId string, consumerGroupId string, ...) (ConsumerAssignmentData, *_nethttp.Response, error)

+ ... func(ctx _context.Context, clusterId string, consumerGroupId string, ...) (ConsumerAssignmentDataList, *_nethttp.Response, error)

+ ClustersClusterIdConsumerGroupsConsumerGroupIdConsumersConsumerIdGet func(ctx _context.Context, clusterId string, consumerGroupId string, ...) (ConsumerData, *_nethttp.Response, error)

+ ClustersClusterIdConsumerGroupsConsumerGroupIdConsumersGet func(ctx _context.Context, clusterId string, consumerGroupId string) (ConsumerDataList, *_nethttp.Response, error)

+ ClustersClusterIdConsumerGroupsConsumerGroupIdGet func(ctx _context.Context, clusterId string, consumerGroupId string) (ConsumerGroupData, *_nethttp.Response, error)

+ ClustersClusterIdConsumerGroupsConsumerGroupIdLagSummaryGet func(ctx _context.Context, clusterId string, consumerGroupId string) (ConsumerGroupLagSummaryData, *_nethttp.Response, error)

+ ClustersClusterIdConsumerGroupsConsumerGroupIdLagsGet func(ctx _context.Context, clusterId string, consumerGroupId string) (ConsumerLagDataList, *_nethttp.Response, error)

+ ClustersClusterIdConsumerGroupsGet func(ctx _context.Context, clusterId string) (ConsumerGroupDataList, *_nethttp.Response, error)

+ type ConsumerGroupApiService service

+ func (a *ConsumerGroupApiService) ClustersClusterIdConsumerGroupsConsumerGroupIdConsumersConsumerIdAssignmentsGet(ctx _context.Context, clusterId string, consumerGroupId string, ...) (ConsumerAssignmentDataList, *_nethttp.Response, error)

+ func (a *ConsumerGroupApiService) ClustersClusterIdConsumerGroupsConsumerGroupIdConsumersConsumerIdAssignmentsTopicNamePartitionsPartitionIdGet(ctx _context.Context, clusterId string, consumerGroupId string, ...) (ConsumerAssignmentData, *_nethttp.Response, error)

+ func (a *ConsumerGroupApiService) ClustersClusterIdConsumerGroupsConsumerGroupIdConsumersConsumerIdGet(ctx _context.Context, clusterId string, consumerGroupId string, ...) (ConsumerData, *_nethttp.Response, error)

+ func (a *ConsumerGroupApiService) ClustersClusterIdConsumerGroupsConsumerGroupIdConsumersGet(ctx _context.Context, clusterId string, consumerGroupId string) (ConsumerDataList, *_nethttp.Response, error)

+ func (a *ConsumerGroupApiService) ClustersClusterIdConsumerGroupsConsumerGroupIdGet(ctx _context.Context, clusterId string, consumerGroupId string) (ConsumerGroupData, *_nethttp.Response, error)

+ func (a *ConsumerGroupApiService) ClustersClusterIdConsumerGroupsConsumerGroupIdLagSummaryGet(ctx _context.Context, clusterId string, consumerGroupId string) (ConsumerGroupLagSummaryData, *_nethttp.Response, error)

+ func (a *ConsumerGroupApiService) ClustersClusterIdConsumerGroupsConsumerGroupIdLagsGet(ctx _context.Context, clusterId string, consumerGroupId string) (ConsumerLagDataList, *_nethttp.Response, error)

+ func (a *ConsumerGroupApiService) ClustersClusterIdConsumerGroupsGet(ctx _context.Context, clusterId string) (ConsumerGroupDataList, *_nethttp.Response, error)

+ type ConsumerGroupData struct

+ ClusterId string

+ Consumer Relationship

+ ConsumerGroupId string

+ Coordinator Relationship

+ IsSimple bool

+ Kind string

+ LagSummary Relationship

+ Metadata ResourceMetadata

+ PartitionAssignor string

+ State ConsumerGroupState

+ type ConsumerGroupDataAllOf struct

+ ClusterId string

+ Consumer Relationship

+ ConsumerGroupId string

+ Coordinator Relationship

+ IsSimple bool

+ LagSummary Relationship

+ PartitionAssignor string

+ State ConsumerGroupState

+ type ConsumerGroupDataList struct

+ Data []ConsumerGroupData

+ Kind string

+ Metadata ResourceCollectionMetadata

+ type ConsumerGroupDataListAllOf struct

+ Data []ConsumerGroupData

+ type ConsumerGroupLagSummaryData struct

+ ClusterId string

+ ConsumerGroupId string

+ Kind string

+ MaxLag int64

+ MaxLagClientId string

+ MaxLagConsumer Relationship

+ MaxLagConsumerId string

+ MaxLagInstanceId *string

+ MaxLagPartition Relationship

+ MaxLagPartitionId int32

+ MaxLagTopicName string

+ Metadata ResourceMetadata

+ TotalLag int64

+ type ConsumerGroupLagSummaryDataAllOf struct

+ ClusterId string

+ ConsumerGroupId string

+ MaxLag int64

+ MaxLagClientId string

+ MaxLagConsumer Relationship

+ MaxLagConsumerId string

+ MaxLagInstanceId *string

+ MaxLagPartition Relationship

+ MaxLagPartitionId int32

+ MaxLagTopicName string

+ TotalLag int64

+ type ConsumerGroupState string

+ const CONSUMERGROUPSTATE_COMPLETING_REBALANCE

+ const CONSUMERGROUPSTATE_DEAD

+ const CONSUMERGROUPSTATE_EMPTY

+ const CONSUMERGROUPSTATE_PREPARING_REBALANCE

+ const CONSUMERGROUPSTATE_STABLE

+ const CONSUMERGROUPSTATE_UNKNOWN

+ type ConsumerLagData struct

+ ClientId string

+ ClusterId string

+ ConsumerGroupId string

+ ConsumerId string

+ CurrentOffset int64

+ InstanceId *string

+ Kind string

+ Lag int64

+ LogEndOffset int64

+ Metadata ResourceMetadata

+ PartitionId int32

+ TopicName string

+ type ConsumerLagDataAllOf struct

+ ClientId string

+ ClusterId string

+ ConsumerGroupId string

+ ConsumerId string

+ CurrentOffset int64

+ InstanceId *string

+ Lag int64

+ LogEndOffset int64

+ PartitionId int32

+ TopicName string

+ type ConsumerLagDataList struct

+ Data []ConsumerLagData

+ Kind string

+ Metadata ResourceCollectionMetadata

+ type ConsumerLagDataListAllOf struct

+ Data []ConsumerLagData

+ type CreateAclRequestData struct

+ Host string

+ Operation AclOperation

+ PatternType AclPatternType

+ Permission AclPermission

+ Principal string

+ ResourceName string

+ ResourceType AclResourceType

+ type CreateLinkRequestData struct

+ Configs []CreateTopicRequestDataConfigs

+ SourceClusterId string

+ type CreateMirrorTopicRequestData struct

+ Configs []CreateTopicRequestDataConfigs

+ ReplicationFactor int32

+ SourceTopicName string

+ type CreateTopicRequestData struct

+ Configs []CreateTopicRequestDataConfigs

+ PartitionsCount int32

+ ReplicasAssignments []CreateTopicRequestDataReplicasAssignments

+ ReplicationFactor int32

+ TopicName string

+ type CreateTopicRequestDataConfigs struct

+ Name string

+ Value *string

+ type CreateTopicRequestDataReplicasAssignments struct

+ BrokerIds []int32

+ PartitionId int32

+ type DeprecatedBrokerShutdownStatus string

+ const DEPRECATEDBROKERSHUTDOWNSTATUS_CANCELED

+ const DEPRECATEDBROKERSHUTDOWNSTATUS_COMPLETE

+ const DEPRECATEDBROKERSHUTDOWNSTATUS_FAILED

+ const DEPRECATEDBROKERSHUTDOWNSTATUS_PENDING

+ type DeprecatedPartitionReassignmentStatus string

+ const DEPRECATEDPARTITIONREASSIGNMENTSTATUS_CANCELED

+ const DEPRECATEDPARTITIONREASSIGNMENTSTATUS_COMPLETE

+ const DEPRECATEDPARTITIONREASSIGNMENTSTATUS_FAILED

+ const DEPRECATEDPARTITIONREASSIGNMENTSTATUS_IN_PROGRESS

+ const DEPRECATEDPARTITIONREASSIGNMENTSTATUS_PENDING

+ type Error struct

+ ErrorCode int32

+ Message string

+ type GenericOpenAPIError struct

+ func (e GenericOpenAPIError) Body() []byte

+ func (e GenericOpenAPIError) Error() string

+ func (e GenericOpenAPIError) Model() interface{}

+ type InlineResponse200 struct

+ Data []AclData

+ type ListLinkConfigsResponseData struct

+ ClusterId string

+ Kind string

+ LinkName string

+ Metadata ResourceMetadata

+ Name string

+ ReadOnly bool

+ Sensitive bool

+ Source string

+ Synonyms []string

+ Value string

+ type ListLinkConfigsResponseDataAllOf struct

+ ClusterId string

+ LinkName string

+ Name string

+ ReadOnly bool

+ Sensitive bool

+ Source string

+ Synonyms []string

+ Value string

+ type ListLinkConfigsResponseDataList struct

+ Data []ListLinkConfigsResponseData

+ Kind string

+ Metadata ResourceCollectionMetadata

+ type ListLinkConfigsResponseDataListAllOf struct

+ Data []ListLinkConfigsResponseData

+ type ListLinksResponseData struct

+ Kind string

+ LinkId string

+ LinkName string

+ Metadata ResourceMetadata

+ SourceClusterId string

+ TopicNames []string

+ type ListLinksResponseDataAllOf struct

+ LinkId string

+ LinkName string

+ SourceClusterId string

+ TopicNames []string

+ type ListLinksResponseDataList struct

+ Data []ListLinksResponseData

+ Kind string

+ Metadata ResourceCollectionMetadata

+ type ListLinksResponseDataListAllOf struct

+ Data []ListLinksResponseData

+ type ListMirrorTopicsResponseData struct

+ Kind string

+ LinkName string

+ Metadata ResourceMetadata

+ MirrorLags []MirrorLag

+ MirrorStatus MirrorTopicStatus

+ MirrorTopicName string

+ NumPartitions int32

+ SourceTopicName string

+ StateTimeMs int64

+ type ListMirrorTopicsResponseDataAllOf struct

+ LinkName string

+ MirrorLags []MirrorLag

+ MirrorStatus MirrorTopicStatus

+ MirrorTopicName string

+ NumPartitions int32

+ SourceTopicName string

+ StateTimeMs int64

+ type ListMirrorTopicsResponseDataList struct

+ Data []ListMirrorTopicsResponseData

+ Kind string

+ Metadata ResourceCollectionMetadata

+ type ListMirrorTopicsResponseDataListAllOf struct

+ Data []ListMirrorTopicsResponseData

+ type MirrorLag struct

+ Lag int64

+ LastSourceFetchOffset int64

+ Partition int32

+ type MirrorTopicStatus string

+ const MIRRORTOPICSTATUS_ACTIVE

+ const MIRRORTOPICSTATUS_FAILED

+ const MIRRORTOPICSTATUS_PAUSED

+ const MIRRORTOPICSTATUS_PENDING_STOPPED

+ const MIRRORTOPICSTATUS_STOPPED

+ type PartitionApi interface

+ ... func(ctx _context.Context, clusterId string, consumerGroupId string, ...) (ConsumerLagData, *_nethttp.Response, error)

+ ClustersClusterIdTopicsPartitionsReassignmentGet func(ctx _context.Context, clusterId string) (ReassignmentDataList, *_nethttp.Response, error)

+ ClustersClusterIdTopicsTopicNamePartitionsGet func(ctx _context.Context, clusterId string, topicName string) (PartitionDataList, *_nethttp.Response, error)

+ ClustersClusterIdTopicsTopicNamePartitionsPartitionIdGet func(ctx _context.Context, clusterId string, topicName string, partitionId int32) (PartitionData, *_nethttp.Response, error)

+ ClustersClusterIdTopicsTopicNamePartitionsPartitionIdReassignmentGet func(ctx _context.Context, clusterId string, topicName string, partitionId int32) (ReassignmentData, *_nethttp.Response, error)

+ ClustersClusterIdTopicsTopicNamePartitionsReassignmentGet func(ctx _context.Context, clusterId string, topicName string) (ReassignmentDataList, *_nethttp.Response, error)

+ type PartitionApiService service

+ func (a *PartitionApiService) ClustersClusterIdConsumerGroupsConsumerGroupIdLagsTopicNamePartitionsPartitionIdGet(ctx _context.Context, clusterId string, consumerGroupId string, ...) (ConsumerLagData, *_nethttp.Response, error)

+ func (a *PartitionApiService) ClustersClusterIdTopicsPartitionsReassignmentGet(ctx _context.Context, clusterId string) (ReassignmentDataList, *_nethttp.Response, error)

+ func (a *PartitionApiService) ClustersClusterIdTopicsTopicNamePartitionsGet(ctx _context.Context, clusterId string, topicName string) (PartitionDataList, *_nethttp.Response, error)

+ func (a *PartitionApiService) ClustersClusterIdTopicsTopicNamePartitionsPartitionIdGet(ctx _context.Context, clusterId string, topicName string, partitionId int32) (PartitionData, *_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 struct

+ ClusterId string

+ Kind string

+ Leader Relationship

+ Metadata ResourceMetadata

+ PartitionId int32

+ Reassignment Relationship

+ Replicas Relationship

+ TopicName string

+ type PartitionDataAllOf struct

+ ClusterId string

+ Leader Relationship

+ PartitionId int32

+ Reassignment Relationship

+ Replicas Relationship

+ TopicName string

+ type PartitionDataList struct

+ Data []PartitionData

+ Kind string

+ Metadata ResourceCollectionMetadata

+ type PartitionDataListAllOf struct

+ Data []PartitionData

+ type PartitionReassignmentStatus string

+ const PARTITIONREASSIGNMENTSTATUS_CANCELED

+ const PARTITIONREASSIGNMENTSTATUS_COMPLETED

+ const PARTITIONREASSIGNMENTSTATUS_ERROR

+ const PARTITIONREASSIGNMENTSTATUS_IN_PROGRESS

+ const PARTITIONREASSIGNMENTSTATUS_PENDING

+ type ReassignmentData struct

+ AddingReplicas []int32

+ ClusterId string

+ Kind string

+ Metadata ResourceMetadata

+ PartitionId int32

+ RemovingReplicas []int32

+ Replicas Relationship

+ TopicName string

+ type ReassignmentDataAllOf struct

+ AddingReplicas []int32

+ ClusterId string

+ PartitionId int32

+ RemovingReplicas []int32

+ Replicas Relationship

+ TopicName string

+ type ReassignmentDataList struct

+ Data []ReassignmentData

+ Kind string

+ Metadata ResourceCollectionMetadata

+ type ReassignmentDataListAllOf struct

+ Data []ReassignmentData

+ type Relationship struct

+ Related string

+ type RemoveBrokerTaskApi interface

+ ClustersClusterIdRemoveBrokerTasksBrokerIdGet func(ctx _context.Context, clusterId string, brokerId int32) (RemoveBrokerTaskData, *_nethttp.Response, error)

+ ClustersClusterIdRemoveBrokerTasksGet func(ctx _context.Context, clusterId string) (RemoveBrokerTaskDataList, *_nethttp.Response, error)

+ type RemoveBrokerTaskApiService service

+ 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 struct

+ Broker Relationship

+ BrokerId int32

+ BrokerShutdownStatus DeprecatedBrokerShutdownStatus

+ ClusterId string

+ ErrorCode *int32

+ ErrorMessage *string

+ Kind string

+ Metadata ResourceMetadata

+ PartitionReassignmentStatus DeprecatedPartitionReassignmentStatus

+ type RemoveBrokerTaskDataAllOf struct

+ Broker Relationship

+ BrokerId int32

+ BrokerShutdownStatus DeprecatedBrokerShutdownStatus

+ ClusterId string

+ ErrorCode *int32

+ ErrorMessage *string

+ PartitionReassignmentStatus DeprecatedPartitionReassignmentStatus

+ type RemoveBrokerTaskDataList struct

+ Data []RemoveBrokerTaskData

+ Kind string

+ Metadata ResourceCollectionMetadata

+ type RemoveBrokerTaskDataListAllOf struct

+ Data []RemoveBrokerTaskData

+ type RemoveBrokersRequestData struct

+ BrokerIds []int32

+ type ReplicaApi interface

+ ClustersClusterIdBrokersBrokerIdPartitionReplicasGet func(ctx _context.Context, clusterId string, brokerId int32) (ReplicaDataList, *_nethttp.Response, error)

+ ClustersClusterIdTopicsTopicNamePartitionsPartitionIdReplicasBrokerIdGet func(ctx _context.Context, clusterId string, topicName string, partitionId int32, ...) (ReplicaData, *_nethttp.Response, error)

+ ClustersClusterIdTopicsTopicNamePartitionsPartitionIdReplicasGet func(ctx _context.Context, clusterId string, topicName string, partitionId int32) (ReplicaDataList, *_nethttp.Response, error)

+ type ReplicaApiService service

+ func (a *ReplicaApiService) ClustersClusterIdBrokersBrokerIdPartitionReplicasGet(ctx _context.Context, clusterId string, brokerId int32) (ReplicaDataList, *_nethttp.Response, error)

+ 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 struct

+ Broker Relationship

+ BrokerId int32

+ ClusterId string

+ IsInSync bool

+ IsLeader bool

+ Kind string

+ Metadata ResourceMetadata

+ PartitionId int32

+ TopicName string

+ type ReplicaDataAllOf struct

+ Broker Relationship

+ BrokerId int32

+ ClusterId string

+ IsInSync bool

+ IsLeader bool

+ PartitionId int32

+ TopicName string

+ type ReplicaDataList struct

+ Data []ReplicaData

+ Kind string

+ Metadata ResourceCollectionMetadata

+ type ReplicaDataListAllOf struct

+ Data []ReplicaData

+ type ReplicaStatusApi interface

+ ClustersClusterIdTopicsTopicNamePartitionsPartitionIdReplicaStatusGet func(ctx _context.Context, clusterId string, topicName string, partitionId int32) (ReplicaStatusDataList, *_nethttp.Response, error)

+ ClustersClusterIdTopicsTopicNamePartitionsReplicaStatusGet func(ctx _context.Context, clusterId string, topicName string) (ReplicaStatusDataList, *_nethttp.Response, error)

+ type ReplicaStatusApiService service

+ 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 struct

+ BrokerId int32

+ ClusterId string

+ IsCaughtUp bool

+ IsInIsr bool

+ IsIsrEligible bool

+ IsLeader bool

+ IsObserver bool

+ Kind string

+ LastCaughtUpTimeMs int64

+ LastFetchTimeMs int64

+ LinkName string

+ LogEndOffset int64

+ LogStartOffset int64

+ Metadata ResourceMetadata

+ PartitionId int32

+ TopicName string

+ type ReplicaStatusDataAllOf struct

+ BrokerId int32

+ ClusterId string

+ IsCaughtUp bool

+ IsInIsr bool

+ IsIsrEligible bool

+ IsLeader bool

+ IsObserver bool

+ LastCaughtUpTimeMs int64

+ LastFetchTimeMs int64

+ LinkName string

+ LogEndOffset int64

+ LogStartOffset int64

+ PartitionId int32

+ TopicName string

+ type ReplicaStatusDataList struct

+ Data []ReplicaStatusData

+ Kind string

+ Metadata ResourceCollectionMetadata

+ type ReplicaStatusDataListAllOf struct

+ Data []ReplicaStatusData

+ type Resource struct

+ Kind string

+ Metadata ResourceMetadata

+ type ResourceCollection struct

+ Kind string

+ Metadata ResourceCollectionMetadata

+ type ResourceCollectionMetadata struct

+ Next *string

+ Self string

+ type ResourceMetadata struct

+ ResourceName *string

+ Self string

+ type ServerConfiguration struct

+ Description string

+ Url string

+ Variables map[string]ServerVariable

+ type ServerVariable struct

+ DefaultValue string

+ Description string

+ EnumValues []string

+ type TopicApi interface

+ ClustersClusterIdTopicsGet func(ctx _context.Context, clusterId string) (TopicDataList, *_nethttp.Response, error)

+ ClustersClusterIdTopicsPost func(ctx _context.Context, clusterId string, ...) (TopicData, *_nethttp.Response, error)

+ ClustersClusterIdTopicsTopicNameDelete func(ctx _context.Context, clusterId string, topicName string) (*_nethttp.Response, error)

+ ClustersClusterIdTopicsTopicNameGet func(ctx _context.Context, clusterId string, topicName string) (TopicData, *_nethttp.Response, error)

+ type TopicApiService service

+ func (a *TopicApiService) ClustersClusterIdTopicsGet(ctx _context.Context, clusterId string) (TopicDataList, *_nethttp.Response, error)

+ func (a *TopicApiService) ClustersClusterIdTopicsPost(ctx _context.Context, clusterId string, ...) (TopicData, *_nethttp.Response, error)

+ func (a *TopicApiService) ClustersClusterIdTopicsTopicNameDelete(ctx _context.Context, clusterId string, topicName string) (*_nethttp.Response, error)

+ func (a *TopicApiService) ClustersClusterIdTopicsTopicNameGet(ctx _context.Context, clusterId string, topicName string) (TopicData, *_nethttp.Response, error)

+ type TopicConfigData struct

+ ClusterId string

+ IsDefault bool

+ IsReadOnly bool

+ IsSensitive bool

+ Kind string

+ Metadata ResourceMetadata

+ Name string

+ Source ConfigSource

+ Synonyms []ConfigSynonymData

+ TopicName string

+ Value *string

+ type TopicConfigDataAllOf struct

+ TopicName string

+ type TopicConfigDataList struct

+ Data []TopicConfigData

+ Kind string

+ Metadata ResourceCollectionMetadata

+ type TopicConfigDataListAllOf struct

+ Data []TopicConfigData

+ type TopicData struct

+ ClusterId string

+ Configs Relationship

+ IsInternal bool

+ Kind string

+ Metadata ResourceMetadata

+ PartitionReassignments Relationship

+ Partitions Relationship

+ ReplicationFactor int32

+ TopicName string

+ type TopicDataAllOf struct

+ ClusterId string

+ Configs Relationship

+ IsInternal bool

+ PartitionReassignments Relationship

+ Partitions Relationship

+ ReplicationFactor int32

+ TopicName string

+ type TopicDataList struct

+ Data []TopicData

+ Kind string

+ Metadata ResourceCollectionMetadata

+ type TopicDataListAllOf struct

+ Data []TopicData

+ type TopicList struct

+ Topics []string

+ type UpdateConfigRequestData struct

+ Value *string

+ type UpdateLinkConfigRequestData struct

+ Value string

v0.3.5

Aug 4, 2021

v0.3.4

Jul 29, 2021

v0.3.3

Jul 28, 2021

v0.3.2

Jul 6, 2021

v0.3.1

May 3, 2021

v0.3.0

Apr 22, 2021

v0.1.2

Mar 26, 2021

v0.1.1

Mar 24, 2021

v0.1.0

Mar 3, 2021

v0.0.3

Dec 11, 2020

v0.0.2

Dec 10, 2020

v0.0.1

Aug 5, 2020

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL