mayankcpdixit

Setting up http trailers in Golang

1. Trailers are of header type in go.
2. You can only read trailer after reading body

package main

import (
	"io/ioutil"
	"log"

mayankcpdixit

Connect with AWS route 53 using Java(Spring) and gradle

Concept:

1. We'll have env vars set

export AWS_ACCESS_KEY_ID="XXXXX"
export AWS_SECRET_KEY="XXXXX"

2. We'll Use AmazonRoute53ClientBuilder to generate client object
3. We'll import core sdk and route53 sdk

mayankcpdixit

1. Install Kafka and start zkServer and kafka-server
2. Uncomment listeners & advertised.listerners in server.properties.
3. SpringBoot App for kafka (sample)
4. Run kafka in local
5. gradle build this repo
6. Start the app using: java -jar build/libs/spring-kafka-0.0.1-SNAPSHOT.jar
7. Publish using http://localhost:8080/greetings?message=HelloManThisIsPublished
8. Check terminal logs for publish and polling logs. Cheers!

App Directory structure. Download from git repo.

mayankcpdixit

Install kafka in your local mac machine

run following commands:

brew install kafka
sudo mkdir -p /usr/local/var/run/zookeeper/data
sudo chmod 777 /usr/local/var/run/zookeeper/data
zkServer start

mkdir -p /usr/local/var/lib/kafka-logs

mayankcpdixit

Spring boot and gradle. Get started in 1 min:

Dir structure of TestRepo:

├── build.gradle
└── src
    └── main
        └── java
            └── hello
                ├── Application.java

mayankcpdixit

Adding custom header to grpc request

md1 := func(context.Context, *http.Request) metadata.MD {
  return metadata.New(map[string]string{
    "custom-header": "custom-value",
  })
}

mux := runtime.NewServeMux(runtime.WithMetadata(md1))

mayankcpdixit

Serving GRPC gateway and docs(swagger) on same endpoint

So idea is pretty simple:

1. We'll create a new httpMux
2. We'll serve runtimeMux on (/)
3. We'll serve index.html (using fileserver) on (/docs/)
4. We'll not forget succeeding "/" on /docs/

In action:

Modify the example pt. 6 in this way:

mayankcpdixit

Using TLS in grpc-gateway

In GRPC client

By default DialOption{grpc.WithInsecure()} is used in example. And as docs mention you just need to replace WithInsecure with transport creds.

//opts := []grpc.DialOption{grpc.WithInsecure()}
creds, _ := credentials.NewClientTLSFromFile("tls.crt", "")
opts := []grpc.DialOption{grpc.WithTransportCredentials(creds)}

In HTTP server