resourceallocator

Documentation

Index

• Constants
• Variables
• func AllocParallelismRes(resourceType ResourceType, num int64) (int64, error)
• func AllocRes(resourceType ResourceType, num int64) (int64, int64, error)
• func DefaultSeriesAllocateFunc(seriesNum int64) error
• func FreeParallelismRes(resourceType ResourceType, num, totalNum int64) error
• func FreeRes(resourceType ResourceType, num, totalNum int64) error
• func InitResAllocator(threshold, minAllocNum, minShardsAllocNum, funcType int64, ...) error
• type BaseResAllocator
  • func NewBaseResAllocator(threshold, minAllocNum, funcType int64) (*BaseResAllocator, error)
  • func (p *BaseResAllocator) Alloc(num int64) (int64, int64, error)
  • func (p *BaseResAllocator) Free(num, totalNum int64)
• type ChunkReaderResAllocator
  • func NewChunkReaderResAllocator(threshold, minAllocNum, funcType int64) (*ChunkReaderResAllocator, error)
  • func (p *ChunkReaderResAllocator) Alloc(num int64) (int64, int64, error)
  • func (p *ChunkReaderResAllocator) AllocParallelism(num int64) (int64, error)
  • func (p *ChunkReaderResAllocator) Free(num, totalNum int64)
  • func (p *ChunkReaderResAllocator) FreeParallelism(num int64, totalNum int64)
• type ResourceManager
• type ResourceType
• type SeriesResAllocator
  • func NewSeriesParallelismAllocator(maxTime time.Duration, maxSeriesParallelism int64) *SeriesResAllocator
  • func (s *SeriesResAllocator) Alloc(num int64) (int64, int64, error)
  • func (s *SeriesResAllocator) AllocParallelism(num int64) (int64, error)
  • func (s *SeriesResAllocator) Free(num, totalNum int64)
  • func (s *SeriesResAllocator) FreeParallelism(num int64, totalNum int64)
• type ShardParallelismAllocator
  • func NewShardsParallelismAllocator(maxTime time.Duration, maxShardsParallelism, minShardsAllocNum int64, ...) (*ShardParallelismAllocator, error)
  • func (s *ShardParallelismAllocator) Alloc(num int64) (int64, int64, error)
  • func (s *ShardParallelismAllocator) AllocParallelism(num int64) (int64, error)
  • func (s *ShardParallelismAllocator) Free(num, totalNum int64)
  • func (s *ShardParallelismAllocator) FreeParallelism(num int64, totalNum int64)

Constants

const (
	DefaultMaxSeriesParallelismNumRatio = 1000000
	DefaultMinimumConcurrency           = 1
	DefaultWaitTimeOut                  = time.Minute
)

const (
	GradientDesc = iota
)

Variables

var ErrResTypeNotFound = errors.New("resource type not found")

Functions

func AllocParallelismRes

func AllocParallelismRes(resourceType ResourceType, num int64) (int64, error)

func AllocRes

func AllocRes(resourceType ResourceType, num int64) (int64, int64, error)

func DefaultSeriesAllocateFunc

func DefaultSeriesAllocateFunc(seriesNum int64) error

func FreeParallelismRes

func FreeParallelismRes(resourceType ResourceType, num, totalNum int64) error

func FreeRes

func FreeRes(resourceType ResourceType, num, totalNum int64) error

func InitResAllocator

func InitResAllocator(threshold, minAllocNum, minShardsAllocNum, funcType int64, resType ResourceType, maxWaitTime time.Duration, ptNumPerNode uint32) error

Types

type BaseResAllocator

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

func NewBaseResAllocator

func NewBaseResAllocator(threshold, minAllocNum, funcType int64) (*BaseResAllocator, error)

func (*BaseResAllocator) Alloc

func (p *BaseResAllocator) Alloc(num int64) (int64, int64, error)

func (*BaseResAllocator) Free

func (p *BaseResAllocator) Free(num, totalNum int64)

type ChunkReaderResAllocator

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

func NewChunkReaderResAllocator

func NewChunkReaderResAllocator(threshold, minAllocNum, funcType int64) (*ChunkReaderResAllocator, error)

func (*ChunkReaderResAllocator) Alloc

func (p *ChunkReaderResAllocator) Alloc(num int64) (int64, int64, error)

func (*ChunkReaderResAllocator) AllocParallelism

func (p *ChunkReaderResAllocator) AllocParallelism(num int64) (int64, error)

not use

func (*ChunkReaderResAllocator) Free

func (p *ChunkReaderResAllocator) Free(num, totalNum int64)

func (*ChunkReaderResAllocator) FreeParallelism

func (p *ChunkReaderResAllocator) FreeParallelism(num int64, totalNum int64)

type ResourceManager

type ResourceManager interface {
	Alloc(num int64) (allocNum int64, totalNum int64, err error)
	Free(num, totalNum int64)
	AllocParallelism(num int64) (int64, error)
	FreeParallelism(num int64, totalNum int64)
}

type ResourceType

type ResourceType int64

const (
	ChunkReaderRes ResourceType = iota
	ShardsParallelismRes
	SeriesParallelismRes
	Bottom
)

type SeriesResAllocator

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

func NewSeriesParallelismAllocator

func NewSeriesParallelismAllocator(maxTime time.Duration, maxSeriesParallelism int64) *SeriesResAllocator

func (*SeriesResAllocator) Alloc

func (s *SeriesResAllocator) Alloc(num int64) (int64, int64, error)

func (*SeriesResAllocator) AllocParallelism

func (s *SeriesResAllocator) AllocParallelism(num int64) (int64, error)

not use

func (*SeriesResAllocator) Free

func (s *SeriesResAllocator) Free(num, totalNum int64)

func (*SeriesResAllocator) FreeParallelism

func (s *SeriesResAllocator) FreeParallelism(num int64, totalNum int64)

not use

type ShardParallelismAllocator

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

func NewShardsParallelismAllocator

func NewShardsParallelismAllocator(maxTime time.Duration, maxShardsParallelism, minShardsAllocNum int64, ptNumPerNode uint32) (*ShardParallelismAllocator, error)

func (*ShardParallelismAllocator) Alloc

func (s *ShardParallelismAllocator) Alloc(num int64) (int64, int64, error)

func (*ShardParallelismAllocator) AllocParallelism

func (s *ShardParallelismAllocator) AllocParallelism(num int64) (int64, error)

func (*ShardParallelismAllocator) Free

func (s *ShardParallelismAllocator) Free(num, totalNum int64)

func (*ShardParallelismAllocator) FreeParallelism

func (s *ShardParallelismAllocator) FreeParallelism(num int64, totalNum int64)