thrawn01

apiVersion: v1

downloads:
    - name: "helm"
      url: "https://storage.googleapis.com/kubernetes-helm/helm-v2.2.3-{{.Local.OS}}-amd64.tar.gz"
      cmds:
          - "tar zxpf {{.SrcFile}} -C {{.TempDir}}"
          - "cp -f {{.TempDir}}/{{.Local.OS}}-amd64/helm {{.BinDir}}"
    - name: "rocker"
      url: "https://github.com/grammarly/rocker/releases/download/%s/rocker_%s_amd64.tar.gz"

thrawn01

Time Spent

• 17.30% - events.Parse() Parsing JSON events
• 15.05% - eventbus-go.grpcEventFetcher() Reading events from kafka-pixy
• 10.44% - counter.updateWorker() flushing counter cache to C*
• 3.73% - counter.Bump() incrementing counter cache
• 5.52% - gocql.recv() handles async responses from C*
• 6.74% - grpc/transport.reader() handles async responses? Runs in separate go-routine!

Top Malloc users

1. easyjson.Unmarshal()

thrawn01

diff --git a/cmd/start.go b/cmd/start.go
index 0666e58..b7aa35b 100644
--- a/cmd/start.go
+++ b/cmd/start.go
@@ -96,7 +96,7 @@ func runConfig(ctx *cli.Context, r *util.RuntimeEnv) error {
                r.Exec("minikube", "config", "set", "cpus", ctx.String("cpus"))
                r.Exec("minikube", "config", "set", "disk-size", ctx.String("disk"))
                r.Exec("minikube", "config", "set", "vm-driver", r.VirtDriver)
-               r.Exec("minikube", "config", "set", "kubernetes-version", ctx.String("k8s-version"))
+               //r.Exec("minikube", "config", "set", "kubernetes-version", ctx.String("k8s-version"))

thrawn01

package main

import (
	"context"
	"fmt"
	"os"
	"time"
	"strings"

	etcd "github.com/coreos/etcd/clientv3"

thrawn01

package main

import (
	"context"
	"fmt"
	"os"
	"os/signal"
	"syscall"
	"time"

thrawn01

Account Totals by Domain

---

This API allows customers to retrieve a single count for a every domain in their account. This allows customers to identify domains based on a stat. (IE: Most active, Most Bounces, etc..)

GET /accounts/totals

Parameter | Description

thrawn01

h2s := &http2.Server{}

handler := http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
    fmt.Fprintf(w, "Hello, %v, http: %v", r.URL.Path, r.TLS == nil)
})

server := &http.Server{
    Addr:    "0.0.0.0:1010",
    Handler: h2c.NewHandler(handler, h2s),
}

thrawn01

server := http2.Server{}

l, err := net.Listen("tcp", "0.0.0.0:1010")
checkErr(err, "while listening")

fmt.Printf("Listening [0.0.0.0:1010]...\n")
for {
    conn, err := l.Accept()
    checkErr(err, "during accept")

thrawn01

client := http.Client{
    Transport: &http2.Transport{
        // So http2.Transport doesn't complain the URL scheme isn't 'https'
        AllowHTTP: true,
        // Pretend we are dialing a TLS endpoint.
        // Note, we ignore the passed tls.Config
        DialTLSContext: func(ctx context.Context, n, a string, _ *tls.Config) (net.Conn, error) {
            var d net.Dialer
            return d.DialContext(ctx, n, a)
        },

thrawn01

package main

import (
	"fmt"
	"strings"
)

func main() {
  // [ and ] have been manually removed
	s := "76 105 99 32 83 105 110 100 105 97 32 78 117 241"