datasemaphore

Documentation

Index

• type DataSemaphore
  • 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

Types

type DataSemaphore

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

func New

func New(maxProcessing dag.Metric, warning func(received dag.Metric, processing dag.Metric, releasing dag.Metric)) *DataSemaphore

func (*DataSemaphore) Acquire

func (s *DataSemaphore) Acquire(weight dag.Metric, timeout time.Duration) bool

func (*DataSemaphore) Available

func (s *DataSemaphore) Available() dag.Metric

func (*DataSemaphore) Processing

func (s *DataSemaphore) Processing() dag.Metric

func (*DataSemaphore) Release

func (s *DataSemaphore) Release(weight dag.Metric)

func (*DataSemaphore) Terminate

func (s *DataSemaphore) Terminate()

func (*DataSemaphore) TryAcquire

func (s *DataSemaphore) TryAcquire(weight dag.Metric) bool