worker

Documentation

Index

• type FanOut
  • func NewFanOut[I, O any](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
• type HashedFanOut
  • func NewHashedFanOut[I, O any](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

Types

type FanOut

type FanOut[I, O any] struct {
	// contains filtered or unexported fields
}

func NewFanOut

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

func (*FanOut[I, O]) Close

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

func (*FanOut[I, O]) Invoke

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

func (*FanOut[I, O]) Process

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

type HashFunc

type HashFunc[I any] func(I) int

type HashedFanOut

type HashedFanOut[I, O any] struct {
	FanOut[I, O]
	// contains filtered or unexported fields
}

HashedFanOut is a special purpose fan out that hashes the input so that the same keys are always processed by the same worker. This is used to ensure guard against race conditions in non-reentrant processors.

func NewHashedFanOut

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

func (*HashedFanOut[I, O]) Close

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

func (*HashedFanOut[I, O]) Invoke

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

func (*HashedFanOut[I, O]) Process

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

type ProcessorFunc

type ProcessorFunc[I any] func(I)