service

Documentation

Index

• type Alloc
• type BizAlloc
  • func (b *BizAlloc) GetId(s *Service) (id int64, err error)
  • func (b *BizAlloc) GetIdArray(cancel context.CancelFunc, s *Service)
  • func (b *BizAlloc) LeftIdCount() (count int64)
  • func (b *BizAlloc) PopId() (id int64)
• type IdArray
• type Service
  • func NewService(c *configs.Config) (s *Service)
  • func (s *Service) Close()
  • func (s *Service) CreateTag(e *entity.Segments) error
  • func (s *Service) GetId(tag string) (id int64, err error)
  • func (s *Service) NewAllocId() (a *Alloc, err error)

Types

type Alloc

type Alloc struct {
	Mu        sync.RWMutex
	BizTagMap map[string]*BizAlloc
}

type BizAlloc

type BizAlloc struct {
	Mu      sync.Mutex
	BazTag  string
	IdArray []*IdArray
	GetDb   bool //当前正在查询DB
}

func (*BizAlloc) GetId

func (b *BizAlloc) GetId(s *Service) (id int64, err error)

func (*BizAlloc) GetIdArray

func (b *BizAlloc) GetIdArray(cancel context.CancelFunc, s *Service)

func (*BizAlloc) LeftIdCount

func (b *BizAlloc) LeftIdCount() (count int64)

func (*BizAlloc) PopId

func (b *BizAlloc) PopId() (id int64)

type IdArray

type IdArray struct {
	Cur   int64 //当前发到哪个位置
	Start int64 //最小值
	End   int64 //最大值
}

type Service

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

func NewService

func NewService(c *configs.Config) (s *Service)

func (*Service) Close

func (s *Service) Close()

func (*Service) CreateTag

func (s *Service) CreateTag(e *entity.Segments) error

func (*Service) GetId

func (s *Service) GetId(tag string) (id int64, err error)

func (*Service) NewAllocId

func (s *Service) NewAllocId() (a *Alloc, err error)