Versions in this module Expand all Collapse all v0 v0.1.1 Aug 23, 2024 v0.1.0 Aug 5, 2024 Changes in this version + type Channel interface + Close func() + Input func(v interface{}) + Len func() int + Output func() <-chan interface{} + Stats func() (produced uint64, consumed uint64) + func New(opts ...Option) Channel + type Option func(c *channel) + func WithNonBlock() Option + func WithRateThrottle(produceRate, consumeRate int) Option + func WithSize(size int) Option + func WithThrottle(producerThrottle, consumerThrottle Throttle) Option + func WithThrottleWindow(window time.Duration) Option + func WithTimeout(timeout time.Duration) Option + func WithTimeoutCallback(timeoutCallback func(interface{})) Option + type Throttle func(c Channel) bool
Go to main page