Sending results to an MQ.

main.go

package main

import (
    "fmt"
    "math"
    "math/big"
    "encoding/json"
    "github.com/iron-io/iron_go3/mq"
    "github.com/iron-io/iron_go/worker"
)

type RangeToCalc struct {
    Begin int
    End int
}

type CalcResults struct {
    Begin int
    End int
    Result string
}

var mqName string = "pi-map-first"

func CalcNumerator(num int) int64 {
    odd := math.Mod(float64(num), 2)
    if (odd == 1) {
        return -1
    }
    return 1 // otherwise, it's even
}

func QueueItUp(sum string, r *RangeToCalc) {
    msg_struct := CalcResults {
        r.Begin,
        r.End,
        sum,
    }

    jsons, err := json.MarshalIndent(msg_struct, "", "    ")
    if err != nil {
        fmt.Println("Error: ", err)
    }
    s := string(jsons)

    q := mq.New(mqName);
    id, err := q.PushString(s)
    if err != nil {
        fmt.Println("Error: ", err)
    }
    fmt.Println("We did the thing! Its Id is: ", id)
}

func main() {
    sum := big.NewRat(0, 1)
    worker.ParseFlags()
    r := &RangeToCalc{}
    worker.PayloadFromJSON(r)

    for i := r.Begin; i <= r.End; i++ {
        leibnizNum := CalcNumerator(i)
        leibnizDen := int64(2 * i + 1)
        leibnizRat := big.NewRat(leibnizNum, leibnizDen)
        sum.Add(sum, leibnizRat)
    }

    QueueItUp(sum.String(), r)
}