blinkinglight

/*
Parallel processing with ordered output in Go
(you can use this pattern by importing https://github.com/MarianoGappa/parseq)

This example implementation is useful when the following 3 conditions are true:
1) the rate of input is higher than the rate of output on the system (i.e. it queues up)
2) the processing of input can be parallelised, and overall throughput increases by doing so
3) the order of output of the system needs to respect order of input

- if 1 is false, KISS!

blinkinglight

package main

import (
	"encoding/json"
	"flag"
	"fmt"
	"github.com/asaskevich/govalidator"
	"github.com/gorilla/mux"
	"log"
	"net/http"

blinkinglight

package main

import (
	"fmt"
	"github.com/grafov/m3u8"
	"io/ioutil"
	"net/http"
	"net/url"
	"os"
	"strconv"

blinkinglight

package main

import (
	"fmt"
	"reflect"
)

type Foo struct {
	FirstName string `tag_name:"tag 1"`
	LastName  string `tag_name:"tag 2"`

blinkinglight

package main

import (
	"bufio"
	"fmt"
	"strings"
)

type Parts []string
type Params []Parts

blinkinglight

type ApacheLogRecord struct {
	http.ResponseWriter

	ip                    string
	time                  time.Time
	method, uri, protocol string
	status                int
	responseBytes         int64
	elapsedTime           time.Duration
}

blinkinglight

package main

import (
	"bufio"
	"bytes"
	"flag"
	"fmt"
	"github.com/spx/llog"
	"github.com/spx/pubsub"
	"io"

blinkinglight

package main

import (
	"flag"
	"fmt"
	"github.com/nats-io/go-nats"
	"strconv"
	"strings"
	"sync"
	"time"

blinkinglight

package main

import (
	"fmt"
	"io"
	"net/http"
	"runtime"
	"sync"
	"time"
)

blinkinglight

package main

import (
	"context"
	"fmt"
	"github.com/nats-io/nuid"
	"log"
	"net/http"
)