datasemaphore

package
v0.1.5 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 31, 2023 License: MIT Imports: 3 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL