syncqueues

Documentation

Index

• Constants
• type ActionPool
  • func NewActionPool(closePeriod, gcPeriod time.Duration, ...) ActionPool
• type Guard
  • func NewGuard() *Guard
  • func (g *Guard) Release(id string)
  • func (g *Guard) TryTake(id string) bool
• type Limit
  • func NewLimit(peerStep, totalStep []int, excludeIds []string, excludedLimit int) *Limit
  • func (l *Limit) Release(id string)
  • func (l *Limit) Stats(id string) string
  • func (l *Limit) Take(id string) bool
• type SyncQueues
  • func New() SyncQueues

Constants

const CName = "common.util.syncqueues"

Types

type ActionPool

type ActionPool interface {
	Run()
	Add(peerId, objectId string, action func(ctx context.Context), remove func())
	Close()
}

func NewActionPool

func NewActionPool(closePeriod, gcPeriod time.Duration, openFunc func(peerId string) *replaceableQueue) ActionPool

type Guard

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

func NewGuard

func NewGuard() *Guard

func (*Guard) Release

func (g *Guard) Release(id string)

func (*Guard) TryTake

func (g *Guard) TryTake(id string) bool

type Limit

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

func NewLimit

func NewLimit(peerStep, totalStep []int, excludeIds []string, excludedLimit int) *Limit

func (*Limit) Release

func (l *Limit) Release(id string)

func (*Limit) Stats

func (l *Limit) Stats(id string) string

func (*Limit) Take

func (l *Limit) Take(id string) bool

type SyncQueues

type SyncQueues interface {
	app.ComponentRunnable
	ActionPool(spaceId string) ActionPool
	Limit(spaceId string) *Limit
}

func New

func New() SyncQueues