metadata.go

package mysqlrouter

import (
	"encoding/json"
	"fmt"
	"time"
)

var (
	metadataURL = "/metadata"
)

// MetadataResponse is the response of getting all metadata endpoint.
type MetadataResponse struct {
	Item []*Metadata `json:"items"`
}

// Metadata is the structure of getting all metadata endpoint.
type Metadata struct {
	Name string `json:"name"`
}

// MetadataConfig is the structure of the configuration of metadata.
type MetadataConfig struct {
	ClusterName        string         `json:"clusterName"`
	TimeRefreshInMs    int            `json:"timeRefreshInMs"`
	GroupReplicationID string         `json:"groupReplicationId"`
	Nodes              []MetadataNode `json:"nodes"`
}

// MetadataNode is the structure of metadata of a node.
type MetadataNode struct {
	Hostname string `json:"hostname"`
	Port     int    `json:"port"`
}

// MetadataStatus is the structure of the information of metadata.
type MetadataStatus struct {
	RefreshFailed            int       `json:"refreshFailed"`
	RefreshSucceeded         int       `json:"refreshSucceeded"`
	TimeLastRefreshSucceeded time.Time `json:"timeLastRefreshSucceeded"`
	LastRefreshHostname      string    `json:"lastRefreshHostname"`
	LastRefreshPort          int       `json:"lastRefreshPort"`
}

// GetAllMetadata returns all metadata.
func (c *Client) GetAllMetadata() ([]*Metadata, error) {
	b, err := c.request(c.URL + metadataURL)
	if err != nil {
		return nil, err
	}

	var r *MetadataResponse
	err = json.Unmarshal(b, &r)
	if err != nil {
		return nil, err
	}

	return r.Item, nil
}

// GetMetadataConfig returns the configuration of metadata.
func (c *Client) GetMetadataConfig(cName string) (*MetadataConfig, error) {
	b, err := c.request(fmt.Sprintf("%s%s/%s/config", c.URL, metadataURL, cName))
	if err != nil {
		return nil, err
	}

	var r *MetadataConfig
	err = json.Unmarshal(b, &r)
	if err != nil {
		return nil, err
	}

	return r, nil
}

// GetMetadataStatus returns the state of metadata.
func (c *Client) GetMetadataStatus(cName string) (*MetadataStatus, error) {
	b, err := c.request(fmt.Sprintf("%s%s/%s/status", c.URL, metadataURL, cName))
	if err != nil {
		return nil, err
	}

	var r *MetadataStatus
	err = json.Unmarshal(b, &r)
	if err != nil {
		return nil, err
	}

	return r, nil
}