Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type InternalClient ¶
type InternalClient struct {
// contains filtered or unexported fields
}
InternalClient provides access to internal admin APIs for cluster management
func NewInternalClient ¶
func NewInternalClient(baseURL string, httpClient *http.Client) *InternalClient
NewInternalClient creates a new internal admin client
func (*InternalClient) AddMetadataPeer ¶
func (c *InternalClient) AddMetadataPeer(nodeID uint64, raftURL string) error
AddMetadataPeer adds a new peer to the metadata raft cluster
func (*InternalClient) GetMetadataStatus ¶
func (c *InternalClient) GetMetadataStatus() (*MetadataStatus, error)
GetMetadataStatus retrieves the current status of the metadata raft cluster
func (*InternalClient) RemoveMetadataPeer ¶
func (c *InternalClient) RemoveMetadataPeer(nodeID uint64) error
RemoveMetadataPeer removes a peer from the metadata raft cluster
type MetadataStatus ¶
type MetadataStatus struct {
Leader uint64
Members map[uint64]string // nodeID -> raft URL (empty URL if not available)
}
MetadataStatus represents the status of the metadata raft cluster
type RaftStatus ¶
type RaftStatus struct {
Lead uint64 `json:"leader_id,omitempty"`
Voters map[uint64]string `json:"voters,omitempty"`
}
RaftStatus represents raft cluster status
type ShardInfo ¶
type ShardInfo struct {
Peers map[uint64]string `json:"peers,omitempty"`
RaftStatus *RaftStatus `json:"raft_status,omitempty"`
}
ShardInfo contains metadata shard information
Source Files
Click to show internal directories.
Click to hide internal directories.