Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

rpadmin: expose rack,host,port,uuid info via api_broker #27

Merged
merged 1 commit into from
Sep 28, 2024
Merged

rpadmin: expose rack,host,port,uuid info via api_broker #27

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
32 changes: 24 additions & 8 deletions rpadmin/api_broker.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -17,8 +17,9 @@ import (
)

const (
brokersEndpoint = "/v1/brokers"
brokerEndpoint = "/v1/brokers/%d"
brokersEndpoint = "/v1/brokers"
brokerEndpoint = "/v1/brokers/%d"
brokerUuidsEndpoint = "/v1/broker_uuids"
)

// MaintenanceStatus is the maintenance status.
Expand All @@ -44,12 +45,15 @@ const (

// Broker is the information returned from the Redpanda admin broker endpoints.
type Broker struct {
NodeID int `json:"node_id"`
NumCores int `json:"num_cores"`
MembershipStatus MembershipStatus `json:"membership_status"`
IsAlive *bool `json:"is_alive"`
Version string `json:"version"`
Maintenance *MaintenanceStatus `json:"maintenance_status"`
NodeID int `json:"node_id"`
NumCores int `json:"num_cores"`
Rack string `json:"rack"`
InternalRPCAddress string `json:"internal_rpc_address"`
InternalRPCPort int `json:"internal_rpc_port"`
MembershipStatus MembershipStatus `json:"membership_status"`
IsAlive *bool `json:"is_alive"`
Version string `json:"version"`
Maintenance *MaintenanceStatus `json:"maintenance_status"`
}

// DecommissionPartitions holds decommission partitions info.
Expand Down Expand Up @@ -77,6 +81,12 @@ type DecommissionStatusResponse struct {
Partitions []DecommissionPartitions `json:"partitions"`
}

// BrokerUuids is information that shows the mapping of node ID to node UUID.
type BrokerUuids struct {
NodeID int `json:"node_id"`
UUID string `json:"uuid"`
}

// Brokers queries one of the client's hosts and returns the list of brokers.
func (a *AdminAPI) Brokers(ctx context.Context) ([]Broker, error) {
var bs []Broker
Expand Down Expand Up @@ -174,3 +184,9 @@ func (a *AdminAPI) CancelNodePartitionsMovement(ctx context.Context, node int) (
var response []PartitionsMovementResult
return response, a.sendAny(ctx, http.MethodPost, fmt.Sprintf("%s/%d/cancel_partition_moves", brokersEndpoint, node), nil, &response)
}

// GetBrokerUuids retrieves the mapping of node ID to node UUID.
func (a *AdminAPI) GetBrokerUuids(ctx context.Context) ([]BrokerUuids, error) {
var response []BrokerUuids
return response, a.sendAny(ctx, http.MethodGet, brokerUuidsEndpoint, nil, &response)
}
Loading