(request *DescribeClusterRequest)
| 458 | } |
| 459 | |
| 460 | func (b *Broker) DescribeCluster(request *DescribeClusterRequest) (*DescribeClusterResponse, error) { |
| 461 | response := new(DescribeClusterResponse) |
| 462 | response.Version = request.Version |
| 463 | |
| 464 | if err := b.sendAndReceive(request, response); err != nil { |
| 465 | return nil, err |
| 466 | } |
| 467 | |
| 468 | return response, nil |
| 469 | } |
| 470 | |
| 471 | // GetConsumerMetadata send a consumer metadata request and returns a consumer metadata response or error |
| 472 | func (b *Broker) GetConsumerMetadata(request *ConsumerMetadataRequest) (*ConsumerMetadataResponse, error) { |
nothing calls this directly
no test coverage detected