worker

Jul 12, 2022

Changes in this version

type HashFunc

+ func StringHasher(keyFunc KeyFunc[I, string]) HashFunc[I]

+ type KeyFunc func(I) K

Jul 12, 2022

Changes in this version

+ type FanOut struct

+ func NewFanOut(workerCount, bufferSize int) *FanOut[I, O]

+ func (f *FanOut[I, O]) Close()

+ func (f *FanOut[I, O]) Invoke(input I)

+ func (f *FanOut[I, O]) Process(p ProcessorFunc[I])

+ type HashFunc func(I) int

+ type HashedFanOut struct

+ func NewHashedFanOut(workerCount, bufferSize int, hasher HashFunc[I]) *HashedFanOut[I, O]

+ func (f *HashedFanOut[I, O]) Close()

+ func (f *HashedFanOut[I, O]) Invoke(input I)

+ func (f *HashedFanOut[I, O]) Process(p ProcessorFunc[I])

+ type ProcessorFunc func(I)