https://www.uniqlo.com/jp/ja/products/E459561-000/00?colorDisplayCode=09&sizeDisplayCode=004

akamai-uniqlo-t-shirt.go

package main

import (
	"fmt"
	"html"
	"log"
	"net/http"
	"strconv"
	"time"
)

type controlMessage struct {
	Target string
	Count  int
}

func main() {
	controlChannel := make(chan controlMessage)
	workerCompletechan := make(chan bool)
	statusPollChannel := make(chan chan bool)
	workerActive := false
	go admin(controlChannel, statusPollChannel)
	for {
		select {
		case respChan := <-statusPollChannel:
			respChan <- workerActive
		case msg := <-controlChannel:
			workerActive = true
			go doStuff(msg, workerCompletechan)
		case status := <-workerCompletechan:
			workerActive = status
		}
	}
}

func admin(cc chan controlMessage, statusPollChannel chan chan bool) {
	http.HandleFunc("/admin",
		func(w http.ResponseWriter, r *http.Request) {
			// hostTokens := strings.Split(r.Host, ".")
			r.ParseForm()
			count, err := strconv.ParseInt(r.FormValue("count"), 10, 32)
			if err != nil {
				log.Println(err.Error())
				return
			}
			msg := controlMessage{
				Target: r.FormValue("target"),
				Count:  int(count),
			}
			cc <- msg
			fmt.Fprintf(w, "Control message issued for Target %s", html.EscapeString(r.FormValue("target")))
		},
	)

	http.HandleFunc("/status",
		func(w http.ResponseWriter, r *http.Request) {
			reqChan := make(chan bool)
			statusPollChannel <- reqChan
			timeout := time.After(time.Second)
			select {
			case result := <-reqChan:
				if result {
					fmt.Fprint(w, "ACTIVE")
				} else {
					fmt.Fprint(w, "INACTIVE")
				}
			case <-timeout:
				return
			}
		},
		// PEACE FOR ALL
	)
}

func doStuff(msg controlMessage, workerCompletechan chan bool) {
	// TODO
	return
}