harunpeksen’s gists

harunpeksen / ConfluentCLIKafkaProducer.sh

Last active March 23, 2022 13:24

	topic_name=cities

	declare -a arr=("Vienna" "Brussels" "London" "Zagreb" "Copenhagen" "Helsinki"
	"Paris" "Berlin" "Athens" "Budapest" "Dublin" "Rome" "Amsterdam"
	"Lisbon" "Ljubljana" "Madrid" "Stockholm" "Oslo")

	(for i in "${arr[@]}"; do echo "$i" ; done) \| \
	confluent kafka topic produce $topic_name

harunpeksen / ClientStreamInterceptor.go

Created March 11, 2022 15:55

	type wrappedStream struct {
	grpc.ClientStream
	}

	func newWrappedStream(s grpc.ClientStream) grpc.ClientStream {
	return &wrappedStream{s}
	}

	func (w *wrappedStream) RecvMsg(m interface{}) error {
	.....

harunpeksen / UnaryClientInterceptor.go

Created March 11, 2022 15:45

	func exampleUnaryClientInterceptor(ctx context.Context, method string, req, reply interface{},
	cc *grpc.ClientConn, invoker grpc.UnaryInvoker, opts ...grpc.CallOption) error {


	// Codes before executing GRPC
	log.Println("Some messages before execution")

	// usual invocation of the remote method
	err := invoker(ctx, method, req, reply, cc, opts...)

harunpeksen / ServerStreamInterceptor.go

Last active March 11, 2022 15:50

	type wrappedStream struct { 1
	grpc.ServerStream
	}

	func newWrappedStream(s grpc.ServerStream) grpc.ServerStream {
	return &wrappedStream{s}
	}

	func (w *wrappedStream) RecvMsg(m interface{}) error {
	------

harunpeksen / UnaryServerInterceptor.go

Created March 10, 2022 16:11

	// Example of Unary Interceptor
	func exampleUnaryServerInterceptor(ctx context.Context, req interface{},
	info *grpc.UnaryServerInfo, handler grpc.UnaryHandler)
	(interface{}, error) {

	// Codes before executing GRPC
	log.Println("Some messages before execution")

	// Usual execution of a unary RPC
	m, err := handler(ctx, req)

harunpeksen / grpc-go-multiplexing.go

Created March 7, 2022 20:48


	grpcServer := grpc.NewServer()

	// Register Product Service
	product_pb.RegisterProductServer(grpcServer, &productServer{})

	// Register Billing Service
	billing_pb.RegisterBillingServer(grpcServer, &billingServer{})

harunpeksen / grpc-error-codes.md

Last active July 19, 2023 20:56

    

Code
Name
HTTP Mapping


0
OK
200 OK

1
CANCELLED
499 Client Closed Request

2
UNKNOWN
500 Internal Server Error

3
INVALID_ARGUMENT
400 Bad Request

4
DEADLINE_EXCEEDED
504 Gateway Timeout

5
NOT_FOUND
404 Not Found

6
ALREADY_EXISTS
409 Conflict

7
PERMISSION_DENIED
403 Forbidden



  

Code	Name	HTTP Mapping
0	OK	200 OK
1	CANCELLED	499 Client Closed Request
2	UNKNOWN	500 Internal Server Error
3	INVALID_ARGUMENT	400 Bad Request
4	DEADLINE_EXCEEDED	504 Gateway Timeout
5	NOT_FOUND	404 Not Found
6	ALREADY_EXISTS	409 Conflict
7	PERMISSION_DENIED	403 Forbidden

harunpeksen / grpc-cancellation.go

Created March 6, 2022 14:44

	ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)

	cancel()

	log.Printf("RPC Status : %s", ctx.Err())

harunpeksen / grpc-deadlines.go

Last active March 6, 2022 14:12

	// Setting a deadline
	clientDeadline := time.Now().Add(time.Duration(deadlineMs) time.Millisecond)
	ctx, cancel := context.WithDeadline(ctx, clientDeadline)

	// Checking deadline
	if ctx.Err() == context.Canceled {
	return status.New(codes.Canceled, "Client cancelled, abandoning.")
	}

harunpeksen / streaming-proto-example.proto

Created February 25, 2022 18:19

	service HelloService {
	rpc SayHello (HelloRequest) returns (HelloResponse);
	rpc ClientStreamHello (stream HelloRequest) returns (HelloResponse);
	rpc ServerStreamHello (HelloRequest) returns (stream HelloResponse);
	rpc BidirectionalStreamHello (stream HelloRequest) returns (stream HelloResponse);
	}