core

package

Go to main page

Versions in this module

v0

v0.3.0

Mar 9, 2022

v0.2.0

Jan 5, 2022

Changes in this version

type BasicCluster

+ DestroyedResources *roaring64.Bitmap

+ DestroyingStatuses map[uint64]*metapb.DestroyingStatus

+ ScheduleGroupKeys map[string]struct{}

+ ScheduleGroupRules []metapb.ScheduleGroupRule

+ func (bc *BasicCluster) AddScheduleGroupRule(rule metapb.ScheduleGroupRule) bool

+ func (bc *BasicCluster) AlreadyRemoved(id uint64) bool

+ func (bc *BasicCluster) GetDestroyResources(bm *roaring64.Bitmap) (*roaring64.Bitmap, *roaring64.Bitmap)

+ func (bc *BasicCluster) GetDestroyingResources() []*CachedResource

+ func (bc *BasicCluster) GetDestroyingStatus(id uint64) *metapb.DestroyingStatus

+ func (bc *BasicCluster) GetResourceGroupRuleCount() int

+ func (bc *BasicCluster) GetScheduleGroupKeys() []string

+ func (bc *BasicCluster) GetScheduleGroupKeysWithPrefix(prefix string) []string

+ func (bc *BasicCluster) UpdateDestroyingStatus(id uint64, status *metapb.DestroyingStatus)

type CachedContainer

+ func (cr *CachedContainer) GetGroupKeys() string

+ func (cr *CachedContainer) GetTotalLeaderCount() int

+ func (cr *CachedContainer) GetTotalLeaderSize() int64

+ func (cr *CachedContainer) GetTotalResourceCount() int

+ func (cr *CachedContainer) GetTotalResourceSize() int64

+ func (ss CachedContainer) GetUsedRatio() float64

type CachedResource

+ func (r *CachedResource) GetGroupKey() string

+ func (r *CachedResource) IsDestroyState() bool

type CachedResources

+ func (r *CachedResources) ForeachCachedResources(group uint64, fn func(res *CachedResource))

+ func (r *CachedResources) GetDestroyingResources() []*CachedResource

type ResourceCreateOption

+ func WithState(state metapb.ResourceState) ResourceCreateOption

type ResourceSetInformer

+ GetScheduleGroupKeys func() []string

+ GetScheduleGroupKeysWithPrefix func(prefix string) []string

v0.1.0

Oct 13, 2021

Changes in this version

+ const EmptyResourceApproximateSize

+ const ImpossibleFlowSize

+ func DiffResourceKeyInfo(origin *CachedResource, other *CachedResource) string

+ func DiffResourcePeersInfo(origin *CachedResource, other *CachedResource) string

+ func DistinctScore(labels []string, containers []*CachedContainer, other *CachedContainer) float64

+ func EncodeToString(src []byte) []byte

+ func HexResourceKey(key []byte) []byte

+ func HexResourceKeyStr(key []byte) string

+ func SortedPeersEqual(peersA, peersB []metapb.Peer) bool

+ func SortedPeersStatsEqual(peersA, peersB []metapb.PeerStats) bool

+ func String(b []byte) (s string)

+ func ToUpperASCIIInplace(s []byte) []byte

+ type BasicCluster struct

+ Containers *CachedContainers

+ RemovedResources *roaring64.Bitmap

+ Resources *CachedResources

+ WaittingCreateResources map[uint64]metadata.Resource

+ func NewBasicCluster(factory func() metadata.Resource) *BasicCluster

+ func (bc *BasicCluster) AddRemovedResources(ids ...uint64)

+ func (bc *BasicCluster) AddWaittingCreateResources(resources ...metadata.Resource)

+ func (bc *BasicCluster) AttachAvailableFunc(containerID uint64, limitType limit.Type, f func() bool)

+ func (bc *BasicCluster) CheckAndPutResource(res *CachedResource) []*CachedResource

+ func (bc *BasicCluster) DeleteContainer(container *CachedContainer)

+ func (bc *BasicCluster) ForeachResources(group uint64, fn func(res metadata.Resource))

+ func (bc *BasicCluster) ForeachWaittingCreateResources(fn func(res metadata.Resource))

+ func (bc *BasicCluster) GetAdjacentResources(res *CachedResource) (*CachedResource, *CachedResource)

+ func (bc *BasicCluster) GetAverageResourceSize() int64

+ func (bc *BasicCluster) GetContainer(containerID uint64) *CachedContainer

