Versions in this module Expand all Collapse all v0 v0.1.0 Jun 23, 2020 Changes in this version + const DefaultTimeout + func GetTLSConfig(kubeCli kubernetes.Interface, namespace Namespace, tcName string, ...) (*tls.Config, error) + func PDEtcdClientURL(namespace Namespace, clusterName string) string + func PdClientURL(namespace Namespace, clusterName string, scheme string) string + type Action struct + ID uint64 + Labels map[string]string + Name string + Replication PDReplicationConfig + type ActionType string + const BeginEvictLeaderActionType + const DeleteMemberActionType + const DeleteMemberByIDActionType + const DeleteStoreActionType + const EndEvictLeaderActionType + const GetClusterActionType + const GetConfigActionType + const GetEvictLeaderSchedulersActionType + const GetHealthActionType + const GetMembersActionType + const GetPDLeaderActionType + const GetStoreActionType + const GetStoresActionType + const GetTombStoneStoresActionType + const SetStoreLabelsActionType + const SetStoreStateActionType + const TransferPDLeaderActionType + const UpdateReplicationActionType + type FakePDClient struct + func NewFakePDClient() *FakePDClient + func (pc *FakePDClient) AddReaction(actionType ActionType, reaction Reaction) + func (pc *FakePDClient) BeginEvictLeader(storeID uint64) error + func (pc *FakePDClient) DeleteMember(name string) error + func (pc *FakePDClient) DeleteMemberByID(id uint64) error + func (pc *FakePDClient) DeleteStore(id uint64) error + func (pc *FakePDClient) EndEvictLeader(storeID uint64) error + func (pc *FakePDClient) GetCluster() (*metapb.Cluster, error) + func (pc *FakePDClient) GetConfig() (*PDConfigFromAPI, error) + func (pc *FakePDClient) GetEvictLeaderSchedulers() ([]string, error) + func (pc *FakePDClient) GetHealth() (*HealthInfo, error) + func (pc *FakePDClient) GetMembers() (*MembersInfo, error) + func (pc *FakePDClient) GetPDLeader() (*pdpb.Member, error) + func (pc *FakePDClient) GetStore(id uint64) (*StoreInfo, error) + func (pc *FakePDClient) GetStores() (*StoresInfo, error) + func (pc *FakePDClient) GetTombStoneStores() (*StoresInfo, error) + func (pc *FakePDClient) SetStoreLabels(storeID uint64, labels map[string]string) (bool, error) + func (pc *FakePDClient) SetStoreState(id uint64, state string) error + func (pc *FakePDClient) TransferPDLeader(memberName string) error + func (pc *FakePDClient) UpdateReplicationConfig(config PDReplicationConfig) error + type FakePDControl struct + func NewFakePDControl(kubeCli kubernetes.Interface) *FakePDControl + func (fpc *FakePDControl) SetPDClient(namespace Namespace, tcName string, pdclient PDClient) + func (pdc *FakePDControl) GetPDClient(namespace Namespace, tcName string, tlsEnabled bool) PDClient + func (pdc *FakePDControl) GetPDEtcdClient(namespace Namespace, tcName string, tlsEnabled bool) (PDEtcdClient, error) + type FileLogConfig struct + Filename string + LogRotate bool + MaxBackups int + MaxDays int + MaxSize int + type HealthInfo struct + Healths []MemberHealth + type MemberHealth struct + ClientUrls []string + Health bool + MemberID uint64 + Name string + type MembersInfo struct + EtcdLeader *pdpb.Member + Header *pdpb.ResponseHeader + Leader *pdpb.Member + Members []*pdpb.Member + type MetaStore struct + StateName string + type Namespace string + type NotFoundReaction struct + func (nfr *NotFoundReaction) Error() string + type PDClient interface + BeginEvictLeader func(storeID uint64) error + DeleteMember func(name string) error + DeleteMemberByID func(memberID uint64) error + DeleteStore func(storeID uint64) error + EndEvictLeader func(storeID uint64) error + GetCluster func() (*metapb.Cluster, error) + GetConfig func() (*PDConfigFromAPI, error) + GetEvictLeaderSchedulers func() ([]string, error) + GetHealth func() (*HealthInfo, error) + GetMembers func() (*MembersInfo, error) + GetPDLeader func() (*pdpb.Member, error) + GetStore func(storeID uint64) (*StoreInfo, error) + GetStores func() (*StoresInfo, error) + GetTombStoneStores func() (*StoresInfo, error) + SetStoreLabels func(storeID uint64, labels map[string]string) (bool, error) + SetStoreState func(storeID uint64, state string) error + TransferPDLeader func(name string) error + UpdateReplicationConfig func(config PDReplicationConfig) error + func NewPDClient(url string, timeout time.Duration, tlsConfig *tls.Config) PDClient + type PDConfigFromAPI struct + Log *PDLogConfig + Replication *PDReplicationConfig + Schedule *PDScheduleConfig + type PDControlInterface interface + GetPDClient func(Namespace, string, bool) PDClient + GetPDEtcdClient func(namespace Namespace, tcName string, tlsEnabled bool) (PDEtcdClient, error) + func NewDefaultPDControl(kubeCli kubernetes.Interface) PDControlInterface + type PDEtcdClient interface + DeleteKey func(key string) error + PutKey func(key, value string) error + func NewPdEtcdClient(url string, timeout time.Duration, tlsConfig *tls.Config) (PDEtcdClient, error) + type PDLabelPropertyConfig map[string]PDStoreLabels + type PDLogConfig struct + Development *bool + DisableCaller *bool + DisableErrorVerbose *bool + DisableStacktrace *bool + DisableTimestamp *bool + File *FileLogConfig + Format string + Level string + type PDReplicationConfig struct + EnablePlacementRules *bool + LocationLabels StringSlice + MaxReplicas *uint64 + StrictlyMatchLabel *bool + type PDScheduleConfig struct + DisableLearner *bool + DisableLocationReplacement *bool + DisableMakeUpReplica *bool + DisableNamespaceRelocation *bool + DisableRemoveDownReplica *bool + DisableRemoveExtraReplica *bool + DisableReplaceOfflineReplica *bool + EnableCrossTableMerge *bool + EnableOneWayMerge *bool + HighSpaceRatio *float64 + HotRegionCacheHitsThreshold *uint64 + HotRegionScheduleLimit *uint64 + LeaderScheduleLimit *uint64 + LowSpaceRatio *float64 + MaxMergeRegionKeys *uint64 + MaxMergeRegionSize *uint64 + MaxPendingPeerCount *uint64 + MaxSnapshotCount *uint64 + MaxStoreDownTime string + MergeScheduleLimit *uint64 + PatrolRegionInterval string + RegionScheduleLimit *uint64 + ReplicaScheduleLimit *uint64 + Schedulers *PDSchedulerConfigs + SchedulersPayload map[string]string + SplitMergeInterval string + TolerantSizeRatio *float64 + type PDSchedulerConfig struct + Args []string + Disable *bool + Type string + type PDSchedulerConfigs []PDSchedulerConfig + type PDStoreLabel struct + Key string + Value string + type PDStoreLabels []PDStoreLabel + type Reaction func(action *Action) (interface{}, error) + type StoreInfo struct + Status *StoreStatus + Store *MetaStore + type StoreStatus struct + ApplyingSnapCount uint32 + Available typeutil.ByteSize + Capacity typeutil.ByteSize + IsBusy bool + LastHeartbeatTS time.Time + LeaderCount int + ReceivingSnapCount uint32 + RegionCount int + SendingSnapCount uint32 + StartTS time.Time + Uptime typeutil.Duration + type StoresInfo struct + Count int + Stores []*StoreInfo + type StringSlice []string + func (s *StringSlice) UnmarshalJSON(text []byte) error + func (s StringSlice) MarshalJSON() ([]byte, error)