Vladimir Mihailenco vmihailenco

## proxy.go
package main

import (
	"bytes"
	"encoding/hex"
	"flag"
	"fmt"
	"io"
	"log"
	"net"

## celery.py
CELERYD_HIJACK_ROOT_LOGGER = False


def setup_task_logger(logger=None, **kwargs):
    logger.propagate = 1

from celery import signals
signals.setup_logging.connect(lambda **kwargs: True)
signals.after_setup_task_logger.connect(setup_task_logger)

## gist:7b71c03d5b5bfaa1df21dd9693c988ed
package main

import (
	"bytes"
	"io/ioutil"
	"testing"

	"github.com/klauspost/compress/zstd"
	"github.com/valyala/gozstd"
)

## gist:2db3d481a71db3264e6ce9f0b2736ba7
package main

import (
	"bytes"
	"io/ioutil"
	"testing"

	"github.com/klauspost/compress/zstd"
	"github.com/valyala/gozstd"
)

## haproxy.cfg
frontend fe_http
    bind *:80
    capture request header Connection len 32
    capture response header Connection len 32
    default_backend be_go

## server.go
package main

import (
	"log"
	"net/http"
)

func main() {
	http.HandleFunc("/upload", func(w http.ResponseWriter, req *http.Request) {
	})

## gist:065dd023bee888f9505edf0099691f00
package main

import (
	"fmt"
	// "log"
	// "time"
	"github.com/go-pg/pg"
	"github.com/go-pg/pg/orm"
)

## gist:5f553d12173a5a9e64d8a3ba19c9b43d
package main

import (
	"fmt"

	"github.com/go-pg/pg"
	"github.com/go-pg/pg/orm"
	"github.com/go-pg/sharding"
)

## gist:1c790383011ebc388dc469a640a76514
package main

import (
	"log"
	"strconv"
	"time"

	redis "gopkg.in/redis.v4"
)

## gist:78768e6eaa93aabd5888
package main

import (
	"log"
	"math/rand"
	"strings"

	"gopkg.in/pg.v4"
)
	package main

	import (
	"bytes"
	"encoding/hex"
	"flag"
	"fmt"
	"io"
	"log"
	"net"
	CELERYD_HIJACK_ROOT_LOGGER = False


	def setup_task_logger(logger=None, **kwargs):
	logger.propagate = 1

	from celery import signals
	signals.setup_logging.connect(lambda **kwargs: True)
	signals.after_setup_task_logger.connect(setup_task_logger)
	frontend fe_http
	bind *:80
	capture request header Connection len 32
	capture response header Connection len 32
	default_backend be_go