rcshubhadeep

Golang Job Queue

A running example of the code from:

• http://marcio.io/2015/07/handling-1-million-requests-per-minute-with-golang
• http://nesv.github.io/golang/2014/02/25/worker-queues-in-go.html

Step 1

Small refactorings made to original code:

rcshubhadeep

from typing import Tuple


class TrieNode(object):
    """
    Our trie node implementation. Very basic. but does the job
    """
    
    def __init__(self, char: str):
        self.char = char

rcshubhadeep

rcshubhadeep

rcshubhadeep

package main

import (
	"errors"
	"fmt"
	"strconv"

	"gonum.org/v1/gonum/graph"
	"gonum.org/v1/gonum/graph/multi"
)

rcshubhadeep

type State struct {
	Id    int64
	Value interface{}
}

type Link struct {
	Id    int64
	T, F  graph.Node
	Rules map[Operator]Event
}

rcshubhadeep

type Event string
type Operator string

var NodeIDCntr = 0
var LineIdCntr = 1

type StateMachine struct {
	PresentState State
	g            *multi.DirectedGraph
}

rcshubhadeep

func New() *StateMachine {
	s := &StateMachine{}
	s.g = multi.NewDirectedGraph()

	return s
}

rcshubhadeep

func (s *StateMachine) Init(initStateValue interface{}) State {
	s.PresentState = State{Id: int64(NodeIDCntr), Value: initStateValue}
	s.g.AddNode(s.PresentState)
	NodeIDCntr++
	return s.PresentState
}

func (s *StateMachine) NewState(stateValue interface{}) State {
	state := State{Id: int64(NodeIDCntr), Value: stateValue}
	s.g.AddNode(state)

rcshubhadeep

func NewRule(triggerConditionOperator Operator, comparisonValue Event) map[Operator]Event {
	return map[Operator]Event{triggerConditionOperator: comparisonValue}
}