id

Documentation

Index

• Variables
• type Allocator
  • func NewAllocatorImpl(logger *zap.Logger, kv clientv3.KV, key string, allocStep uint) Allocator
  • func NewReusableAllocatorImpl(existIDs []uint64, minID uint64) Allocator
• type AllocatorImpl
  • func (a *AllocatorImpl) Alloc(ctx context.Context) (uint64, error)
  • func (a *AllocatorImpl) Collect(_ context.Context, _ uint64) error
• type OrderedList
  • func (l *OrderedList) FindMinHoleValueAndIndex(min uint64) (uint64, int)
  • func (l *OrderedList) Insert(v uint64, i int)
  • func (l *OrderedList) Remove(v uint64) int
• type ReusableAllocatorImpl
  • func (a *ReusableAllocatorImpl) Alloc(_ context.Context) (uint64, error)
  • func (a *ReusableAllocatorImpl) Collect(_ context.Context, id uint64) error

Variables

var (
	ErrTxnPutEndID         = coderr.NewCodeError(coderr.Internal, "put end id in txn")
	ErrAllocID             = coderr.NewCodeError(coderr.Internal, "alloc id")
	ErrCollectID           = coderr.NewCodeError(coderr.Internal, "collect invalid id")
	ErrCollectNotSupported = coderr.NewCodeError(coderr.Internal, "collect is not supported")
)

Types

type Allocator

type Allocator interface {
	// Alloc allocs a unique id.
	Alloc(ctx context.Context) (uint64, error)

	// Collect collect unused id to reused in alloc
	Collect(ctx context.Context, id uint64) error
}

Allocator defines the id allocator on the ceresdb cluster meta info.

func NewAllocatorImpl

func NewAllocatorImpl(logger *zap.Logger, kv clientv3.KV, key string, allocStep uint) Allocator

func NewReusableAllocatorImpl

func NewReusableAllocatorImpl(existIDs []uint64, minID uint64) Allocator

type AllocatorImpl

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

func (*AllocatorImpl) Alloc

func (a *AllocatorImpl) Alloc(ctx context.Context) (uint64, error)

func (*AllocatorImpl) Collect

func (a *AllocatorImpl) Collect(_ context.Context, _ uint64) error

type OrderedList

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

func (*OrderedList) FindMinHoleValueAndIndex

func (l *OrderedList) FindMinHoleValueAndIndex(min uint64) (uint64, int)

FindMinHoleValueAndIndex Find the minimum hole value and its index. If the list is empty, then return min value and 0 as index; If no hole is found, then return the `last_value + 1` in the list and l.Len() as the index;

func (*OrderedList) Insert

func (l *OrderedList) Insert(v uint64, i int)

Insert the value at the idx whose correctness should be ensured by the caller.

func (*OrderedList) Remove

func (l *OrderedList) Remove(v uint64) int

type ReusableAllocatorImpl

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

func (*ReusableAllocatorImpl) Alloc

func (a *ReusableAllocatorImpl) Alloc(_ context.Context) (uint64, error)

func (*ReusableAllocatorImpl) Collect

func (a *ReusableAllocatorImpl) Collect(_ context.Context, id uint64) error