runner

type BlockMapReducer interface {
	Initialise(client *rpc.Client) (acc interface{}, err error)
	BlockRange() (blockRangeFrom, blockRangeTo uint32)
	Map(client *rpc.Client, emit func(interface{}) error, block *rpc.Block) (err error)
	Reduce(client *rpc.Client, acc, value interface{}) (newAcc interface{}, err error)
	ProcessResults(acc interface{}, nextBlockToProcess uint32) (err error)
}

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