operator

package

Go to main page

Versions in this module

v4

v4.0.4

Jul 21, 2020

v4.0.3

Jul 21, 2020

v4.0.2

Jun 23, 2020

Changes in this version

type AddLearner

+ func (al AddLearner) CheckSafety(region *core.RegionInfo) error

type AddLightLearner

+ func (al AddLightLearner) CheckSafety(region *core.RegionInfo) error

type AddLightPeer

+ func (ap AddLightPeer) CheckSafety(region *core.RegionInfo) error

type AddPeer

+ func (ap AddPeer) CheckSafety(region *core.RegionInfo) error

type MergeRegion

+ func (mr MergeRegion) CheckSafety(region *core.RegionInfo) error

type OpStep

+ CheckSafety func(region *core.RegionInfo) error

type PromoteLearner

+ func (pl PromoteLearner) CheckSafety(region *core.RegionInfo) error

type RemovePeer

+ func (rp RemovePeer) CheckSafety(region *core.RegionInfo) error

type SplitRegion

+ func (sr SplitRegion) CheckSafety(region *core.RegionInfo) error

type TransferLeader

+ func (tl TransferLeader) CheckSafety(region *core.RegionInfo) error

v4.0.1

Jun 5, 2020

v4.0.0

May 27, 2020

Changes in this version

+ const LeaderOperatorWaitTime

+ const OperatorExpireTime

+ const RegionOperatorWaitTime

+ func IsEndStatus(s OpStatus) bool

+ func OpStatusToPDPB(s OpStatus) pdpb.OperatorStatus

+ func OpStatusToString(s OpStatus) string

+ func SetOperatorStatusReachTime(op *Operator, st OpStatus, t time.Time)

+ type AddLearner struct

+ PeerID uint64

+ ToStore uint64

+ func (al AddLearner) ConfVerChanged(region *core.RegionInfo) bool

+ func (al AddLearner) Influence(opInfluence OpInfluence, region *core.RegionInfo)

+ func (al AddLearner) IsFinish(region *core.RegionInfo) bool

+ func (al AddLearner) String() string

+ type AddLightLearner struct

+ PeerID uint64

+ ToStore uint64

+ func (al AddLightLearner) ConfVerChanged(region *core.RegionInfo) bool

+ func (al AddLightLearner) Influence(opInfluence OpInfluence, region *core.RegionInfo)

+ func (al AddLightLearner) IsFinish(region *core.RegionInfo) bool

+ func (al AddLightLearner) String() string

+ type AddLightPeer struct

+ PeerID uint64

+ ToStore uint64

+ func (ap AddLightPeer) ConfVerChanged(region *core.RegionInfo) bool

+ func (ap AddLightPeer) Influence(opInfluence OpInfluence, region *core.RegionInfo)

+ func (ap AddLightPeer) IsFinish(region *core.RegionInfo) bool

+ func (ap AddLightPeer) String() string

+ type AddPeer struct

+ PeerID uint64

+ ToStore uint64

+ func (ap AddPeer) ConfVerChanged(region *core.RegionInfo) bool

+ func (ap AddPeer) Influence(opInfluence OpInfluence, region *core.RegionInfo)

+ func (ap AddPeer) IsFinish(region *core.RegionInfo) bool

+ func (ap AddPeer) String() string

+ type Builder struct

+ func NewBuilder(desc string, cluster Cluster, region *core.RegionInfo) *Builder

+ func (b *Builder) AddPeer(p *metapb.Peer) *Builder

+ func (b *Builder) Build(kind OpKind) (*Operator, error)

+ func (b *Builder) PromoteLearner(storeID uint64) *Builder

+ func (b *Builder) RemovePeer(storeID uint64) *Builder

+ func (b *Builder) SetLeader(storeID uint64) *Builder

+ func (b *Builder) SetLightWeight() *Builder

+ func (b *Builder) SetPeers(peers map[uint64]*metapb.Peer) *Builder

+ type Cluster interface

+ AllocID func() (uint64, error)

+ FitRegion func(region *core.RegionInfo) *placement.RegionFit

+ GetStore func(id uint64) *core.StoreInfo

