Method describeClusterUsingAPI

admin.go:403–433

()

}

func (ca *clusterAdmin) describeClusterUsingAPI() (brokers []*Broker, controllerID int32, err error) {
	var response *DescribeClusterResponse
	err = ca.retryOnError(isRetriableControllerError, func() error {
		controller, err := ca.Controller()
		if err != nil {
			return err
		}

		request := NewDescribeClusterRequest(ca.conf.Version)
		response, err = controller.DescribeCluster(request)
		if err != nil {
			return err
		}
		if !errors.Is(response.Err, ErrNoError) {
			if isRetriableControllerError(response.Err) {
				_, _ = ca.refreshController()
			}
			if response.ErrorMessage != nil && *response.ErrorMessage != "" {
				return fmt.Errorf("%w: %s", response.Err, *response.ErrorMessage)
			}
			return response.Err
		}
		return nil
	})
	if err != nil {
		return nil, 0, err
	}

	brokers = convertDescribeClusterBrokers(response.Brokers)
	return brokers, response.ControllerID, nil
}

func (ca *clusterAdmin) describeClusterUsingMetadata() (brokers []*Broker, controllerID int32, err error) {
	var response *MetadataResponse