Documentation ¶
Index ¶
- func Setup(iom *IOMap)
- type ByteLimit
- type IOC
- func (ioc *IOC) Active() bool
- func (ioc *IOC) Checkout(bl *ByteLimit, requested uint64, stream chan uint64) error
- func (ioc *IOC) CheckoutRead(requested uint64, stream chan uint64) error
- func (ioc *IOC) CheckoutWrite(requested uint64, stream chan uint64) error
- func (ioc *IOC) Start()
- func (ioc *IOC) Stop()
- func (ioc *IOC) Update(duration time.Duration, read, write uint64)
- type IOMap
- type Rest
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type ByteLimit ¶
ByteLimit ... Controls how many bytes can be consumed
type IOC ¶
type IOC struct { Mutex sync.RWMutex Notifier *sync.Cond // contains filtered or unexported fields }
IOC Input / Ouput Constraint
func (*IOC) CheckoutRead ¶
CheckoutRead ... gets a read
func (*IOC) CheckoutWrite ¶
CheckoutWrite ... gets a stream ow writes
type IOMap ¶
IOMap ... Mapping of key to IOC
func LoadIOCConfig ¶
LoadIOCConfig ... Takes an io.Reader expecting csv file and returns a *IOMap
Click to show internal directories.
Click to hide internal directories.