Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

schedule

package

Go to main page

Versions in this module

v1

v1.1.0-alpha

Oct 16, 2017

v1.0.2

Nov 13, 2017

v1.0.0

Oct 16, 2017

Changes in this version

+ const MaxOperatorWaitTime

+ const MaxScheduleInterval

+ const MinScheduleInterval

+ const MinSlowScheduleInterval

+ func DistinctScore(labels []string, stores []*core.StoreInfo, other *core.StoreInfo) float64

+ func FilterSource(store *core.StoreInfo, filters []Filter) bool

+ func FilterTarget(store *core.StoreInfo, filters []Filter) bool

+ func RegisterScheduler(name string, createFn CreateSchedulerFunc)

+ type AddPeer struct

+ PeerID uint64

+ ToStore uint64

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

+ func (ap AddPeer) String() string

+ type Cluster interface

+ AllocPeer func(storeID uint64) (*metapb.Peer, error)

+ BlockStore func(id uint64) error

+ GetFollowerStores func(region *core.RegionInfo) []*core.StoreInfo

+ GetLeaderStore func(region *core.RegionInfo) *core.StoreInfo

+ GetRegion func(id uint64) *core.RegionInfo

+ GetRegionStores func(region *core.RegionInfo) []*core.StoreInfo

+ GetStore func(id uint64) *core.StoreInfo

+ GetStores func() []*core.StoreInfo

+ IsRegionHot func(id uint64) bool

+ RandFollowerRegion func(storeID uint64) *core.RegionInfo

+ RandLeaderRegion func(storeID uint64) *core.RegionInfo

+ RegionReadStats func() []*core.RegionStat

+ RegionWriteStats func() []*core.RegionStat

+ UnblockStore func(id uint64)

+ type CreateSchedulerFunc func(opt Options, args []string) (Scheduler, error)

+ type Filter interface

+ FilterSource func(store *core.StoreInfo) bool

+ FilterTarget func(store *core.StoreInfo) bool

+ func NewBlockFilter() Filter

+ func NewCacheFilter(cache *cache.TTLUint64) Filter

+ func NewDistinctScoreFilter(labels []string, stores []*core.StoreInfo, source *core.StoreInfo) Filter

+ func NewExcludedFilter(sources, targets map[uint64]struct{}) Filter

+ func NewHealthFilter(opt Options) Filter

+ func NewNamespaceFilter(classifier namespace.Classifier, namespace string) Filter

+ func NewSnapshotCountFilter(opt Options) Filter

+ func NewStateFilter(opt Options) Filter

+ func NewStorageThresholdFilter(opt Options) Filter

+ type NamespaceChecker struct

+ func NewNamespaceChecker(opt Options, cluster Cluster, classifier namespace.Classifier) *NamespaceChecker

+ func (n *NamespaceChecker) Check(region *core.RegionInfo) *Operator

+ func (n *NamespaceChecker) SelectBestPeerToRelocate(region *core.RegionInfo, targets []*core.StoreInfo, filters ...Filter) *metapb.Peer

+ func (n *NamespaceChecker) SelectBestStoreToRelocate(region *core.RegionInfo, targets []*core.StoreInfo, filters ...Filter) uint64

+ type Operator struct

+ func CreateMovePeerOperator(desc string, region *core.RegionInfo, kind core.ResourceKind, ...) *Operator

+ func CreateRemovePeerOperator(desc string, region *core.RegionInfo, storeID uint64) *Operator

+ func NewOperator(desc string, regionID uint64, kind core.ResourceKind, steps ...OperatorStep) *Operator

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

+ func (o *Operator) Desc() string

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

+ func (o *Operator) IsFinish() bool

+ func (o *Operator) IsTimeout() bool

+ func (o *Operator) Len() int

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

+ func (o *Operator) RegionID() uint64

+ func (o *Operator) ResourceKind() core.ResourceKind

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

+ func (o *Operator) String() string

+ type OperatorStep interface

+ IsFinish func(region *core.RegionInfo) bool

+ type Options interface

+ GetHotRegionLowThreshold func() int

+ GetLeaderScheduleLimit func() uint64

+ GetLocationLabels func() []string

+ GetMaxReplicas func() int

+ GetMaxSnapshotCount func() uint64

+ GetMaxStoreDownTime func() time.Duration

+ GetRegionScheduleLimit func() uint64

+ type RemovePeer struct

+ FromStore uint64

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

+ func (rp RemovePeer) String() string

+ type ReplicaChecker struct

+ func NewReplicaChecker(opt Options, cluster Cluster, classifier namespace.Classifier) *ReplicaChecker

+ func (r *ReplicaChecker) Check(region *core.RegionInfo) *Operator

+ func (r *ReplicaChecker) SelectBestPeerToAddReplica(region *core.RegionInfo, filters ...Filter) *metapb.Peer

+ func (r *ReplicaChecker) SelectBestStoreToAddReplica(region *core.RegionInfo, filters ...Filter) (uint64, float64)

+ type Scheduler interface

+ Cleanup func(cluster Cluster)

+ GetInterval func() time.Duration

+ GetName func() string

+ GetResourceKind func() core.ResourceKind

+ GetResourceLimit func() uint64

+ GetType func() string

+ Prepare func(cluster Cluster) error

+ Schedule func(cluster Cluster) *Operator

+ func CreateScheduler(name string, opt Options, args ...string) (Scheduler, error)

+ type Selector interface

+ SelectSource func(stores []*core.StoreInfo, filters ...Filter) *core.StoreInfo

+ SelectTarget func(stores []*core.StoreInfo, filters ...Filter) *core.StoreInfo

+ func NewBalanceSelector(kind core.ResourceKind, filters []Filter) Selector

+ func NewRandomSelector(filters []Filter) Selector

+ func NewReplicaSelector(regionStores []*core.StoreInfo, labels []string, filters ...Filter) Selector

+ type TransferLeader struct

+ FromStore uint64

+ ToStore uint64

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

+ func (tl TransferLeader) String() string