mapreduce

Nov 30, 2021

Changes in this version

+ type ArrayEnumerator struct

+ func (enum *ArrayEnumerator) Cap() int

+ func (enum *ArrayEnumerator) Container() interface{}

+ func (enum *ArrayEnumerator) Item(i int) interface{}

+ func (enum *ArrayEnumerator) Len() int

+ type Container interface

+ Container func() interface{}

type ContainerIterator

+ func (iter *ContainerIterator) Container() interface{}

+ type Enumerator interface

+ Item func(int) interface{}

+ Len func() int

+ func NewEnumerator(slice interface{}) (Enumerator, error)

+ type EnumeratorIterator struct

+ func (enum *EnumeratorIterator) Next() bool

+ func (enum *EnumeratorIterator) Value() (int, interface{})

Sep 23, 2021

Changes in this version

+ var ErrInvalidChanDir = errors.New("not readable channel")

+ var ErrInvalidMapper = errors.New(...)

+ var ErrInvalidReducer = errors.New(...)

+ var ErrMapperNotFunc = errors.New("mapper must be a function")

+ var ErrMissingInitialValue = errors.New("missing initial value")

+ var ErrNilMapper = errors.New("mapper function cannot be nil")

+ var ErrNilReducer = errors.New("reducer cannot be nil")

+ var ErrNotSupported = errors.New("not supported")

+ var ErrReducerNotFunc = errors.New("reducer must be a function")

+ func Map(mapper interface{}, source interface{}) (interface{}, error)

+ func ParallelMap(mapper interface{}, source interface{}) (interface{}, error)

+ func Reduce(reducer, source interface{}, initials ...interface{}) (interface{}, error)

+ type ArrayIterator struct

+ func (iter *ArrayIterator) Next() bool

+ func (iter *ArrayIterator) Value() (int, interface{})

+ type Capacitor interface

+ Cap func() int

+ type ChanIterator struct

+ func (iter *ChanIterator) Next() bool

+ func (iter *ChanIterator) Value() (int, interface{})

+ type ContainerIterator struct

+ func (iter *ContainerIterator) Cap() int

+ func (iter *ContainerIterator) Initiate() interface{}

+ func (iter *ContainerIterator) Len() int

+ type Initiator interface

+ Initiate func() interface{}

+ type Iterator interface

+ Next func() bool

+ Value func() (int, interface{})

+ func NewIterator(sliceOrChan interface{}) (Iterator, error)

+ type Length interface

+ Len func() int