Don't block when sending readings to g.RPCReadingChan

chrissnell · Oct 22, 2017 · 041f007 · 041f007
1 parent 7edbfe2
commit 041f007
Show file tree

Hide file tree

Showing 4 changed files with 3 additions and 2 deletions.
diff --git a/.gitignore b/.gitignore
@@ -1,2 +1,3 @@
 config-secret.yaml
 gopherwx
+binaries/
diff --git a/grpcweather/grpcweather.pb.go → protobuf/grpcweather.pb.go b/grpcweather/grpcweather.pb.go → protobuf/grpcweather.pb.go
diff --git a/grpcweather/grpcweather.proto → protobuf/grpcweather.proto b/grpcweather/grpcweather.proto → protobuf/grpcweather.proto
diff --git a/storage_grpc.go b/storage_grpc.go
@@ -7,7 +7,7 @@ import (
 	"net"
 	"sync"
 
-	weather "github.com/chrissnell/gopherwx/grpcweather"
+	weather "github.com/chrissnell/gopherwx/protobuf"
 	"github.com/golang/protobuf/ptypes"
 	"google.golang.org/grpc"
 	"google.golang.org/grpc/reflection"
@@ -60,7 +60,7 @@ func (g GRPCStorage) processMetrics(ctx context.Context, wg *sync.WaitGroup, rch
 func (g GRPCStorage) SendReading(r Reading) error {
 	select {
 	case g.RPCReadingChan <- r:
-		//
+	default:
 	}
 
 	return nil