+ func (bc *BasicCluster) GetContainerCount() int

+ func (bc *BasicCluster) GetContainerFollowerCount(containerID uint64) int

+ func (bc *BasicCluster) GetContainerLeaderCount(containerID uint64) int

+ func (bc *BasicCluster) GetContainerLeaderResourceSize(containerID uint64) int64

+ func (bc *BasicCluster) GetContainerPendingPeerCount(containerID uint64) int

+ func (bc *BasicCluster) GetContainerResourceCount(containerID uint64) int

+ func (bc *BasicCluster) GetContainerResourceSize(containerID uint64) int64

+ func (bc *BasicCluster) GetContainerResources(containerID uint64) []*CachedResource

+ func (bc *BasicCluster) GetContainers() []*CachedContainer

+ func (bc *BasicCluster) GetFollowerContainers(res *CachedResource) []*CachedContainer

+ func (bc *BasicCluster) GetLeaderContainer(res *CachedResource) *CachedContainer

+ func (bc *BasicCluster) GetMetaContainers() []metadata.Container

+ func (bc *BasicCluster) GetMetaResources() []metadata.Resource

+ func (bc *BasicCluster) GetOverlaps(res *CachedResource) []*CachedResource

+ func (bc *BasicCluster) GetRemovedResources(bm *roaring64.Bitmap) []uint64

+ func (bc *BasicCluster) GetResource(resourceID uint64) *CachedResource

+ func (bc *BasicCluster) GetResourceContainers(res *CachedResource) []*CachedContainer

+ func (bc *BasicCluster) GetResourceCount() int

+ func (bc *BasicCluster) GetResources() []*CachedResource

+ func (bc *BasicCluster) IsWaittingCreateResource(id uint64) bool

+ func (bc *BasicCluster) PauseLeaderTransfer(containerID uint64) error

+ func (bc *BasicCluster) PreCheckPutResource(res *CachedResource) (*CachedResource, error)

+ func (bc *BasicCluster) PutContainer(container *CachedContainer)

+ func (bc *BasicCluster) PutResource(res *CachedResource) []*CachedResource

+ func (bc *BasicCluster) RandFollowerResource(containerID uint64, ranges []KeyRange, opts ...ResourceOption) *CachedResource

+ func (bc *BasicCluster) RandLeaderResource(containerID uint64, ranges []KeyRange, opts ...ResourceOption) *CachedResource

+ func (bc *BasicCluster) RandLearnerResource(containerID uint64, ranges []KeyRange, opts ...ResourceOption) *CachedResource

+ func (bc *BasicCluster) RandPendingResource(containerID uint64, ranges []KeyRange, opts ...ResourceOption) *CachedResource

+ func (bc *BasicCluster) RemoveResource(res *CachedResource)

+ func (bc *BasicCluster) Reset()

+ func (bc *BasicCluster) ResumeLeaderTransfer(containerID uint64)

+ func (bc *BasicCluster) ScanRange(group uint64, startKey, endKey []byte, limit int) []*CachedResource

+ func (bc *BasicCluster) SearchPrevResource(group uint64, resKey []byte) *CachedResource

+ func (bc *BasicCluster) SearchResource(group uint64, resKey []byte) *CachedResource

+ func (bc *BasicCluster) TakeContainer(containerID uint64) *CachedContainer

+ func (bc *BasicCluster) UpdateContainerStatus(group, containerID uint64, leaderCount int, resourceCount int, ...)

+ type CachedContainer struct

+ Meta metadata.Container

+ func NewCachedContainer(meta metadata.Container, opts ...ContainerCreateOption) *CachedContainer

+ func NewTestCachedContainerWithSizeCount(id uint64, resourceCount, leaderCount int, resourceSize, leaderSize int64) *CachedContainer

+ func NewTestContainerInfoWithLabel(id uint64, resourceCount int, labels map[string]string) *CachedContainer

+ func (cr *CachedContainer) AllowLeaderTransfer() bool

+ func (cr *CachedContainer) AvailableRatio() float64

+ func (cr *CachedContainer) Clone(opts ...ContainerCreateOption) *CachedContainer

+ func (cr *CachedContainer) CompareLocation(other *CachedContainer, labels []string) int

+ func (cr *CachedContainer) DownTime() time.Duration

+ func (cr *CachedContainer) GetLabelValue(key string) string

+ func (cr *CachedContainer) GetLastHeartbeatTS() time.Time

+ func (cr *CachedContainer) GetLeaderCount(group uint64) int

