partition_manager

Documentation

Index

• type AllocPartPolicy
• type PartitionManager
  • func NewPartitionManager(etcd *embed.Etcd, client *clientv3.Client, config *manager.Config) *PartitionManager
  • func (pm *PartitionManager) AmLeader() bool
  • func (pm *PartitionManager) Close()
  • func (pm *PartitionManager) LeaderLoop()
• type SimplePolicy
  • func (SimplePolicy) AllocPart(nodes map[uint64]*pspb.PSDetail) (PSID uint64, err error)

Types

type AllocPartPolicy

type AllocPartPolicy interface {
	AllocPart(nodes map[uint64]*pspb.PSDetail) (PSID uint64, err error)
}

type PartitionManager

type PartitionManager struct {
	ID uint64 //backend ETCD server's ID

	utils.SafeMutex
	// contains filtered or unexported fields
}

FIXME: 考虑重新分配range partitin的情况, 可能把程序变成单线程server, 避免过多的lock

func NewPartitionManager

func NewPartitionManager(etcd *embed.Etcd, client *clientv3.Client, config *manager.Config) *PartitionManager

func (*PartitionManager) AmLeader

func (pm *PartitionManager) AmLeader() bool

func (*PartitionManager) Close

func (pm *PartitionManager) Close()

FIXME

func (*PartitionManager) LeaderLoop

func (pm *PartitionManager) LeaderLoop()

FIXME:put into etcd_op

type SimplePolicy

type SimplePolicy struct{}

func (SimplePolicy) AllocPart

func (SimplePolicy) AllocPart(nodes map[uint64]*pspb.PSDetail) (PSID uint64, err error)

FIXME: should clone