Niraj-Fonseka

package main

import (
	"grpc_stream_medium/server/sensorpb"
	"log"
	"net"

	"google.golang.org/grpc"
)

Niraj-Fonseka

type SensorServer interface {
	TempSensor(*SensorRequest, Sensor_TempSensorServer) error
	HumiditySensor(*SensorRequest, Sensor_HumiditySensorServer) error
}

Niraj-Fonseka

type server struct{}

func (*server) TempSensor(req *sensorpb.SensorRequest,
	stream sensorpb.Sensor_TempSensorServer) error {

	return nil
}

func (*server) HumiditySensor(req *sensorpb.SensorRequest,
	stream sensorpb.Sensor_HumiditySensorServer) error {

Niraj-Fonseka

package sensor

import (
	"log"
	"math/rand"
	"sync"
	"time"
)

type Sensor struct {

Niraj-Fonseka

package main

import (
	"fmt"
	"grpc_stream_medium/server/sensor"
	"grpc_stream_medium/server/sensorpb"
	"log"
	"net"
	"time"

Niraj-Fonseka

protoc sensor.proto \
--js_out=import_style=commonjs,binary:./../js-client/src/sensorpb \
--grpc-web_out=import_style=commonjs,mode=grpcwebtext:./../js-client/src/sensorpb

Niraj-Fonseka

import React from 'react';
import './App.css';

function App() {
  return (
    
  );
}

export default App;

Niraj-Fonseka

admin:
    access_log_path: /tmp/admin_access.log
    address:
      socket_address: { address: 0.0.0.0, port_value: 9901 }
  
  static_resources:
    listeners:
    - name: listener_0
      address:
        socket_address: { address: 0.0.0.0, port_value: 8000 }

Niraj-Fonseka

FROM envoyproxy/envoy:v1.12.2

COPY ./envoy.yaml /etc/envoy/envoy.yaml

CMD /usr/local/bin/envoy -c /etc/envoy/envoy.yaml

Niraj-Fonseka

import { SensorRequest , SensorResponse } from "./sensorpb/sensor_pb"
import { SensorClient} from "./sensorpb/sensor_grpc_web_pb"

var client = new SensorClient('http://localhost:8000')