+ func (cr *CachedContainer) GetLeaderSize(group uint64) int64

+ func (cr *CachedContainer) GetLeaderWeight() float64

+ func (cr *CachedContainer) GetPendingPeerCount() int

+ func (cr *CachedContainer) GetResourceCount(group uint64) int

+ func (cr *CachedContainer) GetResourceSize(group uint64) int64

+ func (cr *CachedContainer) GetResourceWeight() float64

+ func (cr *CachedContainer) GetStartTime() time.Time

+ func (cr *CachedContainer) GetState() metapb.ContainerState

+ func (cr *CachedContainer) GetUptime() time.Duration

+ func (cr *CachedContainer) IsAvailable(limitType limit.Type) bool

+ func (cr *CachedContainer) IsDisconnected() bool

+ func (cr *CachedContainer) IsLowSpace(lowSpaceRatio float64, groups []uint64) bool

+ func (cr *CachedContainer) IsOffline() bool

+ func (cr *CachedContainer) IsPhysicallyDestroyed() bool

+ func (cr *CachedContainer) IsTombstone() bool

+ func (cr *CachedContainer) IsUnhealthy() bool

+ func (cr *CachedContainer) IsUp() bool

+ func (cr *CachedContainer) LeaderScore(group uint64, policy SchedulePolicy, delta int64) float64

+ func (cr *CachedContainer) MergeLabels(labels []metapb.Pair) []metapb.Pair

+ func (cr *CachedContainer) NeedPersist() bool

+ func (cr *CachedContainer) ResourceCount(group uint64, kind metapb.ResourceKind) uint64

+ func (cr *CachedContainer) ResourceScore(group uint64, version string, highSpaceRatio, lowSpaceRatio float64, ...) float64

+ func (cr *CachedContainer) ResourceSize(group uint64, kind metapb.ResourceKind) int64

+ func (cr *CachedContainer) ResourceWeight(kind metapb.ResourceKind) float64

+ func (cr *CachedContainer) ShallowClone(opts ...ContainerCreateOption) *CachedContainer

+ func (cr *CachedContainer) StorageSize() uint64

+ func (ss CachedContainer) GetApplyingSnapCount() uint64

+ func (ss CachedContainer) GetAvailable() uint64

+ func (ss CachedContainer) GetAvailableDeviation() uint64

+ func (ss CachedContainer) GetAvgAvailable() uint64

+ func (ss CachedContainer) GetBytesRead() uint64

+ func (ss CachedContainer) GetBytesWritten() uint64

+ func (ss CachedContainer) GetCapacity() uint64

+ func (ss CachedContainer) GetContainerStats() *metapb.ContainerStats

+ func (ss CachedContainer) GetKeysRead() uint64

+ func (ss CachedContainer) GetKeysWritten() uint64

+ func (ss CachedContainer) GetReceivingSnapCount() uint64

+ func (ss CachedContainer) GetSendingSnapCount() uint64

+ func (ss CachedContainer) GetUsedSize() uint64

+ func (ss CachedContainer) IsBusy() bool

+ type CachedContainers struct

+ func NewCachedContainers() *CachedContainers

+ func (s *CachedContainers) AttachAvailableFunc(containerID uint64, limitType limit.Type, f func() bool)

+ func (s *CachedContainers) DeleteContainer(container *CachedContainer)

+ func (s *CachedContainers) GetContainer(containerID uint64) *CachedContainer

+ func (s *CachedContainers) GetContainerCount() int

+ func (s *CachedContainers) GetContainers() []*CachedContainer

+ func (s *CachedContainers) GetMetaContainers() []metadata.Container

+ func (s *CachedContainers) PauseLeaderTransfer(containerID uint64) error

+ func (s *CachedContainers) ResumeLeaderTransfer(containerID uint64)

+ func (s *CachedContainers) SetContainer(container *CachedContainer)

+ func (s *CachedContainers) SetLeaderCount(group, containerID uint64, leaderCount int)

+ func (s *CachedContainers) SetLeaderSize(group, containerID uint64, leaderSize int64)

+ func (s *CachedContainers) SetPendingPeerCount(group, containerID uint64, pendingPeerCount int)

+ func (s *CachedContainers) SetResourceCount(group, containerID uint64, resourceCount int)

+ func (s *CachedContainers) SetResourceSize(group, containerID uint64, resourceSize int64)

+ func (s *CachedContainers) TakeContainer(containerID uint64) *CachedContainer

+ func (s *CachedContainers) UpdateContainerStatus(group, containerID uint64, leaderCount int, resourceCount int, ...)

+ type CachedResource struct

+ Meta metadata.Resource

+ func MergeTestResources(resources []*CachedResource) []*CachedResource

+ func NewCachedResource(res metadata.Resource, leader *metapb.Peer, opts ...ResourceCreateOption) *CachedResource

+ func NewTestCachedResource(start, end []byte) *CachedResource

+ func ResourceFromHeartbeat(heartbeat rpcpb.ResourceHeartbeatReq, meta metadata.Resource) *CachedResource

+ func SplitTestResources(resources []*CachedResource) []*CachedResource

+ func (r *CachedResource) Clone(opts ...ResourceCreateOption) *CachedResource

+ func (r *CachedResource) GetApproximateKeys() int64

+ func (r *CachedResource) GetApproximateSize() int64

+ func (r *CachedResource) GetBytesRead() uint64

+ func (r *CachedResource) GetBytesWritten() uint64

+ func (r *CachedResource) GetContainerIDs() map[uint64]struct{}

+ func (r *CachedResource) GetContainerLearner(containerID uint64) (metapb.Peer, bool)

+ func (r *CachedResource) GetContainerPeer(containerID uint64) (metapb.Peer, bool)

+ func (r *CachedResource) GetContainerVoter(containerID uint64) (metapb.Peer, bool)

+ func (r *CachedResource) GetDiffFollowers(other *CachedResource) []metapb.Peer

+ func (r *CachedResource) GetDownLearner(peerID uint64) (metapb.Peer, bool)

+ func (r *CachedResource) GetDownPeer(peerID uint64) (metapb.Peer, bool)

+ func (r *CachedResource) GetDownPeers() []metapb.PeerStats

+ func (r *CachedResource) GetDownVoter(peerID uint64) (metapb.Peer, bool)

+ func (r *CachedResource) GetEndKey() []byte

+ func (r *CachedResource) GetFollower() (metapb.Peer, bool)

+ func (r *CachedResource) GetFollowers() map[uint64]metapb.Peer

+ func (r *CachedResource) GetInterval() *metapb.TimeInterval

+ func (r *CachedResource) GetKeysRead() uint64

+ func (r *CachedResource) GetKeysWritten() uint64

+ func (r *CachedResource) GetLeader() *metapb.Peer

+ func (r *CachedResource) GetLearners() []metapb.Peer

+ func (r *CachedResource) GetPeer(peerID uint64) (metapb.Peer, bool)

+ func (r *CachedResource) GetPendingLearner(peerID uint64) (metapb.Peer, bool)

+ func (r *CachedResource) GetPendingPeer(peerID uint64) (metapb.Peer, bool)

+ func (r *CachedResource) GetPendingPeers() []metapb.Peer

+ func (r *CachedResource) GetPendingVoter(peerID uint64) (metapb.Peer, bool)

+ func (r *CachedResource) GetStartKey() []byte

+ func (r *CachedResource) GetStat() *metapb.ResourceStats

+ func (r *CachedResource) GetTerm() uint64

+ func (r *CachedResource) GetVoters() []metapb.Peer

+ type CachedResources struct

+ func NewCachedResources(factory func() metadata.Resource) *CachedResources

+ func (r *CachedResources) AddResource(res *CachedResource) []*CachedResource

+ func (r *CachedResources) ForeachResources(group uint64, fn func(res metadata.Resource))

+ func (r *CachedResources) GetAdjacentResources(res *CachedResource) (*CachedResource, *CachedResource)

+ func (r *CachedResources) GetAverageResourceSize() int64

+ func (r *CachedResources) GetContainerFollowerCount(containerID uint64) int

+ func (r *CachedResources) GetContainerFollowerResourceSize(containerID uint64) int64

+ func (r *CachedResources) GetContainerLeaderCount(containerID uint64) int

+ func (r *CachedResources) GetContainerLeaderResourceSize(containerID uint64) int64

+ func (r *CachedResources) GetContainerLearnerCount(containerID uint64) int

+ func (r *CachedResources) GetContainerLearnerResourceSize(containerID uint64) int64

+ func (r *CachedResources) GetContainerPendingPeerCount(containerID uint64) int

+ func (r *CachedResources) GetContainerResourceCount(containerID uint64) int

+ func (r *CachedResources) GetContainerResourceSize(containerID uint64) int64

+ func (r *CachedResources) GetContainerResources(containerID uint64) []*CachedResource

+ func (r *CachedResources) GetFollower(containerID uint64, res *CachedResource) *CachedResource

+ func (r *CachedResources) GetLeader(containerID uint64, res *CachedResource) *CachedResource

+ func (r *CachedResources) GetMetaResources() []metadata.Resource

+ func (r *CachedResources) GetOverlaps(res *CachedResource) []*CachedResource

+ func (r *CachedResources) GetResource(resourceID uint64) *CachedResource

+ func (r *CachedResources) GetResourceCount() int

+ func (r *CachedResources) GetResources() []*CachedResource

+ func (r *CachedResources) Length() int

+ func (r *CachedResources) RandFollowerResource(containerID uint64, ranges []KeyRange) *CachedResource

+ func (r *CachedResources) RandFollowerResources(containerID uint64, ranges []KeyRange, n int) []*CachedResource

+ func (r *CachedResources) RandLeaderResource(containerID uint64, ranges []KeyRange) *CachedResource

+ func (r *CachedResources) RandLeaderResources(containerID uint64, ranges []KeyRange, n int) []*CachedResource

+ func (r *CachedResources) RandLearnerResource(containerID uint64, ranges []KeyRange) *CachedResource

+ func (r *CachedResources) RandLearnerResources(containerID uint64, ranges []KeyRange, n int) []*CachedResource

+ func (r *CachedResources) RandPendingResource(containerID uint64, ranges []KeyRange) *CachedResource

+ func (r *CachedResources) RandPendingResources(containerID uint64, ranges []KeyRange, n int) []*CachedResource

+ func (r *CachedResources) RemoveResource(res *CachedResource)

+ func (r *CachedResources) ScanRange(group uint64, startKey, endKey []byte, limit int) []*CachedResource

+ func (r *CachedResources) ScanRangeWithIterator(group uint64, startKey []byte, iterator func(res *CachedResource) bool)

+ func (r *CachedResources) SearchPrevResource(group uint64, resKey []byte) *CachedResource

+ func (r *CachedResources) SearchResource(group uint64, resKey []byte) *CachedResource

+ func (r *CachedResources) SetResource(res *CachedResource) []*CachedResource

+ type ContainerCreateOption func(container *CachedContainer)

+ func AttachAvailableFunc(limitType limit.Type, f func() bool) ContainerCreateOption

+ func OfflineContainer(physicallyDestroyed bool) ContainerCreateOption

+ func PauseLeaderTransfer() ContainerCreateOption

+ func ResumeLeaderTransfer() ContainerCreateOption

+ func SetContainerAddress(address, shardAddress string) ContainerCreateOption

+ func SetContainerDeployPath(deployPath string) ContainerCreateOption

+ func SetContainerLabels(labels []metapb.Pair) ContainerCreateOption

+ func SetContainerStartTime(startTS int64) ContainerCreateOption

+ func SetContainerState(state metapb.ContainerState) ContainerCreateOption

+ func SetContainerStats(stats *metapb.ContainerStats) ContainerCreateOption

+ func SetContainerVersion(githash, version string) ContainerCreateOption

+ func SetLastHeartbeatTS(lastHeartbeatTS time.Time) ContainerCreateOption

+ func SetLastPersistTime(lastPersist time.Time) ContainerCreateOption

+ func SetLeaderCount(group uint64, leaderCount int) ContainerCreateOption

+ func SetLeaderSize(group uint64, leaderSize int64) ContainerCreateOption

+ func SetLeaderWeight(leaderWeight float64) ContainerCreateOption

+ func SetNewContainerStats(stats *metapb.ContainerStats) ContainerCreateOption

+ func SetPendingPeerCount(group uint64, pendingPeerCount int) ContainerCreateOption

+ func SetResourceCount(group uint64, resourceCount int) ContainerCreateOption

+ func SetResourceSize(group uint64, resourceSize int64) ContainerCreateOption

+ func SetResourceWeight(resourceWeight float64) ContainerCreateOption

+ func TombstoneContainer() ContainerCreateOption

+ func UpContainer() ContainerCreateOption

+ type ContainerSetController interface

+ AttachAvailableFunc func(id uint64, limitType limit.Type, f func() bool)

+ PauseLeaderTransfer func(id uint64) error

+ ResumeLeaderTransfer func(id uint64)

+ type ContainerSetInformer interface

+ GetContainer func(id uint64) *CachedContainer

