pdtopo

package

v0.0.0-...-0119d12 Latest Latest Go to latest Published: Apr 26, 2024 License: Apache-2.0 Imports: 14 Imported by: 1

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/pingcap/tidb-dashboard

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func GetAlertManagerInstance(ctx context.Context, etcdClient *clientv3.Client) (*topo.AlertManagerInfo, error)
func GetGrafanaInstance(ctx context.Context, etcdClient *clientv3.Client) (*topo.GrafanaInfo, error)
func GetPDInstances(ctx context.Context, pdAPI *pdclient.APIClient) ([]topo.PDInfo, error)
func GetPrometheusInstance(ctx context.Context, etcdClient *clientv3.Client) (*topo.PrometheusInfo, error)
func GetStoreInstances(ctx context.Context, pdAPI *pdclient.APIClient) ([]topo.TiKVStoreInfo, []topo.TiFlashStoreInfo, error)
func GetTiDBInstances(ctx context.Context, etcdClient *clientv3.Client) ([]topo.TiDBInfo, error)
func NewTopologyProviderFromPD(etcdClient *clientv3.Client, pdAPI *pdclient.APIClient) topo.TopologyProvider
type TopologyFromPD

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	ErrNS                  = errorx.NewNamespace("topo.pd")
	ErrEtcdRequestFailed   = ErrNS.NewType("etcd_request_failed")
	ErrInvalidTopologyData = ErrNS.NewType("invalid_topology_data")
)

Functions ¶

func GetAlertManagerInstance ¶

func GetAlertManagerInstance(ctx context.Context, etcdClient *clientv3.Client) (*topo.AlertManagerInfo, error)

func GetGrafanaInstance ¶

func GetGrafanaInstance(ctx context.Context, etcdClient *clientv3.Client) (*topo.GrafanaInfo, error)

func GetPDInstances ¶

func GetPDInstances(ctx context.Context, pdAPI *pdclient.APIClient) ([]topo.PDInfo, error)

func GetPrometheusInstance ¶

func GetPrometheusInstance(ctx context.Context, etcdClient *clientv3.Client) (*topo.PrometheusInfo, error)

func GetStoreInstances ¶

func GetStoreInstances(ctx context.Context, pdAPI *pdclient.APIClient) ([]topo.TiKVStoreInfo, []topo.TiFlashStoreInfo, error)

GetStoreInstances returns TiKV info and TiFlash info.

func GetTiDBInstances ¶

func GetTiDBInstances(ctx context.Context, etcdClient *clientv3.Client) ([]topo.TiDBInfo, error)

func NewTopologyProviderFromPD ¶

func NewTopologyProviderFromPD(etcdClient *clientv3.Client, pdAPI *pdclient.APIClient) topo.TopologyProvider

NewTopologyProviderFromPD creates a provider that gets topology information from PD. The base URL of the PD API client must be correctly set.

Types ¶

type TopologyFromPD ¶

type TopologyFromPD struct {
	// contains filtered or unexported fields
}

TopologyFromPD provides the topology information from PD.

func (*TopologyFromPD) GetAlertManager ¶

func (p *TopologyFromPD) GetAlertManager(ctx context.Context) (*topo.AlertManagerInfo, error)

func (*TopologyFromPD) GetGrafana ¶

func (p *TopologyFromPD) GetGrafana(ctx context.Context) (*topo.GrafanaInfo, error)

func (*TopologyFromPD) GetPD ¶

func (p *TopologyFromPD) GetPD(ctx context.Context) ([]topo.PDInfo, error)

func (*TopologyFromPD) GetPrometheus ¶

func (p *TopologyFromPD) GetPrometheus(ctx context.Context) (*topo.PrometheusInfo, error)

func (*TopologyFromPD) GetTiDB ¶

func (p *TopologyFromPD) GetTiDB(ctx context.Context) ([]topo.TiDBInfo, error)

func (*TopologyFromPD) GetTiFlash ¶

func (p *TopologyFromPD) GetTiFlash(ctx context.Context) ([]topo.TiFlashStoreInfo, error)

func (*TopologyFromPD) GetTiKV ¶

func (p *TopologyFromPD) GetTiKV(ctx context.Context) ([]topo.TiKVStoreInfo, error)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL