globalconfigsync

Documentation

Index

• Constants
• type GlobalConfigSyncer
  • func NewGlobalConfigSyncer(p pd.Client) *GlobalConfigSyncer
  • func (s *GlobalConfigSyncer) Notify(globalConfigItem pd.GlobalConfigItem)
  • func (s *GlobalConfigSyncer) StoreGlobalConfig(ctx context.Context, item pd.GlobalConfigItem) error

Constants

const GlobalConfigPath = "/global/config/"

GlobalConfigPath as Etcd prefix

Types

type GlobalConfigSyncer

type GlobalConfigSyncer struct {
	NotifyCh chan pd.GlobalConfigItem
	// contains filtered or unexported fields
}

GlobalConfigSyncer is used to sync pd global config.

func NewGlobalConfigSyncer

func NewGlobalConfigSyncer(p pd.Client) *GlobalConfigSyncer

NewGlobalConfigSyncer creates a GlobalConfigSyncer.

func (*GlobalConfigSyncer) Notify

func (s *GlobalConfigSyncer) Notify(globalConfigItem pd.GlobalConfigItem)

Notify pushes global config to internal channel and will be sync into pd's GlobalConfig.

func (*GlobalConfigSyncer) StoreGlobalConfig

func (s *GlobalConfigSyncer) StoreGlobalConfig(ctx context.Context, item pd.GlobalConfigItem) error

StoreGlobalConfig is used to store global config.