syncqueues

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

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

type RequestPool interface {
	TryTake(peerId, objectId string) bool
	Release(peerId, objectId string)
	Run()
	QueueRequestAction(peerId, objectId string, action func(ctx context.Context), remove func()) (err error)
	Close()
}

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