Niraj-Fonseka

package main

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

Niraj-Fonseka

package sensor

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

type Sensor struct {

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

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

Niraj-Fonseka

package main

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

	"google.golang.org/grpc"
)

Niraj-Fonseka

syntax = "proto3";
package sensors;
option go_package="sensorpb";

message SensorRequest {
}

message SensorResponse {
    int64 value = 1;
}

Niraj-Fonseka

#!/bin/sh 

echo " ---- Getting credentials for the hd-engineering cluster ---- "

gcloud container clusters get-credentials hd-engineering-cluster --zone us-central1-a --project hd-engineering

echo " ---- Creating a ephemeral pod in the retooling cluster ---- "
echo " ---- run -> telnet internalhostip 6379 to connect to the memorystore instance "

kubectl -n retooling run memorystore-proxy --rm -i --tty --image us.gcr.io/hd-engineering/memorystore-proxy -- bash

Niraj-Fonseka

package main

import (
	"fmt"
	"image/color"
	"log"

	"gocv.io/x/gocv"
)

Niraj-Fonseka

package main

import (
	"log"

	"gocv.io/x/gocv"
)

func main() {
	webcam, err := gocv.VideoCaptureDevice(0)

Niraj-Fonseka

brew install mysql

brew tap homebrew/services

brew services start mysql