ShardReduce

README

** Package integrated into https://git.zutto.fi/zutto/shardedmap **

this github repo will be removed soon.. as i manage to get dependencies out of my projects ^^^

Documentation

Index

• type ShardReduce
  • func NewShardReduce(input *map[string]*interface{}) *ShardReduce
  • func (sr *ShardReduce) Filter(fFunc func(string, interface{}) bool) *ShardReduce
  • func (sr *ShardReduce) Get() *map[string]*interface{}
  • func (sr *ShardReduce) Map(mapFunc func(string, interface{}) interface{}) *ShardReduce
  • func (sr *ShardReduce) NewInput(input *map[string]*interface{}) *ShardReduce
  • func (sr *ShardReduce) Reduce(reduceFunc func(string, interface{}, string, interface{}) interface{}) interface{}

Types

type ShardReduce

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

func NewShardReduce

func NewShardReduce(input *map[string]*interface{}) *ShardReduce

func (*ShardReduce) Filter

func (sr *ShardReduce) Filter(fFunc func(string, interface{}) bool) *ShardReduce

func (*ShardReduce) Get

func (sr *ShardReduce) Get() *map[string]*interface{}

func (*ShardReduce) Map

func (sr *ShardReduce) Map(mapFunc func(string, interface{}) interface{}) *ShardReduce

func (*ShardReduce) NewInput

func (sr *ShardReduce) NewInput(input *map[string]*interface{}) *ShardReduce

func (*ShardReduce) Reduce

func (sr *ShardReduce) Reduce(reduceFunc func(string, interface{}, string, interface{}) interface{}) interface{}