tidb: github.com/pingcap/tidb/domain/infosync Index | Files

package infosync

import "github.com/pingcap/tidb/domain/infosync"

Index

Package Files

info.go

Constants

❖
const (
    // ServerInformationPath store server information such as IP, port and so on.
    ServerInformationPath = "/tidb/server/info"
    // ServerMinStartTSPath store the server min start timestamp.
    ServerMinStartTSPath = "/tidb/server/minstartts"
    // TiFlashTableSyncProgressPath store the tiflash table replica sync progress.
    TiFlashTableSyncProgressPath = "/tiflash/table/sync"

    // InfoSessionTTL is the ETCD session's TTL in seconds.
    InfoSessionTTL = 10 * 60
    // ReportInterval is interval of infoSyncerKeeper reporting min startTS.
    ReportInterval = 30 * time.Second
    // TopologyInformationPath means etcd path for storing topology info.
    TopologyInformationPath = "/topology/tidb"
    // TopologySessionTTL is ttl for topology, ant it's the ETCD session's TTL in seconds.
    TopologySessionTTL = 45
    // TopologyTimeToRefresh means time to refresh etcd.
    TopologyTimeToRefresh = 30 * time.Second
    // TopologyPrometheus means address of prometheus.
    TopologyPrometheus = "/topology/prometheus"
    // TablePrometheusCacheExpiry is the expiry time for prometheus address cache.
    TablePrometheusCacheExpiry = 10 * time.Second
)

Variables

❖
var ErrPrometheusAddrIsNotSet = terror.ClassDomain.New(errno.ErrPrometheusAddrIsNotSet, errno.MySQLErrName[errno.ErrPrometheusAddrIsNotSet])

ErrPrometheusAddrIsNotSet is the error that Prometheus address is not set in PD and etcd

func DeleteTiFlashTableSyncProgress Uses

❖
func DeleteTiFlashTableSyncProgress(tid int64) error

DeleteTiFlashTableSyncProgress is used to delete the tiflash table replica sync progress.

func GetAllServerInfo Uses

❖
func GetAllServerInfo(ctx context.Context) (map[string]*ServerInfo, error)

GetAllServerInfo gets all servers static information from etcd.

func GetPrometheusAddr Uses

❖
func GetPrometheusAddr() (string, error)

GetPrometheusAddr gets prometheus Address

func GetTiFlashTableSyncProgress Uses

❖
func GetTiFlashTableSyncProgress(ctx context.Context) (map[int64]float64, error)

GetTiFlashTableSyncProgress uses to get all the tiflash table replica sync progress.

func UpdateTiFlashTableSyncProgress Uses

❖
func UpdateTiFlashTableSyncProgress(ctx context.Context, tid int64, progress float64) error

UpdateTiFlashTableSyncProgress is used to update the tiflash table replica sync progress.

type InfoSyncer Uses

❖
type InfoSyncer struct {
    // contains filtered or unexported fields
}

InfoSyncer stores server info to etcd when the tidb-server starts and delete when tidb-server shuts down.

func GlobalInfoSyncerInit Uses

❖
func GlobalInfoSyncerInit(ctx context.Context, id string, etcdCli *clientv3.Client) (*InfoSyncer, error)

GlobalInfoSyncerInit return a new InfoSyncer. It is exported for testing.

func (*InfoSyncer) Done Uses

❖
func (is *InfoSyncer) Done() <-chan struct{}

Done returns a channel that closes when the info syncer is no longer being refreshed.

func (*InfoSyncer) GetMinStartTS Uses

❖
func (is *InfoSyncer) GetMinStartTS() uint64

GetMinStartTS get min start timestamp. Export for testing.

func (*InfoSyncer) RemoveMinStartTS Uses

❖
func (is *InfoSyncer) RemoveMinStartTS()

RemoveMinStartTS removes self server min start timestamp from etcd.

func (*InfoSyncer) RemoveServerInfo Uses

❖
func (is *InfoSyncer) RemoveServerInfo()

RemoveServerInfo remove self server static information from etcd.

func (*InfoSyncer) ReportMinStartTS Uses

❖
func (is *InfoSyncer) ReportMinStartTS(store kv.Storage)

ReportMinStartTS reports self server min start timestamp to ETCD.

func (*InfoSyncer) Restart Uses

❖
func (is *InfoSyncer) Restart(ctx context.Context) error

Restart restart the info syncer with new session leaseID and store server info to etcd again.

func (*InfoSyncer) RestartTopology Uses

❖
func (is *InfoSyncer) RestartTopology(ctx context.Context) error

RestartTopology restart the topology syncer with new session leaseID and store server info to etcd again.

func (*InfoSyncer) SetSessionManager Uses

❖
func (is *InfoSyncer) SetSessionManager(manager util2.SessionManager)

SetSessionManager set the session manager for InfoSyncer.

func (*InfoSyncer) StoreTopologyInfo Uses

❖
func (is *InfoSyncer) StoreTopologyInfo(ctx context.Context) error

StoreTopologyInfo stores the topology of tidb to etcd.

func (*InfoSyncer) TopologyDone Uses

❖
func (is *InfoSyncer) TopologyDone() <-chan struct{}

TopologyDone returns a channel that closes when the topology syncer is no longer being refreshed.

type ServerInfo Uses

❖
type ServerInfo struct {
    ServerVersionInfo
    ID             string `json:"ddl_id"`
    IP             string `json:"ip"`
    Port           uint   `json:"listening_port"`
    StatusPort     uint   `json:"status_port"`
    Lease          string `json:"lease"`
    BinlogStatus   string `json:"binlog_status"`
    StartTimestamp int64  `json:"start_timestamp"`
}

ServerInfo is server static information. It will not be updated when tidb-server running. So please only put static information in ServerInfo struct.

func GetServerInfo Uses

❖
func GetServerInfo() (*ServerInfo, error)

GetServerInfo gets self server static information.

func GetServerInfoByID Uses

❖
func GetServerInfoByID(ctx context.Context, id string) (*ServerInfo, error)

GetServerInfoByID gets specified server static information from etcd.

type ServerVersionInfo Uses

❖
type ServerVersionInfo struct {
    Version string `json:"version"`
    GitHash string `json:"git_hash"`
}

ServerVersionInfo is the server version and git_hash.

Package infosync imports 30 packages (graph) and is imported by 18 packages. Updated 2020-06-01. Refresh now. Tools for package owners.