+ type MergeRegion struct

+ FromRegion *metapb.Region

+ IsPassive bool

+ ToRegion *metapb.Region

+ func (mr MergeRegion) ConfVerChanged(region *core.RegionInfo) bool

+ func (mr MergeRegion) Influence(opInfluence OpInfluence, region *core.RegionInfo)

+ func (mr MergeRegion) IsFinish(region *core.RegionInfo) bool

+ func (mr MergeRegion) String() string

+ type OpHistory struct

+ FinishTime time.Time

+ From uint64

+ Kind core.ResourceKind

+ To uint64

+ type OpInfluence struct

+ StoresInfluence map[uint64]*StoreInfluence

+ func (m OpInfluence) GetStoreInfluence(id uint64) *StoreInfluence

+ type OpKind uint32

+ const OpAdjacent

+ const OpAdmin

+ const OpBalance

+ const OpHotRegion

+ const OpLeader

+ const OpMerge

+ const OpRange

+ const OpRegion

+ const OpReplica

+ const OpSplit

+ func ParseOperatorKind(str string) (OpKind, error)

+ func (k OpKind) String() string

+ type OpStatus = uint32

+ const CANCELED

+ const CREATED

+ const EXPIRED

+ const REPLACED

+ const STARTED

+ const SUCCESS

+ const TIMEOUT

+ type OpStatusTracker struct

+ func NewOpStatusTracker() OpStatusTracker

+ func (trk *OpStatusTracker) CheckExpired(exp time.Duration) bool

+ func (trk *OpStatusTracker) CheckTimeout(wait time.Duration) bool

+ func (trk *OpStatusTracker) IsEnd() bool

+ func (trk *OpStatusTracker) ReachTime() time.Time

+ func (trk *OpStatusTracker) ReachTimeOf(s OpStatus) time.Time

+ func (trk *OpStatusTracker) Status() OpStatus

+ func (trk *OpStatusTracker) String() string

+ func (trk *OpStatusTracker) To(dst OpStatus) bool

+ type OpStep interface

+ ConfVerChanged func(region *core.RegionInfo) bool

+ Influence func(opInfluence OpInfluence, region *core.RegionInfo)

+ IsFinish func(region *core.RegionInfo) bool

+ type Operator struct

+ Counters []prometheus.Counter

+ func CreateAddPeerOperator(desc string, cluster Cluster, region *core.RegionInfo, peer *metapb.Peer, ...) (*Operator, error)

+ func CreateMergeRegionOperator(desc string, cluster Cluster, source *core.RegionInfo, target *core.RegionInfo, ...) ([]*Operator, error)

+ func CreateMoveLeaderOperator(desc string, cluster Cluster, region *core.RegionInfo, kind OpKind, ...) (*Operator, error)

+ func CreateMovePeerOperator(desc string, cluster Cluster, region *core.RegionInfo, kind OpKind, ...) (*Operator, error)

+ func CreateMoveRegionOperator(desc string, cluster Cluster, region *core.RegionInfo, kind OpKind, ...) (*Operator, error)

+ func CreatePromoteLearnerOperator(desc string, cluster Cluster, region *core.RegionInfo, peer *metapb.Peer) (*Operator, error)

+ func CreateRemovePeerOperator(desc string, cluster Cluster, kind OpKind, region *core.RegionInfo, ...) (*Operator, error)

+ func CreateScatterRegionOperator(desc string, cluster Cluster, origin *core.RegionInfo, ...) (*Operator, error)

+ func CreateSplitRegionOperator(desc string, region *core.RegionInfo, kind OpKind, policy pdpb.CheckPolicy, ...) *Operator

+ func CreateTransferLeaderOperator(desc string, cluster Cluster, region *core.RegionInfo, sourceStoreID uint64, ...) (*Operator, error)

+ func NewOperator(desc, brief string, regionID uint64, regionEpoch *metapb.RegionEpoch, ...) *Operator

+ func (o *Operator) AttachKind(kind OpKind)

+ func (o *Operator) Cancel() bool

+ func (o *Operator) Check(region *core.RegionInfo) OpStep

