bigbuff

Mar 30, 2022

Changes in this version

+ func Call(caller Callable, options ...CallOption) error

+ func MustCall(caller Callable, options ...CallOption)

+ type CallOption func(config *callConfig) error

+ func CallArgs(args ...interface{}) CallOption

+ func CallArgsRaw(args interface{}) CallOption

+ func CallResults(results ...interface{}) CallOption

+ func CallResultsRaw(results interface{}) CallOption

+ func CallResultsSlice(target interface{}) CallOption

+ type Callable interface

+ Call func(args, results interface{}) error

+ Type func() reflect.Type

+ func NewCallable(fn interface{}) Callable

type Exclusive

+ func (e *Exclusive) CallWithOptions(options ...ExclusiveOption) <-chan *ExclusiveOutcome

+ type ExclusiveOption func(c *exclusiveConfig)

+ func ExclusiveKey(value interface{}) ExclusiveOption

+ func ExclusiveRateLimit(ctx context.Context, minDuration time.Duration) ExclusiveOption

+ func ExclusiveStart(value bool) ExclusiveOption

+ func ExclusiveValue(value func() (interface{}, error)) ExclusiveOption

+ func ExclusiveWait(value time.Duration) ExclusiveOption

+ func ExclusiveWork(value WorkFunc) ExclusiveOption

+ func ExclusiveWrapper(value func(value WorkFunc) WorkFunc) ExclusiveOption

+ type WorkFunc func(resolve func(result interface{}, err error))

+ type Worker struct

+ func (x *Worker) Do(fn func(stop <-chan struct{})) (done func())

Sep 27, 2019

Changes in this version

+ func LinearAttempt(ctx context.Context, rate time.Duration, count int) <-chan time.Time

Jun 19, 2019

Changes in this version

+ func MinDuration(d time.Duration, fn func() (interface{}, error)) func() (interface{}, error)

Jun 18, 2019

Changes in this version

type Exclusive

+ func (e *Exclusive) Start(key interface{}, value func() (interface{}, error))

+ func (e *Exclusive) StartAfter(key interface{}, value func() (interface{}, error), wait time.Duration)

Apr 9, 2019

Changes in this version

type Notifier

+ func (n *Notifier) SubscribeCancel(ctx context.Context, key interface{}, target interface{}) context.CancelFunc

Apr 7, 2019

Changes in this version

+ type Notifier struct

+ func (n *Notifier) Publish(key interface{}, value interface{})

+ func (n *Notifier) PublishContext(ctx context.Context, key interface{}, value interface{})

+ func (n *Notifier) Subscribe(key interface{}, target interface{})

+ func (n *Notifier) SubscribeContext(ctx context.Context, key interface{}, target interface{})

+ func (n *Notifier) Unsubscribe(key interface{}, target interface{})

Feb 22, 2019

Changes in this version

+ func ExponentialRetry(ctx context.Context, rate time.Duration, value func() (interface{}, error)) func() (interface{}, error)

+ func FatalError(err error) error

Oct 28, 2018

Changes in this version

type Workers

+ func (w *Workers) Count() int

+ func (w *Workers) Wait()

Oct 25, 2018

Changes in this version

+ type Workers struct

+ func (w *Workers) Call(count int, value func() (interface{}, error)) (interface{}, error)

+ func (w *Workers) Wrap(count int, value func() (interface{}, error)) func() (interface{}, error)

Oct 23, 2018

Changes in this version

type Exclusive

+ func (e *Exclusive) CallAfterAsync(key interface{}, value func() (interface{}, error), wait time.Duration) <-chan *ExclusiveOutcome

+ func (e *Exclusive) CallAsync(key interface{}, value func() (interface{}, error)) <-chan *ExclusiveOutcome

+ type ExclusiveOutcome struct

+ Error error

+ Result interface{}

Aug 29, 2018

Changes in this version

+ type Exclusive struct

+ func (e *Exclusive) Call(key interface{}, value func() (interface{}, error)) (interface{}, error)

+ func (e *Exclusive) CallAfter(key interface{}, value func() (interface{}, error), wait time.Duration) (interface{}, error)

Jun 19, 2018

Changes in this version

type Buffer

+ func (b *Buffer) Diff(c Consumer) (int, bool)

+ func (b *Buffer) Range(ctx context.Context, c Consumer, fn func(index int, value interface{}) bool) error

May 26, 2018

Changes in this version

+ const DefaultChannelPollRate

+ const DefaultCleanerCooldown

+ func CombineContext(ctx context.Context, others ...context.Context) context.Context

+ func DefaultCleaner(size int, offsets []int) int

+ func Range(ctx context.Context, consumer Consumer, ...) error

+ func WaitCond(ctx context.Context, cond *sync.Cond, fn func() bool) error

+ type Buffer struct

+ func (b *Buffer) CleanerConfig() CleanerConfig

+ func (b *Buffer) Close() (err error)

+ func (b *Buffer) Done() <-chan struct{}

+ func (b *Buffer) NewConsumer() (Consumer, error)

+ func (b *Buffer) Put(ctx context.Context, values ...interface{}) error

+ func (b *Buffer) SetCleanerConfig(config CleanerConfig) error

+ func (b *Buffer) Size() int

+ func (b *Buffer) Slice() []interface{}

+ type Channel struct

+ func NewChannel(ctx context.Context, pollRate time.Duration, source interface{}) (*Channel, error)

+ func (c *Channel) Buffer() []interface{}

+ func (c *Channel) Close() error

+ func (c *Channel) Commit() error

+ func (c *Channel) Done() <-chan struct{}

+ func (c *Channel) Get(ctx context.Context) (value interface{}, err error)

+ func (c *Channel) Rollback() error

+ type Cleaner func(size int, offsets []int) int

+ func FixedBufferCleaner(max int, target int, ...) Cleaner

+ type CleanerConfig struct

+ Cleaner Cleaner

+ Cooldown time.Duration

+ type Consumer interface

+ Commit func() error

+ Done func() <-chan struct{}

+ Get func(ctx context.Context) (interface{}, error)

+ Rollback func() error

+ type FixedBufferCleanerNotification struct

+ Max int

+ Offsets []int

+ Size int

+ Target int

+ Trim int

+ type Producer interface

+ Done func() <-chan struct{}

+ Put func(ctx context.Context, values ...interface{}) error