grpc_gateway_2.go

grpc_gateway_2.go

func New() {
	// chi.Router 초기화 및 middleware 적용

	// gRPC Service 구현체에 context를 넘기기 위한 코드
  
	annotationFunc := func(ctx context.Context, request *http.Request) metadata.MD {
		return metadata.New(map[string]string{
			"key1":  "value1",
			"key2": "value2",
		})
	}

	serveMuxOption := runtime.WithMetadata(annotationFunc)
	// grpc-gateway 사용을 위한 코드
	mux := runtime.NewServeMux(serveMuxOption)
	opts := []grpc.DialOption{
		grpc.WithTransportCredentials(insecure.NewCredentials()),
	}
	err = adminRPC.RegisterAdminHandlerFromEndpoint(ctx, mux, fmt.Sprintf("localhost:%d", RPCPort), opts)
	if err != nil {
		// handle error
	}
	
	router.Route("/api/", func(r chi.Router) {
		r.HandleFunc("/admin/ex1", func(w http.ResponseWriter, r *http.Request) {
			mux.ServeHTTP(w, r)
		})
	})
}