+ func (o *Operator) CheckExpired() bool

+ func (o *Operator) CheckSuccess() bool

+ func (o *Operator) CheckTimeout() bool

+ func (o *Operator) ConfVerChanged(region *core.RegionInfo) int

+ func (o *Operator) Desc() string

+ func (o *Operator) ElapsedTime() time.Duration

+ func (o *Operator) GetCreateTime() time.Time

+ func (o *Operator) GetPriorityLevel() core.PriorityLevel

+ func (o *Operator) GetReachTimeOf(st OpStatus) time.Time

+ func (o *Operator) GetStartTime() time.Time

+ func (o *Operator) HasStarted() bool

+ func (o *Operator) History() []OpHistory

+ func (o *Operator) IsEnd() bool

+ func (o *Operator) Kind() OpKind

+ func (o *Operator) Len() int

+ func (o *Operator) MarshalJSON() ([]byte, error)

+ func (o *Operator) RegionEpoch() *metapb.RegionEpoch

+ func (o *Operator) RegionID() uint64

+ func (o *Operator) Replace() bool

+ func (o *Operator) RunningTime() time.Duration

+ func (o *Operator) SetDesc(desc string)

+ func (o *Operator) SetPriorityLevel(level core.PriorityLevel)

+ func (o *Operator) Start() bool

+ func (o *Operator) Status() OpStatus

+ func (o *Operator) Step(i int) OpStep

+ func (o *Operator) String() string

+ func (o *Operator) TotalInfluence(opInfluence OpInfluence, region *core.RegionInfo)

+ func (o *Operator) UnfinishedInfluence(opInfluence OpInfluence, region *core.RegionInfo)

+ type PromoteLearner struct

+ PeerID uint64

+ ToStore uint64

+ func (pl PromoteLearner) ConfVerChanged(region *core.RegionInfo) bool

+ func (pl PromoteLearner) Influence(opInfluence OpInfluence, region *core.RegionInfo)

+ func (pl PromoteLearner) IsFinish(region *core.RegionInfo) bool

+ func (pl PromoteLearner) String() string

+ type RemovePeer struct

+ FromStore uint64

+ func (rp RemovePeer) ConfVerChanged(region *core.RegionInfo) bool

+ func (rp RemovePeer) Influence(opInfluence OpInfluence, region *core.RegionInfo)

+ func (rp RemovePeer) IsFinish(region *core.RegionInfo) bool

+ func (rp RemovePeer) String() string

+ type SplitRegion struct

+ EndKey []byte

+ Policy pdpb.CheckPolicy

+ SplitKeys [][]byte

+ StartKey []byte

+ func (sr SplitRegion) ConfVerChanged(region *core.RegionInfo) bool

+ func (sr SplitRegion) Influence(opInfluence OpInfluence, region *core.RegionInfo)

+ func (sr SplitRegion) IsFinish(region *core.RegionInfo) bool

+ func (sr SplitRegion) String() string

+ type StoreInfluence struct

+ LeaderCount int64

+ LeaderSize int64

+ RegionCount int64

+ RegionSize int64

+ StepCost map[storelimit.Type]int64

+ func (s *StoreInfluence) AdjustStepCost(limitType storelimit.Type, regionSize int64)

+ func (s StoreInfluence) GetStepCost(limitType storelimit.Type) int64

+ func (s StoreInfluence) ResourceProperty(kind core.ScheduleKind) int64

+ type TransferLeader struct

+ FromStore uint64

+ ToStore uint64

+ func (tl TransferLeader) ConfVerChanged(region *core.RegionInfo) bool

+ func (tl TransferLeader) Influence(opInfluence OpInfluence, region *core.RegionInfo)

+ func (tl TransferLeader) IsFinish(region *core.RegionInfo) bool

+ func (tl TransferLeader) String() string

v4.0.0-rc.2

May 14, 2020

v4.0.0-rc.1

Apr 3, 2020

v4.0.0-rc

Apr 3, 2020

v4.0.0-beta.2

Mar 18, 2020

Other modules containing this package

github.com/pingcap/pd/v3

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