+ GetContainers func() []*CachedContainer

+ GetFollowerContainers func(res *CachedResource) []*CachedContainer

+ GetLeaderContainer func(res *CachedResource) *CachedContainer

+ GetResourceContainers func(res *CachedResource) []*CachedContainer

+ type HexResourceMeta struct

+ func ResourceToHexMeta(meta metadata.Resource) HexResourceMeta

+ func (h HexResourceMeta) String() string

+ type HexResourcesMeta []metadata.Resource

+ func ResourcesToHexMeta(resources []metadata.Resource) HexResourcesMeta

+ func (h HexResourcesMeta) String() string

+ type KeyRange struct

+ EndKey []byte

+ Group uint64

+ StartKey []byte

+ func NewKeyRange(startKey, endKey string) KeyRange

+ type KeyType int

+ const Raw

+ const Table

+ const Txn

+ func StringToKeyType(input string) KeyType

+ func (k KeyType) String() string

+ type PriorityLevel int

+ const HighPriority

+ const LowPriority

+ const NormalPriority

+ type ResourceCreateOption func(res *CachedResource)

+ func SetApproximateKeys(v int64) ResourceCreateOption

+ func SetApproximateSize(v int64) ResourceCreateOption

+ func SetPeers(peers []metapb.Peer) ResourceCreateOption

+ func SetReadBytes(v uint64) ResourceCreateOption

+ func SetReadKeys(v uint64) ResourceCreateOption

+ func SetReportInterval(v uint64) ResourceCreateOption

+ func SetResourceConfVer(confVer uint64) ResourceCreateOption

+ func SetResourceVersion(version uint64) ResourceCreateOption

+ func SetWrittenBytes(v uint64) ResourceCreateOption

+ func SetWrittenKeys(v uint64) ResourceCreateOption

+ func WithAddPeer(peer metapb.Peer) ResourceCreateOption

+ func WithDecConfVer() ResourceCreateOption

+ func WithDecVersion() ResourceCreateOption

+ func WithDownPeers(downPeers []metapb.PeerStats) ResourceCreateOption

+ func WithEndKey(key []byte) ResourceCreateOption

+ func WithIncConfVer() ResourceCreateOption

+ func WithIncVersion() ResourceCreateOption

+ func WithInterval(interval *metapb.TimeInterval) ResourceCreateOption

+ func WithLeader(leader *metapb.Peer) ResourceCreateOption

+ func WithLearners(learners []metapb.Peer) ResourceCreateOption

+ func WithNewPeerIds(peerIDs ...uint64) ResourceCreateOption

+ func WithNewResourceID(id uint64) ResourceCreateOption

+ func WithPendingPeers(pendingPeers []metapb.Peer) ResourceCreateOption

+ func WithPromoteLearner(peerID uint64) ResourceCreateOption

+ func WithRemoveContainerPeer(containerID uint64) ResourceCreateOption

+ func WithReplacePeerContainer(oldContainerID, newContainerID uint64) ResourceCreateOption

+ func WithStartKey(key []byte) ResourceCreateOption

+ type ResourceOption func(res *CachedResource) bool

+ type ResourceSetInformer interface

+ GetAdjacentResources func(res *CachedResource) (*CachedResource, *CachedResource)

+ GetAverageResourceSize func() int64

+ GetContainerResourceCount func(containerID uint64) int

+ GetResource func(id uint64) *CachedResource

+ GetResourceByKey func(group uint64, resKey []byte) *CachedResource

+ GetResourceCount func() int

+ RandFollowerResource func(containerID uint64, ranges []KeyRange, opts ...ResourceOption) *CachedResource

+ RandLeaderResource func(containerID uint64, ranges []KeyRange, opts ...ResourceOption) *CachedResource

+ RandLearnerResource func(containerID uint64, ranges []KeyRange, opts ...ResourceOption) *CachedResource

+ RandPendingResource func(containerID uint64, ranges []KeyRange, opts ...ResourceOption) *CachedResource

+ ScanResources func(group uint64, startKey, endKey []byte, limit int) []*CachedResource

+ type ScheduleKind struct

+ Policy SchedulePolicy

+ ResourceKind metapb.ResourceKind

+ func NewScheduleKind(kind metapb.ResourceKind, Policy SchedulePolicy) ScheduleKind

+ type SchedulePolicy int

+ const ByCount

+ const BySize

+ func StringToSchedulePolicy(input string) SchedulePolicy

+ func (k SchedulePolicy) String() string

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