hierarchical

Documentation

Index

• type Service
  • func NewService(c config.HierarchicalConfig) *Service
  • func (s *Service) Close() error
  • func (s *Service) Open() error
• type WaitGroup
  • func NewWaitGroup(maxN int) *WaitGroup
  • func (wg *WaitGroup) Add(num int)
  • func (wg *WaitGroup) Close()
  • func (wg *WaitGroup) Done()
  • func (wg *WaitGroup) Wait()

Types

type Service

type Service struct {
	MetaClient metaClient

	Logger *logger.Logger

	Config *config.HierarchicalConfig

	Engine engine

	// max concurrency number for move shards
	HsWaitGroup *WaitGroup
	// contains filtered or unexported fields
}

func NewService

func NewService(c config.HierarchicalConfig) *Service

func (*Service) Close

func (s *Service) Close() error

func (*Service) Open

func (s *Service) Open() error

type WaitGroup

type WaitGroup struct {
	// contains filtered or unexported fields
}

func NewWaitGroup

func NewWaitGroup(maxN int) *WaitGroup

func (*WaitGroup) Add

func (wg *WaitGroup) Add(num int)

func (*WaitGroup) Close

func (wg *WaitGroup) Close()

func (*WaitGroup) Done

func (wg *WaitGroup) Done()

func (*WaitGroup) Wait

func (wg *WaitGroup) Wait()