Versions in this module Expand all Collapse all v0 v0.1.0 May 4, 2022 Changes in this version + type DataSemaphore struct + func New(maxProcessing dag.Metric, ...) *DataSemaphore + func (s *DataSemaphore) Acquire(weight dag.Metric, timeout time.Duration) bool + func (s *DataSemaphore) Available() dag.Metric + func (s *DataSemaphore) Processing() dag.Metric + func (s *DataSemaphore) Release(weight dag.Metric) + func (s *DataSemaphore) Terminate() + func (s *DataSemaphore) TryAcquire(weight dag.Metric) bool
Go to main page