mapreduce

package

v1.3.3 Latest Latest Go to latest Published: Mar 13, 2023 License: MIT Imports: 3 Imported by: 7

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/mason-leap-lab/go-utils

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
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 ArrayEnumerator
- func (enum *ArrayEnumerator) Cap() int
- func (enum *ArrayEnumerator) Container() interface{}
- func (enum *ArrayEnumerator) Item(i int) interface{}
- func (enum *ArrayEnumerator) Len() int
type ArrayIterator
- func (iter *ArrayIterator) Next() bool
- func (iter *ArrayIterator) Value() (int, interface{})
type Capacitor
type ChanIterator
- func (iter *ChanIterator) Next() (ok bool)
- func (iter *ChanIterator) Value() (int, interface{})
type Container
type ContainerIterator
- func (iter *ContainerIterator) Cap() int
- func (iter *ContainerIterator) Container() interface{}
- func (iter *ContainerIterator) Len() int
type Enumerator
- func NewEnumerator(slice interface{}) (Enumerator, error)
type EnumeratorIterator
- func (enum *EnumeratorIterator) Next() bool
- func (enum *EnumeratorIterator) Value() (int, interface{})
type Iterator
- func NewIterator(sliceOrChan interface{}) (Iterator, error)
type Length

Constants ¶

This section is empty.

Variables ¶

View Source

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

View Source

var (
	ErrNilMapper     = errors.New("mapper function cannot be nil")
	ErrMapperNotFunc = errors.New("mapper must be a function")
	ErrInvalidMapper = errors.New("invalid Mapper signature, must be \"mapper(TypeA) TypeB\" or \"mapper(TypeA, int) TypeB\"")
)

Map Error Collection

View Source

var (
	ErrNilReducer          = errors.New("reducer cannot be nil")
	ErrReducerNotFunc      = errors.New("reducer must be a function")
	ErrMissingInitialValue = errors.New("missing initial value")
	ErrInvalidReducer      = errors.New("invalid reducer signature, must be \"reducer(TypeA, TypeB, int) TypeA\" or \"reducer(TypeA, TypeB) TypeA\"")
)

Reducer Error Collection

Functions ¶

func Map ¶

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

Map maps iteratible objects into another slice. The mapper can be mapper(TypeA, int) TypeB or mapper(TypeA) TypeB The source accept array, slice, channel or Iterator.

func ParallelMap ¶

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

ParallelMap maps iteratible objects in parallel.

func Reduce ¶

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

Reduce reduces iteratible objects into a scalar value. The reducer can be reducer(TypeA, TypeB, int) TypeA or reducer(TypeA, TypeB) TypeA The source accept array, slice, channel or Iterator.

Types ¶

type ArrayEnumerator ¶ added in v1.2.2

type ArrayEnumerator struct {
	// contains filtered or unexported fields
}

func (*ArrayEnumerator) Cap ¶ added in v1.2.2

func (enum *ArrayEnumerator) Cap() int

func (*ArrayEnumerator) Container ¶ added in v1.2.2

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

func (*ArrayEnumerator) Item ¶ added in v1.2.2

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

func (*ArrayEnumerator) Len ¶ added in v1.2.2

func (enum *ArrayEnumerator) Len() int

type ArrayIterator ¶

type ArrayIterator struct {
	ContainerIterator
}

func (*ArrayIterator) Next ¶

func (iter *ArrayIterator) Next() bool

func (*ArrayIterator) Value ¶

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

type Capacitor ¶

type Capacitor interface {
	Length
	Cap() int
}

type ChanIterator ¶

type ChanIterator struct {
	ContainerIterator
	// contains filtered or unexported fields
}

func (*ChanIterator) Next ¶

func (iter *ChanIterator) Next() (ok bool)

func (*ChanIterator) Value ¶

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

type Container ¶ added in v1.2.2

type Container interface {
	Container() interface{}
}

type ContainerIterator ¶

type ContainerIterator struct {
	// contains filtered or unexported fields
}

func (*ContainerIterator) Cap ¶

func (iter *ContainerIterator) Cap() int

func (*ContainerIterator) Container ¶ added in v1.2.2

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

func (*ContainerIterator) Len ¶

func (iter *ContainerIterator) Len() int

type Enumerator ¶ added in v1.2.2

type Enumerator interface {
	Len() int
	Item(int) interface{}
}

func NewEnumerator ¶ added in v1.2.2

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

type EnumeratorIterator ¶ added in v1.2.2

type EnumeratorIterator struct {
	Enumerator
	// contains filtered or unexported fields
}

func (*EnumeratorIterator) Next ¶ added in v1.2.2

func (enum *EnumeratorIterator) Next() bool

func (*EnumeratorIterator) Value ¶ added in v1.2.2

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

type Iterator ¶

type Iterator interface {
	Next() bool
	Value() (int, interface{})
}

func NewIterator ¶

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

type Length ¶

type Length interface {
	Len() int
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL