Versions in this module Expand all Collapse all v1 v1.0.1 May 4, 2023 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